Skip to content

Commit

Permalink
ConnectionManager: register pending callback on retry
Browse files Browse the repository at this point in the history
Change-Id: Ic7c5bf97c9ac159519eea2c265787cf47d378ce7
  • Loading branch information
aberaud committed Oct 25, 2024
1 parent ce79ae1 commit 3bd76bc
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/connectionmanager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1605,6 +1605,10 @@ ConnectionManager::Impl::retryOnError(const std::shared_ptr<DeviceInfo>& deviceI
return;
if (auto i = deviceInfo->getConnectedInfo()) {
auto ops = deviceInfo->requestPendingOps();
std::unique_lock clk(i->mutex_);
for (const auto& [id, name]: ops)
i->pendingCbs_.emplace(id);
clk.unlock();
lk.unlock();
for (const auto& [id, name]: ops)
sendChannelRequest(deviceInfo, i, i->socket_, name, id);
Expand Down

0 comments on commit 3bd76bc

Please sign in to comment.