Lines Matching refs:sfd
133 return read(c->sfd, buf, count); in tcp_read()
138 return sendmsg(c->sfd, msg, flags); in tcp_sendmsg()
143 return write(c->sfd, buf, count); in tcp_write()
506 "fd %d wants to timeout, but isn't in read state", c->sfd); in conn_close_idle()
511 fprintf(stderr, "Closing idle fd %d\n", c->sfd); in conn_close_idle()
526 event_set(&c->event, c->sfd, c->ev_flags, event_handler, (void *)c); in _conn_event_readd()
627 conn *conn_new(const int sfd, enum conn_states init_state, in conn_new() argument
634 assert(sfd >= 0 && sfd < max_fds); in conn_new()
635 c = conns[sfd]; in conn_new()
672 c->sfd = sfd; in conn_new()
673 conns[sfd] = c; in conn_new()
690 if (getpeername(sfd, (struct sockaddr *) &c->request_addr, in conn_new()
699 &c->request_addr, c->request_addr_size, c->transport, 0, sfd); in conn_new()
704 fprintf(stderr, "<%d server listening (%s)\n", sfd, in conn_new()
707 fprintf(stderr, "<%d server listening (udp)\n", sfd); in conn_new()
710 sfd); in conn_new()
712 fprintf(stderr, "<%d new ascii client connection.\n", sfd); in conn_new()
714 fprintf(stderr, "<%d new binary client connection.\n", sfd); in conn_new()
717 fprintf(stderr, "<%d new proxy client connection.\n", sfd); in conn_new()
721 sfd, c->protocol); in conn_new()
792 event_set(&c->event, sfd, event_flags, event_handler, (void *)c); in conn_new()
806 MEMCACHED_CONN_ALLOCATE(c->sfd); in conn_new()
834 c->sfd, c->protocol == binary_prot ? "binary" : "ascii"); in conn_release_items()
873 assert(c->sfd >= 0 && c->sfd < max_fds); in conn_free()
876 conns[c->sfd] = NULL; in conn_free()
894 c->close_reason, c->sfd); in conn_close()
901 fprintf(stderr, "<%d connection closed.\n", c->sfd); in conn_close()
911 MEMCACHED_CONN_RELEASE(c->sfd); in conn_close()
916 close(c->sfd); in conn_close()
975 c->sfd, state_text(c->state), in conn_set_state()
980 MEMCACHED_PROCESS_COMMAND_END(c->sfd, c->resp->wbuf, c->resp->wbytes); in conn_set_state()
1262 fprintf(stderr, ">%d NOREPLY %s\n", c->sfd, str); in out_string()
1268 fprintf(stderr, ">%d %s\n", c->sfd, str); in out_string()
2139 if (getsockname(c->sfd, in conn_to_str()
2152 getsockname(c->sfd, (struct sockaddr *)&svr_sock_addr, &svr_addr_len); in conn_to_str()
2394 fprintf(stderr, "%d: Client using the %s protocol\n", c->sfd,
2424 res = recvfrom(c->sfd, c->rbuf, c->rsize,
2536 event_set(&c->event, c->sfd, new_flags, event_handler, (void *)c);
2552 if (listen(next->sfd, settings.backlog) != 0) {
2558 if (listen(next->sfd, 0) != 0) {
2873 res = sendmsg(c->sfd, &msg, 0);
2996 int sfd; local
3017 sfd = accept4(c->sfd, (struct sockaddr *)&addr, &addrlen, SOCK_NONBLOCK);
3019 sfd = accept(c->sfd, (struct sockaddr *)&addr, &addrlen);
3022 sfd = accept(c->sfd, (struct sockaddr *)&addr, &addrlen);
3024 if (sfd == -1) {
3045 if (fcntl(sfd, F_SETFL, fcntl(sfd, F_GETFL) | O_NONBLOCK) < 0) {
3047 close(sfd);
3054 reject = sfd >= settings.maxconns - 1;
3066 res = write(sfd, str, strlen(str));
3067 close(sfd);
3071 void *ssl_v = ssl_accept(c, sfd, &fail);
3073 close(sfd);
3077 dispatch_conn_new(sfd, conn_new_cmd, EV_READ | EV_PERSIST,
3405 if (fd != c->sfd) {
3419 int sfd; local
3422 if ((sfd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol)) == -1) {
3426 if ((flags = fcntl(sfd, F_GETFL, 0)) < 0 ||
3427 fcntl(sfd, F_SETFL, flags | O_NONBLOCK) < 0) {
3429 close(sfd);
3432 return sfd;
3439 static void maximize_sndbuf(const int sfd) { argument
3447 if (getsockopt((SOCKET)sfd, SOL_SOCKET, SO_SNDBUF, (char *)&old_size, &intsize) != 0) {
3449 if (getsockopt(sfd, SOL_SOCKET, SO_SNDBUF, &old_size, &intsize) != 0) {
3462 if (setsockopt(sfd, SOL_SOCKET, SO_SNDBUF, (void *)&avg, intsize) == 0) {
3471 fprintf(stderr, "<%d send buffer was %d, now %d\n", sfd, old_size, last_good);
3489 int sfd; local
3517 if ((sfd = new_socket(next)) == -1) {
3532 error = getsockopt(sfd, SOL_SOCKET, SO_INCOMING_NAPI_ID, &napi_id, &len);
3541 error = setsockopt(sfd, IPPROTO_IPV6, IPV6_V6ONLY, (char *) &flags, sizeof(flags));
3544 close(sfd);
3551 …error = setsockopt(sfd, SOL_SOCKET, SOCK_COOKIE_ID, (void *)&settings.sock_cookie_id, sizeof(uint3…
3557 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags));
3559 maximize_sndbuf(sfd);
3561 error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags));
3565 error = setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling));
3569 error = setsockopt(sfd, IPPROTO_TCP, TCP_NODELAY, (void *)&flags, sizeof(flags));
3574 if (bind(sfd, next->ai_addr, next->ai_addrlen) == -1) {
3577 close(sfd);
3581 close(sfd);
3585 if (!IS_UDP(transport) && listen(sfd, settings.backlog) == -1) {
3587 close(sfd);
3599 if (getsockname(sfd, (struct sockaddr*)&my_sockaddr, &len)==0) {
3627 per_thread_fd = sfd;
3629 per_thread_fd = dup(sfd);
3640 if (!(listen_conn_add = conn_new(sfd, conn_listening,
3847 int sfd; local
3850 if ((sfd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
3855 if ((flags = fcntl(sfd, F_GETFL, 0)) < 0 ||
3856 fcntl(sfd, F_SETFL, flags | O_NONBLOCK) < 0) {
3858 close(sfd);
3861 return sfd;
3865 int sfd; local
3876 if ((sfd = new_socket_unix()) == -1) {
3888 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags));
3889 setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags));
3890 setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling));
3902 if (bind(sfd, (struct sockaddr *)&addr, sizeof(addr)) == -1) {
3904 close(sfd);
3909 if (listen(sfd, settings.backlog) == -1) {
3911 close(sfd);
3914 if (!(listen_conn = conn_new(sfd, conn_listening,