Lines Matching refs:Message
67 for (Message &message : mPendingRequests) in ClearRequests()
98 Message *CoapBase::NewMessage(const Message::Settings &aSettings) in NewMessage()
100 Message *message = nullptr; in NewMessage()
109 Message *CoapBase::NewMessage(void) { return NewMessage(Message::Settings::GetDefault()); } in NewMessage()
111 Message *CoapBase::NewPriorityMessage(void) in NewPriorityMessage()
113 return NewMessage(Message::Settings(kWithLinkSecurity, Message::kPriorityNet)); in NewPriorityMessage()
116 Message *CoapBase::NewPriorityConfirmablePostMessage(Uri aUri) in NewPriorityConfirmablePostMessage()
121 Message *CoapBase::NewConfirmablePostMessage(Uri aUri) { return InitMessage(NewMessage(), kTypeConf… in NewConfirmablePostMessage()
123 Message *CoapBase::NewPriorityNonConfirmablePostMessage(Uri aUri) in NewPriorityNonConfirmablePostMessage()
128 Message *CoapBase::NewNonConfirmablePostMessage(Uri aUri) in NewNonConfirmablePostMessage()
133 Message *CoapBase::NewPriorityResponseMessage(const Message &aRequest) in NewPriorityResponseMessage()
138 Message *CoapBase::NewResponseMessage(const Message &aRequest) { return InitResponse(NewMessage(), … in NewResponseMessage()
140 Message *CoapBase::InitMessage(Message *aMessage, Type aType, Uri aUri) in InitMessage()
154 Message *CoapBase::InitResponse(Message *aMessage, const Message &aRequest) in InitResponse()
168 Error CoapBase::Send(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Send()
188 Error CoapBase::SendMessage(Message &aMessage, in SendMessage()
196 Error CoapBase::SendMessage(Message &aMessage, in SendMessage()
204 Message *storedCopy = nullptr; in SendMessage()
302 Message *origRequest = FindRelatedRequest(aMessage, aMessageInfo, handlerMetadata); in SendMessage()
352 Error CoapBase::SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParame… in SendMessage()
357 Error CoapBase::SendMessage(Message &aMessage, in SendMessage()
369 Error CoapBase::SendMessage(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendMessage()
374 Error CoapBase::SendReset(Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendReset()
379 Error CoapBase::SendAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendAck()
384 Error CoapBase::SendEmptyAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo, Code aC… in SendEmptyAck()
389 Error CoapBase::SendEmptyAck(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendEmptyAck()
394 Error CoapBase::SendNotFound(const Message &aRequest, const Ip6::MessageInfo &aMessageInfo) in SendNotFound()
399 Error CoapBase::SendEmptyMessage(Type aType, const Message &aRequest, const Ip6::MessageInfo &aMess… in SendEmptyMessage()
402 Message *message = nullptr; in SendEmptyMessage()
419 Error CoapBase::SendHeaderResponse(Message::Code aCode, const Message &aRequest, const Ip6::Message… in SendHeaderResponse()
422 Message *message = nullptr; in SendHeaderResponse()
462 for (Message &message : mPendingRequests) in HandleRetransmissionTimer()
511 void CoapBase::FinalizeCoapTransaction(Message &aRequest, in FinalizeCoapTransaction()
513 Message *aResponse, in FinalizeCoapTransaction()
530 for (Message &message : mPendingRequests) in AbortTransaction()
544 Message *CoapBase::CopyAndEnqueueMessage(const Message &aMessage, uint16_t aCopyLength, const Metad… in CopyAndEnqueueMessage()
547 Message *messageCopy = nullptr; in CopyAndEnqueueMessage()
562 void CoapBase::DequeueMessage(Message &aMessage) in DequeueMessage()
587 Error CoapBase::CacheLastBlockResponse(Message *aResponse) in CacheLastBlockResponse()
601 Error CoapBase::PrepareNextBlockRequest(Message::BlockType aType, in PrepareNextBlockRequest()
603 Message &aRequestOld, in PrepareNextBlockRequest()
604 Message &aRequest, in PrepareNextBlockRequest()
605 Message &aMessage) in PrepareNextBlockRequest()
612 blockOption = (aType == Message::kBlockType1) ? kOptionBlock1 : kOptionBlock2; in PrepareNextBlockRequest()
663 Error CoapBase::SendNextBlock1Request(Message &aRequest, in SendNextBlock1Request()
664 Message &aMessage, in SendNextBlock1Request()
669 Message *request = nullptr; in SendNextBlock1Request()
699 …SuccessOrExit(error = PrepareNextBlockRequest(Message::kBlockType1, moreBlocks, aRequest, *request… in SendNextBlock1Request()
720 Error CoapBase::SendNextBlock2Request(Message &aRequest, in SendNextBlock2Request()
721 Message &aMessage, in SendNextBlock2Request()
728 Message *request = nullptr; in SendNextBlock2Request()
761 …SuccessOrExit(error = PrepareNextBlockRequest(Message::kBlockType2, aMessage.IsMoreBlocksFlagSet()… in SendNextBlock2Request()
782 Error CoapBase::ProcessBlock1Request(Message &aMessage, in ProcessBlock1Request()
788 Message *response = nullptr; in ProcessBlock1Request()
814 …SuccessOrExit(error = response->AppendBlockOption(Message::kBlockType1, response->GetBlockWiseBloc… in ProcessBlock1Request()
843 Error CoapBase::ProcessBlock2Request(Message &aMessage, in ProcessBlock2Request()
848 Message *response = nullptr; in ProcessBlock2Request()
933 …SuccessOrExit(error = response->AppendBlockOption(Message::kBlockType2, response->GetBlockWiseBloc… in ProcessBlock2Request()
971 void CoapBase::SendCopy(const Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in SendCopy()
974 Message *messageCopy = nullptr; in SendCopy()
991 Message *CoapBase::FindRelatedRequest(const Message &aResponse, in FindRelatedRequest()
995 Message *request = nullptr; in FindRelatedRequest()
997 for (Message &message : mPendingRequests) in FindRelatedRequest()
1035 void CoapBase::Receive(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Receive()
1037 Message &message = AsCoapMessage(&aMessage); in Receive()
1062 void CoapBase::ProcessReceivedResponse(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in ProcessReceivedResponse()
1065 Message *request = nullptr; in ProcessReceivedResponse()
1278 void CoapBase::ProcessReceivedRequest(Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in ProcessReceivedRequest()
1280 char uriPath[Message::kMaxReceivedUriPath + 1]; in ProcessReceivedRequest()
1281 Message *cachedResponse = nullptr; in ProcessReceivedRequest()
1458 Error ResponsesQueue::GetMatchedResponseCopy(const Message &aRequest, in GetMatchedResponseCopy()
1460 Message **aResponse) in GetMatchedResponseCopy()
1463 const Message *cacheResponse; in GetMatchedResponseCopy()
1475 const Message *ResponsesQueue::FindMatchedResponse(const Message &aRequest, const Ip6::MessageInfo … in FindMatchedResponse()
1477 const Message *response = nullptr; in FindMatchedResponse()
1479 for (const Message &message : mQueue) in FindMatchedResponse()
1498 void ResponsesQueue::EnqueueResponse(Message &aMessage, in EnqueueResponse()
1502 Message *responseCopy; in EnqueueResponse()
1527 Message *earliestMsg = nullptr; in UpdateQueue()
1534 for (Message &message : mQueue) in UpdateQueue()
1555 void ResponsesQueue::DequeueResponse(Message &aMessage) { mQueue.DequeueAndFree(aMessage); } in DequeueResponse()
1572 for (Message &message : mQueue) in HandleTimer()
1707 void Coap::HandleUdpReceive(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in HandleUdpReceive()
1712 Error Coap::Send(CoapBase &aCoapBase, ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Send()
1717 Error Coap::Send(ot::Message &aMessage, const Ip6::MessageInfo &aMessageInfo) in Send()