Lines Matching refs:pSender
42 virtual void initialize(SenderImpl *pSender); // Called when this state is started
43 virtual void finalize (SenderImpl *pSender); // Called when this state is finished
44 void update (SenderImpl *pSender);
45 virtual void updatePrologue (SenderImpl *pSender);
46 virtual void updateCore (SenderImpl *pSender);
47 virtual void updateEpilogue (SenderImpl *pSender);
55 void SenderStateBase::initialize(SenderImpl *pSender) in initialize() argument
57 (void)pSender; in initialize()
61 void SenderStateBase::finalize(SenderImpl *pSender) in finalize() argument
63 (void)pSender; in finalize()
67 void SenderStateBase::updatePrologue(SenderImpl *pSender) in updatePrologue() argument
69 (void)pSender; in updatePrologue()
73 void SenderStateBase::updateCore(SenderImpl *pSender) in updateCore() argument
75 (void)pSender; in updateCore()
79 void SenderStateBase::updateEpilogue(SenderImpl *pSender) in updateEpilogue() argument
81 (void)pSender; in updateEpilogue()
85 void SenderStateBase::update(SenderImpl *pSender) in update() argument
87 updatePrologue(pSender); in update()
88 updateCore(pSender); in update()
89 updateEpilogue(pSender); in update()
97 virtual void updateCore(SenderImpl *pSender);
109 virtual void updateCore(SenderImpl *pSender);
121 virtual void updateCore(SenderImpl *pSender);
133 virtual void updateCore(SenderImpl *pSender);
145 virtual void updateCore(SenderImpl *pSender);
157 virtual void initialize(SenderImpl *pSender);
158 virtual void updateCore(SenderImpl *pSender);
180 void SenderStateClosed::initialize(SenderImpl *pSender) in initialize() argument
182 ASSERT(pSender!=NULL); in initialize()
184 pSender->clear(); in initialize()
188 void SenderStateClosed::updateCore(SenderImpl *pSender) in updateCore() argument
190 ASSERT(pSender!=NULL); in updateCore()
194 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()
202 pSender->sendRstSegment(SEQ); in updateCore()
223 void SenderStateOpenRequested::updateCore(SenderImpl *pSender) in updateCore() argument
226 pSender->sendSynSegment(); in updateCore()
229 pSender->setNextState(SenderStateOpening::getInstance()); in updateCore()
246 void SenderStateOpening::updateCore(SenderImpl *pSender) in updateCore() argument
248 ASSERT(pSender!=NULL); in updateCore()
252 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
254 pSender->processReceivedSegment(seg); in updateCore()
259 if(seg.IsAck() && seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
263 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
264 pSender->errorHandling(ResultResetReceived()); in updateCore()
274 if(seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
277 pSender->setNextState(SenderStateOpened::getInstance()); in updateCore()
282 LOG("una : %u\n", pSender->getUnacknowledgeNumber()); in updateCore()
283 LOG("nxt : %u\n", pSender->getNextSequenceNumber()); in updateCore()
290 pSender->processResending(); in updateCore()
307 void SenderStateOpened::updateCore(SenderImpl *pSender) in updateCore() argument
309 ASSERT(pSender!=NULL); in updateCore()
313 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
315 pSender->processReceivedSegment(seg); in updateCore()
320 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
321 pSender->errorHandling(ResultResetReceived()); in updateCore()
329 bSent = pSender->processResending(); in updateCore()
334 if(!pSender->isSendBufferEmpty()) in updateCore()
336 pSender->sendData(); in updateCore()
356 void SenderStateCloseRequested::updateCore(SenderImpl *pSender) in updateCore() argument
358 ASSERT(pSender!=NULL); in updateCore()
362 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
364 pSender->processReceivedSegment(seg); in updateCore()
369 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
370 pSender->errorHandling(ResultResetReceived()); in updateCore()
378 bSent = pSender->processResending(); in updateCore()
380 if(pSender->isSendBufferEmpty()) in updateCore()
385 pSender->sendFinSegment(); in updateCore()
389 pSender->setNextState(SenderStateClosing::getInstance()); in updateCore()
397 pSender->sendData(); in updateCore()
405 if(!pSender->isSendBufferEmpty()) in updateCore()
407 pSender->sendData(); in updateCore()
427 void SenderStateClosing::updateCore(SenderImpl *pSender) in updateCore() argument
429 ASSERT(pSender!=NULL); in updateCore()
432 pSender->processResending(); in updateCore()
436 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
438 pSender->processReceivedSegment(seg); in updateCore()
443 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
444 pSender->errorHandling(ResultResetReceived()); in updateCore()
447 … else if(seg.IsAck() && seg.GetAckNumber()==pSender->m_sendBuffer.GetCurrentSequenceNumber()+1) in updateCore()
451 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()