jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

slightly prettified the code

This commit is contained in:
Emiel Bruijntjes 2019-01-10 08:25:31 +01:00
parent 964398292a
commit e10fd61ac8
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/linux_tcp/sslconnected.h
View File

@ -110,18 +110,14 @@ private:
*/ */
TcpState *repeat(const Monitor &monitor, enum State state, int error) TcpState *repeat(const Monitor &monitor, enum State state, int error)
{ {
// if we are able to repeat the call, we are still in the correct state // if we are not able to repeat the call, we are in an error state and should tear down the connection
if (repeat(state, error)) if (!repeat(state, error)) return monitor.valid() ? new TcpClosed(this) : nullptr;
{
// if the socket was closed in the meantime and we are not sending anything any more, we should initialize the shutdown sequence
if (_closed && _state == state_idle) return new SslShutdown(this, std::move(_ssl));
// otherwise, we just continue as we were, since the calls should be repeated in the future
else return this;
}
// if the monitor is still valid, we should tear down the connection because we are unable to repeat the call // if the socket was closed in the meantime and we are not sending anything any more, we should initialize the shutdown sequence
return monitor.valid() ? new TcpClosed(this) : nullptr; if (_closed && _state == state_idle) return new SslShutdown(this, std::move(_ssl));
// otherwise, we just continue as we were, since the calls should be repeated in the future
else return this;
} }
/** /**