Searched refs:seg (Results 1 – 9 of 9) sorted by relevance
193 Segment seg; in updateCore() local194 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()199 seg.PrintDebugInfo(); in updateCore()251 Segment seg; in updateCore() local252 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()[all …]
120 void HostBase::putSegment(const Segment &seg) in putSegment() argument130 nn::Result result = m_transceiver.Put(seg); in putSegment()137 seg.PrintDebugInfo(); in putSegment()143 seg.PrintDebugInfo(); in putSegment()165 Segment seg; in sendRstSegment() local166 seg.ClearHeader(); in sendRstSegment()167 seg.SetRst(); in sendRstSegment()168 seg.SetSeqNumber(seq); in sendRstSegment()169 putSegment(seg); in sendRstSegment()177 Segment seg; in sendRstAckSegment() local[all …]
141 Segment seg; in update() local142 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()144 if(seg.IsRst()) in update()149 else if(seg.IsSyn()) in update()154 pReceiver->m_recvBuf.SetInitialSequenceNumber(seg.GetSeqNumber()); in update()157 pReceiver->putSynAckSegment(seg.GetSeqNumber() + 1); in update()182 Segment seg; in update() local183 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()186 if(seg.IsRst()) in update()195 if(seg.GetSeqNumber()==rBuf.GetLatestSequenceNumber()+1) in update()[all …]
47 bool ResendQueue::Push(const Segment &seg) in Push() argument56 swt.segment = seg; in Push()60 if(seg.IsSyn()) in Push()112 const Segment &seg = m_queue.Front().segment; in Remove() local113 u32 lastSeq = seg.GetLastSeqNumber(); in Remove()
175 void putSegmentWithResend(const Segment &seg);180 void processReceivedSegment(const Segment &seg);
79 void putSegment(const Segment &seg);
65 nn::Result Put(const Segment &seg);
56 bool Push(const Segment &seg);
347 nn::Result Transceiver::Put(const Segment &seg) in Put() argument352 int n = SendRawData(m_sock, &seg, sizeof(Segment)); in Put()355 int n = SendRawData(&m_sendEp, m_remoteNodeId, m_port, &seg, sizeof(Segment), &ret); in Put()