Go to the documentation of this file.
79 static inline Packet *FlowForceReassemblyPseudoPacketSetup(
82 const int orig_dir = direction;
85 p->
proto = IPPROTO_TCP;
86 FlowReference(&p->
flow, f);
96 DecodeSetNoPacketInspectionFlag(p);
99 DecodeSetNoPayloadInspectionFlag(p);
114 if (direction == 0) {
145 if (direction == 0) {
146 p->
ip4h->s_ip_src.s_addr = f->
src.addr_data32[0];
147 p->
ip4h->s_ip_dst.s_addr = f->
dst.addr_data32[0];
149 p->
ip4h->s_ip_src.s_addr = f->
dst.addr_data32[0];
150 p->
ip4h->s_ip_dst.s_addr = f->
src.addr_data32[0];
159 if (direction == 0) {
182 p->
ip6h->s_ip6_vfc = 0x60;
183 p->
ip6h->s_ip6_flow = 0;
184 p->
ip6h->s_ip6_nxt = IPPROTO_TCP;
185 p->
ip6h->s_ip6_plen = htons(20);
186 p->
ip6h->s_ip6_hlim = 64;
187 if (direction == 0) {
188 p->
ip6h->s_ip6_src[0] = f->
src.addr_data32[0];
189 p->
ip6h->s_ip6_src[1] = f->
src.addr_data32[1];
190 p->
ip6h->s_ip6_src[2] = f->
src.addr_data32[2];
191 p->
ip6h->s_ip6_src[3] = f->
src.addr_data32[3];
192 p->
ip6h->s_ip6_dst[0] = f->
dst.addr_data32[0];
193 p->
ip6h->s_ip6_dst[1] = f->
dst.addr_data32[1];
194 p->
ip6h->s_ip6_dst[2] = f->
dst.addr_data32[2];
195 p->
ip6h->s_ip6_dst[3] = f->
dst.addr_data32[3];
197 p->
ip6h->s_ip6_src[0] = f->
dst.addr_data32[0];
198 p->
ip6h->s_ip6_src[1] = f->
dst.addr_data32[1];
199 p->
ip6h->s_ip6_src[2] = f->
dst.addr_data32[2];
200 p->
ip6h->s_ip6_src[3] = f->
dst.addr_data32[3];
201 p->
ip6h->s_ip6_dst[0] = f->
src.addr_data32[0];
202 p->
ip6h->s_ip6_dst[1] = f->
src.addr_data32[1];
203 p->
ip6h->s_ip6_dst[2] = f->
src.addr_data32[2];
204 p->
ip6h->s_ip6_dst[3] = f->
src.addr_data32[3];
237 (uint16_t *)p->
tcph, 20, 0);
244 (uint16_t *)p->
tcph, 20, 0);
249 if (direction == 0) {
262 FlowDeReference(&p->
flow);
276 return FlowForceReassemblyPseudoPacketSetup(p, direction, f, ssn);
290 if (f == NULL || f->
protoctx == NULL) {
368 static inline void FlowForceReassemblyForHash(
void)
396 RemoveFromHash(f, prev_f);
421 FlowForceReassemblyForHash();
void FlowForceReassemblyForFlow(Flow *f)
Packet * FlowForceReassemblyPseudoPacketGet(int direction, Flow *f, const TcpSession *ssn)
#define FLOW_NOPAYLOAD_INSPECTION
void FlowForceReassembly(void)
Force reassembly for all the flows that have unprocessed segments.
#define FLOW_PKT_TOSERVER
int DatalinkGetGlobalType(void)
#define APP_LAYER_PARSER_EOF_TS
#define GET_PKT_DIRECT_MAX_SIZE(p)
#define FLOWLOCK_UNLOCK(fb)
void TmThreadsInjectFlowById(Flow *f, const int id)
inject a flow into a threads flow queue
#define FLOW_COPY_IPV6_ADDR_TO_PACKET(fa, pa)
@ STREAM_HAS_UNPROCESSED_SEGMENTS_NONE
AppLayerParserState * alparser
#define SET_PKT_LEN(p, len)
uint64_t AppLayerParserGetTransactionActive(const Flow *f, AppLayerParserState *pstate, uint8_t direction)
#define STREAM_HAS_SEEN_DATA(stream)
#define PKT_PSEUDO_STREAM_END
#define FLOWLOCK_WRLOCK(fb)
int FlowForceReassemblyNeedReassembly(Flow *f)
Check if a flow needs forced reassembly, or any other processing.
#define IPV4_GET_RAW_HLEN(ip4h)
uint8_t StreamNeedsReassembly(const TcpSession *ssn, uint8_t direction)
see what if any work the TCP session still needs
int PacketCallocExtPkt(Packet *p, int datalen)
void PacketPoolWait(void)
#define APP_LAYER_PARSER_EOF_TC
#define FBLOCK_UNLOCK(fb)
struct LiveDevice_ * livedev
Data structures and function prototypes for keeping state for the detection engine.
#define FLOW_PKT_TOCLIENT
void AppLayerParserStateSetFlag(AppLayerParserState *pstate, uint16_t flag)
@ STREAM_HAS_UNPROCESSED_SEGMENTS_NEED_ONLY_DETECTION
struct LiveDevice_ * livedev
#define PACKET_PROFILING_START(p)
Packet * PacketPoolGetPacket(void)
Get a new packet from the packet pool.
#define FLOW_PKT_ESTABLISHED
#define FLOW_END_FLAG_SHUTDOWN
uint16_t vlan_id[VLAN_MAX_LAYERS]
uint16_t vlan_id[VLAN_MAX_LAYERS]
#define FLOW_NOPACKET_INSPECTION
AppProto alproto
application level protocol
#define FLOW_DIR_REVERSED
uint64_t AppLayerParserGetTxCnt(const Flow *f, void *alstate)
FlowThreadId thread_id[2]
#define FLOW_COPY_IPV4_ADDR_TO_PACKET(fa, pa)