return true;
}
-void Active::hold_packet(const Packet* p)
+bool Active::hold_packet(const Packet* p)
{
if (active_action >= ACT_HOLD)
- return;
+ return false;
// FIXIT-L same semi-arbitrary heuristic as the retry queue logic - reevaluate later
if (!p->daq_instance || p->daq_instance->get_pool_available() < p->daq_instance->get_batch_size())
{
active_counts.holds_denied++;
- return;
+ return false;
}
active_action = ACT_HOLD;
active_counts.holds_allowed++;
+
+ return true;
}
void Active::cancel_packet_hold()
void drop_packet(const Packet*, bool force = false);
void daq_drop_packet(const Packet*);
bool retry_packet(const Packet*);
- void hold_packet(const Packet*);
+ bool hold_packet(const Packet*);
void cancel_packet_hold();
void allow_session(Packet*);
pool_available = mpool_info.available;
assert(pool_size == pool_available);
if (SnortConfig::log_verbose())
- LogMessage("DAQ pool size: %d\n", pool_size);
+ LogMessage("DAQ instance %d pool size: %d\n", get_instance_id(), pool_size);
dlt = daq_instance_get_datalink_type(instance);
get_tunnel_capabilities();