Lines Matching refs:thread

341                 if (write(c->thread->notify_send_fd, buf, TIMEOUT_MSG_SIZE)  in conn_timeout_thread()
445 c->thread->stats.idle_kicks++; in conn_close_idle()
611 cache_free(c->thread->suffix_cache, *(c->suffixcurr)); in conn_release_items()
1013 pthread_mutex_lock(&c->thread->stats.mutex); in complete_nread_ascii()
1014 c->thread->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in complete_nread_ascii()
1015 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_nread_ascii()
1327 pthread_mutex_lock(&c->thread->stats.mutex); in complete_incr_bin()
1329 c->thread->stats.incr_misses++; in complete_incr_bin()
1331 c->thread->stats.decr_misses++; in complete_incr_bin()
1333 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_incr_bin()
1351 pthread_mutex_lock(&c->thread->stats.mutex); in complete_update_bin()
1352 c->thread->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in complete_update_bin()
1353 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_update_bin()
1468 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()
1470 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
1471 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_bin_get_or_touch()
1473 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
1474 c->thread->stats.slab_stats[ITEM_clsid(it)].get_hits++; in process_bin_get_or_touch()
1476 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_get_or_touch()
1518 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()
1520 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
1521 c->thread->stats.touch_misses++; in process_bin_get_or_touch()
1523 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
1524 c->thread->stats.get_misses++; in process_bin_get_or_touch()
1526 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_get_or_touch()
1939 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
1940 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
1941 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
1955 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
1956 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
1957 c->thread->stats.auth_errors++; in process_bin_complete_sasl_auth()
1958 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
2225 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_bin_update()
2353 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_flush()
2354 c->thread->stats.flush_cmds++; in process_bin_flush()
2355 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_flush()
2388 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_delete()
2389 c->thread->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_bin_delete()
2390 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_delete()
2399 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_delete()
2400 c->thread->stats.delete_misses++; in process_bin_delete()
2401 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_delete()
2579 pthread_mutex_lock(&c->thread->stats.mutex); in do_store_item()
2580 c->thread->stats.cas_misses++; in do_store_item()
2581 pthread_mutex_unlock(&c->thread->stats.mutex); in do_store_item()
2587 pthread_mutex_lock(&c->thread->stats.mutex); in do_store_item()
2588 c->thread->stats.slab_stats[ITEM_clsid(old_it)].cas_hits++; in do_store_item()
2589 pthread_mutex_unlock(&c->thread->stats.mutex); in do_store_item()
2594 pthread_mutex_lock(&c->thread->stats.mutex); in do_store_item()
2595 c->thread->stats.slab_stats[ITEM_clsid(old_it)].cas_badval++; in do_store_item()
2596 pthread_mutex_unlock(&c->thread->stats.mutex); in do_store_item()
2662 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, NULL, in do_store_item()
3213 suffix = cache_alloc(c->thread->suffix_cache); in process_get_command()
3279 pthread_mutex_lock(&c->thread->stats.mutex); in process_get_command()
3280 c->thread->stats.slab_stats[ITEM_clsid(it)].get_hits++; in process_get_command()
3281 c->thread->stats.get_cmds++; in process_get_command()
3282 pthread_mutex_unlock(&c->thread->stats.mutex); in process_get_command()
3288 pthread_mutex_lock(&c->thread->stats.mutex); in process_get_command()
3289 c->thread->stats.get_misses++; in process_get_command()
3290 c->thread->stats.get_cmds++; in process_get_command()
3291 pthread_mutex_unlock(&c->thread->stats.mutex); in process_get_command()
3401 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_update_command()
3454 pthread_mutex_lock(&c->thread->stats.mutex); in process_touch_command()
3455 c->thread->stats.touch_cmds++; in process_touch_command()
3456 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_touch_command()
3457 pthread_mutex_unlock(&c->thread->stats.mutex); in process_touch_command()
3462 pthread_mutex_lock(&c->thread->stats.mutex); in process_touch_command()
3463 c->thread->stats.touch_cmds++; in process_touch_command()
3464 c->thread->stats.touch_misses++; in process_touch_command()
3465 pthread_mutex_unlock(&c->thread->stats.mutex); in process_touch_command()
3505 pthread_mutex_lock(&c->thread->stats.mutex); in process_arithmetic_command()
3507 c->thread->stats.incr_misses++; in process_arithmetic_command()
3509 c->thread->stats.decr_misses++; in process_arithmetic_command()
3511 pthread_mutex_unlock(&c->thread->stats.mutex); in process_arithmetic_command()
3575 pthread_mutex_lock(&c->thread->stats.mutex); in do_add_delta()
3577 c->thread->stats.slab_stats[ITEM_clsid(it)].incr_hits++; in do_add_delta()
3579 c->thread->stats.slab_stats[ITEM_clsid(it)].decr_hits++; in do_add_delta()
3581 pthread_mutex_unlock(&c->thread->stats.mutex); in do_add_delta()
3669 pthread_mutex_lock(&c->thread->stats.mutex); in process_delete_command()
3670 c->thread->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_delete_command()
3671 pthread_mutex_unlock(&c->thread->stats.mutex); in process_delete_command()
3677 pthread_mutex_lock(&c->thread->stats.mutex); in process_delete_command()
3678 c->thread->stats.delete_misses++; in process_delete_command()
3679 pthread_mutex_unlock(&c->thread->stats.mutex); in process_delete_command()
3859 pthread_mutex_lock(&c->thread->stats.mutex); in process_command()
3860 c->thread->stats.flush_cmds++; in process_command()
3861 pthread_mutex_unlock(&c->thread->stats.mutex); in process_command()
4185 pthread_mutex_lock(&c->thread->stats.mutex); in try_read_udp()
4186 c->thread->stats.bytes_read += res; in try_read_udp()
4187 pthread_mutex_unlock(&c->thread->stats.mutex); in try_read_udp()
4259 pthread_mutex_lock(&c->thread->stats.mutex); in try_read_network()
4260 c->thread->stats.bytes_read += res; in try_read_network()
4261 pthread_mutex_unlock(&c->thread->stats.mutex); in try_read_network()
4363 pthread_mutex_lock(&c->thread->stats.mutex); in transmit()
4364 c->thread->stats.bytes_written += res; in transmit()
4365 pthread_mutex_unlock(&c->thread->stats.mutex); in transmit()
4440 pthread_mutex_lock(&c->thread->stats.mutex); in read_into_chunked_item()
4441 c->thread->stats.bytes_read += res; in read_into_chunked_item()
4442 pthread_mutex_unlock(&c->thread->stats.mutex); in read_into_chunked_item()
4588 pthread_mutex_lock(&c->thread->stats.mutex); in drive_machine()
4589 c->thread->stats.conn_yields++; in drive_machine()
4590 pthread_mutex_unlock(&c->thread->stats.mutex); in drive_machine()
4643 pthread_mutex_lock(&c->thread->stats.mutex); in drive_machine()
4644 c->thread->stats.bytes_read += res; in drive_machine()
4645 pthread_mutex_unlock(&c->thread->stats.mutex); in drive_machine()
4705 pthread_mutex_lock(&c->thread->stats.mutex); in drive_machine()
4706 c->thread->stats.bytes_read += res; in drive_machine()
4707 pthread_mutex_unlock(&c->thread->stats.mutex); in drive_machine()