Home
last modified time | relevance | path

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

/CTR-SDK-0.14.4/sources/libraries/rdt/CTR/
Drdt_Segment.cpp35 void Segment::SetData(const void *pBuf, u32 len) in SetData()
45 u32 Segment::GetData(void *pBuf, u32 len) const in GetData()
57 void Segment::Clear(void) in Clear()
64 void Segment::ClearHeader(void) in ClearHeader()
70 u32 Segment::GetLastSeqNumber(void) const in GetLastSeqNumber()
89 u32 Segment::GetSegmentLength(void) const in GetSegmentLength()
105 void Segment::PrintDebugInfo(void) const in PrintDebugInfo()
Drdt_Transceiver.cpp190 nn::rdt::CTR::Segment s_sendSeg;
191 nn::rdt::CTR::Segment s_recvSeg;
349 nn::Result Transceiver::Put(const Segment &seg) in Put()
354 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()
359 if(n==sizeof(Segment)) in Put()
379 nn::Result Transceiver::Pull(Segment *pSeg) in Pull()
385 int n = RecvRawData(m_sock, pSeg, sizeof(Segment)); in Pull()
388 int n = RecvRawData(&m_recvEp, pSeg, sizeof(Segment), &ret); in Pull()
390 if((n==sizeof(Segment)) && pSeg->IsValid()) in Pull()
[all …]
Drdt_ResendQueue.cpp49 bool ResendQueue::Push(const Segment &seg) in Push()
90 bool ResendQueue::Front(Segment *pSeg) const in Front()
114 const Segment &seg = m_queue.Front().segment; in Remove()
219 Segment a; // データは100バイトとする in Test()
223 Segment b; // データは50バイトとする in Test()
227 Segment c; // データは30バイトとする in Test()
258 Segment d; in Test()
280 Segment e, f, g; in Test()
301 Segment s; in Test()
Drdt_ResendQueue.h58 bool Push(const Segment &seg);
64 bool Front(Segment *pSeg) const;
163 Segment segment;
Drdt_HostBase.cpp125 void HostBase::putSegment(const Segment &seg) in putSegment()
152 nn::Result HostBase::pullSegment(Segment *pSeg) in pullSegment()
169 Segment seg; in sendRstSegment()
181 Segment seg; in sendRstAckSegment()
Drdt_SenderImpl.cpp195 Segment seg; in updateCore()
253 Segment seg; in updateCore()
314 Segment seg; in updateCore()
363 Segment seg; in updateCore()
437 Segment seg; in updateCore()
660 Segment seg; in processResending()
707 size_t pullSize = min(Segment::PAYLOAD_SIZE, vacant); // 送信バッファから引き出す量 in sendData()
711 Segment seg; in sendData()
729 Segment seg; in sendSynSegment()
743 Segment seg; in sendFinSegment()
[all …]
Drdt_HostBase.h81 void putSegment(const Segment &seg);
84 nn::Result pullSegment(Segment *pSeg);
Drdt_Transceiver.h67 nn::Result Put(const Segment &seg);
72 nn::Result Pull(Segment *pSeg);
Drdt_ReceiverImpl.cpp143 Segment seg; in update()
184 Segment seg; in update()
277 Segment seg; in update()
335 Segment seg; in update()
371 Segment seg; in update()
611 Segment a; in putSynAckSegment()
621 Segment a; in putAckSegment()
631 Segment a; in putFinAckSegment()
Drdt_Segment.h30 struct Segment{ struct
39 Segment(void){} in Segment() argument
Drdt_SenderImpl.h177 void putSegmentWithResend(const Segment &seg);
182 void processReceivedSegment(const Segment &seg);