Lines Matching refs:rxStatus
131 chppGetRxStatusLabel(context->rxStatus.state), in chppSetRxState()
132 chppGetRxStatusLabel(newState), context->rxStatus.locInState); in chppSetRxState()
133 context->rxStatus.locInState = 0; in chppSetRxState()
134 context->rxStatus.state = newState; in chppSetRxState()
158 context->rxStatus.locInState < CHPP_PREAMBLE_LEN_BYTES) { in chppConsumePreamble()
159 size_t offset = context->rxStatus.locInState; in chppConsumePreamble()
163 context->rxStatus.locInState++; in chppConsumePreamble()
167 context->rxStatus.locInState = 1; in chppConsumePreamble()
171 context->rxStatus.locInState = 0; in chppConsumePreamble()
178 if (context->rxStatus.locInState == CHPP_PREAMBLE_LEN_BYTES) { in chppConsumePreamble()
180 context->rxStatus.packetStartTimeNs = chppGetCurrentTimeNs(); in chppConsumePreamble()
200 CHPP_ASSERT(context->rxStatus.locInState < in chppConsumeHeader()
203 len, (sizeof(struct ChppTransportHeader) - context->rxStatus.locInState)); in chppConsumeHeader()
204 memcpy(((uint8_t *)&context->rxHeader) + context->rxStatus.locInState, buf, in chppConsumeHeader()
206 context->rxStatus.locInState += bytesToCopy; in chppConsumeHeader()
208 if (context->rxStatus.locInState == sizeof(struct ChppTransportHeader)) { in chppConsumeHeader()
266 CHPP_ASSERT(context->rxStatus.locInState < context->rxHeader.length); in chppConsumePayload()
268 MIN(len, (context->rxHeader.length - context->rxStatus.locInState)); in chppConsumePayload()
269 memcpy(context->rxDatagram.payload + context->rxStatus.locInDatagram, buf, in chppConsumePayload()
271 context->rxStatus.locInDatagram += bytesToCopy; in chppConsumePayload()
272 context->rxStatus.locInState += bytesToCopy; in chppConsumePayload()
274 if (context->rxStatus.locInState == context->rxHeader.length) { in chppConsumePayload()
295 CHPP_ASSERT(context->rxStatus.locInState < in chppConsumeFooter()
298 len, (sizeof(struct ChppTransportFooter) - context->rxStatus.locInState)); in chppConsumeFooter()
299 memcpy(((uint8_t *)&context->rxFooter) + context->rxStatus.locInState, buf, in chppConsumeFooter()
302 context->rxStatus.locInState += bytesToCopy; in chppConsumeFooter()
303 if (context->rxStatus.locInState == sizeof(struct ChppTransportFooter)) { in chppConsumeFooter()
390 switch (context->rxStatus.state) { in chppAbortRxPacket()
398 undoLoc = context->rxStatus.locInState; in chppAbortRxPacket()
417 CHPP_ASSERT(context->rxStatus.locInDatagram >= undoLoc); in chppAbortRxPacket()
419 context->rxStatus.locInDatagram -= undoLoc; in chppAbortRxPacket()
561 context->rxStatus.receivedPacketCode = context->rxHeader.packetCode; in chppProcessResetAck()
562 context->rxStatus.expectedSeq = context->rxHeader.seq + 1; in chppProcessResetAck()
591 context->rxStatus.lastGoodPacketTimeMs = (uint32_t)(now / CHPP_NSEC_PER_MSEC); in chppProcessRxPacket()
592 context->rxStatus.receivedPacketCode = context->rxHeader.packetCode; in chppProcessRxPacket()
597 context->rxHeader.seq != context->rxStatus.expectedSeq) { in chppProcessRxPacket()
614 context->rxHeader.seq, context->rxStatus.expectedSeq, in chppProcessRxPacket()
637 context->rxStatus.expectedSeq++; // chppProcessRxPacket() already confirms in chppProcessRxPayload()
647 context->rxDatagram.length, context->rxStatus.expectedSeq); in chppProcessRxPayload()
664 context->rxHeader.length, context->rxStatus.expectedSeq, in chppProcessRxPayload()
683 context->rxStatus.locInDatagram = 0; in chppClearRxDatagram()
701 .payload[context->rxStatus.locInDatagram - context->rxHeader.length], in chppRxChecksumIsOk()
734 context->rxHeader.seq, context->rxStatus.expectedSeq, in chppRxHeaderCheck()
750 if (context->rxStatus.receivedAckSeq != rxAckSeq) { in chppRegisterRxAck()
753 if ((uint8_t)(context->rxStatus.receivedAckSeq + 1) != rxAckSeq) { in chppRegisterRxAck()
755 context->rxStatus.receivedAckSeq, rxAckSeq); in chppRegisterRxAck()
761 context->rxStatus.receivedAckSeq, rxAckSeq, in chppRegisterRxAck()
767 context->rxStatus.receivedAckSeq = rxAckSeq; in chppRegisterRxAck()
858 txHeader->ackSeq = context->rxStatus.expectedSeq; in chppAddHeader()
1016 txHeader->seq = context->rxStatus.receivedAckSeq; in chppTransportDoWork()
1046 context->txDatagramQueue.pending, context->rxStatus.receivedAckSeq, in chppTransportDoWork()
1048 chppGetRxStatusLabel(context->rxStatus.state)); in chppTransportDoWork()
1229 memset(&context->rxStatus, 0, sizeof(struct ChppRxStatus)); in chppResetTransportContext()
1289 transportContext->rxStatus.receivedPacketCode = in chppReset()
1291 transportContext->rxStatus.expectedSeq = transportContext->rxHeader.seq + 1; in chppReset()
1472 if (context->rxStatus.state != CHPP_STATE_PREAMBLE && in chppRxDataCb()
1474 context->rxStatus.packetStartTimeNs + CHPP_TRANSPORT_RX_TIMEOUT_NS) { in chppRxDataCb()
1481 chppGetRxStatusLabel(context->rxStatus.state)); in chppRxDataCb()
1483 context->rxStatus.lastDataTimeMs = (uint32_t)(now / CHPP_NSEC_PER_MSEC); in chppRxDataCb()
1484 context->rxStatus.numTotalDataBytes += len; in chppRxDataCb()
1494 switch (context->rxStatus.state) { in chppRxDataCb()
1514 context->rxStatus.state); in chppRxDataCb()
1521 return (context->rxStatus.state == CHPP_STATE_PREAMBLE && in chppRxDataCb()
1522 context->rxStatus.locInState == 0); in chppRxDataCb()
1527 if (context->rxStatus.state != CHPP_STATE_PREAMBLE) { in chppRxPacketCompleteCb()
1529 chppGetRxStatusLabel(context->rxStatus.state), in chppRxPacketCompleteCb()