analyzer.cc (snort3-3.1.29.0) | : | analyzer.cc (snort3-3.1.30.0) | ||
---|---|---|---|---|
skipping to change at line 411 | skipping to change at line 411 | |||
p->daq_instance = daq_instance; | p->daq_instance = daq_instance; | |||
PacketManager::decode(p, pkthdr, daq_msg_get_data(msg), daq_msg_get_data_len (msg), false, retry); | PacketManager::decode(p, pkthdr, daq_msg_get_data(msg), daq_msg_get_data_len (msg), false, retry); | |||
if (process_packet(p)) | if (process_packet(p)) | |||
{ | { | |||
post_process_daq_pkt_msg(p); | post_process_daq_pkt_msg(p); | |||
switcher->stop(); | switcher->stop(); | |||
} | } | |||
// Beyond this point, we don't have an active context, but e.g. calls to | ||||
// get_current_packet() or get_current_wire_packet() require a context. | ||||
// We must ensure that a context is available when one is needed. | ||||
Stream::handle_timeouts(false); | Stream::handle_timeouts(false); | |||
HighAvailabilityManager::process_receive(); | HighAvailabilityManager::process_receive(); | |||
} | } | |||
void Analyzer::process_daq_msg(DAQ_Msg_h msg, bool retry) | void Analyzer::process_daq_msg(DAQ_Msg_h msg, bool retry) | |||
{ | { | |||
oops_handler->set_current_message(msg); | oops_handler->set_current_message(msg); | |||
memory::MemoryCap::free_space(); | memory::MemoryCap::free_space(); | |||
DAQ_Verdict verdict = DAQ_VERDICT_PASS; | DAQ_Verdict verdict = DAQ_VERDICT_PASS; | |||
End of changes. 1 change blocks. | ||||
0 lines changed or deleted | 3 lines changed or added |