Lines Matching refs:j
774 int j, iteration = 0; in activeExpireCycle() local
808 for (j = 0; j < dbs_per_call; j++) { in activeExpireCycle()
912 int j; in getInstantaneousMetric() local
915 for (j = 0; j < STATS_METRIC_SAMPLES; j++) in getInstantaneousMetric()
916 sum += server.inst_metric[metric].samples[j]; in getInstantaneousMetric()
1036 int j; in databasesCron() local
1042 for (j = 0; j < dbs_per_call; j++) { in databasesCron()
1049 for (j = 0; j < dbs_per_call; j++) { in databasesCron()
1091 int j; in serverCron() local
1141 for (j = 0; j < server.dbnum; j++) { in serverCron()
1144 size = dictSlots(server.db[j].dict); in serverCron()
1145 used = dictSize(server.db[j].dict); in serverCron()
1146 vkeys = dictSize(server.db[j].expires); in serverCron()
1148 … serverLog(LL_VERBOSE,"DB %d: %lld keys (%lld volatile) in %lld slots HT.",j,used,vkeys,size); in serverCron()
1214 for (j = 0; j < server.saveparamslen; j++) { in serverCron()
1215 struct saveparam *sp = server.saveparams+j; in serverCron()
1360 int j; in createSharedObjects() local
1411 for (j = 0; j < PROTO_SHARED_SELECT_CMDS; j++) { in createSharedObjects()
1415 dictid_len = ll2string(dictid_str,sizeof(dictid_str),j); in createSharedObjects()
1416 shared.select[j] = createObject(OBJ_STRING, in createSharedObjects()
1431 for (j = 0; j < OBJ_SHARED_INTEGERS; j++) { in createSharedObjects()
1432 shared.integers[j] = createObject(OBJ_STRING,(void*)(long)j); in createSharedObjects()
1433 shared.integers[j]->encoding = OBJ_ENCODING_INT; in createSharedObjects()
1435 for (j = 0; j < OBJ_SHARED_BULKHDR_LEN; j++) { in createSharedObjects()
1436 shared.mbulkhdr[j] = createObject(OBJ_STRING, in createSharedObjects()
1437 sdscatprintf(sdsempty(),"*%d\r\n",j)); in createSharedObjects()
1438 shared.bulkhdr[j] = createObject(OBJ_STRING, in createSharedObjects()
1439 sdscatprintf(sdsempty(),"$%d\r\n",j)); in createSharedObjects()
1450 int j; in initServerConfig() local
1571 for (j = 0; j < CLIENT_TYPE_OBUF_COUNT; j++) in initServerConfig()
1572 server.client_obuf_limits[j] = clientBufferLimitsDefaults[j]; in initServerConfig()
1627 int j; in restartServer() local
1644 for (j = 3; j < (int)server.maxclients + 1024; j++) close(j); in restartServer()
1772 int j; in listenToPort() local
1777 for (j = 0; j < server.bindaddr_count || j == 0; j++) { in listenToPort()
1778 if (server.bindaddr[j] == NULL) { in listenToPort()
1799 } else if (strchr(server.bindaddr[j],':')) { in listenToPort()
1801 fds[*count] = anetTcp6Server(server.neterr,port,server.bindaddr[j], in listenToPort()
1805 fds[*count] = anetTcpServer(server.neterr,port,server.bindaddr[j], in listenToPort()
1811 server.bindaddr[j] ? server.bindaddr[j] : "*", in listenToPort()
1825 int j; in resetServerStats() local
1839 for (j = 0; j < STATS_METRIC_COUNT; j++) { in resetServerStats()
1840 server.inst_metric[j].idx = 0; in resetServerStats()
1841 server.inst_metric[j].last_sample_time = mstime(); in resetServerStats()
1842 server.inst_metric[j].last_sample_count = 0; in resetServerStats()
1843 memset(server.inst_metric[j].samples,0, in resetServerStats()
1844 sizeof(server.inst_metric[j].samples)); in resetServerStats()
1852 int j; in initServer() local
1907 for (j = 0; j < server.dbnum; j++) { in initServer()
1908 server.db[j].dict = dictCreate(&dbDictType,NULL); in initServer()
1909 server.db[j].expires = dictCreate(&keyptrDictType,NULL); in initServer()
1910 server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL); in initServer()
1911 server.db[j].ready_keys = dictCreate(&setDictType,NULL); in initServer()
1912 server.db[j].watched_keys = dictCreate(&keylistDictType,NULL); in initServer()
1913 server.db[j].eviction_pool = evictionPoolAlloc(); in initServer()
1914 server.db[j].id = j; in initServer()
1915 server.db[j].avg_ttl = 0; in initServer()
1953 for (j = 0; j < server.ipfd_count; j++) { in initServer()
1954 if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE, in initServer()
1996 int j; in populateCommandTable() local
1999 for (j = 0; j < numcommands; j++) { in populateCommandTable()
2000 struct redisCommand *c = redisCommandTable+j; in populateCommandTable()
2034 int j; in resetCommandTableStats() local
2036 for (j = 0; j < numcommands; j++) { in resetCommandTableStats()
2037 struct redisCommand *c = redisCommandTable+j; in resetCommandTableStats()
2069 int j; in redisOpArrayFree() local
2074 for (j = 0; j < op->argc; j++) in redisOpArrayFree()
2075 decrRefCount(op->argv[j]); in redisOpArrayFree()
2146 int j; in alsoPropagate() local
2151 for (j = 0; j < argc; j++) { in alsoPropagate()
2152 argvcopy[j] = argv[j]; in alsoPropagate()
2153 incrRefCount(argv[j]); in alsoPropagate()
2315 int j; in call() local
2319 for (j = 0; j < server.also_propagate.numops; j++) { in call()
2320 rop = &server.also_propagate.ops[j]; in call()
2533 int j; in closeListeningSockets() local
2535 for (j = 0; j < server.ipfd_count; j++) close(server.ipfd[j]); in closeListeningSockets()
2538 for (j = 0; j < server.cfd_count; j++) close(server.cfd[j]); in closeListeningSockets()
2633 unsigned int j; in time_independent_strcmp() local
2650 for (j = 0; j < sizeof(bufa); j++) { in time_independent_strcmp()
2651 diff |= (bufa[j] ^ bufb[j]); in time_independent_strcmp()
2778 int *keys, numkeys, j; in commandCommand() local
2792 for (j = 0; j < numkeys; j++) addReplyBulk(c,c->argv[keys[j]+2]); in commandCommand()
2836 int j, numcommands; in genRedisInfoString() local
3262 for (j = 0; j < numcommands; j++) { in genRedisInfoString()
3263 struct redisCommand *c = redisCommandTable+j; in genRedisInfoString()
3286 for (j = 0; j < server.dbnum; j++) { in genRedisInfoString()
3289 keys = dictSize(server.db[j].dict); in genRedisInfoString()
3290 vkeys = dictSize(server.db[j].expires); in genRedisInfoString()
3294 j, keys, vkeys, server.db[j].avg_ttl); in genRedisInfoString()
3363 int j; in evictionPoolAlloc() local
3366 for (j = 0; j < MAXMEMORY_EVICTION_POOL_SIZE; j++) { in evictionPoolAlloc()
3367 ep[j].idle = 0; in evictionPoolAlloc()
3368 ep[j].key = NULL; in evictionPoolAlloc()
3384 int j, k, count; in evictionPoolPopulate() local
3397 for (j = 0; j < count; j++) { in evictionPoolPopulate()
3403 de = samples[j]; in evictionPoolPopulate()
3486 int j, k, keys_freed = 0; in freeMemoryIfNeeded() local
3488 for (j = 0; j < server.dbnum; j++) { in freeMemoryIfNeeded()
3492 redisDb *db = server.db+j; in freeMemoryIfNeeded()
3498 dict = server.db[j].dict; in freeMemoryIfNeeded()
3500 dict = server.db[j].expires; in freeMemoryIfNeeded()
3789 int j; in checkForSentinelMode() local
3792 for (j = 1; j < argc; j++) in checkForSentinelMode()
3793 if (!strcmp(argv[j],"--sentinel")) return 1; in checkForSentinelMode()
3934 int j; in main() local
3980 for (j = 0; j < argc; j++) server.exec_argv[j] = zstrdup(argv[j]); in main()
3997 j = 1; /* First option to parse in argv[] */ in main()
4018 if (argv[j][0] != '-' || argv[j][1] != '-') { in main()
4019 configfile = argv[j]; in main()
4023 zfree(server.exec_argv[j]); in main()
4024 server.exec_argv[j] = zstrdup(server.configfile); in main()
4025 j++; in main()
4032 while(j != argc) { in main()
4033 if (argv[j][0] == '-' && argv[j][1] == '-') { in main()
4035 if (!strcmp(argv[j], "--check-rdb")) { in main()
4037 j++; in main()
4041 options = sdscat(options,argv[j]+2); in main()
4045 options = sdscatrepr(options,argv[j],strlen(argv[j])); in main()
4048 j++; in main()