Lines Matching refs:server

55         if (server.rdb_child_pid == -1 &&  in lookupKey()
56 server.aof_child_pid == -1 && in lookupKey()
95 if (server.masterhost == NULL) return NULL; in lookupKeyReadWithFlags()
109 if (server.current_client && in lookupKeyReadWithFlags()
110 server.current_client != server.master && in lookupKeyReadWithFlags()
111 server.current_client->cmd && in lookupKeyReadWithFlags()
112 server.current_client->cmd->flags & CMD_READONLY) in lookupKeyReadWithFlags()
119 server.stat_keyspace_misses++; in lookupKeyReadWithFlags()
121 server.stat_keyspace_hits++; in lookupKeyReadWithFlags()
163 if (server.cluster_enabled) slotToKeyAdd(key); in dbAdd()
231 if (server.cluster_enabled) slotToKeyDel(key); in dbDelete()
280 for (j = 0; j < server.dbnum; j++) { in emptyDb()
281 removed += dictSize(server.db[j].dict); in emptyDb()
282 dictEmpty(server.db[j].dict,callback); in emptyDb()
283 dictEmpty(server.db[j].expires,callback); in emptyDb()
285 if (server.cluster_enabled) slotToKeyFlush(); in emptyDb()
290 if (id < 0 || id >= server.dbnum) in selectDb()
292 c->db = &server.db[id]; in selectDb()
318 server.dirty += dictSize(c->db->dict); in flushdbCommand()
322 if (server.cluster_enabled) slotToKeyFlush(); in flushdbCommand()
328 server.dirty += emptyDb(NULL); in flushallCommand()
330 if (server.rdb_child_pid != -1) { in flushallCommand()
331 kill(server.rdb_child_pid,SIGUSR1); in flushallCommand()
332 rdbRemoveTempFile(server.rdb_child_pid); in flushallCommand()
334 if (server.saveparamslen > 0) { in flushallCommand()
337 int saved_dirty = server.dirty; in flushallCommand()
338 rdbSave(server.rdb_filename); in flushallCommand()
339 server.dirty = saved_dirty; in flushallCommand()
341 server.dirty++; in flushallCommand()
353 server.dirty++; in delCommand()
380 if (server.cluster_enabled && id != 0) { in selectCommand()
680 addReplyLongLong(c,server.lastsave); in lastsaveCommand()
725 if (server.loading || server.sentinel_mode) in shutdownCommand()
769 server.dirty++; in renameGenericCommand()
787 if (server.cluster_enabled) { in moveCommand()
832 server.dirty++; in moveCommand()
888 if (server.aof_state != AOF_OFF) in propagateExpire()
889 feedAppendOnlyFile(server.delCommand,db->id,argv,2); in propagateExpire()
890 replicationFeedSlaves(server.slaves,db->id,argv,2); in propagateExpire()
903 if (server.loading) return 0; in expireIfNeeded()
910 now = server.lua_caller ? server.lua_time_start : mstime(); in expireIfNeeded()
919 if (server.masterhost != NULL) return now > when; in expireIfNeeded()
925 server.stat_expiredkeys++; in expireIfNeeded()
965 if (when <= mstime() && !server.loading && !server.masterhost) { in expireGenericCommand()
969 server.dirty++; in expireGenericCommand()
984 server.dirty++; in expireGenericCommand()
1044 server.dirty++; in persistCommand()
1243 zslInsert(server.cluster->slots_to_keys,hashslot,key); in slotToKeyAdd()
1250 zslDelete(server.cluster->slots_to_keys,hashslot,key); in slotToKeyDel()
1254 zslFree(server.cluster->slots_to_keys); in slotToKeyFlush()
1255 server.cluster->slots_to_keys = zslCreate(); in slotToKeyFlush()
1266 n = zslFirstInRange(server.cluster->slots_to_keys, &range); in getKeysInSlot()
1284 n = zslFirstInRange(server.cluster->slots_to_keys, &range); in delKeysInSlot()
1289 dbDelete(&server.db[0],key); in delKeysInSlot()
1297 zskiplist *zsl = server.cluster->slots_to_keys; in countKeysInSlot()