Lines Matching refs:seg

193     Segment seg;  in updateCore()  local
194 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()
199 seg.PrintDebugInfo(); in updateCore()
251 Segment seg; in updateCore() local
252 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
254 pSender->processReceivedSegment(seg); in updateCore()
256 if(seg.IsRst()) in updateCore()
259 if(seg.IsAck() && seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
262 LOG("SYN rejected. CLOSED... ack of segment = %u\n", seg.GetAckNumber()); in updateCore()
272 else if(seg.IsAck()) in updateCore()
274 if(seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
281 LOG("ack : %u\n", seg.GetAckNumber()); in updateCore()
312 Segment seg; in updateCore() local
313 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
315 pSender->processReceivedSegment(seg); in updateCore()
317 if(seg.IsRst()) in updateCore()
361 Segment seg; in updateCore() local
362 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
364 pSender->processReceivedSegment(seg); in updateCore()
366 if(seg.IsRst()) in updateCore()
435 Segment seg; in updateCore() local
436 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
438 pSender->processReceivedSegment(seg); in updateCore()
440 if(seg.IsRst()) in updateCore()
447 … else if(seg.IsAck() && seg.GetAckNumber()==pSender->m_sendBuffer.GetCurrentSequenceNumber()+1) in updateCore()
655 Segment seg; in processResending() local
661 bool ret = m_resendQueue.Front(&seg); in processResending()
664 VERBOSE("The send segment sequence number is: %d. \n", seg.GetSeqNumber()); in processResending()
665 putSegment(seg); in processResending()
706 Segment seg; in sendData() local
707 seg.ClearHeader(); in sendData()
711 size_t sz = m_sendBuffer.Pull(seg.payload, &seq, pullSize); in sendData()
716 seg.header.dataLength = sz; in sendData()
717 seg.SetSeqNumber(seq); in sendData()
718 putSegmentWithResend(seg); in sendData()
724 Segment seg; in sendSynSegment() local
725 seg.ClearHeader(); in sendSynSegment()
726 seg.SetSeqNumber(getInitialSequenceNumber()); in sendSynSegment()
727 seg.SetSyn(); in sendSynSegment()
728 putSegmentWithResend(seg); in sendSynSegment()
738 Segment seg; in sendFinSegment() local
739 seg.ClearHeader(); in sendFinSegment()
740 seg.SetFin(); in sendFinSegment()
741 seg.SetSeqNumber(m_sendBuffer.GetCurrentSequenceNumber()); in sendFinSegment()
742 putSegmentWithResend(seg); in sendFinSegment()
807 void SenderImpl::putSegmentWithResend(const Segment &seg) in putSegmentWithResend() argument
812 putSegment(seg); in putSegmentWithResend()
817 m_nxt = seg.GetLastSeqNumber() + 1; in putSegmentWithResend()
823 bool ret = m_resendQueue.Push(seg); in putSegmentWithResend()
832 void SenderImpl::processReceivedSegment(const Segment &seg) in processReceivedSegment() argument
840 if(seg.IsAck()) in processReceivedSegment()
842 const u32 ack = seg.GetAckNumber(); in processReceivedSegment()
852 m_remoteWindowSize = seg.GetWindowSize(); in processReceivedSegment()