| 7038 | } |
| 7039 | |
| 7040 | static void RedisGearsPy_ClearAllData(){ |
| 7041 | RedisGearsPy_ClearRequirements(); |
| 7042 | PythonSessionCtx** sessions = array_new(PythonSessionCtx*, 10); |
| 7043 | RedisModuleDictIter *iter = RedisModule_DictIteratorStartC(SessionsDict, "^", NULL, 0); |
| 7044 | char* key; |
| 7045 | size_t keyLen; |
| 7046 | PythonSessionCtx* s; |
| 7047 | while((key = RedisModule_DictNextC(iter, &keyLen, (void**)&s))){ |
| 7048 | sessions = array_append(sessions, s); |
| 7049 | } |
| 7050 | RedisModule_DictIteratorStop(iter); |
| 7051 | |
| 7052 | for (size_t i = 0 ; i < array_len(sessions) ; ++i) { |
| 7053 | PythonSessionCtx_Unlink(sessions[i]); |
| 7054 | } |
| 7055 | array_free(sessions); |
| 7056 | |
| 7057 | RedisModule_FreeDict(staticCtx, SessionsDict); |
| 7058 | SessionsDict = RedisModule_CreateDict(staticCtx); |
| 7059 | } |
| 7060 | |
| 7061 | static void RedisGearsPy_OnLoadedEvent(RedisModuleCtx *ctx, RedisModuleEvent eid, uint64_t subevent, void *data){ |
| 7062 | if(subevent == REDISMODULE_SUBEVENT_LOADING_RDB_START || |
no test coverage detected