Lines Matching refs:sfd
438 "fd %d wants to timeout, but isn't in read state", c->sfd); in conn_close_idle()
443 fprintf(stderr, "Closing idle fd %d\n", c->sfd); in conn_close_idle()
452 conn *conn_new(const int sfd, enum conn_states init_state, in conn_new() argument
458 assert(sfd >= 0 && sfd < max_fds); in conn_new()
459 c = conns[sfd]; in conn_new()
507 c->sfd = sfd; in conn_new()
508 conns[sfd] = c; in conn_new()
524 if (getpeername(sfd, (struct sockaddr *) &c->request_addr, in conn_new()
533 fprintf(stderr, "<%d server listening (%s)\n", sfd, in conn_new()
536 fprintf(stderr, "<%d server listening (udp)\n", sfd); in conn_new()
539 sfd); in conn_new()
541 fprintf(stderr, "<%d new ascii client connection.\n", sfd); in conn_new()
543 fprintf(stderr, "<%d new binary client connection.\n", sfd); in conn_new()
546 sfd, c->protocol); in conn_new()
574 event_set(&c->event, sfd, event_flags, event_handler, (void *)c); in conn_new()
588 MEMCACHED_CONN_ALLOCATE(c->sfd); in conn_new()
646 assert(c->sfd >= 0 && c->sfd < max_fds); in conn_free()
649 conns[c->sfd] = NULL; in conn_free()
675 fprintf(stderr, "<%d connection closed.\n", c->sfd); in conn_close()
679 MEMCACHED_CONN_RELEASE(c->sfd); in conn_close()
681 close(c->sfd); in conn_close()
783 c->sfd, state_text(c->state), in conn_set_state()
788 MEMCACHED_PROCESS_COMMAND_END(c->sfd, c->wbuf, c->wbytes); in conn_set_state()
950 fprintf(stderr, ">%d NOREPLY %s\n", c->sfd, str); in out_string()
957 fprintf(stderr, ">%d %s\n", c->sfd, str); in out_string()
1054 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1058 MEMCACHED_COMMAND_REPLACE(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1062 MEMCACHED_COMMAND_APPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1066 MEMCACHED_COMMAND_PREPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1070 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1074 MEMCACHED_COMMAND_CAS(c->sfd, ITEM_key(it), it->nkey, it->nbytes, in complete_nread_ascii()
1154 fprintf(stderr, ">%d Writing bin response:", c->sfd); in add_bin_header()
1157 fprintf(stderr, "\n>%d ", c->sfd); in add_bin_header()
1208 fprintf(stderr, ">%d UNHANDLED ERROR: %d\n", c->sfd, err); in write_bin_error()
1213 fprintf(stderr, ">%d Writing an error: %s\n", c->sfd, errstr); in write_bin_error()
1384 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1388 MEMCACHED_COMMAND_REPLACE(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1392 MEMCACHED_COMMAND_APPEND(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1396 MEMCACHED_COMMAND_PREPEND(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1400 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1448 fprintf(stderr, "<%d %s ", c->sfd, should_touch ? "TOUCH" : "GET"); in process_bin_get_or_touch()
1479 MEMCACHED_COMMAND_TOUCH(c->sfd, ITEM_key(it), it->nkey, in process_bin_get_or_touch()
1482 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_bin_get_or_touch()
1529 MEMCACHED_COMMAND_TOUCH(c->sfd, key, nkey, -1, 0); in process_bin_get_or_touch()
1531 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_bin_get_or_touch()
1672 fprintf(stderr, "<%d STATS ", c->sfd); in process_bin_stat()
1750 c->sfd, (unsigned long)c->rsize, (unsigned long)nsize); in bin_read_key()
1759 c->sfd); in bin_read_key()
1774 fprintf(stderr, "%d: Repack input buffer\n", c->sfd); in bin_read_key()
1789 c->binary_header.request.opcode, c->sfd); in handle_binary_protocol_error()
1998 MEMCACHED_PROCESS_COMMAND_START(c->sfd, c->rcurr, c->rbytes); in dispatch_bin_command()
2192 fprintf(stderr, "<%d ADD ", c->sfd); in process_bin_update()
2194 fprintf(stderr, "<%d SET ", c->sfd); in process_bin_update()
2196 fprintf(stderr, "<%d REPLACE ", c->sfd); in process_bin_update()
2387 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_bin_delete()
2977 if (getsockname(c->sfd, in conn_to_str()
3195 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_get_command()
3246 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_get_command()
3271 fprintf(stderr, ">%d sending key ", c->sfd); in process_get_command()
3292 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_get_command()
3317 fprintf(stderr, ">%d END\n", c->sfd); in process_get_command()
3565 MEMCACHED_COMMAND_INCR(c->sfd, ITEM_key(it), it->nkey, value); in do_add_delta()
3572 MEMCACHED_COMMAND_DECR(c->sfd, ITEM_key(it), it->nkey, value); in do_add_delta()
3667 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_delete_command()
3744 switch(logger_add_watcher(c, c->sfd, f)) { in process_watch_command()
3791 MEMCACHED_PROCESS_COMMAND_START(c->sfd, c->rcurr, c->rbytes); in process_command()
3794 fprintf(stderr, "<%d %s\n", c->sfd, command); in process_command()
4052 fprintf(stderr, "%d: Client using the %s protocol\n", c->sfd, in try_read_command()
4069 fprintf(stderr, "%d: Realign input buffer\n", c->sfd); in try_read_command()
4079 fprintf(stderr, "<%d Read binary protocol data:", c->sfd); in try_read_command()
4082 fprintf(stderr, "\n<%d ", c->sfd); in try_read_command()
4180 res = recvfrom(c->sfd, c->rbuf, c->rsize, in try_read_udp()
4257 res = read(c->sfd, c->rbuf + c->rbytes, avail); in try_read_network()
4290 event_set(&c->event, c->sfd, new_flags, event_handler, (void *)c); in update_event()
4306 if (listen(next->sfd, settings.backlog) != 0) { in do_accept_new_conns()
4312 if (listen(next->sfd, 0) != 0) { in do_accept_new_conns()
4361 res = sendmsg(c->sfd, m, 0); in transmit()
4437 res = read(c->sfd, ch->data + ch->used, in read_into_chunked_item()
4469 int sfd; in drive_machine() local
4490 sfd = accept4(c->sfd, (struct sockaddr *)&addr, &addrlen, SOCK_NONBLOCK); in drive_machine()
4492 sfd = accept(c->sfd, (struct sockaddr *)&addr, &addrlen); in drive_machine()
4495 sfd = accept(c->sfd, (struct sockaddr *)&addr, &addrlen); in drive_machine()
4497 if (sfd == -1) { in drive_machine()
4518 if (fcntl(sfd, F_SETFL, fcntl(sfd, F_GETFL) | O_NONBLOCK) < 0) { in drive_machine()
4520 close(sfd); in drive_machine()
4528 res = write(sfd, str, strlen(str)); in drive_machine()
4529 close(sfd); in drive_machine()
4534 dispatch_conn_new(sfd, conn_new_cmd, EV_READ | EV_PERSIST, in drive_machine()
4641 res = read(c->sfd, c->ritem, c->rlbytes); in drive_machine()
4703 res = read(c->sfd, c->rbuf, c->rsize > c->sbytes ? c->sbytes : c->rsize); in drive_machine()
4823 if (fd != c->sfd) { in event_handler()
4837 int sfd; in new_socket() local
4840 if ((sfd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol)) == -1) { in new_socket()
4844 if ((flags = fcntl(sfd, F_GETFL, 0)) < 0 || in new_socket()
4845 fcntl(sfd, F_SETFL, flags | O_NONBLOCK) < 0) { in new_socket()
4847 close(sfd); in new_socket()
4850 return sfd; in new_socket()
4857 static void maximize_sndbuf(const int sfd) { in maximize_sndbuf() argument
4864 if (getsockopt(sfd, SOL_SOCKET, SO_SNDBUF, &old_size, &intsize) != 0) { in maximize_sndbuf()
4876 if (setsockopt(sfd, SOL_SOCKET, SO_SNDBUF, (void *)&avg, intsize) == 0) { in maximize_sndbuf()
4885 fprintf(stderr, "<%d send buffer was %d, now %d\n", sfd, old_size, last_good); in maximize_sndbuf()
4901 int sfd; in server_socket() local
4929 if ((sfd = new_socket(next)) == -1) { in server_socket()
4943 error = setsockopt(sfd, IPPROTO_IPV6, IPV6_V6ONLY, (char *) &flags, sizeof(flags)); in server_socket()
4946 close(sfd); in server_socket()
4952 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags)); in server_socket()
4954 maximize_sndbuf(sfd); in server_socket()
4956 error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags)); in server_socket()
4960 error = setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling)); in server_socket()
4964 error = setsockopt(sfd, IPPROTO_TCP, TCP_NODELAY, (void *)&flags, sizeof(flags)); in server_socket()
4969 if (bind(sfd, next->ai_addr, next->ai_addrlen) == -1) { in server_socket()
4972 close(sfd); in server_socket()
4976 close(sfd); in server_socket()
4980 if (!IS_UDP(transport) && listen(sfd, settings.backlog) == -1) { in server_socket()
4982 close(sfd); in server_socket()
4994 if (getsockname(sfd, (struct sockaddr*)&my_sockaddr, &len)==0) { in server_socket()
5020 int per_thread_fd = c ? dup(sfd) : sfd; in server_socket()
5026 if (!(listen_conn_add = conn_new(sfd, conn_listening, in server_socket()
5106 int sfd; in new_socket_unix() local
5109 if ((sfd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) { in new_socket_unix()
5114 if ((flags = fcntl(sfd, F_GETFL, 0)) < 0 || in new_socket_unix()
5115 fcntl(sfd, F_SETFL, flags | O_NONBLOCK) < 0) { in new_socket_unix()
5117 close(sfd); in new_socket_unix()
5120 return sfd; in new_socket_unix()
5124 int sfd; in server_socket_unix() local
5135 if ((sfd = new_socket_unix()) == -1) { in server_socket_unix()
5147 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags)); in server_socket_unix()
5148 setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags)); in server_socket_unix()
5149 setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling)); in server_socket_unix()
5161 if (bind(sfd, (struct sockaddr *)&addr, sizeof(addr)) == -1) { in server_socket_unix()
5163 close(sfd); in server_socket_unix()
5168 if (listen(sfd, settings.backlog) == -1) { in server_socket_unix()
5170 close(sfd); in server_socket_unix()
5173 if (!(listen_conn = conn_new(sfd, conn_listening, in server_socket_unix()