Lines Matching refs:c
407 conn *c = conn_new(item->sfd, item->init_state, item->event_flags, in thread_libevent_process() local
410 if (c == NULL) { in thread_libevent_process()
422 c->thread = me; in thread_libevent_process()
489 void redispatch_conn(conn *c) { in redispatch_conn() argument
498 c->state = conn_closed; in redispatch_conn()
499 close(c->sfd); in redispatch_conn()
502 LIBEVENT_THREAD *thread = c->thread; in redispatch_conn()
506 item->event_flags = c->event_flags; in redispatch_conn()
507 item->conn = c; in redispatch_conn()
512 void sidethread_conn_close(conn *c) { in sidethread_conn_close() argument
513 c->state = conn_closed; in sidethread_conn_close()
515 fprintf(stderr, "<%d connection closed from side thread.\n", c->sfd); in sidethread_conn_close()
516 close(c->sfd); in sidethread_conn_close()
548 item *item_get(const char *key, const size_t nkey, conn *c) { in item_get() argument
553 it = do_item_get(key, nkey, hv, c); in item_get()
558 item *item_touch(const char *key, size_t nkey, uint32_t exptime, conn *c) { in item_touch() argument
563 it = do_item_touch(key, nkey, exptime, hv, c); in item_touch()
630 enum delta_result_type add_delta(conn *c, const char *key, in add_delta() argument
639 ret = do_add_delta(c, key, nkey, incr, delta, buf, cas, hv); in add_delta()
647 enum store_item_type store_item(item *item, int comm, conn* c) { in store_item() argument
653 ret = do_store_item(item, comm, c, hv); in store_item()