Lines Matching refs:server
67 char *argv[2] = {"",server.rdb_filename}; in rdbCheckThenExit()
358 if (server.rdb_compression && len > 20) { in rdbSaveRawString()
770 if (server.rdb_checksum) in rdbSaveRio()
776 for (j = 0; j < server.dbnum; j++) { in rdbSaveRio()
777 redisDb *db = server.db+j; in rdbSaveRio()
906 server.dirty = 0; in rdbSave()
907 server.lastsave = time(NULL); in rdbSave()
908 server.lastbgsave_status = C_OK; in rdbSave()
922 if (server.aof_child_pid != -1 || server.rdb_child_pid != -1) return C_ERR; in rdbSaveBackground()
924 server.dirty_before_bgsave = server.dirty; in rdbSaveBackground()
925 server.lastbgsave_try = time(NULL); in rdbSaveBackground()
947 server.stat_fork_time = ustime()-start; in rdbSaveBackground()
948 …server.stat_fork_rate = (double) zmalloc_used_memory() * 1000000 / server.stat_fork_time / (1024*1… in rdbSaveBackground()
949 latencyAddSampleIfNeeded("fork",server.stat_fork_time/1000); in rdbSaveBackground()
951 server.lastbgsave_status = C_ERR; in rdbSaveBackground()
957 server.rdb_save_time_start = time(NULL); in rdbSaveBackground()
958 server.rdb_child_pid = childpid; in rdbSaveBackground()
959 server.rdb_child_type = RDB_CHILD_TYPE_DISK; in rdbSaveBackground()
989 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
990 server.list_compress_depth); in rdbLoadObject()
1006 if (len > server.set_max_intset_entries) { in rdbLoadObject()
1070 if (zsetLength(o) <= server.zset_max_ziplist_entries && in rdbLoadObject()
1071 maxelelen <= server.zset_max_ziplist_value) in rdbLoadObject()
1083 if (len > server.hash_max_ziplist_entries) in rdbLoadObject()
1103 if (sdslen(field->ptr) > server.hash_max_ziplist_value || in rdbLoadObject()
1104 sdslen(value->ptr) > server.hash_max_ziplist_value) in rdbLoadObject()
1141 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
1142 server.list_compress_depth); in rdbLoadObject()
1188 if (hashTypeLength(o) > server.hash_max_ziplist_entries || in rdbLoadObject()
1189 maxlen > server.hash_max_ziplist_value) in rdbLoadObject()
1203 if (intsetLen(o->ptr) > server.set_max_intset_entries) in rdbLoadObject()
1209 if (zsetLength(o) > server.zset_max_ziplist_entries) in rdbLoadObject()
1215 if (hashTypeLength(o) > server.hash_max_ziplist_entries) in rdbLoadObject()
1234 server.loading = 1; in startLoading()
1235 server.loading_start_time = time(NULL); in startLoading()
1236 server.loading_loaded_bytes = 0; in startLoading()
1238 server.loading_total_bytes = 0; in startLoading()
1240 server.loading_total_bytes = sb.st_size; in startLoading()
1246 server.loading_loaded_bytes = pos; in loadingProgress()
1247 if (server.stat_peak_memory < zmalloc_used_memory()) in loadingProgress()
1248 server.stat_peak_memory = zmalloc_used_memory(); in loadingProgress()
1253 server.loading = 0; in stopLoading()
1259 if (server.rdb_checksum) in rdbLoadProgressCallback()
1261 if (server.loading_process_events_interval_bytes && in rdbLoadProgressCallback()
1262 …(r->processed_bytes + len)/server.loading_process_events_interval_bytes > r->processed_bytes/serve… in rdbLoadProgressCallback()
1268 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER) in rdbLoadProgressCallback()
1278 redisDb *db = server.db+0; in rdbLoad()
1288 rdb.max_processing_chunk = server.loading_process_events_interval_bytes; in rdbLoad()
1337 if (dbid >= (unsigned)server.dbnum) { in rdbLoad()
1341 "databases. Exiting\n", server.dbnum); in rdbLoad()
1344 db = server.db+dbid; in rdbLoad()
1395 if (server.masterhost == NULL && expiretime != -1 && expiretime < now) { in rdbLoad()
1409 if (rdbver >= 5 && server.rdb_checksum) { in rdbLoad()
1438 server.dirty = server.dirty - server.dirty_before_bgsave; in backgroundSaveDoneHandlerDisk()
1439 server.lastsave = time(NULL); in backgroundSaveDoneHandlerDisk()
1440 server.lastbgsave_status = C_OK; in backgroundSaveDoneHandlerDisk()
1443 server.lastbgsave_status = C_ERR; in backgroundSaveDoneHandlerDisk()
1450 rdbRemoveTempFile(server.rdb_child_pid); in backgroundSaveDoneHandlerDisk()
1456 server.lastbgsave_status = C_ERR; in backgroundSaveDoneHandlerDisk()
1458 server.rdb_child_pid = -1; in backgroundSaveDoneHandlerDisk()
1459 server.rdb_child_type = RDB_CHILD_TYPE_NONE; in backgroundSaveDoneHandlerDisk()
1460 server.rdb_save_time_last = time(NULL)-server.rdb_save_time_start; in backgroundSaveDoneHandlerDisk()
1461 server.rdb_save_time_start = -1; in backgroundSaveDoneHandlerDisk()
1482 server.rdb_child_pid = -1; in backgroundSaveDoneHandlerSocket()
1483 server.rdb_child_type = RDB_CHILD_TYPE_NONE; in backgroundSaveDoneHandlerSocket()
1484 server.rdb_save_time_start = -1; in backgroundSaveDoneHandlerSocket()
1498 if (read(server.rdb_pipe_read_result_from_child, ok_slaves, readlen) == in backgroundSaveDoneHandlerSocket()
1507 read(server.rdb_pipe_read_result_from_child, ok_slaves+1, in backgroundSaveDoneHandlerSocket()
1515 close(server.rdb_pipe_read_result_from_child); in backgroundSaveDoneHandlerSocket()
1516 close(server.rdb_pipe_write_result_to_parent); in backgroundSaveDoneHandlerSocket()
1523 listRewind(server.slaves,&li); in backgroundSaveDoneHandlerSocket()
1564 switch(server.rdb_child_type) { in backgroundSaveDoneHandler()
1589 if (server.aof_child_pid != -1 || server.rdb_child_pid != -1) return C_ERR; in rdbSaveToSlavesSockets()
1595 server.rdb_pipe_read_result_from_child = pipefds[0]; in rdbSaveToSlavesSockets()
1596 server.rdb_pipe_write_result_to_parent = pipefds[1]; in rdbSaveToSlavesSockets()
1600 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1604 clientids = zmalloc(sizeof(uint64_t)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1607 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
1619 anetSendTimeout(NULL,slave->fd,server.repl_timeout*1000); in rdbSaveToSlavesSockets()
1681 write(server.rdb_pipe_write_result_to_parent,msg,msglen) in rdbSaveToSlavesSockets()
1693 server.stat_fork_time = ustime()-start; in rdbSaveToSlavesSockets()
1694 …server.stat_fork_rate = (double) zmalloc_used_memory() * 1000000 / server.stat_fork_time / (1024*1… in rdbSaveToSlavesSockets()
1695 latencyAddSampleIfNeeded("fork",server.stat_fork_time/1000); in rdbSaveToSlavesSockets()
1703 listRewind(server.slaves,&li); in rdbSaveToSlavesSockets()
1720 server.rdb_save_time_start = time(NULL); in rdbSaveToSlavesSockets()
1721 server.rdb_child_pid = childpid; in rdbSaveToSlavesSockets()
1722 server.rdb_child_type = RDB_CHILD_TYPE_SOCKET; in rdbSaveToSlavesSockets()
1733 if (server.rdb_child_pid != -1) { in saveCommand()
1737 if (rdbSave(server.rdb_filename) == C_OK) { in saveCommand()
1759 if (server.rdb_child_pid != -1) { in bgsaveCommand()
1761 } else if (server.aof_child_pid != -1) { in bgsaveCommand()
1763 server.rdb_bgsave_scheduled = 1; in bgsaveCommand()
1771 } else if (rdbSaveBackground(server.rdb_filename) == C_OK) { in bgsaveCommand()