Lines Matching refs:server
351 client *c = server.lua_client; in luaRedisGenericCommand()
362 if (server.lua_multi_emitted || (server.lua_caller->flags & CLIENT_MULTI)) { in luaRedisGenericCommand()
492 if (server.lua_random_dirty && !server.lua_replicate_commands) { in luaRedisGenericCommand()
496 } else if (server.masterhost && server.repl_slave_ro && in luaRedisGenericCommand()
497 !server.loading && in luaRedisGenericCommand()
498 !(server.lua_caller->flags & CLIENT_MASTER)) in luaRedisGenericCommand()
508 strerror(server.aof_last_write_errno)); in luaRedisGenericCommand()
520 if (server.maxmemory && /* Maxmemory is actually enabled. */ in luaRedisGenericCommand()
521 !server.loading && /* Don't care about mem if loading. */ in luaRedisGenericCommand()
522 !server.masterhost && /* Slave must execute the script. */ in luaRedisGenericCommand()
523 server.lua_write_dirty == 0 && /* Script had no side effects so far. */ in luaRedisGenericCommand()
532 if (cmd->flags & CMD_RANDOM) server.lua_random_dirty = 1; in luaRedisGenericCommand()
533 if (cmd->flags & CMD_WRITE) server.lua_write_dirty = 1; in luaRedisGenericCommand()
538 if (server.cluster_enabled && !server.loading && in luaRedisGenericCommand()
539 !(server.lua_caller->flags & CLIENT_MASTER)) in luaRedisGenericCommand()
543 c->flags |= server.lua_caller->flags & (CLIENT_READONLY|CLIENT_ASKING); in luaRedisGenericCommand()
545 server.cluster->myself) in luaRedisGenericCommand()
557 if (server.lua_replicate_commands && in luaRedisGenericCommand()
558 !server.lua_multi_emitted && in luaRedisGenericCommand()
559 !(server.lua_caller->flags & CLIENT_MULTI) && in luaRedisGenericCommand()
560 server.lua_write_dirty && in luaRedisGenericCommand()
561 server.lua_repl != PROPAGATE_NONE) in luaRedisGenericCommand()
563 execCommandPropagateMulti(server.lua_caller); in luaRedisGenericCommand()
564 server.lua_multi_emitted = 1; in luaRedisGenericCommand()
569 if (server.lua_replicate_commands) { in luaRedisGenericCommand()
571 if (server.lua_repl & PROPAGATE_AOF) in luaRedisGenericCommand()
573 if (server.lua_repl & PROPAGATE_REPL) in luaRedisGenericCommand()
608 (server.lua_replicate_commands == 0) && in luaRedisGenericCommand()
722 if (server.lua_write_dirty) { in luaRedisReplicateCommandsCommand()
725 server.lua_replicate_commands = 1; in luaRedisReplicateCommandsCommand()
775 if (server.lua_replicate_commands == 0) { in luaRedisSetReplCommand()
788 server.lua_repl = flags; in luaRedisSetReplCommand()
922 server.lua_client = NULL; in scriptingInit()
923 server.lua_caller = NULL; in scriptingInit()
924 server.lua_timedout = 0; in scriptingInit()
934 server.lua_scripts = dictCreate(&shaScriptObjectDictType,NULL); in scriptingInit()
935 server.lua_scripts_mem = 0; in scriptingInit()
1077 if (server.lua_client == NULL) { in scriptingInit()
1078 server.lua_client = createClient(-1); in scriptingInit()
1079 server.lua_client->flags |= CLIENT_LUA; in scriptingInit()
1087 server.lua = lua; in scriptingInit()
1093 dictRelease(server.lua_scripts); in scriptingRelease()
1094 server.lua_scripts_mem = 0; in scriptingRelease()
1095 lua_close(server.lua); in scriptingRelease()
1189 if ((de = dictFind(server.lua_scripts,sha)) != NULL) { in luaCreateFunction()
1227 int retval = dictAdd(server.lua_scripts,sha,body); in luaCreateFunction()
1228 serverAssertWithInfo(c ? c : server.lua_client,NULL,retval == DICT_OK); in luaCreateFunction()
1229 server.lua_scripts_mem += sdsZmallocSize(sha) + getStringObjectSdsUsedMemory(body); in luaCreateFunction()
1236 long long elapsed = mstime() - server.lua_time_start; in luaMaskCountHook()
1242 if (elapsed >= server.lua_time_limit && server.lua_timedout == 0) { in luaMaskCountHook()
1244 server.lua_timedout = 1; in luaMaskCountHook()
1250 protectClient(server.lua_caller); in luaMaskCountHook()
1252 if (server.lua_timedout) processEventsWhileBlocked(); in luaMaskCountHook()
1253 if (server.lua_kill) { in luaMaskCountHook()
1261 lua_State *lua = server.lua; in evalGenericCommand()
1264 long long initial_server_dirty = server.dirty; in evalGenericCommand()
1279 server.lua_random_dirty = 0; in evalGenericCommand()
1280 server.lua_write_dirty = 0; in evalGenericCommand()
1281 server.lua_replicate_commands = server.lua_always_replicate_commands; in evalGenericCommand()
1282 server.lua_multi_emitted = 0; in evalGenericCommand()
1283 server.lua_repl = PROPAGATE_AOF|PROPAGATE_REPL; in evalGenericCommand()
1349 selectDb(server.lua_client,c->db->id); in evalGenericCommand()
1358 server.lua_caller = c; in evalGenericCommand()
1359 server.lua_time_start = mstime(); in evalGenericCommand()
1360 server.lua_kill = 0; in evalGenericCommand()
1361 if (server.lua_time_limit > 0 && ldb.active == 0) { in evalGenericCommand()
1365 lua_sethook(server.lua,luaLdbLineHook,LUA_MASKLINE|LUA_MASKCOUNT,100000); in evalGenericCommand()
1376 if (server.lua_timedout) { in evalGenericCommand()
1377 server.lua_timedout = 0; in evalGenericCommand()
1381 if (server.masterhost && server.master) in evalGenericCommand()
1382 queueClientForReprocessing(server.master); in evalGenericCommand()
1384 server.lua_caller = NULL; in evalGenericCommand()
1416 if (server.lua_replicate_commands) { in evalGenericCommand()
1418 if (server.lua_multi_emitted) { in evalGenericCommand()
1421 alsoPropagate(server.execCommand,c->db->id,propargv,1, in evalGenericCommand()
1437 if (evalsha && !server.lua_replicate_commands) { in evalGenericCommand()
1442 robj *script = dictFetchValue(server.lua_scripts,c->argv[1]->ptr); in evalGenericCommand()
1451 if (server.dirty == initial_server_dirty) { in evalGenericCommand()
1505 server.dirty++; /* Propagating this command is a good idea. */ in scriptCommand()
1511 if (dictFind(server.lua_scripts,c->argv[j]->ptr)) in scriptCommand()
1517 sds sha = luaCreateFunction(c,server.lua,c->argv[2]); in scriptCommand()
1522 if (server.lua_caller == NULL) { in scriptCommand()
1524 } else if (server.lua_caller->flags & CLIENT_MASTER) { in scriptCommand()
1526 } else if (server.lua_write_dirty) { in scriptCommand()
1529 server.lua_kill = 1; in scriptCommand()
2238 int j, saved_rc = server.lua_replicate_commands; in ldbRedis()
2246 server.lua_replicate_commands = 1; in ldbRedis()
2249 server.lua_replicate_commands = saved_rc; in ldbRedis()
2423 mstime_t elapsed = mstime() - server.lua_time_start; in luaLdbLineHook()
2424 mstime_t timelimit = server.lua_time_limit ? in luaLdbLineHook()
2425 server.lua_time_limit : 5000; in luaLdbLineHook()
2453 server.lua_time_start = mstime(); in luaLdbLineHook()