Lines Matching refs:pSender
44 virtual void initialize(SenderImpl *pSender); // この状態が開始されるときに呼ばれる
45 virtual void finalize (SenderImpl *pSender); // この状態が終了されるときに呼ばれる
46 void update (SenderImpl *pSender);
47 virtual void updatePrologue (SenderImpl *pSender);
48 virtual void updateCore (SenderImpl *pSender);
49 virtual void updateEpilogue (SenderImpl *pSender);
57 void SenderStateBase::initialize(SenderImpl *pSender) in initialize() argument
59 (void)pSender; in initialize()
63 void SenderStateBase::finalize(SenderImpl *pSender) in finalize() argument
65 (void)pSender; in finalize()
69 void SenderStateBase::updatePrologue(SenderImpl *pSender) in updatePrologue() argument
71 (void)pSender; in updatePrologue()
75 void SenderStateBase::updateCore(SenderImpl *pSender) in updateCore() argument
77 (void)pSender; in updateCore()
81 void SenderStateBase::updateEpilogue(SenderImpl *pSender) in updateEpilogue() argument
83 (void)pSender; in updateEpilogue()
87 void SenderStateBase::update(SenderImpl *pSender) in update() argument
89 updatePrologue(pSender); in update()
90 updateCore(pSender); in update()
91 updateEpilogue(pSender); in update()
99 virtual void updateCore(SenderImpl *pSender);
111 virtual void updateCore(SenderImpl *pSender);
123 virtual void updateCore(SenderImpl *pSender);
135 virtual void updateCore(SenderImpl *pSender);
147 virtual void updateCore(SenderImpl *pSender);
159 virtual void initialize(SenderImpl *pSender);
160 virtual void updateCore(SenderImpl *pSender);
182 void SenderStateClosed::initialize(SenderImpl *pSender) in initialize() argument
184 ASSERT(pSender!=NULL); in initialize()
186 pSender->clear(); in initialize()
190 void SenderStateClosed::updateCore(SenderImpl *pSender) in updateCore() argument
192 ASSERT(pSender!=NULL); in updateCore()
196 if(pSender->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in updateCore()
204 pSender->sendRstSegment(SEQ); in updateCore()
225 void SenderStateOpenRequested::updateCore(SenderImpl *pSender) in updateCore() argument
228 pSender->sendSynSegment(); in updateCore()
231 pSender->setNextState(SenderStateOpening::getInstance()); in updateCore()
248 void SenderStateOpening::updateCore(SenderImpl *pSender) in updateCore() argument
250 ASSERT(pSender!=NULL); in updateCore()
254 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
256 pSender->processReceivedSegment(seg); in updateCore()
261 if(seg.IsAck() && seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
265 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
266 pSender->errorHandling(ResultResetReceived()); in updateCore()
276 if(seg.GetAckNumber()==pSender->getInitialSequenceNumber()+1) in updateCore()
279 pSender->setNextState(SenderStateOpened::getInstance()); in updateCore()
284 LOG("una : %u\n", pSender->getUnacknowledgeNumber()); in updateCore()
285 LOG("nxt : %u\n", pSender->getNextSequenceNumber()); in updateCore()
292 pSender->processResending(); in updateCore()
309 void SenderStateOpened::updateCore(SenderImpl *pSender) in updateCore() argument
311 ASSERT(pSender!=NULL); in updateCore()
315 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
317 pSender->processReceivedSegment(seg); in updateCore()
322 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
323 pSender->errorHandling(ResultResetReceived()); in updateCore()
331 bSent = pSender->processResending(); in updateCore()
336 if(!pSender->isSendBufferEmpty()) in updateCore()
338 pSender->sendData(); in updateCore()
358 void SenderStateCloseRequested::updateCore(SenderImpl *pSender) in updateCore() argument
360 ASSERT(pSender!=NULL); in updateCore()
364 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
366 pSender->processReceivedSegment(seg); in updateCore()
371 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
372 pSender->errorHandling(ResultResetReceived()); in updateCore()
380 bSent = pSender->processResending(); in updateCore()
382 if(pSender->isSendBufferEmpty()) in updateCore()
387 pSender->sendFinSegment(); in updateCore()
391 pSender->setNextState(SenderStateClosing::getInstance()); in updateCore()
399 pSender->sendData(); in updateCore()
407 if(!pSender->isSendBufferEmpty()) in updateCore()
409 pSender->sendData(); in updateCore()
429 void SenderStateClosing::updateCore(SenderImpl *pSender) in updateCore() argument
431 ASSERT(pSender!=NULL); in updateCore()
434 pSender->processResending(); in updateCore()
438 if(pSender->pullSegment(&seg).IsSuccess()) in updateCore()
440 pSender->processReceivedSegment(seg); in updateCore()
445 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()
446 pSender->errorHandling(ResultResetReceived()); in updateCore()
449 … else if(seg.IsAck() && seg.GetAckNumber()==pSender->m_sendBuffer.GetCurrentSequenceNumber()+1) in updateCore()
453 pSender->setNextState(SenderStateClosed::getInstance()); in updateCore()