mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-24 22:24:44 +02:00
parent
6cd931726d
commit
b6a799d53e
@ -318,13 +318,17 @@ void TlsStream::Shutdown(void)
|
|||||||
*/
|
*/
|
||||||
void TlsStream::Close(void)
|
void TlsStream::Close(void)
|
||||||
{
|
{
|
||||||
|
if (!m_Eof) {
|
||||||
|
m_Eof = true;
|
||||||
|
SignalDataAvailable();
|
||||||
|
}
|
||||||
|
|
||||||
Stream::Close();
|
Stream::Close();
|
||||||
|
|
||||||
SocketEvents::Unregister();
|
SocketEvents::Unregister();
|
||||||
|
|
||||||
boost::mutex::scoped_lock lock(m_Mutex);
|
boost::mutex::scoped_lock lock(m_Mutex);
|
||||||
|
|
||||||
m_Eof = true;
|
|
||||||
|
|
||||||
if (!m_SSL)
|
if (!m_SSL)
|
||||||
return;
|
return;
|
||||||
|
@ -216,6 +216,12 @@ void HttpServerConnection::DataAvailableHandler(void)
|
|||||||
|
|
||||||
if (close)
|
if (close)
|
||||||
Disconnect();
|
Disconnect();
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (m_Stream->IsEof())
|
||||||
|
Disconnect();
|
||||||
}
|
}
|
||||||
|
|
||||||
void HttpServerConnection::CheckLiveness(void)
|
void HttpServerConnection::CheckLiveness(void)
|
||||||
|
@ -249,6 +249,12 @@ void JsonRpcConnection::DataAvailableHandler(void)
|
|||||||
|
|
||||||
if (close)
|
if (close)
|
||||||
Disconnect();
|
Disconnect();
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (m_Stream->IsEof())
|
||||||
|
Disconnect();
|
||||||
}
|
}
|
||||||
|
|
||||||
Value SetLogPositionHandler(const MessageOrigin::Ptr& origin, const Dictionary::Ptr& params)
|
Value SetLogPositionHandler(const MessageOrigin::Ptr& origin, const Dictionary::Ptr& params)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user