Home
last modified time | relevance | path

Searched refs:server (Results 1 – 25 of 188) sorted by relevance

12345678

/f-stack/app/redis-5.0.5/src/
H A Dreplication.c87 server.repl_backlog_off = server.master_repl_offset+1; in createReplicationBacklog()
1029 memcpy(server.replid2,server.replid,sizeof(server.replid)); in shiftReplicationId()
1219 server.repl_transfer_lastio = server.unixtime; in readSyncBulkPayload()
1309 memcpy(server.replid,server.master->replid,sizeof(server.replid)); in readSyncBulkPayload()
1989 if (server.master) freeClient(server.master); in replicationUnsetMaster()
2017 server.repl_down_since = server.unixtime; in replicationHandleMasterDisconnection()
2190 server.cached_master = server.master; in replicationCacheMaster()
2220 memcpy(server.master->replid, server.replid, sizeof(server.replid)); in replicationCacheMasterUsingMyself()
2224 server.cached_master = server.master; in replicationCacheMasterUsingMyself()
2247 server.master = server.cached_master; in replicationResurrectCachedMaster()
[all …]
H A Dconfig.c146 … server.saveparams = zrealloc(server.saveparams,sizeof(struct saveparam)*(server.saveparamslen+1)); in appendServerSaveParams()
147 server.saveparams[server.saveparamslen].seconds = seconds; in appendServerSaveParams()
148 server.saveparams[server.saveparamslen].changes = changes; in appendServerSaveParams()
221 if (server.port < 0 || server.port > 65535) { in loadServerConfigFromString()
295 if (server.syslog_ident) zfree(server.syslog_ident); in loadServerConfigFromString()
809 if (server.cluster_enabled && server.masterhost) { in loadServerConfigFromString()
1551 server.masterhost, server.masterport);
1567 sds aux = sdsjoin(server.bindaddr,server.bindaddr_count," ");
1909 if (server.cluster_enabled || server.masterhost == NULL) {
1914 server.masterhost, server.masterport);
[all …]
H A Dserver.c1109 server.hz = server.config_hz; in serverCron()
1539 server.hz = server.config_hz = CONFIG_DEFAULT_HZ; in initServerConfig()
2032 server.hz = server.config_hz; in initServer()
2062 listenToPort(server.port,server.ipfd,&server.ipfd_count) == C_ERR) in initServer()
2068 server.sofd = anetUnixServer(server.neterr,server.unixsocket, in initServer()
2078 if (server.ipfd_count == 0 && server.sofd < 0) { in initServer()
2148 if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE, in initServer()
2164 server.aof_fd = open(server.aof_filename, in initServer()
2625 if (server.maxmemory && !server.lua_timedout) { in processCommand()
2755 if (server.sofd != -1) close(server.sofd); in closeListeningSockets()
[all …]
H A Dchildinfo.c44 memset(&server.child_info_data,0,sizeof(server.child_info_data)); in openChildInfoPipe()
50 if (server.child_info_pipe[0] != -1 || in closeChildInfoPipe()
51 server.child_info_pipe[1] != -1) in closeChildInfoPipe()
53 close(server.child_info_pipe[0]); in closeChildInfoPipe()
54 close(server.child_info_pipe[1]); in closeChildInfoPipe()
55 server.child_info_pipe[0] = -1; in closeChildInfoPipe()
56 server.child_info_pipe[1] = -1; in closeChildInfoPipe()
67 if (write(server.child_info_pipe[1],&server.child_info_data,wlen) != wlen) { in sendChildInfo()
76 if (read(server.child_info_pipe[0],&server.child_info_data,wlen) == wlen && in receiveChildInfo()
80 server.stat_rdb_cow_bytes = server.child_info_data.cow_size; in receiveChildInfo()
[all …]
H A Daof.c285 server.aof_last_fsync = server.unixtime; in startAppendOnly()
350 server.unixtime > server.aof_last_fsync && in flushAppendOnlyFile()
389 nwritten = aofWrite(server.aof_fd,server.aof_buf,sdslen(server.aof_buf)); in flushAppendOnlyFile()
506 server.aof_fsync_offset = server.aof_current_size; in flushAppendOnlyFile()
507 server.aof_last_fsync = server.unixtime; in flushAppendOnlyFile()
509 server.unixtime > server.aof_last_fsync)) { in flushAppendOnlyFile()
512 server.aof_fsync_offset = server.aof_current_size; in flushAppendOnlyFile()
514 server.aof_last_fsync = server.unixtime; in flushAppendOnlyFile()
718 server.aof_fsync_offset = server.aof_current_size; in loadAppendOnlyFile()
856 server.aof_rewrite_base_size = server.aof_current_size; in loadAppendOnlyFile()
[all …]
H A Devict.c338 …unsigned long num_periods = server.lfu_decay_time ? LFUTimeElapsed(ldt) / server.lfu_decay_time : … in LFUDecrAndReturn()
360 listRewind(server.slaves,&li); in freeMemoryGetNotCountedMemory()
366 if (server.aof_state != AOF_OFF) { in freeMemoryGetNotCountedMemory()
405 int return_ok_asap = !server.maxmemory || mem_reported <= server.maxmemory; in getMaxmemoryState()
416 if (!server.maxmemory) { in getMaxmemoryState()
449 if (server.masterhost && server.repl_slave_ignore_maxmemory) return C_OK; in freeMemoryIfNeeded()
490 db = server.db+i; in freeMemoryIfNeeded()
540 db = server.db+j; in freeMemoryIfNeeded()
554 db = server.db+bestdbid; in freeMemoryIfNeeded()
576 server.stat_evictedkeys++; in freeMemoryIfNeeded()
[all …]
H A Dcluster.c452 memset(server.cluster->slots,0, sizeof(server.cluster->slots)); in clusterInit()
474 server.cfd_count = 0; in clusterInit()
489 server.cfd,&server.cfd_count) == C_ERR) in clusterInit()
496 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
626 if (server.masterhost == NULL && server.loading) return; in clusterAcceptHandler()
2279 server.cluster_announce_port : server.port; in clusterBuildMessageHdr()
2734 if (server.cluster->lastVoteEpoch == server.cluster->currentEpoch) { in clusterSendFailoverAuthIfNeeded()
2801 server.cluster->lastVoteEpoch = server.cluster->currentEpoch; in clusterSendFailoverAuthIfNeeded()
3084 server.cluster->failover_auth_epoch = server.cluster->currentEpoch; in clusterHandleSlaveFailover()
3276 if (server.cluster->mf_end && server.cluster->mf_end < mstime()) { in manualFailoverCheckTimeout()
[all …]
H A Dslowlog.c90 se->id = server.slowlog_entry_id++; in slowlogCreateEntry()
115 server.slowlog = listCreate(); in slowlogInit()
116 server.slowlog_entry_id = 0; in slowlogInit()
117 listSetFreeMethod(server.slowlog,slowlogFreeEntry); in slowlogInit()
125 if (duration >= server.slowlog_log_slower_than) in slowlogPushEntryIfNeeded()
126 listAddNodeHead(server.slowlog, in slowlogPushEntryIfNeeded()
130 while (listLength(server.slowlog) > server.slowlog_max_len) in slowlogPushEntryIfNeeded()
131 listDelNode(server.slowlog,listLast(server.slowlog)); in slowlogPushEntryIfNeeded()
136 while (listLength(server.slowlog) > 0) in slowlogReset()
137 listDelNode(server.slowlog,listLast(server.slowlog)); in slowlogReset()
[all …]
H A Ddb.c125 server.current_client != server.master && in lookupKeyReadWithFlags()
382 c->db = &server.db[id]; in selectDb()
464 server.dirty++; in flushallCommand()
479 server.dirty++; in delGenericCommand()
863 if (server.loading || server.sentinel_mode) in shutdownCommand()
907 server.dirty++; in renameGenericCommand()
970 server.dirty++; in moveCommand()
1005 redisDb *db1 = &server.db[id1], *db2 = &server.db[id2]; in dbSwapDatabases()
1056 server.dirty++; in swapdbCommand()
1085 int writable_slave = server.masterhost && server.repl_slave_ro == 0; in setExpire()
[all …]
H A Drdb.c1270 server.dirty = 0; in rdbSave()
1286 if (server.aof_child_pid != -1 || server.rdb_child_pid != -1) return C_ERR; in rdbSaveBackground()
1288 server.dirty_before_bgsave = server.dirty; in rdbSaveBackground()
1808 server.loading = 1; in startLoading()
1827 server.loading = 0; in stopLoading()
1842 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER) in rdbLoadProgressCallback()
2090 server.dirty = server.dirty - server.dirty_before_bgsave; in backgroundSaveDoneHandlerDisk()
2112 server.rdb_save_time_last = time(NULL)-server.rdb_save_time_start; in backgroundSaveDoneHandlerDisk()
2462 if (!server.masterhost && server.repl_backlog) { in rdbPopulateSaveInfo()
2468 rsi->repl_stream_db = server.slaveseldb == -1 ? 0 : server.slaveseldb; in rdbPopulateSaveInfo()
[all …]
H A Dexpire.c61 if (server.lazyfree_lazy_expire) in activeExpireCycleTryExpire()
68 server.stat_expiredkeys++; in activeExpireCycleTryExpire()
129 if (dbs_per_call > server.dbnum || timelimit_exit) in activeExpireCycle()
130 dbs_per_call = server.dbnum; in activeExpireCycle()
151 redisDb *db = server.db+(current_db % server.dbnum); in activeExpireCycle()
300 while(dbids && dbid < server.dbnum) { in expireSlaveKeys()
302 redisDb *db = server.db+dbid; in expireSlaveKeys()
427 if (when <= mstime() && !server.loading && !server.masterhost) { in expireGenericCommand()
433 server.dirty++; in expireGenericCommand()
447 server.dirty++; in expireGenericCommand()
[all …]
H A Ddefrag.c62 server.stat_active_defrag_misses++; in activeDefragAlloc()
69 server.stat_active_defrag_misses++; in activeDefragAlloc()
460 server.stat_active_defrag_scanned++; in scanLaterZsetCallback()
479 server.stat_active_defrag_scanned++; in scanLaterSetCallback()
500 server.stat_active_defrag_scanned++; in scanLaterHashCallback()
847 server.stat_active_defrag_scanned++; in defragScanCallback()
1001 if (!server.active_defrag_running) { in computeDefragCycles()
1002 …if(frag_pct < server.active_defrag_threshold_lower || frag_bytes < server.active_defrag_ignore_byt… in computeDefragCycles()
1042 if (server.aof_child_pid!=-1 || server.rdb_child_pid!=-1) in activeDefragCycle()
1050 if (!server.active_defrag_running) in activeDefragCycle()
[all …]
H A Dnetworking.c96 if (server.tcpkeepalive) in createClient()
677 if (listLength(server.clients) > server.maxclients) { in acceptCommonHandler()
693 if (server.protected_mode && in acceptCommonHandler()
730 server.stat_numconnections++; in acceptCommonHandler()
798 if (server.current_client == c) server.current_client = NULL; in unlinkClient()
914 list *l = (c->flags & CLIENT_MONITOR) ? server.monitors : server.slaves; in freeClient()
922 server.repl_no_slaves_since = server.unixtime; in freeClient()
1425 server.current_client = c; in processInputBuffer()
2182 if (!server.clients_paused || end > server.clients_pause_end_time) in pauseClients()
2184 server.clients_paused = 1; in pauseClients()
[all …]
H A Dscripting.c362 if (server.lua_multi_emitted || (server.lua_caller->flags & CLIENT_MULTI)) { in luaRedisGenericCommand()
492 if (server.lua_random_dirty && !server.lua_replicate_commands) { in luaRedisGenericCommand()
496 } else if (server.masterhost && server.repl_slave_ro && in luaRedisGenericCommand()
538 if (server.cluster_enabled && !server.loading && in luaRedisGenericCommand()
1087 server.lua = lua; in scriptingInit()
1095 lua_close(server.lua); in scriptingRelease()
1242 if (elapsed >= server.lua_time_limit && server.lua_timedout == 0) { in luaMaskCountHook()
1253 if (server.lua_kill) { in luaMaskCountHook()
1281 server.lua_replicate_commands = server.lua_always_replicate_commands; in evalGenericCommand()
1360 server.lua_kill = 0; in evalGenericCommand()
[all …]
H A Dlatency.c140 di = dictGetSafeIterator(server.latency_events); in latencyResetEvent()
145 dictDelete(server.latency_events, event); in latencyResetEvent()
239 if (dictSize(server.latency_events) == 0 && in createLatencyReport()
240 server.latency_monitor_threshold == 0) in createLatencyReport()
252 di = dictGetSafeIterator(server.latency_events); in createLatencyReport()
277 if (server.stat_fork_rate < 10) { in createLatencyReport()
281 } else if (server.stat_fork_rate < 25) { in createLatencyReport()
285 } else if (server.stat_fork_rate < 100) { in createLatencyReport()
297 if (server.slowlog_log_slower_than < 0) { in createLatencyReport()
454 if (advise_hz && server.hz < 100) { in createLatencyReport()
[all …]
H A Dobject.c136 if (server.maxmemory == 0 || in createStringObjectFromLongLongWithOptions()
461 if ((server.maxmemory == 0 || in tryObjectEncoding()
962 (float)server.cron_malloc_stats.process_rss / server.cron_malloc_stats.zmalloc_used; in getMemoryOverheadData()
964 server.cron_malloc_stats.process_rss - server.cron_malloc_stats.zmalloc_used; in getMemoryOverheadData()
968 server.cron_malloc_stats.allocator_active - server.cron_malloc_stats.allocator_allocated; in getMemoryOverheadData()
972 server.cron_malloc_stats.allocator_resident - server.cron_malloc_stats.allocator_active; in getMemoryOverheadData()
974 (float)server.cron_malloc_stats.process_rss / server.cron_malloc_stats.allocator_resident; in getMemoryOverheadData()
976 server.cron_malloc_stats.process_rss - server.cron_malloc_stats.allocator_resident; in getMemoryOverheadData()
981 if (server.repl_backlog) in getMemoryOverheadData()
1028 mem = server.lua_scripts_mem; in getMemoryOverheadData()
[all …]
H A Dmulti.c111 propagate(server.multiCommand,c->db->id,&multistring,1, in execCommandPropagateMulti()
122 int was_master = server.masterhost == NULL; in execCommand()
147 if (!server.loading && server.masterhost && server.repl_slave_ro && in execCommand()
178 call(c,server.loading ? CMD_CALL_NONE : CMD_CALL_FULL); in execCommand()
193 int is_master = server.masterhost == NULL; in execCommand()
194 server.dirty++; in execCommand()
200 if (server.repl_backlog && was_master && !is_master) { in execCommand()
212 if (listLength(server.monitors) && !server.loading) in execCommand()
213 replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc); in execCommand()
321 listRewind(server.clients,&li1); in touchWatchedKeysOnFlush()
H A Dpubsub.c68 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
71 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
100 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
110 dictDelete(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
138 listAddNodeTail(server.pubsub_patterns,pat); in pubsubSubscribePattern()
161 ln = listSearchKey(server.pubsub_patterns,&pat); in pubsubUnsubscribePattern()
162 listDelNode(server.pubsub_patterns,ln); in pubsubUnsubscribePattern()
232 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
250 if (listLength(server.pubsub_patterns)) { in pubsubPublishMessage()
251 listRewind(server.pubsub_patterns,&li); in pubsubPublishMessage()
[all …]
H A Dblocked.c105 server.blocked_clients++; in blockClient()
106 server.blocked_clients_by_type[btype]++; in blockClient()
117 ln = listFirst(server.unblocked_clients); in processUnblockedClients()
120 listDelNode(server.unblocked_clients,ln); in processUnblockedClients()
176 server.blocked_clients--; in unblockClient()
177 server.blocked_clients_by_type[c->btype]--; in unblockClient()
211 listRewind(server.clients,&li); in disconnectAllBlockedClients()
247 while(listLength(server.ready_keys) != 0) { in handleClientsBlockedOnKeys()
254 l = server.ready_keys; in handleClientsBlockedOnKeys()
255 server.ready_keys = listCreate(); in handleClientsBlockedOnKeys()
[all …]
H A Dlatency.h71 #define latencyStartMonitor(var) if (server.latency_monitor_threshold) { \
79 #define latencyEndMonitor(var) if (server.latency_monitor_threshold) { \
85 if (server.latency_monitor_threshold && \
86 (var) >= server.latency_monitor_threshold) \
/f-stack/app/nginx-1.16.1/src/stream/
H A Dngx_stream_upstream_hash_module.c322 server = &peer->server; in ngx_stream_upstream_init_chash()
329 if (server->len >= 5 in ngx_stream_upstream_init_chash()
332 host = server->data + 5; in ngx_stream_upstream_init_chash()
340 c = server->data[server->len - j - 1]; in ngx_stream_upstream_init_chash()
345 port = server->data + server->len - j; in ngx_stream_upstream_init_chash()
355 host = server->data; in ngx_stream_upstream_init_chash()
356 host_len = server->len; in ngx_stream_upstream_init_chash()
377 points->point[points->number].server = server; in ngx_stream_upstream_init_chash()
528 server = point[hp->hash % points->number].server; in ngx_stream_upstream_get_chash_peer()
564 if (peer->server.len != server->len in ngx_stream_upstream_get_chash_peer()
[all …]
H A Dngx_stream_upstream_round_robin.c49 server = us->servers->elts; in ngx_stream_upstream_init_round_robin()
55 if (server[i].backup) { in ngx_stream_upstream_init_round_robin()
59 n += server[i].naddrs; in ngx_stream_upstream_init_round_robin()
60 w += server[i].naddrs * server[i].weight; in ngx_stream_upstream_init_round_robin()
90 if (server[i].backup) { in ngx_stream_upstream_init_round_robin()
105 peer[n].server = server[i].name; in ngx_stream_upstream_init_round_robin()
121 if (!server[i].backup) { in ngx_stream_upstream_init_round_robin()
125 n += server[i].naddrs; in ngx_stream_upstream_init_round_robin()
126 w += server[i].naddrs * server[i].weight; in ngx_stream_upstream_init_round_robin()
154 if (!server[i].backup) { in ngx_stream_upstream_init_round_robin()
[all …]
/f-stack/app/nginx-1.16.1/src/http/modules/
H A Dngx_http_upstream_hash_module.c322 server = &peer->server; in ngx_http_upstream_init_chash()
329 if (server->len >= 5 in ngx_http_upstream_init_chash()
332 host = server->data + 5; in ngx_http_upstream_init_chash()
340 c = server->data[server->len - j - 1]; in ngx_http_upstream_init_chash()
345 port = server->data + server->len - j; in ngx_http_upstream_init_chash()
355 host = server->data; in ngx_http_upstream_init_chash()
356 host_len = server->len; in ngx_http_upstream_init_chash()
377 points->point[points->number].server = server; in ngx_http_upstream_init_chash()
527 server = point[hp->hash % points->number].server; in ngx_http_upstream_get_chash_peer()
563 if (peer->server.len != server->len in ngx_http_upstream_get_chash_peer()
[all …]
/f-stack/app/nginx-1.16.1/src/http/
H A Dngx_http_upstream_round_robin.c43 server = us->servers->elts; in ngx_http_upstream_init_round_robin()
49 if (server[i].backup) { in ngx_http_upstream_init_round_robin()
53 n += server[i].naddrs; in ngx_http_upstream_init_round_robin()
54 w += server[i].naddrs * server[i].weight; in ngx_http_upstream_init_round_robin()
84 if (server[i].backup) { in ngx_http_upstream_init_round_robin()
99 peer[n].server = server[i].name; in ngx_http_upstream_init_round_robin()
115 if (!server[i].backup) { in ngx_http_upstream_init_round_robin()
119 n += server[i].naddrs; in ngx_http_upstream_init_round_robin()
120 w += server[i].naddrs * server[i].weight; in ngx_http_upstream_init_round_robin()
148 if (!server[i].backup) { in ngx_http_upstream_init_round_robin()
[all …]
/f-stack/freebsd/contrib/openzfs/etc/systemd/system/
H A Dzfs-share.service.in4 After=nfs-server.service nfs-kernel-server.service
9 PartOf=nfs-server.service nfs-kernel-server.service

12345678