version 1.1.2.5, 2012/02/28 00:25:25
|
version 1.1.2.6, 2012/02/28 09:28:00
|
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 440 mpool_chkaddr(void * __restrict data)
|
Line 443 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_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); |
|
} |
} |
} |