Lines Matching refs:server
64 char *argv[2] = {"",server.rdb_filename}; in rdbCheckThenExit()
420 if (server.rdb_compression && len > 20) { in rdbSaveRawString()
1009 int savelru = server.maxmemory_policy & MAXMEMORY_FLAG_LRU; in rdbSaveKeyValuePair()
1010 int savelfu = server.maxmemory_policy & MAXMEMORY_FLAG_LFU; in rdbSaveKeyValuePair()
1085 if (rdbSaveAuxFieldStrStr(rdb,"repl-id",server.replid) in rdbSaveInfoAuxFields()
1087 if (rdbSaveAuxFieldStrInt(rdb,"repl-offset",server.master_repl_offset) in rdbSaveInfoAuxFields()
1110 if (server.rdb_checksum) in rdbSaveRio()
1116 for (j = 0; j < server.dbnum; j++) { in rdbSaveRio()
1117 redisDb *db = server.db+j; in rdbSaveRio()
1165 if (rsi && dictSize(server.lua_scripts)) { in rdbSaveRio()
1166 di = dictGetIterator(server.lua_scripts); in rdbSaveRio()
1241 if (server.rdb_save_incremental_fsync) in rdbSave()
1270 server.dirty = 0; in rdbSave()
1271 server.lastsave = time(NULL); in rdbSave()
1272 server.lastbgsave_status = C_OK; 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()
1289 server.lastbgsave_try = time(NULL); in rdbSaveBackground()
1310 server.child_info_data.cow_size = private_dirty; in rdbSaveBackground()
1316 server.stat_fork_time = ustime()-start; in rdbSaveBackground()
1317 …server.stat_fork_rate = (double) zmalloc_used_memory() * 1000000 / server.stat_fork_time / (1024*1… in rdbSaveBackground()
1318 latencyAddSampleIfNeeded("fork",server.stat_fork_time/1000); in rdbSaveBackground()
1321 server.lastbgsave_status = C_ERR; in rdbSaveBackground()
1327 server.rdb_save_time_start = time(NULL); in rdbSaveBackground()
1328 server.rdb_child_pid = childpid; in rdbSaveBackground()
1329 server.rdb_child_type = RDB_CHILD_TYPE_DISK; in rdbSaveBackground()
1398 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
1399 server.list_compress_depth); in rdbLoadObject()
1415 if (len > server.set_max_intset_entries) { in rdbLoadObject()
1487 if (zsetLength(o) <= server.zset_max_ziplist_entries && in rdbLoadObject()
1488 maxelelen <= server.zset_max_ziplist_value) in rdbLoadObject()
1501 if (len > server.hash_max_ziplist_entries) in rdbLoadObject()
1520 if (sdslen(field) > server.hash_max_ziplist_value || in rdbLoadObject()
1521 sdslen(value) > server.hash_max_ziplist_value) in rdbLoadObject()
1556 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
1557 server.list_compress_depth); in rdbLoadObject()
1605 if (hashTypeLength(o) > server.hash_max_ziplist_entries || in rdbLoadObject()
1606 maxlen > server.hash_max_ziplist_value) in rdbLoadObject()
1620 if (intsetLen(o->ptr) > server.set_max_intset_entries) in rdbLoadObject()
1626 if (zsetLength(o) > server.zset_max_ziplist_entries) in rdbLoadObject()
1632 if (hashTypeLength(o) > server.hash_max_ziplist_entries) in rdbLoadObject()
1808 server.loading = 1; in startLoading()
1809 server.loading_start_time = time(NULL); in startLoading()
1810 server.loading_loaded_bytes = 0; in startLoading()
1812 server.loading_total_bytes = 0; in startLoading()
1814 server.loading_total_bytes = sb.st_size; in startLoading()
1820 server.loading_loaded_bytes = pos; in loadingProgress()
1821 if (server.stat_peak_memory < zmalloc_used_memory()) in loadingProgress()
1822 server.stat_peak_memory = zmalloc_used_memory(); in loadingProgress()
1827 server.loading = 0; in stopLoading()
1833 if (server.rdb_checksum) in rdbLoadProgressCallback()
1835 if (server.loading_process_events_interval_bytes && in rdbLoadProgressCallback()
1836 …(r->processed_bytes + len)/server.loading_process_events_interval_bytes > r->processed_bytes/serve… in rdbLoadProgressCallback()
1842 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER) in rdbLoadProgressCallback()
1854 redisDb *db = server.db+0; in rdbLoadRio()
1858 rdb->max_processing_chunk = server.loading_process_events_interval_bytes; in rdbLoadRio()
1914 if (dbid >= (unsigned)server.dbnum) { in rdbLoadRio()
1918 "databases. Exiting\n", server.dbnum); in rdbLoadRio()
1921 db = server.db+dbid; in rdbLoadRio()
1962 if (luaCreateFunction(NULL,server.lua,auxval) == NULL) { in rdbLoadRio()
2016 if (server.masterhost == NULL && !loading_aof && expiretime != -1 && expiretime < now) { in rdbLoadRio()
2045 if (server.rdb_checksum) { in rdbLoadRio()
2090 server.dirty = server.dirty - server.dirty_before_bgsave; in backgroundSaveDoneHandlerDisk()
2091 server.lastsave = time(NULL); in backgroundSaveDoneHandlerDisk()
2092 server.lastbgsave_status = C_OK; in backgroundSaveDoneHandlerDisk()
2095 server.lastbgsave_status = C_ERR; in backgroundSaveDoneHandlerDisk()
2102 rdbRemoveTempFile(server.rdb_child_pid); in backgroundSaveDoneHandlerDisk()
2108 server.lastbgsave_status = C_ERR; in backgroundSaveDoneHandlerDisk()
2110 server.rdb_child_pid = -1; in backgroundSaveDoneHandlerDisk()
2111 server.rdb_child_type = RDB_CHILD_TYPE_NONE; in backgroundSaveDoneHandlerDisk()
2112 server.rdb_save_time_last = time(NULL)-server.rdb_save_time_start; in backgroundSaveDoneHandlerDisk()
2113 server.rdb_save_time_start = -1; in backgroundSaveDoneHandlerDisk()
2134 server.rdb_child_pid = -1; in backgroundSaveDoneHandlerSocket()
2135 server.rdb_child_type = RDB_CHILD_TYPE_NONE; in backgroundSaveDoneHandlerSocket()
2136 server.rdb_save_time_start = -1; in backgroundSaveDoneHandlerSocket()
2150 if (read(server.rdb_pipe_read_result_from_child, ok_slaves, readlen) == in backgroundSaveDoneHandlerSocket()
2159 read(server.rdb_pipe_read_result_from_child, ok_slaves+1, in backgroundSaveDoneHandlerSocket()
2167 close(server.rdb_pipe_read_result_from_child); in backgroundSaveDoneHandlerSocket()
2168 close(server.rdb_pipe_write_result_to_parent); in backgroundSaveDoneHandlerSocket()
2175 listRewind(server.slaves,&li); in backgroundSaveDoneHandlerSocket()
2216 switch(server.rdb_child_type) { in backgroundSaveDoneHandler()
2241 if (server.aof_child_pid != -1 || server.rdb_child_pid != -1) return C_ERR; in rdbSaveToSlavesSockets()
2247 server.rdb_pipe_read_result_from_child = pipefds[0]; in rdbSaveToSlavesSockets()
2248 server.rdb_pipe_write_result_to_parent = pipefds[1]; in rdbSaveToSlavesSockets()
2252 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
2256 clientids = zmalloc(sizeof(uint64_t)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
2259 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
2271 anetSendTimeout(NULL,slave->fd,server.repl_timeout*1000); in rdbSaveToSlavesSockets()
2303 server.child_info_data.cow_size = private_dirty; in rdbSaveToSlavesSockets()
2338 write(server.rdb_pipe_write_result_to_parent,msg,msglen) in rdbSaveToSlavesSockets()
2357 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
2373 server.stat_fork_time = ustime()-start; in rdbSaveToSlavesSockets()
2374 …server.stat_fork_rate = (double) zmalloc_used_memory() * 1000000 / server.stat_fork_time / (1024*1… in rdbSaveToSlavesSockets()
2375 latencyAddSampleIfNeeded("fork",server.stat_fork_time/1000); in rdbSaveToSlavesSockets()
2379 server.rdb_save_time_start = time(NULL); in rdbSaveToSlavesSockets()
2380 server.rdb_child_pid = childpid; in rdbSaveToSlavesSockets()
2381 server.rdb_child_type = RDB_CHILD_TYPE_SOCKET; in rdbSaveToSlavesSockets()
2392 if (server.rdb_child_pid != -1) { in saveCommand()
2398 if (rdbSave(server.rdb_filename,rsiptr) == C_OK) { in saveCommand()
2423 if (server.rdb_child_pid != -1) { in bgsaveCommand()
2425 } else if (server.aof_child_pid != -1) { in bgsaveCommand()
2427 server.rdb_bgsave_scheduled = 1; in bgsaveCommand()
2435 } else if (rdbSaveBackground(server.rdb_filename,rsiptr) == C_OK) { in bgsaveCommand()
2462 if (!server.masterhost && server.repl_backlog) { in rdbPopulateSaveInfo()
2468 rsi->repl_stream_db = server.slaveseldb == -1 ? 0 : server.slaveseldb; in rdbPopulateSaveInfo()
2474 if (server.master) { in rdbPopulateSaveInfo()
2475 rsi->repl_stream_db = server.master->db->id; in rdbPopulateSaveInfo()
2484 if (server.cached_master) { in rdbPopulateSaveInfo()
2485 rsi->repl_stream_db = server.cached_master->db->id; in rdbPopulateSaveInfo()