Home
last modified time | relevance | path

Searched refs:Segment (Results 1 – 11 of 11) sorted by relevance

/CTR-SDK-4.2.5/sources/libraries/rdt/CTR/
Drdt_Segment.cpp33 void Segment::SetData(const void *pBuf, u32 len) in SetData()
43 u32 Segment::GetData(void *pBuf, u32 len) const in GetData()
55 void Segment::Clear(void) in Clear()
62 void Segment::ClearHeader(void) in ClearHeader()
68 u32 Segment::GetLastSeqNumber(void) const in GetLastSeqNumber()
87 u32 Segment::GetSegmentLength(void) const in GetSegmentLength()
103 void Segment::PrintDebugInfo(void) const in PrintDebugInfo()
Drdt_Transceiver.cpp188 nn::rdt::CTR::Segment s_sendSeg;
189 nn::rdt::CTR::Segment s_recvSeg;
347 nn::Result Transceiver::Put(const Segment &seg) in Put()
352 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()
357 if(n==sizeof(Segment)) in Put()
377 nn::Result Transceiver::Pull(Segment *pSeg) in Pull()
383 int n = RecvRawData(m_sock, pSeg, sizeof(Segment)); in Pull()
386 int n = RecvRawData(&m_recvEp, pSeg, sizeof(Segment), &ret); in Pull()
388 if((n==sizeof(Segment)) && pSeg->IsValid()) in Pull()
[all …]
Drdt_ResendQueue.cpp47 bool ResendQueue::Push(const Segment &seg) in Push()
88 bool ResendQueue::Front(Segment *pSeg) const in Front()
112 const Segment &seg = m_queue.Front().segment; in Remove()
217 Segment a; // Data is 100 bytes in Test()
221 Segment b; // Data is 50 bytes in Test()
225 Segment c; // Data is 30 bytes in Test()
256 Segment d; in Test()
278 Segment e, f, g; in Test()
299 Segment s; in Test()
Drdt_ResendQueue.h56 bool Push(const Segment &seg);
62 bool Front(Segment *pSeg) const;
161 Segment segment;
Drdt_HostBase.cpp120 void HostBase::putSegment(const Segment &seg) in putSegment()
148 nn::Result HostBase::pullSegment(Segment *pSeg) in pullSegment()
165 Segment seg; in sendRstSegment()
177 Segment seg; in sendRstAckSegment()
Drdt_SenderImpl.cpp193 Segment seg; in updateCore()
251 Segment seg; in updateCore()
312 Segment seg; in updateCore()
361 Segment seg; in updateCore()
435 Segment seg; in updateCore()
655 Segment seg; in processResending()
702 size_t pullSize = min(Segment::PAYLOAD_SIZE, vacant); // Amount pulled from the send buffer in sendData()
706 Segment seg; in sendData()
724 Segment seg; in sendSynSegment()
738 Segment seg; in sendFinSegment()
[all …]
Drdt_HostBase.h79 void putSegment(const Segment &seg);
82 nn::Result pullSegment(Segment *pSeg);
Drdt_Transceiver.h65 nn::Result Put(const Segment &seg);
70 nn::Result Pull(Segment *pSeg);
Drdt_ReceiverImpl.cpp141 Segment seg; in update()
182 Segment seg; in update()
275 Segment seg; in update()
333 Segment seg; in update()
372 Segment seg; in update()
612 Segment a; in putSynAckSegment()
622 Segment a; in putAckSegment()
632 Segment a; in putFinAckSegment()
Drdt_Segment.h28 struct Segment{ struct
37 Segment(void){} in Segment() function
Drdt_SenderImpl.h175 void putSegmentWithResend(const Segment &seg);
180 void processReceivedSegment(const Segment &seg);