Lines Matching refs:server
74 if (server.tcpkeepalive) in createClient()
75 anetKeepAlive(NULL,fd,server.tcpkeepalive); in createClient()
76 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
86 c->id = server.next_client_id++; in createClient()
100 c->ctime = c->lastinteraction = server.unixtime; in createClient()
128 if (fd != -1) listAddNodeTail(server.clients,c); in createClient()
186 listAddNodeHead(server.clients_pending_write,c); in prepareClientToWrite()
629 if (listLength(server.clients) > server.maxclients) { in acceptCommonHandler()
636 server.stat_rejected_conn++; in acceptCommonHandler()
645 if (server.protected_mode && in acceptCommonHandler()
646 server.bindaddr_count == 0 && in acceptCommonHandler()
647 server.requirepass == NULL && in acceptCommonHandler()
676 server.stat_rejected_conn++; in acceptCommonHandler()
682 server.stat_numconnections++; in acceptCommonHandler()
694 cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport); in acceptTcpHandler()
698 "Accepting client connection: %s", server.neterr); in acceptTcpHandler()
713 cfd = anetUnixAccept(server.neterr, fd); in acceptUnixHandler()
717 "Accepting client connection: %s", server.neterr); in acceptUnixHandler()
720 serverLog(LL_VERBOSE,"Accepted connection to %s", server.unixsocket); in acceptUnixHandler()
737 while (listLength(server.slaves)) { in disconnectSlaves()
738 listNode *ln = listFirst(server.slaves); in disconnectSlaves()
750 if (server.current_client == c) server.current_client = NULL; in unlinkClient()
757 ln = listSearchKey(server.clients,c); in unlinkClient()
759 listDelNode(server.clients,ln); in unlinkClient()
762 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in unlinkClient()
763 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in unlinkClient()
770 ln = listSearchKey(server.clients_pending_write,c); in unlinkClient()
772 listDelNode(server.clients_pending_write,ln); in unlinkClient()
779 ln = listSearchKey(server.unblocked_clients,c); in unlinkClient()
781 listDelNode(server.unblocked_clients,ln); in unlinkClient()
794 if (server.master && c->flags & CLIENT_MASTER) { in freeClient()
846 list *l = (c->flags & CLIENT_MONITOR) ? server.monitors : server.slaves; in freeClient()
853 if (c->flags & CLIENT_SLAVE && listLength(server.slaves) == 0) in freeClient()
854 server.repl_no_slaves_since = server.unixtime; in freeClient()
865 ln = listSearchKey(server.clients_to_close,c); in freeClient()
867 listDelNode(server.clients_to_close,ln); in freeClient()
886 listAddNodeTail(server.clients_to_close,c); in freeClientAsync()
890 while (listLength(server.clients_to_close)) { in freeClientsInAsyncFreeQueue()
891 listNode *ln = listFirst(server.clients_to_close); in freeClientsInAsyncFreeQueue()
896 listDelNode(server.clients_to_close,ln); in freeClientsInAsyncFreeQueue()
952 server.stat_net_output_bytes += totwritten; in writeToClient()
954 (server.maxmemory == 0 || in writeToClient()
955 zmalloc_used_memory() < server.maxmemory)) break; in writeToClient()
972 if (!(c->flags & CLIENT_MASTER)) c->lastinteraction = server.unixtime; in writeToClient()
976 if (handler_installed) aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in writeToClient()
1001 int processed = listLength(server.clients_pending_write); in handleClientsWithPendingWrites()
1003 listRewind(server.clients_pending_write,&li); in handleClientsWithPendingWrites()
1007 listDelNode(server.clients_pending_write,ln); in handleClientsWithPendingWrites()
1015 aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, in handleClientsWithPendingWrites()
1085 c->repl_ack_time = server.unixtime; in processInlineBuffer()
1112 if (server.verbosity <= LL_VERBOSE) { in setProtocolError()
1261 server.current_client = c; in processInputBuffer()
1301 if (server.current_client == NULL) break; in processInputBuffer()
1304 server.current_client = NULL; in processInputBuffer()
1348 c->lastinteraction = server.unixtime; in readQueryFromClient()
1350 server.stat_net_input_bytes += nread; in readQueryFromClient()
1351 if (sdslen(c->querybuf) > server.client_max_querybuf_len) { in readQueryFromClient()
1371 listRewind(server.clients,&li); in getClientsMaxBuffers()
1397 snprintf(peerid,peerid_len,"%s:0",server.unixsocket); in genClientPeerId()
1443 emask = client->fd == -1 ? 0 : aeGetFileEvents(server.el,client->fd); in catClientInfoString()
1454 (long long)(server.unixtime - client->ctime), in catClientInfoString()
1455 (long long)(server.unixtime - client->lastinteraction), in catClientInfoString()
1474 sds o = sdsnewlen(NULL,200*listLength(server.clients)); in getAllClientsInfoString()
1476 listRewind(server.clients,&li); in getAllClientsInfoString()
1565 listRewind(server.clients,&li); in clientCommand()
1780 if (server.client_obuf_limits[class].hard_limit_bytes && in checkClientOutputBufferLimits()
1781 used_mem >= server.client_obuf_limits[class].hard_limit_bytes) in checkClientOutputBufferLimits()
1783 if (server.client_obuf_limits[class].soft_limit_bytes && in checkClientOutputBufferLimits()
1784 used_mem >= server.client_obuf_limits[class].soft_limit_bytes) in checkClientOutputBufferLimits()
1791 c->obuf_soft_limit_reached_time = server.unixtime; in checkClientOutputBufferLimits()
1794 time_t elapsed = server.unixtime - c->obuf_soft_limit_reached_time; in checkClientOutputBufferLimits()
1797 server.client_obuf_limits[class].soft_limit_seconds) { in checkClientOutputBufferLimits()
1836 listRewind(server.slaves,&li); in flushSlavesOutputBuffers()
1847 events = aeGetFileEvents(server.el,slave->fd); in flushSlavesOutputBuffers()
1875 if (!server.clients_paused || end > server.clients_pause_end_time) in pauseClients()
1876 server.clients_pause_end_time = end; in pauseClients()
1877 server.clients_paused = 1; in pauseClients()
1883 if (server.clients_paused && in clientsArePaused()
1884 server.clients_pause_end_time < server.mstime) in clientsArePaused()
1890 server.clients_paused = 0; in clientsArePaused()
1894 listRewind(server.clients,&li); in clientsArePaused()
1902 listAddNodeTail(server.unblocked_clients,c); in clientsArePaused()
1905 return server.clients_paused; in clientsArePaused()
1925 events += aeProcessEvents(server.el, AE_FILE_EVENTS|AE_DONT_WAIT); in processEventsWhileBlocked()