[BACK]Return to subr_pool.c CVS log [TXT][DIR] Up to [cvs.NetBSD.org] / src / sys / kern

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/kern/subr_pool.c between version 1.176 and 1.179

version 1.176, 2009/10/15 20:50:12 version 1.179, 2010/01/02 15:20:39
Line 104  static struct pool *drainpp;
Line 104  static struct pool *drainpp;
 static kmutex_t pool_head_lock;  static kmutex_t pool_head_lock;
 static kcondvar_t pool_busy;  static kcondvar_t pool_busy;
   
   /* This lock protects initialization of a potentially shared pool allocator */
   static kmutex_t pool_allocator_lock;
   
 typedef uint32_t pool_item_bitmap_t;  typedef uint32_t pool_item_bitmap_t;
 #define BITMAP_SIZE     (CHAR_BIT * sizeof(pool_item_bitmap_t))  #define BITMAP_SIZE     (CHAR_BIT * sizeof(pool_item_bitmap_t))
 #define BITMAP_MASK     (BITMAP_SIZE - 1)  #define BITMAP_MASK     (BITMAP_SIZE - 1)
Line 231  int pool_logsize = POOL_LOGSIZE;
Line 234  int pool_logsize = POOL_LOGSIZE;
 static inline void  static inline void
 pr_log(struct pool *pp, void *v, int action, const char *file, long line)  pr_log(struct pool *pp, void *v, int action, const char *file, long line)
 {  {
         int n = pp->pr_curlogentry;          int n;
         struct pool_log *pl;          struct pool_log *pl;
   
         if ((pp->pr_roflags & PR_LOGGING) == 0)          if ((pp->pr_roflags & PR_LOGGING) == 0)
                 return;                  return;
   
           if (pp->pr_log == NULL) {
                   if (kmem_map != NULL)
                           pp->pr_log = malloc(
                                   pool_logsize * sizeof(struct pool_log),
                                   M_TEMP, M_NOWAIT | M_ZERO);
                   if (pp->pr_log == NULL)
                           return;
                   pp->pr_curlogentry = 0;
                   pp->pr_logsize = pool_logsize;
           }
   
         /*          /*
          * Fill in the current entry. Wrap around and overwrite           * Fill in the current entry. Wrap around and overwrite
          * the oldest entry if necessary.           * the oldest entry if necessary.
          */           */
           n = pp->pr_curlogentry;
         pl = &pp->pr_log[n];          pl = &pp->pr_log[n];
         pl->pl_file = file;          pl->pl_file = file;
         pl->pl_line = line;          pl->pl_line = line;
Line 258  pr_printlog(struct pool *pp, struct pool
Line 273  pr_printlog(struct pool *pp, struct pool
         int i = pp->pr_logsize;          int i = pp->pr_logsize;
         int n = pp->pr_curlogentry;          int n = pp->pr_curlogentry;
   
         if ((pp->pr_roflags & PR_LOGGING) == 0)          if (pp->pr_log == NULL)
                 return;                  return;
   
         /*          /*
Line 590  pool_subsystem_init(void)
Line 605  pool_subsystem_init(void)
         struct pool_allocator *pa;          struct pool_allocator *pa;
   
         mutex_init(&pool_head_lock, MUTEX_DEFAULT, IPL_NONE);          mutex_init(&pool_head_lock, MUTEX_DEFAULT, IPL_NONE);
           mutex_init(&pool_allocator_lock, MUTEX_DEFAULT, IPL_NONE);
         cv_init(&pool_busy, "poolbusy");          cv_init(&pool_busy, "poolbusy");
   
         while ((pa = SLIST_FIRST(&pa_deferinitq)) != NULL) {          while ((pa = SLIST_FIRST(&pa_deferinitq)) != NULL) {
Line 650  pool_init(struct pool *pp, size_t size, 
Line 666  pool_init(struct pool *pp, size_t size, 
                         palloc = &pool_allocator_nointr_fullpage;                          palloc = &pool_allocator_nointr_fullpage;
         }          }
 #endif /* POOL_SUBPAGE */  #endif /* POOL_SUBPAGE */
         if ((palloc->pa_flags & PA_INITIALIZED) == 0) {          mutex_enter(&pool_allocator_lock);
           if (palloc->pa_refcnt++ == 0) {
                 if (palloc->pa_pagesz == 0)                  if (palloc->pa_pagesz == 0)
                         palloc->pa_pagesz = PAGE_SIZE;                          palloc->pa_pagesz = PAGE_SIZE;
   
Line 663  pool_init(struct pool *pp, size_t size, 
Line 680  pool_init(struct pool *pp, size_t size, 
                 if (palloc->pa_backingmapptr != NULL) {                  if (palloc->pa_backingmapptr != NULL) {
                         pa_reclaim_register(palloc);                          pa_reclaim_register(palloc);
                 }                  }
                 palloc->pa_flags |= PA_INITIALIZED;  
         }          }
           mutex_exit(&pool_allocator_lock);
   
         if (align == 0)          if (align == 0)
                 align = ALIGN(1);                  align = ALIGN(1);
Line 787  pool_init(struct pool *pp, size_t size, 
Line 804  pool_init(struct pool *pp, size_t size, 
         pp->pr_nidle = 0;          pp->pr_nidle = 0;
         pp->pr_refcnt = 0;          pp->pr_refcnt = 0;
   
 #ifdef POOL_DIAGNOSTIC          pp->pr_log = NULL;
         if (flags & PR_LOGGING) {  
                 if (kmem_map == NULL ||  
                     (pp->pr_log = malloc(pool_logsize * sizeof(struct pool_log),  
                      M_TEMP, M_NOWAIT)) == NULL)  
                         pp->pr_roflags &= ~PR_LOGGING;  
                 pp->pr_curlogentry = 0;  
                 pp->pr_logsize = pool_logsize;  
         }  
 #endif  
   
         pp->pr_entered_file = NULL;          pp->pr_entered_file = NULL;
         pp->pr_entered_line = 0;          pp->pr_entered_line = 0;
Line 892  pool_destroy(struct pool *pp)
Line 900  pool_destroy(struct pool *pp)
         TAILQ_REMOVE(&pp->pr_alloc->pa_list, pp, pr_alloc_list);          TAILQ_REMOVE(&pp->pr_alloc->pa_list, pp, pr_alloc_list);
         mutex_exit(&pp->pr_alloc->pa_lock);          mutex_exit(&pp->pr_alloc->pa_lock);
   
           mutex_enter(&pool_allocator_lock);
           if (--pp->pr_alloc->pa_refcnt == 0)
                   mutex_destroy(&pp->pr_alloc->pa_lock);
           mutex_exit(&pool_allocator_lock);
   
         mutex_enter(&pp->pr_lock);          mutex_enter(&pp->pr_lock);
   
         KASSERT(pp->pr_cache == NULL);          KASSERT(pp->pr_cache == NULL);
Line 917  pool_destroy(struct pool *pp)
Line 930  pool_destroy(struct pool *pp)
         pr_pagelist_free(pp, &pq);          pr_pagelist_free(pp, &pq);
   
 #ifdef POOL_DIAGNOSTIC  #ifdef POOL_DIAGNOSTIC
         if ((pp->pr_roflags & PR_LOGGING) != 0)          if (pp->pr_log != NULL) {
                 free(pp->pr_log, M_TEMP);                  free(pp->pr_log, M_TEMP);
                   pp->pr_log = NULL;
           }
 #endif  #endif
   
         cv_destroy(&pp->pr_cv);          cv_destroy(&pp->pr_cv);
Line 2300  pool_cache_invalidate(pool_cache_t pc)
Line 2315  pool_cache_invalidate(pool_cache_t pc)
         pcg_t *full, *empty, *part;          pcg_t *full, *empty, *part;
         uint64_t where;          uint64_t where;
   
         if (ncpu < 2) {          if (ncpu < 2 || !mp_online) {
                 /*                  /*
                  * We might be called early enough in the boot process                   * We might be called early enough in the boot process
                  * for the CPU data structures to not be fully initialized.                   * for the CPU data structures to not be fully initialized.
Legend:
Removed from v.1.176  
changed lines
  Added in v.1.179
CVSweb <webmaster@jp.NetBSD.org>