Bug #186 » 0001-Bug-186-fix.-It-seems-that-on-Mac-OS-X-we-where-reac.patch
| src/detect-engine-state.c | ||
|---|---|---|
|
}
|
||
|
memset(d, 0x00, sizeof(DetectEngineState));
|
||
|
SCMutexInit(&d->m, NULL);
|
||
|
SCReturnPtr(d, "DetectEngineState");
|
||
|
}
|
||
|
/**
|
||
|
* \brief Free a DetectEngineState object
|
||
|
* You must lock the flow mutex for de_state
|
||
|
* (f->de_state_m)
|
||
|
* \param state DetectEngineState object to free
|
||
|
*/
|
||
|
void DetectEngineStateFree(DetectEngineState *state) {
|
||
|
DeStateStore *iter = NULL;
|
||
|
DeStateStore *aux = NULL;
|
||
|
if (state == NULL)
|
||
|
return;
|
||
|
if (state->head != NULL) {
|
||
|
DeStateStoreFree(state->head);
|
||
|
iter = state->head;
|
||
|
while (iter != NULL) {
|
||
|
aux = iter;
|
||
|
iter = iter->next;
|
||
|
SCFree(aux);
|
||
|
}
|
||
|
SCMutexDestroy(&state->m);
|
||
|
state->head = NULL;
|
||
|
state->tail = NULL;
|
||
|
state->cnt = 0;
|
||
|
SCFree(state);
|
||
|
}
|
||
| ... | ... | |
|
void DetectEngineStateReset(DetectEngineState *state) {
|
||
|
SCEnter();
|
||
|
if (state == NULL) {
|
||
|
SCReturn;
|
||
|
}
|
||
|
DeStateStore *iter = NULL;
|
||
|
DeStateStore *aux = NULL;
|
||
|
SCMutexLock(&state->m);
|
||
|
if (state == NULL)
|
||
|
return;
|
||
|
if (state->head != NULL) {
|
||
|
DeStateStoreFree(state->head);
|
||
|
iter = state->head;
|
||
|
while (iter != NULL) {
|
||
|
aux = iter;
|
||
|
iter = iter->next;
|
||
|
SCFree(aux);
|
||
|
}
|
||
|
state->head = NULL;
|
||
|
state->tail = NULL;
|
||
|
state->cnt = 0;
|
||
|
SCMutexUnlock(&state->m);
|
||
|
SCReturn;
|
||
|
}
|
||
| ... | ... | |
|
SCLogDebug("detection done, store results: sm %p, uri %d, dce %d",
|
||
|
sm, umatch, dmatch);
|
||
|
SCMutexLock(&f->m);
|
||
|
/* match or no match, we store the state anyway
|
||
|
* "sm" here is either NULL (complete match) or
|
||
|
* the last SigMatch that didn't match */
|
||
|
SCMutexLock(&f->de_state_m);
|
||
|
if (f->de_state == NULL) {
|
||
|
f->de_state = DetectEngineStateAlloc();
|
||
|
}
|
||
|
SCMutexUnlock(&f->m);
|
||
|
if (f->de_state != NULL) {
|
||
|
SCMutexLock(&f->de_state->m);
|
||
|
DeStateSignatureAppend(f->de_state, s, sm, umatch, dmatch);
|
||
|
SCMutexUnlock(&f->de_state->m);
|
||
|
}
|
||
|
SCMutexUnlock(&f->de_state_m);
|
||
|
SCReturnInt(r);
|
||
|
}
|
||
| ... | ... | |
|
return 0;
|
||
|
}
|
||
|
SCMutexLock(&f->de_state->m);
|
||
|
SCMutexLock(&f->de_state_m);
|
||
|
if (f->de_state->cnt == 0)
|
||
|
if (f->de_state == NULL || f->de_state->cnt == 0)
|
||
|
goto end;
|
||
|
/* loop through the stores */
|
||
| ... | ... | |
|
}
|
||
|
end:
|
||
|
SCMutexUnlock(&f->de_state->m);
|
||
|
SCMutexUnlock(&f->de_state_m);
|
||
|
SCReturnInt(0);
|
||
|
}
|
||
| ... | ... | |
|
/* first clear the existing state as it belongs
|
||
|
* to the previous transaction */
|
||
|
SCMutexLock(&f->m);
|
||
|
SCMutexLock(&f->de_state_m);
|
||
|
if (f->de_state != NULL) {
|
||
|
SCMutexLock(&f->de_state->m);
|
||
|
DetectEngineStateReset(f->de_state);
|
||
|
SCMutexUnlock(&f->de_state->m);
|
||
|
}
|
||
|
SCMutexUnlock(&f->m);
|
||
|
SCMutexUnlock(&f->de_state_m);
|
||
|
SCReturnInt(0);
|
||
|
}
|
||
| src/detect-engine-state.h | ||
|---|---|---|
|
DeStateStore *head; /**< signature state storage */
|
||
|
DeStateStore *tail; /**< tail item of the storage list */
|
||
|
SigIntId cnt; /**< number of sigs in the storage */
|
||
|
SCMutex m; /**< lock for the de_state object */
|
||
|
} DetectEngineState;
|
||
|
void DeStateRegisterTests(void);
|
||
| src/detect.c | ||
|---|---|---|
|
int de_state_status = DeStateUpdateInspectTransactionId(p->flow,
|
||
|
(flags & STREAM_TOSERVER) ? STREAM_TOSERVER : STREAM_TOCLIENT);
|
||
|
SCLogDebug("de_state_status %d", de_state_status);
|
||
|
if (de_state_status == 2) {
|
||
|
SCMutexLock(&p->flow->de_state_m);
|
||
|
DetectEngineStateReset(p->flow->de_state);
|
||
|
SCMutexUnlock(&p->flow->de_state_m);
|
||
|
}
|
||
|
}
|
||
| src/flow-util.h | ||
|---|---|---|
|
#define FLOW_INITIALIZE(f) do { \
|
||
|
SCMutexInit(&(f)->m, NULL); \
|
||
|
SCMutexInit(&(f)->de_state_m, NULL); \
|
||
|
(f)->lnext = NULL; \
|
||
|
(f)->lprev = NULL; \
|
||
|
(f)->hnext = NULL; \
|
||
| ... | ... | |
|
(f)->flowvar = NULL; \
|
||
|
(f)->protoctx = NULL; \
|
||
|
SC_ATOMIC_RESET((f)->use_cnt); \
|
||
|
DetectEngineStateFree((f)->de_state); \
|
||
|
SCMutexLock(&(f)->de_state_m); \
|
||
|
if ((f)->de_state != NULL) { \
|
||
|
DetectEngineStateFree((f)->de_state); \
|
||
|
} \
|
||
|
SCMutexUnlock(&(f)->de_state_m); \
|
||
|
(f)->de_state = NULL; \
|
||
|
(f)->sgh_toserver = NULL; \
|
||
|
(f)->sgh_toclient = NULL; \
|
||
| ... | ... | |
|
(f)->flowvar = NULL; \
|
||
|
(f)->protoctx = NULL; \
|
||
|
SC_ATOMIC_DESTROY((f)->use_cnt); \
|
||
|
DetectEngineStateFree((f)->de_state); \
|
||
|
SCMutexLock(&(f)->de_state_m); \
|
||
|
if ((f)->de_state != NULL) { \
|
||
|
DetectEngineStateFree((f)->de_state); \
|
||
|
} \
|
||
|
SCMutexUnlock(&(f)->de_state_m); \
|
||
|
SCMutexDestroy(&(f)->de_state_m); \
|
||
|
(f)->de_state = NULL; \
|
||
|
AppLayerParserCleanupState(f); \
|
||
|
FlowL7DataPtrFree(f); \
|
||
| src/flow.h | ||
|---|---|---|
|
/** detection engine state */
|
||
|
struct DetectEngineState_ *de_state;
|
||
|
SCMutex de_state_m; /**< mutex lock for the de_state object */
|
||
|
/** toclient sgh for this flow. Only use when FLOW_SGH_TOCLIENT flow flag
|
||
|
* has been set. */
|
||
- « Previous
- 1
- 2
- Next »