| /memcached-1.6.32/ |
| D | daemon.c | 46 int fd; in daemonize() local
67 if (noclose == 0 && (fd = open("/dev/null", O_RDWR, 0)) != -1) { in daemonize()
68 if(dup2(fd, STDIN_FILENO) < 0) { in daemonize()
72 if(dup2(fd, STDOUT_FILENO) < 0) { in daemonize()
76 if(dup2(fd, STDERR_FILENO) < 0) { in daemonize()
81 if(close(fd) < 0) { in daemonize()
89 close(fd); in daemonize()
|
| D | proxy_network.c | 44 static void proxy_backend_handler(const int fd, const short which, void *arg);
46 static void proxy_beconn_handler(const int fd, const short which, void *arg);
48 static void proxy_event_handler(evutil_socket_t fd, short which, void *arg);
49 static void proxy_event_beconn(evutil_socket_t fd, short which, void *arg);
255 if (read(fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in proxy_event_beconn()
261 if (read(fd, buf, 1) != 1) { in proxy_event_beconn()
367 if (read(fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in proxy_event_handler()
380 if (read(fd, buf, 1) != 1) { in proxy_event_handler()
410 int fd = mcmc_fd(be->client); in _set_main_event() local
411 if (fd == 0) { in _set_main_event()
[all …]
|
| D | extstore.c | 67 int fd; member
293 f->fd = open(f->file, O_RDWR | O_CREAT, 0644); in extstore_init()
294 if (f->fd < 0) { in extstore_init()
308 if (fcntl(f->fd, F_SETLK, &lock) < 0) { in extstore_init()
313 if (ftruncate(f->fd, 0) < 0) { in extstore_init()
356 e->pages[i].fd = f->fd; in extstore_init()
904 ret = lseek(p->fd, p->offset + cur_io->offset, SEEK_SET); in extstore_io_thread()
907 ret = read(p->fd, cur_io->buf, cur_io->len); in extstore_io_thread()
909 ret = readv(p->fd, cur_io->iov, cur_io->iovcnt); in extstore_io_thread()
914 … ret = pread(p->fd, cur_io->buf, cur_io->len, p->offset + cur_io->offset); in extstore_io_thread()
[all …]
|
| D | thread.c | 106 static void thread_libevent_process(evutil_socket_t fd, short which, void *arg);
107 static void thread_libevent_ionotify(evutil_socket_t fd, short which, void *arg);
546 static void thread_libevent_ionotify(evutil_socket_t fd, short which, void *arg) { in thread_libevent_ionotify() argument
553 if (read(fd, &ev_count, sizeof(uint64_t)) != sizeof(uint64_t)) { in thread_libevent_ionotify()
561 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_ionotify()
587 static void thread_libevent_process(evutil_socket_t fd, short which, void *arg) { in thread_libevent_process() argument
596 if (read(fd, &ev_count, sizeof(uint64_t)) != sizeof(uint64_t)) { in thread_libevent_process()
604 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_process()
|
| D | extstore.h | 59 int fd; // internal usage member
|
| D | logger.c | 793 watchers_pollfds[nfd].fd = w->sfd; in logger_thread_poll_watchers()
797 watchers_pollfds[nfd].fd = w->sfd; in logger_thread_poll_watchers()
|
| D | memcached.c | 95 static void event_handler(const evutil_socket_t fd, const short which, void *arg);
156 static void maxconns_handler(const evutil_socket_t fd, const short which, void *arg) { in maxconns_handler() argument
159 if (fd == -42 || allow_new_conns == false) { in maxconns_handler()
3396 void event_handler(const evutil_socket_t fd, const short which, void *arg) { argument
3405 if (fd != c->sfd) {
3950 static void clock_handler(const evutil_socket_t fd, const short which, void *arg) { argument
|
| D | crawler.c | 378 to_poll[0].fd = c->sfd; in lru_crawler_write()
|
| D | proto_proxy.c | 116 static void proxy_gc_timerpoke(evutil_socket_t fd, short event, void *arg) { in proxy_gc_timerpoke() argument
|
| D | proxy_luafgen.c | 45 static void mcp_funcgen_wait_handler(const int fd, const short which, void *arg) { in mcp_funcgen_wait_handler() argument
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 35 int fd; member
760 return ctx->fd; in mcmc_fd()
782 if (getsockopt(ctx->fd, SOL_SOCKET, SO_ERROR, err, &errsize) == 0) { in mcmc_check_nonblock_connect()
815 ctx->fd = 0; in mcmc_connect()
881 ctx->fd = sock; in mcmc_connect()
898 int sent = send(ctx->fd, r, l, 0); in mcmc_send_request()
930 *sent = writev(ctx->fd, iov, iovcnt); in mcmc_request_writev()
1067 if (ctx->fd != 0) { in mcmc_disconnect()
1068 close(ctx->fd); in mcmc_disconnect()
1069 ctx->fd = 0; in mcmc_disconnect()
|
| /memcached-1.6.32/doc/ |
| D | tls.txt | 56 |......|--> read(fd) --> BIO_write(rbio) -->|.....|--> SSL_read(ssl) --> IN
60 |......|<-- write(fd) <-- BIO_read(wbio) <--|.....|<-- SSL_write(ssl) <-- OUT
|
| /memcached-1.6.32/t/ |
| D | client_crt.pem | 32 4f:38:da:f0:3d:68:3c:40:e7:db:fd:7a:79:89:4c:
|