* packets need to force reassembly, in which case we just
* set dummy ack/seq values.
*/
-static inline Packet *FlowForceReassemblyPseudoPacketSetup(Packet *p,
- int direction,
- Flow *f,
- TcpSession *ssn)
+static inline Packet *FlowForceReassemblyPseudoPacketSetup(
+ Packet *p, int direction, Flow *f, const TcpSession *ssn)
{
const int orig_dir = direction;
p->tenant_id = f->tenant_id;
return NULL;
}
-Packet *FlowForceReassemblyPseudoPacketGet(int direction,
- Flow *f,
- TcpSession *ssn);
-Packet *FlowForceReassemblyPseudoPacketGet(int direction,
- Flow *f,
- TcpSession *ssn)
+Packet *FlowForceReassemblyPseudoPacketGet(int direction, Flow *f, const TcpSession *ssn)
{
PacketPoolWait();
Packet *p = PacketPoolGetPacket();
#ifndef __FLOW_TIMEOUT_H__
#define __FLOW_TIMEOUT_H__
+#include "stream-tcp-private.h"
+
void FlowForceReassemblyForFlow(Flow *f);
int FlowForceReassemblyNeedReassembly(Flow *f);
void FlowForceReassembly(void);
+Packet *FlowForceReassemblyPseudoPacketGet(int direction, Flow *f, const TcpSession *ssn);
#endif /* __FLOW_TIMEOUT_H__ */
} FlowWorkerThreadData;
-static void FlowWorkerFlowTimeout(ThreadVars *tv, Packet *p, FlowWorkerThreadData *fw, void *detect_thread);
-Packet *FlowForceReassemblyPseudoPacketGet(int direction, Flow *f, TcpSession *ssn);
+static void FlowWorkerFlowTimeout(
+ ThreadVars *tv, Packet *p, FlowWorkerThreadData *fw, void *detect_thread);
/**
* \internal