Lines Matching full:eid
48 uint8_t eid = respAddr->smctp_addr.s_addr; in processRecvMsg() local
50 if (!completionCallbacks.contains(eid)) in processRecvMsg()
53 "MctpRequester failed to get the callback for the EID: {EID}", in processRecvMsg()
54 "EID", static_cast<int>(eid)); in processRecvMsg()
58 auto& callback = completionCallbacks.at(eid); in processRecvMsg()
110 uint8_t eid, const std::span<const uint8_t> reqMsg, in handleSendMsgCompletion() argument
114 if (!completionCallbacks.contains(eid)) in handleSendMsgCompletion()
117 "MctpRequester failed to get the callback for the EID: {EID}", in handleSendMsgCompletion()
118 "EID", static_cast<int>(eid)); in handleSendMsgCompletion()
122 auto& callback = completionCallbacks.at(eid); in handleSendMsgCompletion()
135 expiryTimer.async_wait([this, eid](const boost::system::error_code& ec) { in handleSendMsgCompletion()
138 auto& callback = completionCallbacks.at(eid); in handleSendMsgCompletion()
148 void Requester::sendRecvMsg(uint8_t eid, const std::span<const uint8_t> reqMsg, in sendRecvMsg() argument
159 completionCallbacks[eid] = std::move(callback); in sendRecvMsg()
163 addr.smctp_addr.s_addr = eid; in sendRecvMsg()
171 std::bind_front(&Requester::handleSendMsgCompletion, this, eid, reqMsg, in sendRecvMsg()
175 void QueuingRequester::sendRecvMsg(uint8_t eid, std::span<const uint8_t> reqMsg, in sendRecvMsg() argument
183 auto& queue = requestContextQueues[eid]; in sendRecvMsg()
188 processQueue(eid); in sendRecvMsg()
192 void QueuingRequester::handleResult(uint8_t eid, int result) in handleResult() argument
194 auto& queue = requestContextQueues[eid]; in handleResult()
201 processQueue(eid); in handleResult()
204 void QueuingRequester::processQueue(uint8_t eid) in processQueue() argument
206 auto& queue = requestContextQueues[eid]; in processQueue()
216 eid, reqCtx->reqMsg, reqCtx->respMsg, in processQueue()
217 std::bind_front(&QueuingRequester::handleResult, this, eid)); in processQueue()