Lines Matching refs:seg
195 Segment seg; in updateCore() local
196 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()
201 seg.PrintDebugInfo(); in updateCore()
253 Segment seg; in updateCore() local
254 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
256 pSender->processReceivedSegment(seg); in updateCore()
258 if(seg.IsRst()) in updateCore()
261 if(seg.IsAck() && seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
264 LOG("SYN rejected. CLOSED... ack of segment = %u\n", seg.GetAckNumber()); in updateCore()
274 else if(seg.IsAck()) in updateCore()
276 if(seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
283 LOG("ack : %u\n", seg.GetAckNumber()); in updateCore()
314 Segment seg; in updateCore() local
315 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
317 pSender->processReceivedSegment(seg); in updateCore()
319 if(seg.IsRst()) in updateCore()
363 Segment seg; in updateCore() local
364 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
366 pSender->processReceivedSegment(seg); in updateCore()
368 if(seg.IsRst()) in updateCore()
437 Segment seg; in updateCore() local
438 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
440 pSender->processReceivedSegment(seg); in updateCore()
442 if(seg.IsRst()) in updateCore()
449 … else if(seg.IsAck() && seg.GetAckNumber()==pSender->m_sendBuffer.GetCurrentSequenceNumber()+1) in updateCore()
657 Segment seg; in processResending() local
663 bool ret = m_resendQueue.Front(&seg); in processResending()
666 VERBOSE("The send segment sequence number is: %d. \n", seg.GetSeqNumber()); in processResending()
667 putSegment(seg); in processResending()
708 Segment seg; in sendData() local
709 seg.ClearHeader(); in sendData()
713 size_t sz = m_sendBuffer.Pull(seg.payload, &seq, pullSize); in sendData()
718 seg.header.dataLength = sz; in sendData()
719 seg.SetSeqNumber(seq); in sendData()
720 putSegmentWithResend(seg); in sendData()
726 Segment seg; in sendSynSegment() local
727 seg.ClearHeader(); in sendSynSegment()
728 seg.SetSeqNumber(getInitialSequenceNumber()); in sendSynSegment()
729 seg.SetSyn(); in sendSynSegment()
730 putSegmentWithResend(seg); in sendSynSegment()
740 Segment seg; in sendFinSegment() local
741 seg.ClearHeader(); in sendFinSegment()
742 seg.SetFin(); in sendFinSegment()
743 seg.SetSeqNumber(m_sendBuffer.GetCurrentSequenceNumber()); in sendFinSegment()
744 putSegmentWithResend(seg); in sendFinSegment()
809 void SenderImpl::putSegmentWithResend(const Segment &seg) in putSegmentWithResend() argument
814 putSegment(seg); in putSegmentWithResend()
819 m_nxt = seg.GetLastSeqNumber() + 1; in putSegmentWithResend()
825 bool ret = m_resendQueue.Push(seg); in putSegmentWithResend()
834 void SenderImpl::processReceivedSegment(const Segment &seg) in processReceivedSegment() argument
842 if(seg.IsAck()) in processReceivedSegment()
844 const u32 ack = seg.GetAckNumber(); in processReceivedSegment()
854 m_remoteWindowSize = seg.GetWindowSize(); in processReceivedSegment()