[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.99.8.2 and 1.100

version 1.99.8.2, 2006/03/10 13:19:42 version 1.100, 2005/04/01 11:59:37
Line 174  struct pool_item {
Line 174  struct pool_item {
 /* The cache group pool. */  /* The cache group pool. */
 static struct pool pcgpool;  static struct pool pcgpool;
   
 static void     pool_cache_reclaim(struct pool_cache *, struct pool_pagelist *);  static void     pool_cache_reclaim(struct pool_cache *);
   
 static int      pool_catchup(struct pool *);  static int      pool_catchup(struct pool *);
 static void     pool_prime_page(struct pool *, caddr_t,  static void     pool_prime_page(struct pool *, caddr_t,
Line 384  pr_find_pagehead(struct pool *pp, caddr_
Line 384  pr_find_pagehead(struct pool *pp, caddr_
         return ph;          return ph;
 }  }
   
 static void  
 pr_pagelist_free(struct pool *pp, struct pool_pagelist *pq)  
 {  
         struct pool_item_header *ph;  
         int s;  
   
         while ((ph = LIST_FIRST(pq)) != NULL) {  
                 LIST_REMOVE(ph, ph_pagelist);  
                 pool_allocator_free(pp, ph->ph_page);  
                 if ((pp->pr_roflags & PR_PHINPAGE) == 0) {  
                         s = splvm();  
                         pool_put(pp->pr_phpool, ph);  
                         splx(s);  
                 }  
         }  
 }  
   
 /*  /*
  * Remove a page from the pool.   * Remove a page from the pool.
  */   */
Line 408  static __inline void
Line 391  static __inline void
 pr_rmpage(struct pool *pp, struct pool_item_header *ph,  pr_rmpage(struct pool *pp, struct pool_item_header *ph,
      struct pool_pagelist *pq)       struct pool_pagelist *pq)
 {  {
           int s;
   
         LOCK_ASSERT(simple_lock_held(&pp->pr_slock));          LOCK_ASSERT(!simple_lock_held(&pp->pr_slock) || pq != NULL);
   
         /*          /*
          * If the page was idle, decrement the idle page count.           * If the page was idle, decrement the idle page count.
Line 427  pr_rmpage(struct pool *pp, struct pool_i
Line 411  pr_rmpage(struct pool *pp, struct pool_i
         pp->pr_nitems -= pp->pr_itemsperpage;          pp->pr_nitems -= pp->pr_itemsperpage;
   
         /*          /*
          * Unlink the page from the pool and queue it for release.           * Unlink a page from the pool and release it (or queue it for release).
          */           */
         LIST_REMOVE(ph, ph_pagelist);          LIST_REMOVE(ph, ph_pagelist);
         if ((pp->pr_roflags & PR_PHINPAGE) == 0)          if ((pp->pr_roflags & PR_PHINPAGE) == 0)
                 SPLAY_REMOVE(phtree, &pp->pr_phtree, ph);                  SPLAY_REMOVE(phtree, &pp->pr_phtree, ph);
         LIST_INSERT_HEAD(pq, ph, ph_pagelist);          if (pq) {
                   LIST_INSERT_HEAD(pq, ph, ph_pagelist);
           } else {
                   pool_allocator_free(pp, ph->ph_page);
                   if ((pp->pr_roflags & PR_PHINPAGE) == 0) {
                           s = splvm();
                           pool_put(pp->pr_phpool, ph);
                           splx(s);
                   }
           }
         pp->pr_npages--;          pp->pr_npages--;
         pp->pr_npagefree++;          pp->pr_npagefree++;
   
Line 480  pool_init(struct pool *pp, size_t size, 
Line 472  pool_init(struct pool *pp, size_t size, 
                 flags |= PR_LOGGING;                  flags |= PR_LOGGING;
 #endif  #endif
   
   #ifdef POOL_SUBPAGE
           /*
            * XXX We don't provide a real `nointr' back-end
            * yet; all sub-pages come from a kmem back-end.
            * maybe some day...
            */
           if (palloc == NULL) {
                   extern struct pool_allocator pool_allocator_kmem_subpage;
                   palloc = &pool_allocator_kmem_subpage;
           }
           /*
            * We'll assume any user-specified back-end allocator
            * will deal with sub-pages, or simply don't care.
            */
   #else
         if (palloc == NULL)          if (palloc == NULL)
                 palloc = &pool_allocator_kmem;                  palloc = &pool_allocator_kmem;
 #ifdef POOL_SUBPAGE  
         if (size > palloc->pa_pagesz) {  
                 if (palloc == &pool_allocator_kmem)  
                         palloc = &pool_allocator_kmem_fullpage;  
                 else if (palloc == &pool_allocator_nointr)  
                         palloc = &pool_allocator_nointr_fullpage;  
         }  
 #endif /* POOL_SUBPAGE */  #endif /* POOL_SUBPAGE */
         if ((palloc->pa_flags & PA_INITIALIZED) == 0) {          if ((palloc->pa_flags & PA_INITIALIZED) == 0) {
                 if (palloc->pa_pagesz == 0)                  if (palloc->pa_pagesz == 0) {
   #ifdef POOL_SUBPAGE
                           if (palloc == &pool_allocator_kmem)
                                   palloc->pa_pagesz = PAGE_SIZE;
                           else
                                   palloc->pa_pagesz = POOL_SUBPAGE;
   #else
                         palloc->pa_pagesz = PAGE_SIZE;                          palloc->pa_pagesz = PAGE_SIZE;
   #endif /* POOL_SUBPAGE */
                   }
   
                 TAILQ_INIT(&palloc->pa_list);                  TAILQ_INIT(&palloc->pa_list);
   
Line 688  pool_init(struct pool *pp, size_t size, 
Line 696  pool_init(struct pool *pp, size_t size, 
 void  void
 pool_destroy(struct pool *pp)  pool_destroy(struct pool *pp)
 {  {
         struct pool_pagelist pq;  
         struct pool_item_header *ph;          struct pool_item_header *ph;
           struct pool_cache *pc;
         int s;          int s;
   
         /* Remove from global pool list */          /* Locking order: pool_allocator -> pool */
         simple_lock(&pool_head_slock);  
         TAILQ_REMOVE(&pool_head, pp, pr_poollist);  
         if (drainpp == pp)  
                 drainpp = NULL;  
         simple_unlock(&pool_head_slock);  
   
         /* Remove this pool from its allocator's list of pools. */  
         s = splvm();          s = splvm();
         simple_lock(&pp->pr_alloc->pa_slock);          simple_lock(&pp->pr_alloc->pa_slock);
         TAILQ_REMOVE(&pp->pr_alloc->pa_list, pp, pr_alloc_list);          TAILQ_REMOVE(&pp->pr_alloc->pa_list, pp, pr_alloc_list);
         simple_unlock(&pp->pr_alloc->pa_slock);          simple_unlock(&pp->pr_alloc->pa_slock);
         splx(s);          splx(s);
   
         s = splvm();          /* Destroy all caches for this pool. */
         simple_lock(&pp->pr_slock);          while ((pc = TAILQ_FIRST(&pp->pr_cachelist)) != NULL)
                   pool_cache_destroy(pc);
         KASSERT(TAILQ_EMPTY(&pp->pr_cachelist));  
   
 #ifdef DIAGNOSTIC  #ifdef DIAGNOSTIC
         if (pp->pr_nout != 0) {          if (pp->pr_nout != 0) {
Line 719  pool_destroy(struct pool *pp)
Line 719  pool_destroy(struct pool *pp)
         }          }
 #endif  #endif
   
         KASSERT(LIST_EMPTY(&pp->pr_fullpages));  
         KASSERT(LIST_EMPTY(&pp->pr_partpages));  
   
         /* Remove all pages */          /* Remove all pages */
         LIST_INIT(&pq);  
         while ((ph = LIST_FIRST(&pp->pr_emptypages)) != NULL)          while ((ph = LIST_FIRST(&pp->pr_emptypages)) != NULL)
                 pr_rmpage(pp, ph, &pq);                  pr_rmpage(pp, ph, NULL);
           KASSERT(LIST_EMPTY(&pp->pr_fullpages));
         simple_unlock(&pp->pr_slock);          KASSERT(LIST_EMPTY(&pp->pr_partpages));
         splx(s);  
   
         pr_pagelist_free(pp, &pq);          /* Remove from global pool list */
           simple_lock(&pool_head_slock);
           TAILQ_REMOVE(&pool_head, pp, pr_poollist);
           if (drainpp == pp) {
                   drainpp = NULL;
           }
           simple_unlock(&pool_head_slock);
   
 #ifdef POOL_DIAGNOSTIC  #ifdef POOL_DIAGNOSTIC
         if ((pp->pr_roflags & PR_LOGGING) != 0)          if ((pp->pr_roflags & PR_LOGGING) != 0)
Line 1036  pool_get(struct pool *pp, int flags)
Line 1037  pool_get(struct pool *pp, int flags)
  * Internal version of pool_put().  Pool is already locked/entered.   * Internal version of pool_put().  Pool is already locked/entered.
  */   */
 static void  static void
 pool_do_put(struct pool *pp, void *v, struct pool_pagelist *pq)  pool_do_put(struct pool *pp, void *v)
 {  {
         struct pool_item *pi = v;          struct pool_item *pi = v;
         struct pool_item_header *ph;          struct pool_item_header *ph;
Line 1124  pool_do_put(struct pool *pp, void *v, st
Line 1125  pool_do_put(struct pool *pp, void *v, st
                 if (pp->pr_npages > pp->pr_minpages &&                  if (pp->pr_npages > pp->pr_minpages &&
                     (pp->pr_npages > pp->pr_maxpages ||                      (pp->pr_npages > pp->pr_maxpages ||
                      (pp->pr_alloc->pa_flags & PA_WANT) != 0)) {                       (pp->pr_alloc->pa_flags & PA_WANT) != 0)) {
                         pr_rmpage(pp, ph, pq);                          simple_unlock(&pp->pr_slock);
                           pr_rmpage(pp, ph, NULL);
                           simple_lock(&pp->pr_slock);
                 } else {                  } else {
                         LIST_REMOVE(ph, ph_pagelist);                          LIST_REMOVE(ph, ph_pagelist);
                         LIST_INSERT_HEAD(&pp->pr_emptypages, ph, ph_pagelist);                          LIST_INSERT_HEAD(&pp->pr_emptypages, ph, ph_pagelist);
Line 1162  pool_do_put(struct pool *pp, void *v, st
Line 1165  pool_do_put(struct pool *pp, void *v, st
 void  void
 _pool_put(struct pool *pp, void *v, const char *file, long line)  _pool_put(struct pool *pp, void *v, const char *file, long line)
 {  {
         struct pool_pagelist pq;  
   
         LIST_INIT(&pq);  
   
         simple_lock(&pp->pr_slock);          simple_lock(&pp->pr_slock);
         pr_enter(pp, file, line);          pr_enter(pp, file, line);
   
         pr_log(pp, v, PRLOG_PUT, file, line);          pr_log(pp, v, PRLOG_PUT, file, line);
   
         pool_do_put(pp, v, &pq);          pool_do_put(pp, v);
   
         pr_leave(pp);          pr_leave(pp);
         simple_unlock(&pp->pr_slock);          simple_unlock(&pp->pr_slock);
   
         if (! LIST_EMPTY(&pq))  
                 pr_pagelist_free(pp, &pq);  
 }  }
 #undef pool_put  #undef pool_put
 #endif /* POOL_DIAGNOSTIC */  #endif /* POOL_DIAGNOSTIC */
Line 1185  _pool_put(struct pool *pp, void *v, cons
Line 1182  _pool_put(struct pool *pp, void *v, cons
 void  void
 pool_put(struct pool *pp, void *v)  pool_put(struct pool *pp, void *v)
 {  {
         struct pool_pagelist pq;  
   
         LIST_INIT(&pq);  
   
         simple_lock(&pp->pr_slock);          simple_lock(&pp->pr_slock);
         pool_do_put(pp, v, &pq);  
         simple_unlock(&pp->pr_slock);  
   
         if (! LIST_EMPTY(&pq))          pool_do_put(pp, v);
                 pr_pagelist_free(pp, &pq);  
           simple_unlock(&pp->pr_slock);
 }  }
   
 #ifdef POOL_DIAGNOSTIC  #ifdef POOL_DIAGNOSTIC
Line 1476  pool_reclaim(struct pool *pp)
Line 1469  pool_reclaim(struct pool *pp)
          * Reclaim items from the pool's caches.           * Reclaim items from the pool's caches.
          */           */
         TAILQ_FOREACH(pc, &pp->pr_cachelist, pc_poollist)          TAILQ_FOREACH(pc, &pp->pr_cachelist, pc_poollist)
                 pool_cache_reclaim(pc, &pq);                  pool_cache_reclaim(pc);
   
         s = splclock();          s = splclock();
         curtime = mono_time;          curtime = mono_time;
Line 1510  pool_reclaim(struct pool *pp)
Line 1503  pool_reclaim(struct pool *pp)
         if (LIST_EMPTY(&pq))          if (LIST_EMPTY(&pq))
                 return (0);                  return (0);
   
         pr_pagelist_free(pp, &pq);          while ((ph = LIST_FIRST(&pq)) != NULL) {
                   LIST_REMOVE(ph, ph_pagelist);
                   pool_allocator_free(pp, ph->ph_page);
                   if (pp->pr_roflags & PR_PHINPAGE) {
                           continue;
                   }
                   s = splvm();
                   pool_put(pp->pr_phpool, ph);
                   splx(s);
           }
   
         return (1);          return (1);
 }  }
   
Line 2021  pool_cache_destruct_object(struct pool_c
Line 2024  pool_cache_destruct_object(struct pool_c
 }  }
   
 /*  /*
  * pool_cache_invalidate:   * pool_cache_do_invalidate:
  *   *
  *      Invalidate a pool cache (destruct and release all of the   *      This internal function implements pool_cache_invalidate() and
  *      cached objects).   *      pool_cache_reclaim().
  */   */
 void  static void
 pool_cache_invalidate(struct pool_cache *pc)  pool_cache_do_invalidate(struct pool_cache *pc, int free_groups,
       void (*putit)(struct pool *, void *))
 {  {
         struct pool_pagelist pq;  
         struct pool_cache_group *pcg, *npcg;          struct pool_cache_group *pcg, *npcg;
         void *object;          void *object;
           int s;
         LIST_INIT(&pq);  
   
         simple_lock(&pc->pc_slock);  
         simple_lock(&pc->pc_pool->pr_slock);  
   
         for (pcg = TAILQ_FIRST(&pc->pc_grouplist); pcg != NULL;          for (pcg = TAILQ_FIRST(&pc->pc_grouplist); pcg != NULL;
              pcg = npcg) {               pcg = npcg) {
Line 2048  pool_cache_invalidate(struct pool_cache 
Line 2047  pool_cache_invalidate(struct pool_cache 
                                 pc->pc_allocfrom = NULL;                                  pc->pc_allocfrom = NULL;
                         if (pc->pc_dtor != NULL)                          if (pc->pc_dtor != NULL)
                                 (*pc->pc_dtor)(pc->pc_arg, object);                                  (*pc->pc_dtor)(pc->pc_arg, object);
                         pool_do_put(pc->pc_pool, object, &pq);                          (*putit)(pc->pc_pool, object);
                   }
                   if (free_groups) {
                           pc->pc_ngroups--;
                           TAILQ_REMOVE(&pc->pc_grouplist, pcg, pcg_list);
                           if (pc->pc_freeto == pcg)
                                   pc->pc_freeto = NULL;
                           s = splvm();
                           pool_put(&pcgpool, pcg);
                           splx(s);
                 }                  }
         }          }
   }
   
         simple_unlock(&pc->pc_pool->pr_slock);  /*
         simple_unlock(&pc->pc_slock);   * pool_cache_invalidate:
    *
    *      Invalidate a pool cache (destruct and release all of the
    *      cached objects).
    */
   void
   pool_cache_invalidate(struct pool_cache *pc)
   {
   
         if (! LIST_EMPTY(&pq))          simple_lock(&pc->pc_slock);
                 pr_pagelist_free(pc->pc_pool, &pq);          pool_cache_do_invalidate(pc, 0, pool_put);
           simple_unlock(&pc->pc_slock);
 }  }
   
 /*  /*
Line 2065  pool_cache_invalidate(struct pool_cache 
Line 2082  pool_cache_invalidate(struct pool_cache 
  *      Reclaim a pool cache for pool_reclaim().   *      Reclaim a pool cache for pool_reclaim().
  */   */
 static void  static void
 pool_cache_reclaim(struct pool_cache *pc, struct pool_pagelist *pq)  pool_cache_reclaim(struct pool_cache *pc)
 {  {
         struct pool_cache_group *pcg, *npcg;  
         void *object;  
         int s;  
   
         /*  
          * We're locking in the wrong order (normally pool_cache -> pool,  
          * but the pool is already locked when we get here), so we have  
          * to use trylock.  If we can't lock the pool_cache, it's not really  
          * a big deal here.  
          */  
         if (simple_lock_try(&pc->pc_slock) == 0)  
                 return;  
   
         for (pcg = TAILQ_FIRST(&pc->pc_grouplist); pcg != NULL;  
              pcg = npcg) {  
                 npcg = TAILQ_NEXT(pcg, pcg_list);  
                 while (pcg->pcg_avail != 0) {  
                         pc->pc_nitems--;  
                         object = pcg_get(pcg, NULL);  
                         if (pcg->pcg_avail == 0 && pc->pc_allocfrom == pcg)  
                                 pc->pc_allocfrom = NULL;  
                         if (pc->pc_dtor != NULL)  
                                 (*pc->pc_dtor)(pc->pc_arg, object);  
                         pool_do_put(pc->pc_pool, object, pq);  
                 }  
                 pc->pc_ngroups--;  
                 TAILQ_REMOVE(&pc->pc_grouplist, pcg, pcg_list);  
                 if (pc->pc_freeto == pcg)  
                         pc->pc_freeto = NULL;  
                 s = splvm();  
                 pool_put(&pcgpool, pcg);  
                 splx(s);  
         }  
   
           simple_lock(&pc->pc_slock);
           pool_cache_do_invalidate(pc, 1, pool_do_put);
         simple_unlock(&pc->pc_slock);          simple_unlock(&pc->pc_slock);
 }  }
   
Line 2120  pool_cache_reclaim(struct pool_cache *pc
Line 2106  pool_cache_reclaim(struct pool_cache *pc
 void    *pool_page_alloc(struct pool *, int);  void    *pool_page_alloc(struct pool *, int);
 void    pool_page_free(struct pool *, void *);  void    pool_page_free(struct pool *, void *);
   
 #ifdef POOL_SUBPAGE  
 struct pool_allocator pool_allocator_kmem_fullpage = {  
         pool_page_alloc, pool_page_free, 0,  
 };  
 #else  
 struct pool_allocator pool_allocator_kmem = {  struct pool_allocator pool_allocator_kmem = {
         pool_page_alloc, pool_page_free, 0,          pool_page_alloc, pool_page_free, 0,
 };  };
 #endif  
   
 void    *pool_page_alloc_nointr(struct pool *, int);  void    *pool_page_alloc_nointr(struct pool *, int);
 void    pool_page_free_nointr(struct pool *, void *);  void    pool_page_free_nointr(struct pool *, void *);
   
 #ifdef POOL_SUBPAGE  
 struct pool_allocator pool_allocator_nointr_fullpage = {  
         pool_page_alloc_nointr, pool_page_free_nointr, 0,  
 };  
 #else  
 struct pool_allocator pool_allocator_nointr = {  struct pool_allocator pool_allocator_nointr = {
         pool_page_alloc_nointr, pool_page_free_nointr, 0,          pool_page_alloc_nointr, pool_page_free_nointr, 0,
 };  };
 #endif  
   
 #ifdef POOL_SUBPAGE  #ifdef POOL_SUBPAGE
 void    *pool_subpage_alloc(struct pool *, int);  void    *pool_subpage_alloc(struct pool *, int);
 void    pool_subpage_free(struct pool *, void *);  void    pool_subpage_free(struct pool *, void *);
   
 struct pool_allocator pool_allocator_kmem = {  struct pool_allocator pool_allocator_kmem_subpage = {
         pool_subpage_alloc, pool_subpage_free, POOL_SUBPAGE,          pool_subpage_alloc, pool_subpage_free, 0,
 };  
   
 void    *pool_subpage_alloc_nointr(struct pool *, int);  
 void    pool_subpage_free_nointr(struct pool *, void *);  
   
 struct pool_allocator pool_allocator_nointr = {  
         pool_subpage_alloc, pool_subpage_free, POOL_SUBPAGE,  
 };  };
 #endif /* POOL_SUBPAGE */  #endif /* POOL_SUBPAGE */
   
Line 2284  pool_page_alloc(struct pool *pp, int fla
Line 2251  pool_page_alloc(struct pool *pp, int fla
 {  {
         boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;          boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;
   
         return ((void *) uvm_km_alloc_poolpage_cache(kmem_map, NULL, waitok));          return ((void *) uvm_km_alloc_poolpage_cache(kmem_map, waitok));
 }  }
   
 void  void
Line 2299  pool_page_alloc_meta(struct pool *pp, in
Line 2266  pool_page_alloc_meta(struct pool *pp, in
 {  {
         boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;          boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;
   
         return ((void *) uvm_km_alloc_poolpage1(kmem_map, NULL, waitok));          return ((void *) uvm_km_alloc_poolpage(kmem_map, waitok));
 }  }
   
 static void  static void
 pool_page_free_meta(struct pool *pp, void *v)  pool_page_free_meta(struct pool *pp, void *v)
 {  {
   
         uvm_km_free_poolpage1(kmem_map, (vaddr_t) v);          uvm_km_free_poolpage(kmem_map, (vaddr_t) v);
 }  }
   
 #ifdef POOL_SUBPAGE  #ifdef POOL_SUBPAGE
Line 2333  pool_subpage_free(struct pool *pp, void 
Line 2300  pool_subpage_free(struct pool *pp, void 
   
 /* We don't provide a real nointr allocator.  Maybe later. */  /* We don't provide a real nointr allocator.  Maybe later. */
 void *  void *
 pool_subpage_alloc_nointr(struct pool *pp, int flags)  pool_page_alloc_nointr(struct pool *pp, int flags)
 {  {
   
         return (pool_subpage_alloc(pp, flags));          return (pool_subpage_alloc(pp, flags));
 }  }
   
 void  void
 pool_subpage_free_nointr(struct pool *pp, void *v)  pool_page_free_nointr(struct pool *pp, void *v)
 {  {
   
         pool_subpage_free(pp, v);          pool_subpage_free(pp, v);
 }  }
 #endif /* POOL_SUBPAGE */  #else
 void *  void *
 pool_page_alloc_nointr(struct pool *pp, int flags)  pool_page_alloc_nointr(struct pool *pp, int flags)
 {  {
         boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;          boolean_t waitok = (flags & PR_WAITOK) ? TRUE : FALSE;
   
         return ((void *) uvm_km_alloc_poolpage_cache(kernel_map,          return ((void *) uvm_km_alloc_poolpage_cache(kernel_map, waitok));
             uvm.kernel_object, waitok));  
 }  }
   
 void  void
Line 2361  pool_page_free_nointr(struct pool *pp, v
Line 2327  pool_page_free_nointr(struct pool *pp, v
   
         uvm_km_free_poolpage_cache(kernel_map, (vaddr_t) v);          uvm_km_free_poolpage_cache(kernel_map, (vaddr_t) v);
 }  }
   #endif /* POOL_SUBPAGE */
Legend:
Removed from v.1.99.8.2  
changed lines
  Added in v.1.100
CVSweb <webmaster@jp.NetBSD.org>