Lines Matching refs:aMessageInfo

168 Error CoapBase::Send(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo)  in Send()  argument
173 Get<Utils::Otns>().EmitCoapSend(AsCoapMessage(&aMessage), aMessageInfo); in Send()
176 error = mSender(*this, aMessage, aMessageInfo); in Send()
181 Get<Utils::Otns>().EmitCoapSendFailure(error, AsCoapMessage(&aMessage), aMessageInfo); in Send()
189 const Ip6::MessageInfo &aMessageInfo, in SendMessage() argument
197 const Ip6::MessageInfo &aMessageInfo, in SendMessage()
231 mResponsesQueue.EnqueueResponse(aMessage, aMessageInfo, aTxParameters); in SendMessage()
302 Message *origRequest = FindRelatedRequest(aMessage, aMessageInfo, handlerMetadata); in SendMessage()
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()
322 metadata.mHopLimit = aMessageInfo.GetHopLimit(); in SendMessage()
323 metadata.mIsHostInterface = aMessageInfo.IsHostInterface(); in SendMessage()
340 SuccessOrExit(error = Send(aMessage, aMessageInfo)); in SendMessage()
352 Error CoapBase::SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParame… in SendMessage() argument
354 return SendMessage(aMessage, aMessageInfo, aTxParameters, nullptr, nullptr); in SendMessage()
358 const Ip6::MessageInfo &aMessageInfo, in SendMessage() argument
363 …return SendMessage(aMessage, aMessageInfo, TxParameters::GetDefault(), aHandler, aContext, nullptr… in SendMessage()
365 return SendMessage(aMessage, aMessageInfo, TxParameters::GetDefault(), aHandler, aContext); in SendMessage()
369 Error CoapBase::SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendMessage() argument
371 return SendMessage(aMessage, aMessageInfo, nullptr, nullptr); in SendMessage()
374 Error CoapBase::SendReset(Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendReset() argument
376 return SendEmptyMessage(kTypeReset, aRequest, aMessageInfo); in SendReset()
379 Error CoapBase::SendAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendAck() argument
381 return SendEmptyMessage(kTypeAck, aRequest, aMessageInfo); in SendAck()
384 Error CoapBase::SendEmptyAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo, Code aC… in SendEmptyAck() argument
386 …return (aRequest.IsConfirmable() ? SendHeaderResponse(aCode, aRequest, aMessageInfo) : kErrorInval… in SendEmptyAck()
389 Error CoapBase::SendEmptyAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendEmptyAck() argument
391 return SendEmptyAck(aRequest, aMessageInfo, kCodeChanged); in SendEmptyAck()
394 Error CoapBase::SendNotFound(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendNotFound() argument
396 return SendHeaderResponse(kCodeNotFound, aRequest, aMessageInfo); in SendNotFound()
399 …apBase::SendEmptyMessage(Type aType, const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendEmptyMessage() argument
412 SuccessOrExit(error = Send(*message, aMessageInfo)); in SendEmptyMessage()
419 …dHeaderResponse(Message::Code aCode, const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendHeaderResponse() argument
444 SuccessOrExit(error = SendMessage(*message, aMessageInfo)); in SendHeaderResponse()
514 const Ip6::MessageInfo *aMessageInfo, in FinalizeCoapTransaction() argument
521 aMetadata.mResponseHandler(aMetadata.mResponseContext, aResponse, aMessageInfo, aResult); in FinalizeCoapTransaction()
665 const Ip6::MessageInfo &aMessageInfo, in SendNextBlock1Request() argument
680 FinalizeCoapTransaction(aRequest, aCoapMetadata, &aMessage, &aMessageInfo, kErrorNone); in SendNextBlock1Request()
710 SuccessOrExit(error = SendMessage(*request, aMessageInfo, TxParameters::GetDefault(), in SendNextBlock1Request()
722 const Ip6::MessageInfo &aMessageInfo, in SendNextBlock2Request() argument
755 FinalizeCoapTransaction(aRequest, aCoapMetadata, &aMessage, &aMessageInfo, kErrorNone); in SendNextBlock2Request()
773 … SendMessage(*request, aMessageInfo, TxParameters::GetDefault(), aCoapMetadata.mResponseHandler, in SendNextBlock2Request()
783 const Ip6::MessageInfo &aMessageInfo, in ProcessBlock1Request() argument
823 SuccessOrExit(error = SendMessage(*response, aMessageInfo)); in ProcessBlock1Request()
844 const Ip6::MessageInfo &aMessageInfo, in ProcessBlock2Request() argument
862 aResource.HandleRequest(aMessage, aMessageInfo); in ProcessBlock2Request()
962 SuccessOrExit(error = SendMessage(*response, aMessageInfo)); in ProcessBlock2Request()
971 void CoapBase::SendCopy(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendCopy() argument
980 SuccessOrExit(error = Send(*messageCopy, aMessageInfo)); in SendCopy()
992 const Ip6::MessageInfo &aMessageInfo, in FindRelatedRequest() argument
1001 if (((aMetadata.mDestinationAddress == aMessageInfo.GetPeerAddr()) || in FindRelatedRequest()
1004 (aMetadata.mDestinationPort == aMessageInfo.GetPeerPort())) in FindRelatedRequest()
1035 void CoapBase::Receive(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Receive() argument
1043 if (!aMessageInfo.GetSockAddr().IsMulticast() && message.IsConfirmable()) in Receive()
1045 IgnoreError(SendReset(message, aMessageInfo)); in Receive()
1050 ProcessReceivedRequest(message, aMessageInfo); in Receive()
1054 ProcessReceivedResponse(message, aMessageInfo); in Receive()
1058 Get<Utils::Otns>().EmitCoapReceive(message, aMessageInfo); in Receive()
1062 void CoapBase::ProcessReceivedResponse(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in ProcessReceivedResponse() argument
1075 request = FindRelatedRequest(aMessage, aMessageInfo, metadata); in ProcessReceivedResponse()
1110 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1141 … metadata.mResponseHandler(metadata.mResponseContext, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1185 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1190 error = SendNextBlock1Request(*request, aMessage, aMessageInfo, metadata); in ProcessReceivedResponse()
1196 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); in ProcessReceivedResponse()
1203 … SendNextBlock2Request(*request, aMessage, aMessageInfo, metadata, totalTransferSize, false); in ProcessReceivedResponse()
1209 … FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, error); 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()
1240 IgnoreError(SendAck(aMessage, aMessageInfo)); in ProcessReceivedResponse()
1255 … metadata.mResponseHandler(metadata.mResponseContext, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1259 FinalizeCoapTransaction(*request, metadata, &aMessage, &aMessageInfo, kErrorNone); in ProcessReceivedResponse()
1273 IgnoreError(SendReset(aMessage, aMessageInfo)); in ProcessReceivedResponse()
1278 void CoapBase::ProcessReceivedRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in ProcessReceivedRequest() argument
1292 SuccessOrExit(error = mInterceptor.Invoke(aMessage, aMessageInfo)); in ProcessReceivedRequest()
1295 switch (mResponsesQueue.GetMatchedResponseCopy(aMessage, aMessageInfo, &cachedResponse)) in ProcessReceivedRequest()
1299 error = Send(*cachedResponse, aMessageInfo); in ProcessReceivedRequest()
1366 … switch (ProcessBlock1Request(aMessage, aMessageInfo, resource, totalTransferSize)) in ProcessReceivedRequest()
1369 resource.HandleRequest(aMessage, aMessageInfo); in ProcessReceivedRequest()
1375 … IgnoreReturnValue(SendHeaderResponse(kCodeRequestTooLarge, aMessage, aMessageInfo)); in ProcessReceivedRequest()
1379 … IgnoreReturnValue(SendHeaderResponse(kCodeRequestIncomplete, aMessage, aMessageInfo)); in ProcessReceivedRequest()
1383 … IgnoreReturnValue(SendHeaderResponse(kCodeInternalError, aMessage, aMessageInfo)); in ProcessReceivedRequest()
1392 … if ((error = ProcessBlock2Request(aMessage, aMessageInfo, resource)) != kErrorNone) in ProcessReceivedRequest()
1394 … IgnoreReturnValue(SendHeaderResponse(kCodeInternalError, aMessage, aMessageInfo)); in ProcessReceivedRequest()
1404 resource.HandleRequest(aMessage, aMessageInfo); in ProcessReceivedRequest()
1413 if ((mResourceHandler != nullptr) && mResourceHandler(*this, uriPath, aMessage, aMessageInfo)) in ProcessReceivedRequest()
1423 resource.HandleRequest(aMessage, aMessageInfo); in ProcessReceivedRequest()
1431 mDefaultHandler.Invoke(&aMessage, &aMessageInfo); in ProcessReceivedRequest()
1444 if (error == kErrorNotFound && !aMessageInfo.GetSockAddr().IsMulticast()) in ProcessReceivedRequest()
1446 IgnoreError(SendNotFound(aMessage, aMessageInfo)); in ProcessReceivedRequest()
1459 const Ip6::MessageInfo &aMessageInfo, in GetMatchedResponseCopy() argument
1465 cacheResponse = FindMatchedResponse(aRequest, aMessageInfo); in GetMatchedResponseCopy()
1475 …nsesQueue::FindMatchedResponse(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) const in FindMatchedResponse()
1487 if (metadata.mMessageInfo.HasSamePeerAddrAndPort(aMessageInfo)) in FindMatchedResponse()
1499 const Ip6::MessageInfo &aMessageInfo, in EnqueueResponse() argument
1506 metadata.mMessageInfo = aMessageInfo; in EnqueueResponse()
1508 VerifyOrExit(FindMatchedResponse(aMessage, aMessageInfo) == nullptr); in EnqueueResponse()
1707 void Coap::HandleUdpReceive(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in HandleUdpReceive() argument
1709 Receive(AsCoapMessage(&aMessage), aMessageInfo); in HandleUdpReceive()
1712 Error Coap::Send(CoapBase &aCoapBase, ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Send() argument
1714 return static_cast<Coap &>(aCoapBase).Send(aMessage, aMessageInfo); in Send()
1717 Error Coap::Send(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Send() argument
1719 return mSocket.IsBound() ? mSocket.SendTo(aMessage, aMessageInfo) : kErrorInvalidState; in Send()