Skip to content

Commit 20e3a13

Browse files
committed
Fix deadlock due to missed error notification.
1 parent 8cb7496 commit 20e3a13

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ClientSource/Connection/PABotBase.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,10 @@ void PABotBase::wait_for_all_requests(const Cancellable* cancelled){
157157
ReadSpinLock lg0(m_state_lock);
158158
throw InvalidConnectionStateException(m_error_message);
159159
}
160+
if (m_error.load(std::memory_order_acquire)){
161+
ReadSpinLock lg0(m_state_lock);
162+
throw ConnectionException(&m_logger, m_error_message);
163+
}
160164
{
161165
ReadSpinLock lg1(m_state_lock, "PABotBase::wait_for_all_requests()");
162166
#if 0

0 commit comments

Comments
 (0)