if (engine->tx_min_progress > tx->tx_progress)
goto next;
if (tx->tx_progress > engine->tx_min_progress) {
- if (tx->prefilter_flags & (1<<(engine->id))) {
+ if (tx->prefilter_flags & (1<<(engine->local_id))) {
goto next;
}
}
PROFILING_PREFILTER_END(p, engine->gid);
if (tx->tx_progress > engine->tx_min_progress) {
- tx->prefilter_flags |= (1<<(engine->id));
+ tx->prefilter_flags |= (1<<(engine->local_id));
}
next:
if (engine->is_last)
PrefilterEngine *e = sgh->pkt_engines;
for (el = sgh->init->pkt_engines ; el != NULL; el = el->next) {
- e->id = el->id;
+ e->local_id = el->id;
e->cb.Prefilter = el->Prefilter;
e->pectx = el->pectx;
el->pectx = NULL; // e now owns the ctx
PrefilterEngine *e = sgh->payload_engines;
for (el = sgh->init->payload_engines ; el != NULL; el = el->next) {
- e->id = el->id;
+ e->local_id = el->id;
e->cb.Prefilter = el->Prefilter;
e->pectx = el->pectx;
el->pectx = NULL; // e now owns the ctx
}
memset(sgh->tx_engines, 0x00, (cnt * sizeof(PrefilterEngine)));
+ uint32_t local_id = 0;
PrefilterEngine *e = sgh->tx_engines;
for (el = sgh->init->tx_engines ; el != NULL; el = el->next) {
- e->id = el->id;
+ e->local_id = local_id++;
e->alproto = el->alproto;
e->tx_min_progress = el->tx_min_progress;
e->cb.PrefilterTx = el->PrefilterTx;
}
e++;
}
+ SCLogDebug("sgh %p max local_id %u", sgh, local_id);
}
}