Lines Matching refs:b
104 static bool lru_bump_async(lru_bump_buf *b, item *it, uint32_t hv);
1283 static void lru_bump_buf_link_q(lru_bump_buf *b) { in lru_bump_buf_link_q() argument
1285 assert(b != bump_buf_head); in lru_bump_buf_link_q()
1287 b->prev = 0; in lru_bump_buf_link_q()
1288 b->next = bump_buf_head; in lru_bump_buf_link_q()
1289 if (b->next) b->next->prev = b; in lru_bump_buf_link_q()
1290 bump_buf_head = b; in lru_bump_buf_link_q()
1291 if (bump_buf_tail == 0) bump_buf_tail = b; in lru_bump_buf_link_q()
1297 lru_bump_buf *b = calloc(1, sizeof(lru_bump_buf)); in item_lru_bump_buf_create() local
1298 if (b == NULL) { in item_lru_bump_buf_create()
1302 b->buf = bipbuf_new(sizeof(lru_bump_entry) * LRU_BUMP_BUF_SIZE); in item_lru_bump_buf_create()
1303 if (b->buf == NULL) { in item_lru_bump_buf_create()
1304 free(b); in item_lru_bump_buf_create()
1308 pthread_mutex_init(&b->mutex, NULL); in item_lru_bump_buf_create()
1310 lru_bump_buf_link_q(b); in item_lru_bump_buf_create()
1311 return b; in item_lru_bump_buf_create()
1314 static bool lru_bump_async(lru_bump_buf *b, item *it, uint32_t hv) { in lru_bump_async() argument
1317 pthread_mutex_lock(&b->mutex); in lru_bump_async()
1318 lru_bump_entry *be = (lru_bump_entry *) bipbuf_request(b->buf, sizeof(lru_bump_entry)); in lru_bump_async()
1322 if (bipbuf_push(b->buf, sizeof(lru_bump_entry)) == 0) { in lru_bump_async()
1324 b->dropped++; in lru_bump_async()
1328 b->dropped++; in lru_bump_async()
1333 pthread_mutex_unlock(&b->mutex); in lru_bump_async()
1344 lru_bump_buf *b; in lru_maintainer_bumps() local
1350 for (b = bump_buf_head; b != NULL; b=b->next) { in lru_maintainer_bumps()
1351 pthread_mutex_lock(&b->mutex); in lru_maintainer_bumps()
1352 be = (lru_bump_entry *) bipbuf_peek_all(b->buf, &size); in lru_maintainer_bumps()
1353 pthread_mutex_unlock(&b->mutex); in lru_maintainer_bumps()
1370 pthread_mutex_lock(&b->mutex); in lru_maintainer_bumps()
1371 be = (lru_bump_entry *) bipbuf_poll(b->buf, size); in lru_maintainer_bumps()
1372 pthread_mutex_unlock(&b->mutex); in lru_maintainer_bumps()
1380 lru_bump_buf *b; in lru_total_bumps_dropped() local
1382 for (b = bump_buf_head; b != NULL; b=b->next) { in lru_total_bumps_dropped()
1383 pthread_mutex_lock(&b->mutex); in lru_total_bumps_dropped()
1384 total += b->dropped; in lru_total_bumps_dropped()
1385 pthread_mutex_unlock(&b->mutex); in lru_total_bumps_dropped()