Skip to content

Commit de1843a

Browse files
WIP
1 parent 036c6af commit de1843a

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/Client/Connection.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ template<class BUFFER, class NetProvider>
123123
ConnectionImpl<BUFFER, NetProvider>::~ConnectionImpl()
124124
{
125125
assert(refs == 0);
126-
if (!strm.has_status(SS_DEAD)) {
126+
if (strm.get_fd() != -1) {
127127
connector.close(this);
128128
}
129129
}

src/Client/Connector.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -188,8 +188,8 @@ template<class BUFFER, class NetProvider>
188188
void
189189
Connector<BUFFER, NetProvider>::close(ConnectionImpl<BUFFER, NetProvider> *conn)
190190
{
191-
assert(!conn->get_strm().has_status(SS_DEAD));
192-
m_NetProvider.close(conn->get_strm());
191+
if (conn->get_strm().get_fd() != -1)
192+
m_NetProvider.close(conn->get_strm());
193193
}
194194

195195
template <class BUFFER, class NetProvider>

0 commit comments

Comments
 (0)