Lines Matching refs:pReceiver
37 virtual void initialize(ReceiverImpl *pReceiver); // Called when this state begins
38 virtual void finalize (ReceiverImpl *pReceiver); // Called when this state ends
39 virtual void update (ReceiverImpl *pReceiver);
47 void ReceiverStateBase::initialize(ReceiverImpl *pReceiver) in initialize() argument
49 (void)pReceiver; in initialize()
53 void ReceiverStateBase::finalize(ReceiverImpl *pReceiver) in finalize() argument
55 (void)pReceiver; in finalize()
59 void ReceiverStateBase::update(ReceiverImpl *pReceiver) in update() argument
61 (void)pReceiver; in update()
68 virtual void update(ReceiverImpl *pReceiver);
79 virtual void update(ReceiverImpl *pReceiver);
90 virtual void update(ReceiverImpl *pReceiver);
101 virtual void update(ReceiverImpl *pReceiver);
112 virtual void initialize(ReceiverImpl *pReceiver);
113 virtual void update (ReceiverImpl *pReceiver);
136 void ReceiverStateWaiting::update(ReceiverImpl *pReceiver) in update() argument
138 ASSERT(pReceiver!=NULL); in update()
142 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()
154 pReceiver->m_recvBuf.SetInitialSequenceNumber(seg.GetSeqNumber()); in update()
157 pReceiver->putSynAckSegment(seg.GetSeqNumber() + 1); in update()
158 pReceiver->setNextState(ReceiverStateOpened::getInstance()); in update()
177 void ReceiverStateOpened::update(ReceiverImpl *pReceiver) in update() argument
179 ASSERT(pReceiver!=NULL); in update()
183 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()
188 pReceiver->setNextState(ReceiverStateClosed::getInstance()); in update()
189 pReceiver->errorHandling(ResultResetReceived()); in update()
194 ReceiveBuffer &rBuf = pReceiver->m_recvBuf; in update()
214 pReceiver->putFinAckSegment(seg.GetSeqNumber() + 1); in update()
215 pReceiver->setNextState(ReceiverStateWaitingFinished::getInstance()); in update()
230 pReceiver->putSynAckSegment(seg.GetSeqNumber() + 1); in update()
243 pReceiver->putAckSegment(); in update()
265 void ReceiverStateWaitingFinished::update(ReceiverImpl *pReceiver) in update() argument
272 ASSERT(pReceiver!=NULL); in update()
276 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()
281 pReceiver->setNextState(ReceiverStateClosed::getInstance()); in update()
282 pReceiver->errorHandling(ResultResetReceived()); in update()
287 ReceiveBuffer &rBuf = pReceiver->m_recvBuf; in update()
292 pReceiver->putFinAckSegment(seg.GetSeqNumber() + 1); in update()
308 if(pReceiver->isSenderClosed()) in update()
310 pReceiver->setNextState(ReceiverStateFinished::getInstance()); in update()
328 void ReceiverStateFinished::update(ReceiverImpl *pReceiver) in update() argument
330 ASSERT(pReceiver!=NULL); in update()
334 if(pReceiver->pullSegment(&seg).IsSuccess()) in update()
359 void ReceiverStateClosed::initialize(ReceiverImpl *pReceiver) in initialize() argument
361 ASSERT(pReceiver!=NULL); in initialize()
363 pReceiver->clear(); in initialize()
367 void ReceiverStateClosed::update(ReceiverImpl *pReceiver) in update() argument
369 ASSERT(pReceiver!=NULL); in update()
373 if(pReceiver->pullSegment(&seg).IsSuccess() && !seg.IsRst()) in update()
378 pReceiver->sendRstSegment(seg.GetAckNumber()); in update()
384 pReceiver->sendRstAckSegment(SEQ, ACK); in update()