Log(LogWarning, "JsonRpcConnection")
<< "API client disconnected for identity '" << m_Identity << "'";
+ {
+ CpuBoundWork removeClient (yc);
+
+ if (m_Endpoint) {
+ m_Endpoint->RemoveClient(this);
+ } else {
+ ApiListener::GetInstance()->RemoveAnonymousClient(this);
+ }
+ }
+
m_OutgoingMessagesQueued.Set();
m_WriterDone.Wait(yc);
m_CheckLivenessTimer.cancel();
m_HeartbeatTimer.cancel();
-
- CpuBoundWork removeClient (yc);
-
- if (m_Endpoint) {
- m_Endpoint->RemoveClient(this);
- } else {
- auto listener (ApiListener::GetInstance());
- listener->RemoveAnonymousClient(this);
- }
}
});
}