| /memcached-1.6.32/ |
| D | memcached.c | 634 assert(sfd >= 0 && sfd < max_fds); in conn_new()
672 c->sfd = sfd; in conn_new()
873 assert(c->sfd >= 0 && c->sfd < max_fds); in conn_free()
916 close(c->sfd); in conn_close()
2996 int sfd; local
3419 int sfd; local
3432 return sfd;
3489 int sfd; local
3847 int sfd; local
3861 return sfd;
[all …]
|
| D | thread.c | 43 int sfd; member
368 item->sfd = sfd; in notify_worker_fd()
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
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()
[all …]
|
| D | proto_bin.c | 65 fprintf(stderr, "\n<%d ", c->sfd); in try_read_command_binary()
156 fprintf(stderr, ">%d Writing bin response:", c->sfd); in add_bin_header()
159 fprintf(stderr, "\n>%d ", c->sfd); in add_bin_header()
238 c->binary_header.request.opcode, c->sfd); in handle_binary_protocol_error()
385 c->thread->cur_sfd = c->sfd; // for store_item logging. in complete_update_bin()
612 fprintf(stderr, "<%d STATS ", c->sfd); in process_bin_stat()
892 c->thread->cur_sfd = c->sfd; // cuddle sfd for logging. in dispatch_bin_command()
1101 fprintf(stderr, "<%d ADD ", c->sfd); in process_bin_update()
1103 fprintf(stderr, "<%d SET ", c->sfd); in process_bin_update()
1105 fprintf(stderr, "<%d REPLACE ", c->sfd); in process_bin_update()
[all …]
|
| D | logger.h | 99 int sfd; member
110 int sfd; member
125 int sfd; member
204 int sfd; /* client fd */ member
248 enum logger_add_watcher_ret logger_add_watcher(void *c, const int sfd, uint16_t f);
|
| D | logger.c | 102 int sfd = va_arg(ap, int); in _logger_log_item_get() local
110 le->sfd = sfd; in _logger_log_item_get()
122 int sfd = va_arg(ap, int); in _logger_log_item_store() local
136 le->sfd = sfd; in _logger_log_item_store()
157 int sfd = va_arg(ap, int); in _logger_log_conn_event() local
162 le->sfd = sfd; in _logger_log_conn_event()
333 reason_map[le->reason], le->sfd); in _logger_parse_cce()
793 watchers_pollfds[nfd].fd = w->sfd; in logger_thread_poll_watchers()
797 watchers_pollfds[nfd].fd = w->sfd; in logger_thread_poll_watchers()
1104 w->sfd = sfd; in logger_add_watcher()
[all …]
|
| D | tls.h | 10 void *ssl_accept(conn *c, int sfd, bool *fail);
26 #define ssl_accept(c, sfd, fail) NULL argument
|
| D | crawler.h | 36 void *c, const int sfd, unsigned int remaining);
39 void *c, const int sfd);
|
| D | tls.c | 40 void *ssl_accept(conn *c, int sfd, bool *fail) { in ssl_accept() argument
63 SSL_set_fd(ssl, sfd); in ssl_accept()
86 NULL, c->sfd, strerror(errno)); in ssl_accept()
93 NULL, c->sfd, ssl_err); in ssl_accept()
178 NULL, c->sfd, strerror(errno)); in ssl_read()
185 NULL, c->sfd, ssl_err); in ssl_read()
214 NULL, c->sfd, strerror(errno)); in ssl_write()
221 NULL, c->sfd, ssl_err); in ssl_write()
|
| D | crawler.c | 31 int sfd; /* client fd. */ member
378 to_poll[0].fd = c->sfd; in lru_crawler_write()
738 static int lru_crawler_set_client(crawler_module_t *cm, void *c, const int sfd) { in lru_crawler_set_client() argument
744 crawlc->sfd = sfd; in lru_crawler_set_client()
759 void *c, const int sfd) { in lru_crawler_start() argument
799 if (c == NULL || sfd == 0) { in lru_crawler_start()
803 if (lru_crawler_set_client(&active_crawler_mod, c, sfd) != 0) { in lru_crawler_start()
839 void *c, const int sfd, unsigned int remaining) { in lru_crawler_crawl() argument
870 starts = lru_crawler_start(hash_crawl ? NULL : tocrawl, remaining, type, NULL, c, sfd); in lru_crawler_crawl()
|
| D | proto_text.c | 181 c->thread->cur_sfd = c->sfd; // cuddle sfd for logging. in complete_nread_ascii()
188 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
204 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
693 fprintf(stderr, ">%d END\n", c->sfd); in process_get_command()
1353 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_mget_command()
2060 NULL, status, comm, key, nkey, 0, 0, c->sfd); in process_update_command()
2386 switch(logger_add_watcher(c, c->sfd, f)) { in process_watch_command()
2698 c, c->sfd, LRU_CRAWLER_CAP_REMAINING); in process_lru_crawler_command()
2739 c, c->sfd, LRU_CRAWLER_CAP_REMAINING); in process_lru_crawler_command()
2834 fprintf(stderr, "<%d %s\n", c->sfd, command); in process_command_ascii()
[all …]
|
| D | memcached.h | 828 int sfd; member
961 conn *conn_new(const int sfd, const enum conn_states init_state, const int event_flags, const int r…
992 void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags, int read_buffer_size,
|
| D | proto_proxy.c | 1183 rctx->conn_fd = c->sfd; in proxy_process_command()
|