Skip to content
Snippets Groups Projects
Commit 3bd76bcc authored by Adrien Béraud's avatar Adrien Béraud
Browse files

ConnectionManager: register pending callback on retry

Change-Id: Ic7c5bf97c9ac159519eea2c265787cf47d378ce7
parent ce79ae14
Branches
No related tags found
No related merge requests found
...@@ -1605,6 +1605,10 @@ ConnectionManager::Impl::retryOnError(const std::shared_ptr<DeviceInfo>& deviceI ...@@ -1605,6 +1605,10 @@ ConnectionManager::Impl::retryOnError(const std::shared_ptr<DeviceInfo>& deviceI
return; return;
if (auto i = deviceInfo->getConnectedInfo()) { if (auto i = deviceInfo->getConnectedInfo()) {
auto ops = deviceInfo->requestPendingOps(); auto ops = deviceInfo->requestPendingOps();
std::unique_lock clk(i->mutex_);
for (const auto& [id, name]: ops)
i->pendingCbs_.emplace(id);
clk.unlock();
lk.unlock(); lk.unlock();
for (const auto& [id, name]: ops) for (const auto& [id, name]: ops)
sendChannelRequest(deviceInfo, i, i->socket_, name, id); sendChannelRequest(deviceInfo, i, i->socket_, name, id);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment