Lines Matching refs:sfd
43 int sfd; member
102 static void notify_worker_fd(LIBEVENT_THREAD *t, int sfd, enum conn_queue_item_modes mode);
354 static void notify_worker_fd(LIBEVENT_THREAD *t, int sfd, enum conn_queue_item_modes mode) { in notify_worker_fd() argument
368 item->sfd = sfd; in notify_worker_fd()
620 c = conn_new(item->sfd, item->init_state, item->event_flags, in thread_libevent_process()
630 item->sfd); in thread_libevent_process()
636 close(item->sfd); in thread_libevent_process()
655 conn_close_idle(conns[item->sfd]); in thread_libevent_process()
659 conn_worker_readd(conns[item->sfd]); in thread_libevent_process()
725 static LIBEVENT_THREAD *select_thread_by_napi_id(int sfd) in select_thread_by_napi_id() argument
733 err = getsockopt(sfd, SOL_SOCKET, SO_INCOMING_NAPI_ID, &napi_id, &len); in select_thread_by_napi_id()
772 void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags, in dispatch_conn_new() argument
781 thread = select_thread_by_napi_id(sfd); in dispatch_conn_new()
785 close(sfd); in dispatch_conn_new()
791 item->sfd = sfd; in dispatch_conn_new()
801 MEMCACHED_CONN_DISPATCH(sfd, (int64_t)thread->thread_id); in dispatch_conn_new()
810 notify_worker_fd(c->thread, c->sfd, queue_redispatch); in redispatch_conn()
814 notify_worker_fd(c->thread, c->sfd, queue_timeout); in timeout_conn()
854 fprintf(stderr, "<%d connection closing from side thread.\n", c->sfd); in sidethread_conn_close()