Lines Matching refs:server

63         if (server.rdb_child_pid == -1 &&  in lookupKey()
64 server.aof_child_pid == -1 && in lookupKey()
67 if (server.maxmemory_policy & MAXMEMORY_FLAG_LFU) { in lookupKey()
107 if (server.masterhost == NULL) { in lookupKeyReadWithFlags()
108 server.stat_keyspace_misses++; in lookupKeyReadWithFlags()
124 if (server.current_client && in lookupKeyReadWithFlags()
125 server.current_client != server.master && in lookupKeyReadWithFlags()
126 server.current_client->cmd && in lookupKeyReadWithFlags()
127 server.current_client->cmd->flags & CMD_READONLY) in lookupKeyReadWithFlags()
129 server.stat_keyspace_misses++; in lookupKeyReadWithFlags()
135 server.stat_keyspace_misses++; in lookupKeyReadWithFlags()
137 server.stat_keyspace_hits++; in lookupKeyReadWithFlags()
181 if (server.cluster_enabled) slotToKeyAdd(key); in dbAdd()
195 if (server.maxmemory_policy & MAXMEMORY_FLAG_LFU) { in dbOverwrite()
200 if (server.lazyfree_lazy_server_del) { in dbOverwrite()
250 if (allvolatile && server.masterhost && --maxtries == 0) { in dbRandomKey()
276 if (server.cluster_enabled) slotToKeyDel(key); in dbSyncDelete()
286 return server.lazyfree_lazy_server_del ? dbAsyncDelete(db,key) : in dbDelete()
346 if (dbnum < -1 || dbnum >= server.dbnum) { in emptyDb()
354 enddb = server.dbnum-1; in emptyDb()
360 removed += dictSize(server.db[j].dict); in emptyDb()
362 emptyDbAsync(&server.db[j]); in emptyDb()
364 dictEmpty(server.db[j].dict,callback); in emptyDb()
365 dictEmpty(server.db[j].expires,callback); in emptyDb()
368 if (server.cluster_enabled) { in emptyDb()
380 if (id < 0 || id >= server.dbnum) in selectDb()
382 c->db = &server.db[id]; in selectDb()
437 server.dirty += emptyDb(c->db->id,flags,NULL); in flushdbCommand()
449 server.dirty += emptyDb(-1,flags,NULL); in flushallCommand()
451 if (server.rdb_child_pid != -1) { in flushallCommand()
452 kill(server.rdb_child_pid,SIGUSR1); in flushallCommand()
453 rdbRemoveTempFile(server.rdb_child_pid); in flushallCommand()
455 if (server.saveparamslen > 0) { in flushallCommand()
458 int saved_dirty = server.dirty; in flushallCommand()
461 rdbSave(server.rdb_filename,rsiptr); in flushallCommand()
462 server.dirty = saved_dirty; in flushallCommand()
464 server.dirty++; in flushallCommand()
479 server.dirty++; in delGenericCommand()
513 if (server.cluster_enabled && id != 0) { in selectCommand()
813 addReplyLongLong(c,server.lastsave); in lastsaveCommand()
863 if (server.loading || server.sentinel_mode) in shutdownCommand()
907 server.dirty++; in renameGenericCommand()
925 if (server.cluster_enabled) { in moveCommand()
970 server.dirty++; in moveCommand()
1001 if (id1 < 0 || id1 >= server.dbnum || in dbSwapDatabases()
1002 id2 < 0 || id2 >= server.dbnum) return C_ERR; in dbSwapDatabases()
1004 redisDb aux = server.db[id1]; in dbSwapDatabases()
1005 redisDb *db1 = &server.db[id1], *db2 = &server.db[id2]; in dbSwapDatabases()
1037 if (server.cluster_enabled) { in swapdbCommand()
1056 server.dirty++; in swapdbCommand()
1085 int writable_slave = server.masterhost && server.repl_slave_ro == 0; in setExpire()
1121 if (server.aof_state != AOF_OFF) in propagateExpire()
1122 feedAppendOnlyFile(server.delCommand,db->id,argv,2); in propagateExpire()
1123 replicationFeedSlaves(server.slaves,db->id,argv,2); in propagateExpire()
1136 if (server.loading) return 0; in keyIsExpired()
1143 mstime_t now = server.lua_caller ? server.lua_time_start : mstime(); in keyIsExpired()
1178 if (server.masterhost != NULL) return 1; in expireIfNeeded()
1181 server.stat_expiredkeys++; in expireIfNeeded()
1182 propagateExpire(db,key,server.lazyfree_lazy_expire); in expireIfNeeded()
1185 return server.lazyfree_lazy_expire ? dbAsyncDelete(db,key) : in expireIfNeeded()
1476 server.cluster->slots_keys_count[hashslot] += add ? 1 : -1; in slotToKeyUpdateKey()
1482 raxInsert(server.cluster->slots_to_keys,indexed,keylen+2,NULL,NULL); in slotToKeyUpdateKey()
1484 raxRemove(server.cluster->slots_to_keys,indexed,keylen+2,NULL); in slotToKeyUpdateKey()
1498 raxFree(server.cluster->slots_to_keys); in slotToKeyFlush()
1499 server.cluster->slots_to_keys = raxNew(); in slotToKeyFlush()
1500 memset(server.cluster->slots_keys_count,0, in slotToKeyFlush()
1501 sizeof(server.cluster->slots_keys_count)); in slotToKeyFlush()
1514 raxStart(&iter,server.cluster->slots_to_keys); in getKeysInSlot()
1533 raxStart(&iter,server.cluster->slots_to_keys); in delKeysInSlot()
1534 while(server.cluster->slots_keys_count[hashslot]) { in delKeysInSlot()
1539 dbDelete(&server.db[0],key); in delKeysInSlot()
1548 return server.cluster->slots_keys_count[hashslot]; in countKeysInSlot()