[BACK]Return to mem.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitsess / src

Diff for /libaitsess/src/Attic/mem.c between versions 1.1.2.3 and 1.1.2.7

version 1.1.2.3, 2012/02/27 23:57:12 version 1.1.2.7, 2012/02/28 10:34:43
Line 49  SUCH DAMAGE. Line 49  SUCH DAMAGE.
 /*  /*
  * mpool_init() - Init memory pool   * mpool_init() - Init memory pool
  *   *
    * @maxmem = If !=0 set maximum memory quota
  * return: =NULL error or !=NULL new allocated pool   * return: =NULL error or !=NULL new allocated pool
  */   */
 mpool_t *  mpool_t *
mpool_init(void)mpool_init(u_long maxmem)
 {  {
         mpool_t *mp;          mpool_t *mp;
         register int i;          register int i;
Line 66  mpool_init(void) Line 67  mpool_init(void)
   
         pthread_mutex_init(&mp->pool_mtx, NULL);          pthread_mutex_init(&mp->pool_mtx, NULL);
   
           mp->pool_quota.max = maxmem;
   
         mpool_lock(mp);          mpool_lock(mp);
         for (i = 0; i < MEM_BUCKETS; i++) {          for (i = 0; i < MEM_BUCKETS; i++) {
                 TAILQ_INIT(&mp->pool_active[i]);                  TAILQ_INIT(&mp->pool_active[i]);
Line 228  mpool_malloc(mpool_t * __restrict mp, u_int size, cons Line 231  mpool_malloc(mpool_t * __restrict mp, u_int size, cons
 }  }
   
 /*  /*
    * mpool_realloc() Reallocate memory block with new size
    *
    * @mp = Memory pool
    * @data = Allocated memory data
    * @newsize = New size of memory block
    * @memname = Optional new memory block name
    * return: NULL error or !=NULL new reallocated memory block
    */
   void *
   mpool_realloc(mpool_t * __restrict mp, void * __restrict data, u_int newsize, const char *memname)
   {
           struct tagAlloc *m, *tmp;
           int idx, align, oidx, osize;
           void *p;
   
           /* if !data execute mpool_malloc() */
           if (!data)
                   return mpool_malloc(mp, newsize, memname);
   
           if (!mp) {
                   sess_SetErr(EINVAL, "Pool not specified");
                   return NULL;
           }
           /* check address range & sentinel */
           if (MEM_BADADDR(data) || MEM_CORRUPT(data)) {
                   sess_SetErr(EFAULT, "Corrupted memory address");
                   return NULL;
           } else {
                   osize = ((u_int*)data)[-2] * sizeof(u_int);
                   oidx = BucketIndex(osize);
           }
           /* prepare new size */
           if (newsize > MEM_ALLOC_MAX) {
                   sess_SetErr(ENOMEM, "Memory size is too large");
                   return NULL;
           } else {
                   newsize = (newsize + 3) & ~3;   /* must align to 4 because needed room for sentinels */
                   idx = BucketIndex(newsize);
           }
   
           mpool_lock(mp);
   
           /* quota */
           if (mp->pool_quota.max && 
                           (mp->pool_quota.curr + (newsize - osize)) > mp->pool_quota.max) {
                   sess_SetErr(ENOMEM, "Max.allocate memory quota has been reached");
                   mpool_unlock(mp);
                   return NULL;
           }
   
           /* find old memory block */
           TAILQ_FOREACH_SAFE(m, &mp->pool_active[oidx], alloc_node, tmp)
                   if (mem_data(m, void*) == data && mem_size(m) == osize) {
                           TAILQ_REMOVE(&mp->pool_active[oidx], m, alloc_node);
                           /* statistics */
                           mp->pool_calls.alloc--;
                           mp->pool_bytes.alloc -= osize;
                   }
           /* memory block not found! */
           if (!m) {
                   mpool_unlock(mp);
                   sess_SetErr(EFAULT, "Memory block not found");
                   return NULL;
           }
   
           /* try to reallocate memory block to new bucket */
           align = 1 << (idx + MEM_MIN_BUCKET);
           p = realloc(m->alloc_mem, align + 12);
           if (!p) {
                   LOGERR;
   
                   /* restore to old bucket pulled memory block for reallocation */
                   TAILQ_INSERT_HEAD(&mp->pool_active[oidx], m, alloc_node);
                   /* statistics */
                   mp->pool_calls.alloc++;
                   mp->pool_bytes.alloc += osize;
   
                   mpool_unlock(mp);
                   return NULL;
           } else  /* quota */
                   mp->pool_quota.curr += (newsize - osize);
   
           m->alloc_mem[0] = newsize / sizeof(u_int);
           m->alloc_mem[1] = MEM_MAGIC_START;
           m->alloc_mem[2 + newsize / sizeof(u_int)] = MEM_MAGIC_STOP;
           TAILQ_INSERT_HEAD(&mp->pool_active[idx], m, alloc_node);
           /* statistics */
           mp->pool_calls.alloc++;
           mp->pool_bytes.alloc += newsize;
   
           if (memname)
                   strlcpy(m->alloc_name, memname, sizeof m->alloc_name);
   
           mpool_unlock(mp);
           return mem_data(m, void*);
   }
   
   /*
  * mpool_purge() - Purge memory block cache and release resources   * mpool_purge() - Purge memory block cache and release resources
  *   *
  * @mp = Memory pool   * @mp = Memory pool
Line 235  mpool_malloc(mpool_t * __restrict mp, u_int size, cons Line 336  mpool_malloc(mpool_t * __restrict mp, u_int size, cons
  * return: -1 error or 0 ok   * return: -1 error or 0 ok
  */   */
 int  int
mpool_purge(mpool_t * __restrict mp, int atmost)mpool_purge(mpool_t * __restrict mp, u_int atmost)
 {  {
        register int i, cx = 0;        register int i, cx;
         struct tagAlloc *m, *tmp;          struct tagAlloc *m, *tmp;
   
         if (!mp) {          if (!mp) {
Line 247  mpool_purge(mpool_t * __restrict mp, int atmost) Line 348  mpool_purge(mpool_t * __restrict mp, int atmost)
   
         mpool_lock(mp);          mpool_lock(mp);
   
        for (i = 0; i < MEM_BUCKETS; i++) {        for (i = cx = 0; i < MEM_BUCKETS; cx = 0, i++) {
                 TAILQ_FOREACH_SAFE(m, &mp->pool_inactive[i], alloc_node, tmp) {                  TAILQ_FOREACH_SAFE(m, &mp->pool_inactive[i], alloc_node, tmp) {
                        /* count barrier for purge */                        /* barrier for purge */
                        if (cx++ < atmost)                        if (cx < atmost) {
                                 cx++;
                                 continue;                                  continue;
                           }
   
                         TAILQ_REMOVE(&mp->pool_inactive[i], m, alloc_node);                          TAILQ_REMOVE(&mp->pool_inactive[i], m, alloc_node);
                         /* statistics */                          /* statistics */
Line 285  int Line 388  int
 mpool_free(mpool_t * __restrict mp, void * __restrict data, int purge)  mpool_free(mpool_t * __restrict mp, void * __restrict data, int purge)
 {  {
         int idx;          int idx;
        struct tagAlloc *m;        struct tagAlloc *m, *tmp;
   
         if (!mp) {          if (!mp) {
                 sess_SetErr(EINVAL, "Pool not specified");                  sess_SetErr(EINVAL, "Pool not specified");
Line 296  mpool_free(mpool_t * __restrict mp, void * __restrict  Line 399  mpool_free(mpool_t * __restrict mp, void * __restrict 
                 sess_SetErr(EFAULT, "Corrupted memory address");                  sess_SetErr(EFAULT, "Corrupted memory address");
                 return -2;                  return -2;
         } else          } else
                idx = BucketIndex(((u_int*)data)[-2]);                idx = BucketIndex(((u_int*)data)[-2] * sizeof(u_int));
   
         mpool_lock(mp);          mpool_lock(mp);
        TAILQ_FOREACH(m, &mp->pool_active[idx], alloc_node)        TAILQ_FOREACH_SAFE(m, &mp->pool_active[idx], alloc_node, tmp)
                 if (mem_data(m, void*) == data) {                  if (mem_data(m, void*) == data) {
                         TAILQ_REMOVE(&mp->pool_active[idx], m, alloc_node);                          TAILQ_REMOVE(&mp->pool_active[idx], m, alloc_node);
                         /* statistics */                          /* statistics */
Line 342  int Line 445  int
 mpool_free2(mpool_t * __restrict mp, u_int size, const char *memname, int purge)  mpool_free2(mpool_t * __restrict mp, u_int size, const char *memname, int purge)
 {  {
         int idx;          int idx;
        struct tagAlloc *m;        struct tagAlloc *m, *tmp;
   
         if (!mp || !memname) {          if (!mp || !memname) {
                 sess_SetErr(EINVAL, "Pool or memory name is not specified");                  sess_SetErr(EINVAL, "Pool or memory name is not specified");
Line 351  mpool_free2(mpool_t * __restrict mp, u_int size, const Line 454  mpool_free2(mpool_t * __restrict mp, u_int size, const
                 idx = BucketIndex(size);                  idx = BucketIndex(size);
   
         mpool_lock(mp);          mpool_lock(mp);
        TAILQ_FOREACH(m, &mp->pool_active[idx], alloc_node)        TAILQ_FOREACH_SAFE(m, &mp->pool_active[idx], alloc_node, tmp)
                 if (!strcmp(m->alloc_name, memname)) {                  if (!strcmp(m->alloc_name, memname)) {
                         TAILQ_REMOVE(&mp->pool_active[idx], m, alloc_node);                          TAILQ_REMOVE(&mp->pool_active[idx], m, alloc_node);
                         /* statistics */                          /* statistics */
Line 438  mpool_chkaddr(void * __restrict data) Line 541  mpool_chkaddr(void * __restrict data)
                 return 1;                  return 1;
         /* data address is ok! */          /* data address is ok! */
         return 0;          return 0;
   }
   
   /*
    * mpool_setquota() - Change maximum memory quota
    *
    * @mp = Memory pool
    * @maxmem = New max quota size
    * return: old maximum memory quota size
    */
   inline u_long
   mpool_setquota(mpool_t * __restrict mp, u_long maxmem)
   {
           u_long ret;
   
           if (!mp)
                   return 0;
   
           ret = mp->pool_quota.max;
           mp->pool_quota.max = maxmem;
   
           /* if new max quota is less then current allocated memory, 
            *      try to purge memory cache blocks
            */
           if (mp->pool_quota.max < mp->pool_quota.curr)
                   mpool_purge(mp, 0);
   
           return ret;
   }
   
   /*
    * mpool_getquota() - Get memory quota
    *
    * @mp = Memory pool
    * @currmem = Return current memory
    * @maxmem = Return max quota size
    * return: none
    */
   inline void
   mpool_getquota(mpool_t * __restrict mp, u_long *currmem, u_long *maxmem)
   {
           if (!mp)
                   return;
   
           if (maxmem)
                   *maxmem = mp->pool_quota.max;
           if (currmem)
                   *currmem = mp->pool_quota.curr;
   }
   
   /* ----------------------------------------------------------- */
   
   /*
    * mpool_statistics() - Dump statistics from memory pool buckets
    *
    * @mp = Memory pool
    * @cb = Export statistics to callback
    * return: none
    */
   void
   mpool_statistics(mpool_t * __restrict mp, mpool_stat_cb cb)
   {
           struct tagAlloc *m;
           register int i, act, inact;
   
           if (!mp || !cb)
                   return;
   
           for (i = act = inact = 0; i < MEM_BUCKETS; act = inact = 0, i++) {
                   TAILQ_FOREACH(m, &mp->pool_active[i], alloc_node)
                           act++;
                   TAILQ_FOREACH(m, &mp->pool_inactive[i], alloc_node)
                           inact++;
   
                   cb(1 << (i + MEM_MIN_BUCKET), act, inact);
           }
 }  }
Removed from v.1.1.2.3  
changed lines
  Added in v.1.1.2.7

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>