Lines Matching refs:rxStatus
112 context->rxStatus.state, newState, context->rxStatus.locInState); in chppSetRxState()
113 context->rxStatus.locInState = 0; in chppSetRxState()
114 context->rxStatus.state = newState; in chppSetRxState()
138 context->rxStatus.locInState < CHPP_PREAMBLE_LEN_BYTES) { in chppConsumePreamble()
139 size_t offset = context->rxStatus.locInState; in chppConsumePreamble()
143 context->rxStatus.locInState++; in chppConsumePreamble()
147 context->rxStatus.locInState = 1; in chppConsumePreamble()
151 context->rxStatus.locInState = 0; in chppConsumePreamble()
158 if (context->rxStatus.locInState == CHPP_PREAMBLE_LEN_BYTES) { in chppConsumePreamble()
160 context->rxStatus.packetStartTimeNs = chppGetCurrentTimeNs(); in chppConsumePreamble()
180 CHPP_ASSERT(context->rxStatus.locInState < in chppConsumeHeader()
183 len, (sizeof(struct ChppTransportHeader) - context->rxStatus.locInState)); in chppConsumeHeader()
184 memcpy(((uint8_t *)&context->rxHeader) + context->rxStatus.locInState, buf, in chppConsumeHeader()
186 context->rxStatus.locInState += bytesToCopy; in chppConsumeHeader()
188 if (context->rxStatus.locInState == sizeof(struct ChppTransportHeader)) { in chppConsumeHeader()
246 CHPP_ASSERT(context->rxStatus.locInState < context->rxHeader.length); in chppConsumePayload()
248 MIN(len, (context->rxHeader.length - context->rxStatus.locInState)); in chppConsumePayload()
249 memcpy(context->rxDatagram.payload + context->rxStatus.locInDatagram, buf, in chppConsumePayload()
251 context->rxStatus.locInDatagram += bytesToCopy; in chppConsumePayload()
252 context->rxStatus.locInState += bytesToCopy; in chppConsumePayload()
254 if (context->rxStatus.locInState == context->rxHeader.length) { in chppConsumePayload()
275 CHPP_ASSERT(context->rxStatus.locInState < in chppConsumeFooter()
278 len, (sizeof(struct ChppTransportFooter) - context->rxStatus.locInState)); in chppConsumeFooter()
279 memcpy(((uint8_t *)&context->rxFooter) + context->rxStatus.locInState, buf, in chppConsumeFooter()
282 context->rxStatus.locInState += bytesToCopy; in chppConsumeFooter()
283 if (context->rxStatus.locInState == sizeof(struct ChppTransportFooter)) { in chppConsumeFooter()
370 switch (context->rxStatus.state) { in chppAbortRxPacket()
378 undoLoc = context->rxStatus.locInState; in chppAbortRxPacket()
397 CHPP_ASSERT(context->rxStatus.locInDatagram >= undoLoc); in chppAbortRxPacket()
399 context->rxStatus.locInDatagram -= undoLoc; in chppAbortRxPacket()
542 context->rxStatus.receivedPacketCode = context->rxHeader.packetCode; in chppProcessResetAck()
543 context->rxStatus.expectedSeq = context->rxHeader.seq + 1; in chppProcessResetAck()
576 context->rxStatus.lastGoodPacketTimeMs = (uint32_t)(now / CHPP_NSEC_PER_MSEC); in chppProcessRxPacket()
577 context->rxStatus.receivedPacketCode = context->rxHeader.packetCode; in chppProcessRxPacket()
582 context->rxHeader.seq != context->rxStatus.expectedSeq) { in chppProcessRxPacket()
599 context->rxHeader.seq, context->rxStatus.expectedSeq, in chppProcessRxPacket()
616 context->rxStatus.expectedSeq++; // chppProcessRxPacket() already confirms in chppProcessRxPayload()
626 context->rxDatagram.length, context->rxStatus.expectedSeq); in chppProcessRxPayload()
643 context->rxHeader.length, context->rxStatus.expectedSeq, in chppProcessRxPayload()
662 context->rxStatus.locInDatagram = 0; in chppClearRxDatagram()
680 .payload[context->rxStatus.locInDatagram - context->rxHeader.length], in chppRxChecksumIsOk()
719 context->rxHeader.seq, context->rxStatus.expectedSeq, in chppRxHeaderCheck()
735 if (context->rxStatus.receivedAckSeq != rxAckSeq) { in chppRegisterRxAck()
738 if ((uint8_t)(context->rxStatus.receivedAckSeq + 1) != rxAckSeq) { in chppRegisterRxAck()
740 context->rxStatus.receivedAckSeq, rxAckSeq); in chppRegisterRxAck()
746 context->rxStatus.receivedAckSeq, rxAckSeq, in chppRegisterRxAck()
752 context->rxStatus.receivedAckSeq = rxAckSeq; in chppRegisterRxAck()
843 txHeader->ackSeq = context->rxStatus.expectedSeq; in chppAddHeader()
997 txHeader->seq = context->rxStatus.receivedAckSeq; in chppTransportDoWork()
1027 context->txDatagramQueue.pending, context->rxStatus.receivedAckSeq, in chppTransportDoWork()
1028 context->txStatus.sentSeq, context->rxStatus.state); in chppTransportDoWork()
1188 memset(&context->rxStatus, 0, sizeof(struct ChppRxStatus)); in chppResetTransportContext()
1248 transportContext->rxStatus.receivedPacketCode = in chppReset()
1250 transportContext->rxStatus.expectedSeq = transportContext->rxHeader.seq + 1; in chppReset()
1400 if (context->rxStatus.state != CHPP_STATE_PREAMBLE && in chppRxDataCb()
1402 context->rxStatus.packetStartTimeNs + CHPP_TRANSPORT_RX_TIMEOUT_NS) { in chppRxDataCb()
1409 context->rxStatus.state); in chppRxDataCb()
1411 context->rxStatus.lastDataTimeMs = (uint32_t)(now / CHPP_NSEC_PER_MSEC); in chppRxDataCb()
1412 context->rxStatus.numTotalDataBytes += len; in chppRxDataCb()
1422 switch (context->rxStatus.state) { in chppRxDataCb()
1441 CHPP_LOGE("Invalid RX state %" PRIu8, context->rxStatus.state); in chppRxDataCb()
1449 return (context->rxStatus.state == CHPP_STATE_PREAMBLE && in chppRxDataCb()
1450 context->rxStatus.locInState == 0); in chppRxDataCb()
1455 if (context->rxStatus.state != CHPP_STATE_PREAMBLE) { in chppRxPacketCompleteCb()
1458 context->rxStatus.state, context->rxHeader.seq, in chppRxPacketCompleteCb()