// the key difference is that we operate on forward moving data
// because we don't wait until it is acknowledged
static inline uint32_t flush_pdu_ips (
- TcpSession* ssn, StreamTracker* trk, Packet* pkt, uint32_t* flags)
+ TcpSession* ssn, StreamTracker* trk, uint32_t* flags)
{
- bool to_srv = ( *flags == PKT_FROM_CLIENT );
uint32_t total = 0, avail;
StreamSegment* seg;
PROFILE_VARS;
case STREAM_FLPOLICY_ON_DATA:
{
uint32_t flags = GetForwardDir(p);
- uint32_t flush_amt = flush_pdu_ips(tcpssn, listener, p, &flags);
+ uint32_t flush_amt = flush_pdu_ips(tcpssn, listener, &flags);
uint32_t this_flush;
while ( flush_amt > 0 )
flushed += this_flush;
flags = GetForwardDir(p);
- flush_amt = flush_pdu_ips(tcpssn, listener, p, &flags);
+ flush_amt = flush_pdu_ips(tcpssn, listener, &flags);
}
if ( !flags && listener->splitter->is_paf() )
{
// know where we left off and can resume scanning the remainder
static inline uint32_t flush_pdu_ackd (
- TcpSession* ssn, StreamTracker* trk, Packet* pkt, uint32_t* flags)
+ TcpSession* ssn, StreamTracker* trk, uint32_t* flags)
{
- bool to_srv = ( *flags == PKT_FROM_CLIENT );
uint32_t total = 0;
StreamSegment* seg;
PROFILE_VARS;
case STREAM_FLPOLICY_ON_ACK:
{
uint32_t flags = GetReverseDir(p);
- uint32_t flush_amt = flush_pdu_ackd(tcpssn, talker, p, &flags);
+ uint32_t flush_amt = flush_pdu_ackd(tcpssn, talker, &flags);
while ( flush_amt > 0 )
{
break;
flags = GetReverseDir(p);
- flush_amt = flush_pdu_ackd(tcpssn, talker, p, &flags);
+ flush_amt = flush_pdu_ackd(tcpssn, talker, &flags);
}
if ( !flags && talker->splitter->is_paf() )
{