[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.161 and 1.162

version 1.161, 2008/05/31 13:31:25 version 1.162, 2008/07/04 13:28:08
Line 179  static struct pool cache_cpu_pool;
Line 179  static struct pool cache_cpu_pool;
 TAILQ_HEAD(,pool_cache) pool_cache_head =  TAILQ_HEAD(,pool_cache) pool_cache_head =
     TAILQ_HEAD_INITIALIZER(pool_cache_head);      TAILQ_HEAD_INITIALIZER(pool_cache_head);
   
 int pool_cache_disable;  int pool_cache_disable;         /* global disable for caching */
   static pcg_t pcg_dummy;         /* zero sized: always empty, yet always full */
   
   static bool     pool_cache_put_slow(pool_cache_cpu_t *, int,
 static pool_cache_cpu_t *pool_cache_put_slow(pool_cache_cpu_t *, int *,                                      void *);
                                              void *, paddr_t);  static bool     pool_cache_get_slow(pool_cache_cpu_t *, int,
 static pool_cache_cpu_t *pool_cache_get_slow(pool_cache_cpu_t *, int *,                                      void **, paddr_t *, int);
                                              void **, paddr_t *, int);  
 static void     pool_cache_cpu_init1(struct cpu_info *, pool_cache_t);  static void     pool_cache_cpu_init1(struct cpu_info *, pool_cache_t);
 static void     pool_cache_invalidate_groups(pool_cache_t, pcg_t *);  static void     pool_cache_invalidate_groups(pool_cache_t, pcg_t *);
 static void     pool_cache_xcall(pool_cache_t);  static void     pool_cache_xcall(pool_cache_t);
Line 2151  pool_cache_destroy(pool_cache_t pc)
Line 2151  pool_cache_destroy(pool_cache_t pc)
         for (i = 0; i < MAXCPUS; i++) {          for (i = 0; i < MAXCPUS; i++) {
                 if ((cc = pc->pc_cpus[i]) == NULL)                  if ((cc = pc->pc_cpus[i]) == NULL)
                         continue;                          continue;
                 if ((pcg = cc->cc_current) != NULL) {                  if ((pcg = cc->cc_current) != &pcg_dummy) {
                         pcg->pcg_next = NULL;                          pcg->pcg_next = NULL;
                         pool_cache_invalidate_groups(pc, pcg);                          pool_cache_invalidate_groups(pc, pcg);
                 }                  }
                 if ((pcg = cc->cc_previous) != NULL) {                  if ((pcg = cc->cc_previous) != &pcg_dummy) {
                         pcg->pcg_next = NULL;                          pcg->pcg_next = NULL;
                         pool_cache_invalidate_groups(pc, pcg);                          pool_cache_invalidate_groups(pc, pcg);
                 }                  }
Line 2209  pool_cache_cpu_init1(struct cpu_info *ci
Line 2209  pool_cache_cpu_init1(struct cpu_info *ci
         cc->cc_cpuindex = index;          cc->cc_cpuindex = index;
         cc->cc_hits = 0;          cc->cc_hits = 0;
         cc->cc_misses = 0;          cc->cc_misses = 0;
         cc->cc_current = NULL;          cc->cc_current = &pcg_dummy;
         cc->cc_previous = NULL;          cc->cc_previous = &pcg_dummy;
   
         pc->pc_cpus[index] = cc;          pc->pc_cpus[index] = cc;
 }  }
Line 2359  pool_cache_sethardlimit(pool_cache_t pc,
Line 2359  pool_cache_sethardlimit(pool_cache_t pc,
         pool_sethardlimit(&pc->pc_pool, n, warnmess, ratecap);          pool_sethardlimit(&pc->pc_pool, n, warnmess, ratecap);
 }  }
   
 static inline pool_cache_cpu_t *  static bool __noinline
 pool_cache_cpu_enter(pool_cache_t pc, int *s)  pool_cache_get_slow(pool_cache_cpu_t *cc, int s, void **objectp,
 {  
         pool_cache_cpu_t *cc;  
   
         /*  
          * Prevent other users of the cache from accessing our  
          * CPU-local data.  To avoid touching shared state, we  
          * pull the neccessary information from CPU local data.  
          */  
         KPREEMPT_DISABLE(curlwp);  
         cc = pc->pc_cpus[curcpu()->ci_index];  
         KASSERT(cc->cc_cache == pc);  
         if (cc->cc_ipl != IPL_NONE) {  
                 *s = splraiseipl(cc->cc_iplcookie);  
         }  
   
         return cc;  
 }  
   
 static inline void  
 pool_cache_cpu_exit(pool_cache_cpu_t *cc, int *s)  
 {  
   
         /* No longer need exclusive access to the per-CPU data. */  
         if (cc->cc_ipl != IPL_NONE) {  
                 splx(*s);  
         }  
         KPREEMPT_ENABLE(curlwp);  
 }  
   
 pool_cache_cpu_t * __noinline  
 pool_cache_get_slow(pool_cache_cpu_t *cc, int *s, void **objectp,  
                     paddr_t *pap, int flags)                      paddr_t *pap, int flags)
 {  {
         pcg_t *pcg, *cur;          pcg_t *pcg, *cur;
Line 2406  pool_cache_get_slow(pool_cache_cpu_t *cc
Line 2375  pool_cache_get_slow(pool_cache_cpu_t *cc
          * Nothing was available locally.  Try and grab a group           * Nothing was available locally.  Try and grab a group
          * from the cache.           * from the cache.
          */           */
         if (!mutex_tryenter(&pc->pc_lock)) {          if (__predict_false(!mutex_tryenter(&pc->pc_lock))) {
                 ncsw = curlwp->l_ncsw;                  ncsw = curlwp->l_ncsw;
                 mutex_enter(&pc->pc_lock);                  mutex_enter(&pc->pc_lock);
                 pc->pc_contended++;                  pc->pc_contended++;
Line 2418  pool_cache_get_slow(pool_cache_cpu_t *cc
Line 2387  pool_cache_get_slow(pool_cache_cpu_t *cc
                  */                   */
                 if (curlwp->l_ncsw != ncsw) {                  if (curlwp->l_ncsw != ncsw) {
                         mutex_exit(&pc->pc_lock);                          mutex_exit(&pc->pc_lock);
                         pool_cache_cpu_exit(cc, s);                          return true;
                         return pool_cache_cpu_enter(pc, s);  
                 }                  }
         }          }
   
         if ((pcg = pc->pc_fullgroups) != NULL) {          if (__predict_true((pcg = pc->pc_fullgroups) != NULL)) {
                 /*                  /*
                  * If there's a full group, release our empty                   * If there's a full group, release our empty
                  * group back to the cache.  Install the full                   * group back to the cache.  Install the full
                  * group as cc_current and return.                   * group as cc_current and return.
                  */                   */
                 if ((cur = cc->cc_current) != NULL) {                  if (__predict_true((cur = cc->cc_current) != &pcg_dummy)) {
                         KASSERT(cur->pcg_avail == 0);                          KASSERT(cur->pcg_avail == 0);
                         cur->pcg_next = pc->pc_emptygroups;                          cur->pcg_next = pc->pc_emptygroups;
                         pc->pc_emptygroups = cur;                          pc->pc_emptygroups = cur;
Line 2441  pool_cache_get_slow(pool_cache_cpu_t *cc
Line 2409  pool_cache_get_slow(pool_cache_cpu_t *cc
                 pc->pc_hits++;                  pc->pc_hits++;
                 pc->pc_nfull--;                  pc->pc_nfull--;
                 mutex_exit(&pc->pc_lock);                  mutex_exit(&pc->pc_lock);
                 return cc;                  return true;
         }          }
   
         /*          /*
Line 2451  pool_cache_get_slow(pool_cache_cpu_t *cc
Line 2419  pool_cache_get_slow(pool_cache_cpu_t *cc
          */           */
         pc->pc_misses++;          pc->pc_misses++;
         mutex_exit(&pc->pc_lock);          mutex_exit(&pc->pc_lock);
         pool_cache_cpu_exit(cc, s);          splx(s);
   
         object = pool_get(&pc->pc_pool, flags);          object = pool_get(&pc->pc_pool, flags);
         *objectp = object;          *objectp = object;
         if (object == NULL)          if (__predict_false(object == NULL))
                 return NULL;                  return false;
   
         if ((*pc->pc_ctor)(pc->pc_arg, object, flags) != 0) {          if (__predict_false((*pc->pc_ctor)(pc->pc_arg, object, flags) != 0)) {
                 pool_put(&pc->pc_pool, object);                  pool_put(&pc->pc_pool, object);
                 *objectp = NULL;                  *objectp = NULL;
                 return NULL;                  return false;
         }          }
   
         KASSERT((((vaddr_t)object + pc->pc_pool.pr_itemoffset) &          KASSERT((((vaddr_t)object + pc->pc_pool.pr_itemoffset) &
Line 2476  pool_cache_get_slow(pool_cache_cpu_t *cc
Line 2444  pool_cache_get_slow(pool_cache_cpu_t *cc
         }          }
   
         FREECHECK_OUT(&pc->pc_freecheck, object);          FREECHECK_OUT(&pc->pc_freecheck, object);
         return NULL;          return false;
 }  }
   
 /*  /*
Line 2499  pool_cache_get_paddr(pool_cache_t pc, in
Line 2467  pool_cache_get_paddr(pool_cache_t pc, in
         }          }
 #endif  #endif
   
         cc = pool_cache_cpu_enter(pc, &s);          /* Lock out interrupts and disable preemption. */
           s = splvm();
         do {          do {
                 /* Try and allocate an object from the current group. */                  /* Try and allocate an object from the current group. */
                   cc = pc->pc_cpus[curcpu()->ci_index];
                   KASSERT(cc->cc_cache == pc);
                 pcg = cc->cc_current;                  pcg = cc->cc_current;
                 if (pcg != NULL && pcg->pcg_avail > 0) {                  if (__predict_true(pcg->pcg_avail > 0)) {
                         object = pcg->pcg_objects[--pcg->pcg_avail].pcgo_va;                          object = pcg->pcg_objects[--pcg->pcg_avail].pcgo_va;
                         if (pap != NULL)                          if (__predict_false(pap != NULL))
                                 *pap = pcg->pcg_objects[pcg->pcg_avail].pcgo_pa;                                  *pap = pcg->pcg_objects[pcg->pcg_avail].pcgo_pa;
 #if defined(DIAGNOSTIC)  #if defined(DIAGNOSTIC)
                         pcg->pcg_objects[pcg->pcg_avail].pcgo_va = NULL;                          pcg->pcg_objects[pcg->pcg_avail].pcgo_va = NULL;
Line 2513  pool_cache_get_paddr(pool_cache_t pc, in
Line 2484  pool_cache_get_paddr(pool_cache_t pc, in
                         KASSERT(pcg->pcg_avail <= pcg->pcg_size);                          KASSERT(pcg->pcg_avail <= pcg->pcg_size);
                         KASSERT(object != NULL);                          KASSERT(object != NULL);
                         cc->cc_hits++;                          cc->cc_hits++;
                         pool_cache_cpu_exit(cc, &s);                          splx(s);
                         FREECHECK_OUT(&pc->pc_freecheck, object);                          FREECHECK_OUT(&pc->pc_freecheck, object);
                         return object;                          return object;
                 }                  }
Line 2523  pool_cache_get_paddr(pool_cache_t pc, in
Line 2494  pool_cache_get_paddr(pool_cache_t pc, in
                  * it with the current group and allocate from there.                   * it with the current group and allocate from there.
                  */                   */
                 pcg = cc->cc_previous;                  pcg = cc->cc_previous;
                 if (pcg != NULL && pcg->pcg_avail > 0) {                  if (__predict_true(pcg->pcg_avail > 0)) {
                         cc->cc_previous = cc->cc_current;                          cc->cc_previous = cc->cc_current;
                         cc->cc_current = pcg;                          cc->cc_current = pcg;
                         continue;                          continue;
Line 2532  pool_cache_get_paddr(pool_cache_t pc, in
Line 2503  pool_cache_get_paddr(pool_cache_t pc, in
                 /*                  /*
                  * Can't allocate from either group: try the slow path.                   * Can't allocate from either group: try the slow path.
                  * If get_slow() allocated an object for us, or if                   * If get_slow() allocated an object for us, or if
                  * no more objects are available, it will return NULL.                   * no more objects are available, it will return false.
                  * Otherwise, we need to retry.                   * Otherwise, we need to retry.
                  */                   */
                 cc = pool_cache_get_slow(cc, &s, &object, pap, flags);          } while (pool_cache_get_slow(cc, s, &object, pap, flags));
         } while (cc != NULL);  
   
         return object;          return object;
 }  }
   
 pool_cache_cpu_t * __noinline  static bool __noinline
 pool_cache_put_slow(pool_cache_cpu_t *cc, int *s, void *object, paddr_t pa)  pool_cache_put_slow(pool_cache_cpu_t *cc, int s, void *object)
 {  {
         pcg_t *pcg, *cur;          pcg_t *pcg, *cur, *empty;
         uint64_t ncsw;          uint64_t ncsw;
         pool_cache_t pc;          pool_cache_t pc;
         u_int nobj;  
   
         pc = cc->cc_cache;          pc = cc->cc_cache;
         cc->cc_misses++;          cc->cc_misses++;
   
         /*          /*
          * No free slots locally.  Try to grab an empty, unused           * If there appear to be no empty groups in the cache then
          * group from the cache.           * allocate one in advance.
          */           */
         if (!mutex_tryenter(&pc->pc_lock)) {          empty = NULL;
                 ncsw = curlwp->l_ncsw;          if (__predict_false(pc->pc_emptygroups == NULL)) {
                   if (__predict_false(pool_cache_disable)) {
                           empty = NULL;
                   } else if (pc->pc_pcgsize == PCG_NOBJECTS_LARGE) {
                           empty = pool_get(&pcg_large_pool, PR_NOWAIT);
                   } else {
                           empty = pool_get(&pcg_normal_pool, PR_NOWAIT);
                   }
           }
   
           /* Lock the cache. */
           ncsw = curlwp->l_ncsw;
           if (__predict_false(!mutex_tryenter(&pc->pc_lock))) {
                 mutex_enter(&pc->pc_lock);                  mutex_enter(&pc->pc_lock);
                 pc->pc_contended++;                  pc->pc_contended++;
           }
   
                 /*          /*
                  * If we context switched while locking, then           * If we speculatively allocated an empty group, link it into
                  * our view of the per-CPU data is invalid:           * the cache's list.
                  * retry.           */
                  */          if (empty != NULL) {
                 if (curlwp->l_ncsw != ncsw) {                  empty->pcg_avail = 0;
                         mutex_exit(&pc->pc_lock);                  empty->pcg_size = pc->pc_pcgsize;
                         pool_cache_cpu_exit(cc, s);                  empty->pcg_next = pc->pc_emptygroups;
                         return pool_cache_cpu_enter(pc, s);                  pc->pc_emptygroups = empty;
                 }                  pc->pc_nempty++;
                   pc->pc_misses++;
         }          }
   
         if ((pcg = pc->pc_emptygroups) != NULL) {          /*
                 /*           * If we context switched while locking, then our view of the
                  * If there's a empty group, release our full           * per-CPU data is invalid: retry.
                  * group back to the cache.  Install the empty           */
                  * group and return.          if (__predict_false(curlwp->l_ncsw != ncsw)) {
                  */                  mutex_exit(&pc->pc_lock);
                   return true;
           }
   
           /*
            * If there's a empty group, release our full group back
            * to the cache.  Install the empty group to the local CPU
            * and return.
            */
           if (__predict_true((pcg = pc->pc_emptygroups) != NULL)) {
                 KASSERT(pcg->pcg_avail == 0);                  KASSERT(pcg->pcg_avail == 0);
                 pc->pc_emptygroups = pcg->pcg_next;                  pc->pc_emptygroups = pcg->pcg_next;
                 if (cc->cc_previous == NULL) {                  if (__predict_false(cc->cc_previous == &pcg_dummy)) {
                         cc->cc_previous = pcg;                          cc->cc_previous = pcg;
                 } else {                  } else {
                         if ((cur = cc->cc_current) != NULL) {                          cur = cc->cc_current;
                           if (__predict_true(cur != &pcg_dummy)) {
                                 KASSERT(cur->pcg_avail == pcg->pcg_size);                                  KASSERT(cur->pcg_avail == pcg->pcg_size);
                                 cur->pcg_next = pc->pc_fullgroups;                                  cur->pcg_next = pc->pc_fullgroups;
                                 pc->pc_fullgroups = cur;                                  pc->pc_fullgroups = cur;
Line 2592  pool_cache_put_slow(pool_cache_cpu_t *cc
Line 2585  pool_cache_put_slow(pool_cache_cpu_t *cc
                         }                          }
                         cc->cc_current = pcg;                          cc->cc_current = pcg;
                 }                  }
                 pc->pc_hits++;                  pc->pc_hits += (empty == NULL);
                 pc->pc_nempty--;                  pc->pc_nempty--;
                 mutex_exit(&pc->pc_lock);                  mutex_exit(&pc->pc_lock);
                 return cc;                  return true;
         }          }
   
         /*          /*
          * Nothing available locally or in cache.  Take the           * Nothing available locally or in cache, and we didn't
          * slow path and try to allocate a new group that we           * allocate an empty group.  Take the slow path and destroy
          * can release to.           * the object here and now.
          */           */
         pc->pc_misses++;          pc->pc_misses++;
         mutex_exit(&pc->pc_lock);          mutex_exit(&pc->pc_lock);
         pool_cache_cpu_exit(cc, s);          splx(s);
           pool_cache_destruct_object(pc, object);
         /*  
          * If we can't allocate a new group, just throw the  
          * object away.  
          */  
         nobj = pc->pc_pcgsize;  
         if (pool_cache_disable) {  
                 pcg = NULL;  
         } else if (nobj == PCG_NOBJECTS_LARGE) {  
                 pcg = pool_get(&pcg_large_pool, PR_NOWAIT);  
         } else {  
                 pcg = pool_get(&pcg_normal_pool, PR_NOWAIT);  
         }  
         if (pcg == NULL) {  
                 pool_cache_destruct_object(pc, object);  
                 return NULL;  
         }  
         pcg->pcg_avail = 0;  
         pcg->pcg_size = nobj;  
   
         /*  
          * Add the empty group to the cache and try again.  
          */  
         mutex_enter(&pc->pc_lock);  
         pcg->pcg_next = pc->pc_emptygroups;  
         pc->pc_emptygroups = pcg;  
         pc->pc_nempty++;  
         mutex_exit(&pc->pc_lock);  
   
         return pool_cache_cpu_enter(pc, s);          return false;
 }  }
   
 /*  /*
Line 2653  pool_cache_put_paddr(pool_cache_t pc, vo
Line 2619  pool_cache_put_paddr(pool_cache_t pc, vo
   
         FREECHECK_IN(&pc->pc_freecheck, object);          FREECHECK_IN(&pc->pc_freecheck, object);
   
         cc = pool_cache_cpu_enter(pc, &s);          /* Lock out interrupts and disable preemption. */
           s = splvm();
         do {          do {
                 /* If the current group isn't full, release it there. */                  /* If the current group isn't full, release it there. */
                   cc = pc->pc_cpus[curcpu()->ci_index];
                   KASSERT(cc->cc_cache == pc);
                 pcg = cc->cc_current;                  pcg = cc->cc_current;
                 if (pcg != NULL && pcg->pcg_avail < pcg->pcg_size) {                  if (__predict_true(pcg->pcg_avail < pcg->pcg_size)) {
                         pcg->pcg_objects[pcg->pcg_avail].pcgo_va = object;                          pcg->pcg_objects[pcg->pcg_avail].pcgo_va = object;
                         pcg->pcg_objects[pcg->pcg_avail].pcgo_pa = pa;                          pcg->pcg_objects[pcg->pcg_avail].pcgo_pa = pa;
                         pcg->pcg_avail++;                          pcg->pcg_avail++;
                         cc->cc_hits++;                          cc->cc_hits++;
                         pool_cache_cpu_exit(cc, &s);                          splx(s);
                         return;                          return;
                 }                  }
   
                 /*                  /*
                  * That failed.  If the previous group is empty, swap                   * That failed.  If the previous group isn't full, swap
                  * it with the current group and try again.                   * it with the current group and try again.
                  */                   */
                 pcg = cc->cc_previous;                  pcg = cc->cc_previous;
                 if (pcg != NULL && pcg->pcg_avail == 0) {                  if (__predict_true(pcg->pcg_avail < pcg->pcg_size)) {
                         cc->cc_previous = cc->cc_current;                          cc->cc_previous = cc->cc_current;
                         cc->cc_current = pcg;                          cc->cc_current = pcg;
                         continue;                          continue;
Line 2680  pool_cache_put_paddr(pool_cache_t pc, vo
Line 2649  pool_cache_put_paddr(pool_cache_t pc, vo
                 /*                  /*
                  * Can't free to either group: try the slow path.                   * Can't free to either group: try the slow path.
                  * If put_slow() releases the object for us, it                   * If put_slow() releases the object for us, it
                  * will return NULL.  Otherwise we need to retry.                   * will return false.  Otherwise we need to retry.
                  */                   */
                 cc = pool_cache_put_slow(cc, &s, object, pa);          } while (pool_cache_put_slow(cc, s, object));
         } while (cc != NULL);  
 }  }
   
 /*  /*
Line 2697  pool_cache_xcall(pool_cache_t pc)
Line 2665  pool_cache_xcall(pool_cache_t pc)
 {  {
         pool_cache_cpu_t *cc;          pool_cache_cpu_t *cc;
         pcg_t *prev, *cur, **list;          pcg_t *prev, *cur, **list;
         int s = 0; /* XXXgcc */          int s;
   
         cc = pool_cache_cpu_enter(pc, &s);  
         cur = cc->cc_current;  
         cc->cc_current = NULL;  
         prev = cc->cc_previous;  
         cc->cc_previous = NULL;  
         pool_cache_cpu_exit(cc, &s);  
   
         /*  
          * XXXSMP Go to splvm to prevent kernel_lock from being taken,  
          * because locks at IPL_SOFTXXX are still spinlocks.  Does not  
          * apply to IPL_SOFTBIO.  Cross-call threads do not take the  
          * kernel_lock.  
          */  
         s = splvm();          s = splvm();
         mutex_enter(&pc->pc_lock);          mutex_enter(&pc->pc_lock);
         if (cur != NULL) {          cc = pc->pc_cpus[curcpu()->ci_index];
           cur = cc->cc_current;
           cc->cc_current = &pcg_dummy;
           prev = cc->cc_previous;
           cc->cc_previous = &pcg_dummy;
           if (cur != &pcg_dummy) {
                 if (cur->pcg_avail == cur->pcg_size) {                  if (cur->pcg_avail == cur->pcg_size) {
                         list = &pc->pc_fullgroups;                          list = &pc->pc_fullgroups;
                         pc->pc_nfull++;                          pc->pc_nfull++;
Line 2728  pool_cache_xcall(pool_cache_t pc)
Line 2688  pool_cache_xcall(pool_cache_t pc)
                 cur->pcg_next = *list;                  cur->pcg_next = *list;
                 *list = cur;                  *list = cur;
         }          }
         if (prev != NULL) {          if (prev != &pcg_dummy) {
                 if (prev->pcg_avail == prev->pcg_size) {                  if (prev->pcg_avail == prev->pcg_size) {
                         list = &pc->pc_fullgroups;                          list = &pc->pc_fullgroups;
                         pc->pc_nfull++;                          pc->pc_nfull++;
Legend:
Removed from v.1.161  
changed lines
  Added in v.1.162
CVSweb <webmaster@jp.NetBSD.org>