enum DetectEngineSyncState {
IDLE, /**< ready to start a reload */
RELOAD, /**< command main thread to do the reload */
- DONE, /**< main thread telling us reload is done */
};
}
/* main thread sets done when it's done */
-void DetectEngineReloadSetDone(void)
+void DetectEngineReloadSetIdle(void)
{
SCMutexLock(&detect_sync.m);
- detect_sync.state = DONE;
+ detect_sync.state = IDLE;
SCMutexUnlock(&detect_sync.m);
}
/* caller loops this until it returns 1 */
-int DetectEngineReloadIsDone(void)
+int DetectEngineReloadIsIdle(void)
{
int r = 0;
SCMutexLock(&detect_sync.m);
- if (detect_sync.state == DONE) {
+ if (detect_sync.state == IDLE) {
r = 1;
- detect_sync.state = IDLE;
}
SCMutexUnlock(&detect_sync.m);
return r;
int DetectEngineReloadStart(void);
int DetectEngineReloadIsStart(void);
-void DetectEngineReloadSetDone(void);
-int DetectEngineReloadIsDone(void);
+void DetectEngineReloadSetIdle(void);
+int DetectEngineReloadIsIdle(void);
int DetectEngineLoadTenantBlocking(uint32_t tenant_id, const char *yaml);
int DetectEngineReloadTenantBlocking(uint32_t tenant_id, const char *yaml, int reload_cnt);
if (!(DetectEngineReloadIsStart())) {
DetectEngineReloadStart();
DetectEngineReload(suri);
- DetectEngineReloadSetDone();
+ DetectEngineReloadSetIdle();
sigusr2_count--;
}
}
if (suri->sig_file != NULL) {
SCLogWarning(SC_ERR_LIVE_RULE_SWAP, "Live rule reload not "
"possible if -s or -S option used at runtime.");
- DetectEngineReloadSetDone();
+ DetectEngineReloadSetIdle();
} else {
DetectEngineReload(suri);
- DetectEngineReloadSetDone();
+ DetectEngineReloadSetIdle();
}
}
SCEnter();
DetectEngineReloadStart();
- while (DetectEngineReloadIsDone() == 0)
+ while (!DetectEngineReloadIsIdle())
usleep(100);
json_object_set_new(server_msg, "message", json_string("done"));