|
@@ -391,7 +391,6 @@ void TlsTransport::stop() {
|
|
unregisterIncoming();
|
|
unregisterIncoming();
|
|
mIncomingQueue.stop();
|
|
mIncomingQueue.stop();
|
|
mRecvThread.join();
|
|
mRecvThread.join();
|
|
- SSL_shutdown(mSsl);
|
|
|
|
}
|
|
}
|
|
|
|
|
|
bool TlsTransport::send(message_ptr message) {
|
|
bool TlsTransport::send(message_ptr message) {
|
|
@@ -483,6 +482,9 @@ void TlsTransport::runRecvLoop() {
|
|
recv(message); // Pass zero-sized messages through
|
|
recv(message); // Pass zero-sized messages through
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ std::lock_guard lock(mSslMutex);
|
|
|
|
+ SSL_shutdown(mSsl);
|
|
|
|
+
|
|
} catch (const std::exception &e) {
|
|
} catch (const std::exception &e) {
|
|
PLOG_ERROR << "TLS recv: " << e.what();
|
|
PLOG_ERROR << "TLS recv: " << e.what();
|
|
}
|
|
}
|