Lines Matching refs:metadata
69 Metadata metadata; in ClearRequests() local
71 metadata.ReadFrom(message); in ClearRequests()
73 if ((aAddress == nullptr) || (metadata.mSourceAddress == *aAddress)) in ClearRequests()
75 FinalizeCoapTransaction(message, metadata, nullptr, nullptr, kErrorAbort); in ClearRequests()
276 Metadata metadata; in SendMessage() local
311 metadata.mSourceAddress = aMessageInfo.GetSockAddr(); in SendMessage()
312 metadata.mDestinationPort = aMessageInfo.GetPeerPort(); in SendMessage()
313 metadata.mDestinationAddress = aMessageInfo.GetPeerAddr(); in SendMessage()
314 metadata.mMulticastLoop = aMessageInfo.GetMulticastLoop(); in SendMessage()
315 metadata.mResponseHandler = aHandler; in SendMessage()
316 metadata.mResponseContext = aContext; in SendMessage()
317 metadata.mRetransmissionsRemaining = aTxParameters.mMaxRetransmit; in SendMessage()
318 metadata.mRetransmissionTimeout = aTxParameters.CalculateInitialRetransmissionTimeout(); in SendMessage()
319 metadata.mAcknowledged = false; in SendMessage()
320 metadata.mConfirmable = aMessage.IsConfirmable(); in SendMessage()
322 metadata.mHopLimit = aMessageInfo.GetHopLimit(); in SendMessage()
323 metadata.mIsHostInterface = aMessageInfo.IsHostInterface(); in SendMessage()
326 metadata.mBlockwiseReceiveHook = aReceiveHook; in SendMessage()
327 metadata.mBlockwiseTransmitHook = aTransmitHook; in SendMessage()
330 metadata.mObserve = observe; in SendMessage()
332 metadata.mNextTimerShot = in SendMessage()
334 …(metadata.mConfirmable ? metadata.mRetransmissionTimeout : aTxParameters.CalculateMaxTransmitWait(… in SendMessage()
336 storedCopy = CopyAndEnqueueMessage(aMessage, copyLength, metadata); in SendMessage()
459 Metadata metadata; in HandleRetransmissionTimer() local
464 metadata.ReadFrom(message); in HandleRetransmissionTimer()
466 if (nextTime.GetNow() >= metadata.mNextTimerShot) in HandleRetransmissionTimer()
469 if (message.IsRequest() && metadata.mObserve && metadata.mAcknowledged) in HandleRetransmissionTimer()
476 if (!metadata.mConfirmable || (metadata.mRetransmissionsRemaining == 0)) in HandleRetransmissionTimer()
479 FinalizeCoapTransaction(message, metadata, nullptr, nullptr, kErrorResponseTimeout); in HandleRetransmissionTimer()
484 metadata.mRetransmissionsRemaining--; in HandleRetransmissionTimer()
485 metadata.mRetransmissionTimeout *= 2; in HandleRetransmissionTimer()
486 metadata.mNextTimerShot = nextTime.GetNow() + metadata.mRetransmissionTimeout; in HandleRetransmissionTimer()
487 metadata.UpdateIn(message); in HandleRetransmissionTimer()
490 if (!metadata.mAcknowledged) in HandleRetransmissionTimer()
492 messageInfo.SetPeerAddr(metadata.mDestinationAddress); in HandleRetransmissionTimer()
493 messageInfo.SetPeerPort(metadata.mDestinationPort); in HandleRetransmissionTimer()
494 messageInfo.SetSockAddr(metadata.mSourceAddress); in HandleRetransmissionTimer()
496 messageInfo.SetHopLimit(metadata.mHopLimit); in HandleRetransmissionTimer()
497 messageInfo.SetIsHostInterface(metadata.mIsHostInterface); in HandleRetransmissionTimer()
499 messageInfo.SetMulticastLoop(metadata.mMulticastLoop); in HandleRetransmissionTimer()
505 nextTime.UpdateIfEarlier(metadata.mNextTimerShot); in HandleRetransmissionTimer()
528 Metadata metadata; in AbortTransaction() local
532 metadata.ReadFrom(message); in AbortTransaction()
534 if (metadata.mResponseHandler == aHandler && metadata.mResponseContext == aContext) in AbortTransaction()
536 FinalizeCoapTransaction(message, metadata, nullptr, nullptr, kErrorAbort); in AbortTransaction()
1064 Metadata metadata; in ProcessReceivedResponse() local
1075 request = FindRelatedRequest(aMessage, aMessageInfo, metadata); in ProcessReceivedResponse()
1079 if (metadata.mObserve && request->IsRequest()) in ProcessReceivedResponse()
1094 FinalizeCoapTransaction(*request, metadata, nullptr, nullptr, kErrorAbort); in ProcessReceivedResponse()
1105 if (metadata.mObserve && !request->IsRequest()) in ProcessReceivedResponse()
1110 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1117 if (metadata.mConfirmable) in ProcessReceivedResponse()
1119 metadata.mAcknowledged = true; in ProcessReceivedResponse()
1120 metadata.UpdateIn(*request); in ProcessReceivedResponse()
1125 if (metadata.mResponseHandler == nullptr) in ProcessReceivedResponse()
1138 if (metadata.mObserve && responseObserve && (metadata.mResponseHandler != nullptr)) in ProcessReceivedResponse()
1141 … metadata.mResponseHandler(metadata.mResponseContext, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1144 metadata.mAcknowledged = true; in ProcessReceivedResponse()
1145 metadata.UpdateIn(*request); in ProcessReceivedResponse()
1151 … if (metadata.mBlockwiseTransmitHook != nullptr || metadata.mBlockwiseReceiveHook != nullptr) in ProcessReceivedResponse()
1185 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1188 … if (aMessage.GetCode() == kCodeContinue && metadata.mBlockwiseTransmitHook != nullptr) in ProcessReceivedResponse()
1190 error = SendNextBlock1Request(*request, aMessage, aMessageInfo, metadata); in ProcessReceivedResponse()
1193 … if (aMessage.GetCode() != kCodeContinue || metadata.mBlockwiseTransmitHook == nullptr || in ProcessReceivedResponse()
1196 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); in ProcessReceivedResponse()
1200 … if (aMessage.GetCode() < kCodeBadRequest && metadata.mBlockwiseReceiveHook != nullptr) in ProcessReceivedResponse()
1203 … SendNextBlock2Request(*request, aMessage, aMessageInfo, metadata, totalTransferSize, false); in ProcessReceivedResponse()
1206 … if (aMessage.GetCode() >= kCodeBadRequest || metadata.mBlockwiseReceiveHook == nullptr || in ProcessReceivedResponse()
1209 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); in ProcessReceivedResponse()
1213 … if (aMessage.GetCode() < kCodeBadRequest && metadata.mBlockwiseReceiveHook != nullptr) in ProcessReceivedResponse()
1216 … SendNextBlock2Request(*request, aMessage, aMessageInfo, metadata, totalTransferSize, true); in ProcessReceivedResponse()
1219 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); in ProcessReceivedResponse()
1223 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); in ProcessReceivedResponse()
1229 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1248 if ((metadata.mResponseHandler != nullptr) && (metadata.mDestinationAddress.IsMulticast() in ProcessReceivedResponse()
1250 || (metadata.mObserve && responseObserve) in ProcessReceivedResponse()
1255 … metadata.mResponseHandler(metadata.mResponseContext, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1259 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1483 ResponseMetadata metadata; in FindMatchedResponse() local
1485 metadata.ReadFrom(message); in FindMatchedResponse()
1487 if (metadata.mMessageInfo.HasSamePeerAddrAndPort(aMessageInfo)) in FindMatchedResponse()
1503 ResponseMetadata metadata; in EnqueueResponse() local
1505 metadata.mDequeueTime = TimerMilli::GetNow() + aTxParameters.CalculateExchangeLifetime(); in EnqueueResponse()
1506 metadata.mMessageInfo = aMessageInfo; in EnqueueResponse()
1514 VerifyOrExit(metadata.AppendTo(*responseCopy) == kErrorNone, responseCopy->Free()); in EnqueueResponse()
1518 mTimer.FireAtIfEarlier(metadata.mDequeueTime); in EnqueueResponse()
1536 ResponseMetadata metadata; in UpdateQueue() local
1538 metadata.ReadFrom(message); in UpdateQueue()
1540 if ((earliestMsg == nullptr) || (metadata.mDequeueTime < earliestDequeueTime)) in UpdateQueue()
1543 earliestDequeueTime = metadata.mDequeueTime; in UpdateQueue()
1574 ResponseMetadata metadata; in HandleTimer() local
1576 metadata.ReadFrom(message); in HandleTimer()
1578 if (nextDequeueTime.GetNow() >= metadata.mDequeueTime) in HandleTimer()
1584 nextDequeueTime.UpdateIfEarlier(metadata.mDequeueTime); in HandleTimer()