Lines Matching refs:message
66 for (Message &message : mPendingQueries) in Stop()
70 queryMetadata.ReadFrom(message); in Stop()
71 FinalizeSntpTransaction(message, queryMetadata, 0, kErrorAbort); in Stop()
81 Message *message = nullptr; in Query() local
93 VerifyOrExit((message = NewMessage(header)) != nullptr, error = kErrorNoBufs); in Query()
105 …VerifyOrExit((messageCopy = CopyAndEnqueueMessage(*message, queryMetadata)) != nullptr, error = kE… in Query()
106 SuccessOrExit(error = SendMessage(*message, *messageInfo)); in Query()
112 if (message) in Query()
114 message->Free(); in Query()
128 Message *message = nullptr; in NewMessage() local
130 VerifyOrExit((message = mSocket.NewMessage(sizeof(aHeader))) != nullptr); in NewMessage()
131 IgnoreError(message->Prepend(aHeader)); in NewMessage()
132 message->SetOffset(0); in NewMessage()
135 return message; in NewMessage()
197 for (Message &message : mPendingQueries) in FindRelatedQuery()
200 aQueryMetadata.ReadFrom(message); in FindRelatedQuery()
204 matchedMessage = &message; in FindRelatedQuery()
227 for (Message &message : mPendingQueries) in HandleRetransmissionTimer()
229 queryMetadata.ReadFrom(message); in HandleRetransmissionTimer()
236 FinalizeSntpTransaction(message, queryMetadata, 0, kErrorResponseTimeout); in HandleRetransmissionTimer()
243 queryMetadata.UpdateIn(message); in HandleRetransmissionTimer()
250 SendCopy(message, messageInfo); in HandleRetransmissionTimer()
266 Message *message = nullptr; in HandleUdpReceive() local
271 VerifyOrExit((message = FindRelatedQuery(responseHeader, queryMetadata)) != nullptr); in HandleUdpReceive()
309 FinalizeSntpTransaction(*message, queryMetadata, unixTime, kErrorNone); in HandleUdpReceive()
313 if (message != nullptr && error != kErrorNone) in HandleUdpReceive()
315 FinalizeSntpTransaction(*message, queryMetadata, 0, error); in HandleUdpReceive()