Lines Matching refs:eid
90 std::optional<uint8_t> expectedEid = recvEndPoint.eid(); in processRecvMsg()
110 uint8_t eid = *expectedEid; in processRecvMsg() local
117 handleResult(eid, static_cast<std::error_code>(ec), {}); in processRecvMsg()
134 "EID", eid); in processRecvMsg()
148 auto it = requestContextQueues.find(eid); in processRecvMsg()
164 iid, "EID", eid, "E_IID", it->second.iid); in processRecvMsg()
168 handleResult(eid, std::error_code{}, responseBuffer); in processRecvMsg()
172 uint8_t eid, const boost::system::error_code& ec, size_t /* length */) in handleSendMsgCompletion() argument
179 handleResult(eid, static_cast<std::error_code>(ec), {}); in handleSendMsgCompletion()
183 auto it = requestContextQueues.find(eid); in handleSendMsgCompletion()
197 expiryTimer.async_wait([this, eid](const boost::system::error_code& ec) { in handleSendMsgCompletion()
200 lg2::error("Operation timed out on eid {EID}", "EID", eid); in handleSendMsgCompletion()
201 handleResult(eid, std::make_error_code(std::errc::timed_out), {}); in handleSendMsgCompletion()
207 uint8_t eid, std::span<const uint8_t> reqMsg, in sendRecvMsg() argument
215 auto [it, inserted] = requestContextQueues.try_emplace(eid, io); in sendRecvMsg()
223 processQueue(eid); in sendRecvMsg()
233 void MctpRequester::handleResult(uint8_t eid, const std::error_code& ec, in handleResult() argument
236 auto it = requestContextQueues.find(eid); in handleResult()
266 "eid {} encountered a fatal error: {}", eid, ec.message())); in handleResult()
273 processQueue(eid); in handleResult()
276 std::optional<uint8_t> MctpRequester::getNextIid(uint8_t eid) in getNextIid() argument
278 auto it = requestContextQueues.find(eid); in getNextIid()
313 void MctpRequester::processQueue(uint8_t eid) in processQueue() argument
315 auto it = requestContextQueues.find(eid); in processQueue()
332 std::optional<uint8_t> iid = getNextIid(eid); in processQueue()
336 handleResult(eid, std::make_error_code(std::errc::no_such_device), {}); in processQueue()
344 handleResult(eid, success.error(), {}); in processQueue()
348 MctpAsioEndpoint sendEndPoint(eid, in processQueue()
353 std::bind_front(&MctpRequester::handleSendMsgCompletion, this, eid)); in processQueue()