Searched refs:seg (Results 1 – 9 of 9) sorted by relevance
195 Segment seg; in updateCore() local196 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()201 seg.PrintDebugInfo(); in updateCore()253 Segment seg; in updateCore() local254 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()[all …]
125 void HostBase::putSegment(const Segment &seg) in putSegment() argument134 nn::Result result = m_transceiver.Put(seg); in putSegment()141 seg.PrintDebugInfo(); in putSegment()147 seg.PrintDebugInfo(); in putSegment()169 Segment seg; in sendRstSegment() local170 seg.ClearHeader(); in sendRstSegment()171 seg.SetRst(); in sendRstSegment()172 seg.SetSeqNumber(seq); in sendRstSegment()173 putSegment(seg); in sendRstSegment()181 Segment seg; in sendRstAckSegment() local[all …]
143 Segment seg; in update() local144 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()146 if(seg.IsRst()) in update()151 else if(seg.IsSyn()) in update()156 pReceiver->m_recvBuf.SetInitialSequenceNumber(seg.GetSeqNumber()); in update()159 pReceiver->putSynAckSegment(seg.GetSeqNumber() + 1); in update()184 Segment seg; in update() local185 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()188 if(seg.IsRst()) in update()197 if(seg.GetSeqNumber()==rBuf.GetLatestSequenceNumber()+1) in update()[all …]
49 bool ResendQueue::Push(const Segment &seg) in Push() argument58 swt.segment = seg; in Push()62 if(seg.IsSyn()) in Push()114 const Segment &seg = m_queue.Front().segment; in Remove() local115 u32 lastSeq = seg.GetLastSeqNumber(); in Remove()
177 void putSegmentWithResend(const Segment &seg);182 void processReceivedSegment(const Segment &seg);
81 void putSegment(const Segment &seg);
58 bool Push(const Segment &seg);
67 nn::Result Put(const Segment &seg);
349 nn::Result Transceiver::Put(const Segment &seg) in Put() argument354 int n = SendRawData(m_sock, &seg, sizeof(Segment)); in Put()357 int n = SendRawData(&m_sendEp, m_remoteNodeId, m_port, &seg, sizeof(Segment), &ret); in Put()