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()
660 Segment seg; in processResending() local
666 bool ret = m_resendQueue.Front(&seg); in processResending()
669 VERBOSE("送信セグメントのシーケンス番号は:%dです。\n", seg.GetSeqNumber()); in processResending()
670 putSegment(seg); in processResending()
711 Segment seg; in sendData() local
712 seg.ClearHeader(); in sendData()
716 size_t sz = m_sendBuffer.Pull(seg.payload, &seq, pullSize); in sendData()
721 seg.header.dataLength = sz; in sendData()
722 seg.SetSeqNumber(seq); in sendData()
723 putSegmentWithResend(seg); in sendData()
729 Segment seg; in sendSynSegment() local
730 seg.ClearHeader(); in sendSynSegment()
731 seg.SetSeqNumber(getInitialSequenceNumber()); in sendSynSegment()
732 seg.SetSyn(); in sendSynSegment()
733 putSegmentWithResend(seg); in sendSynSegment()
743 Segment seg; in sendFinSegment() local
744 seg.ClearHeader(); in sendFinSegment()
745 seg.SetFin(); in sendFinSegment()
746 seg.SetSeqNumber(m_sendBuffer.GetCurrentSequenceNumber()); in sendFinSegment()
747 putSegmentWithResend(seg); in sendFinSegment()
812 void SenderImpl::putSegmentWithResend(const Segment &seg) in putSegmentWithResend() argument
817 putSegment(seg); in putSegmentWithResend()
822 m_nxt = seg.GetLastSeqNumber() + 1; in putSegmentWithResend()
828 bool ret = m_resendQueue.Push(seg); in putSegmentWithResend()
837 void SenderImpl::processReceivedSegment(const Segment &seg) in processReceivedSegment() argument
845 if(seg.IsAck()) in processReceivedSegment()
847 const u32 ack = seg.GetAckNumber(); in processReceivedSegment()
857 m_remoteWindowSize = seg.GetWindowSize(); in processReceivedSegment()