client: fix double-close condition for connections

Currently, to avoid double-close of a connection we check for the `SS_DEAD`
status on its stream. However, the `SS_DEAD` status can be set for a
multitude of reasons without the connection being closed or even connected.
For instance, we set it if a send/recv failed unrecoverably.

To fix this, let's rely on the fact that a connection is open iff the file
descriptor of its stream is a valid (i.e., not -1). This approach seems to
be portable to the Windows platform too.

Closes #142

Author: CuriousGeorgiy

src/Client/Connection.hpp

@@ -124,7 +124,7 @@ template<class BUFFER, class NetProvider>
 ConnectionImpl<BUFFER, NetProvider>::~ConnectionImpl()
 {
 	assert(refs == 0);
-	if (!strm.has_status(SS_DEAD)) {
+	if (strm.get_fd() != -1) {
 		connector.close(this);
 	}
 }

src/Client/Connector.hpp

@@ -184,12 +184,13 @@ Connector<BUFFER, NetProvider>::close(Connection<BUFFER, NetProvider> &conn)
 	return close(conn.getImpl());
 }
 
-template<class BUFFER, class NetProvider>
+template <class BUFFER, class NetProvider>
 void
 Connector<BUFFER, NetProvider>::close(ConnectionImpl<BUFFER, NetProvider> *conn)
 {
-	assert(!conn->get_strm().has_status(SS_DEAD));
-	m_NetProvider.close(conn->get_strm());
+	if (conn->get_strm().get_fd() != -1) {
+		m_NetProvider.close(conn->get_strm());
+	}
 }
 
 template <class BUFFER, class NetProvider>

test/ClientTest.cpp

@@ -182,6 +182,8 @@ trivial(Connector<BUFFER, NetProvider> &client)
 	TEST_CASE("Connect timeout");
 	rc = test_connect(client, conn, "8.8.8.8", port);
 	fail_unless(rc != 0);
+	TEST_CASE("Close of non-established connection (gh-142)");
+	client.close(conn);
 }
 
 /** Single connection, separate/sequence pings, no errors */
@@ -235,6 +237,9 @@ single_conn_ping(Connector<BUFFER, NetProvider> &client)
 		fail_unless(response->body.error_stack == std::nullopt);
 	}
 	client.close(conn);
+
+	TEST_CASE("Double close of connection (gh-142)");
+	client.close(conn);
 }
 
 template <class BUFFER, class NetProvider>
@@ -1065,6 +1070,10 @@ test_sigpipe(void)
 	fail_unless(saved_errno == EPIPE);
 #endif
 	fail_if(conn.futureIsReady(f));
+
+	TEST_CASE("Close of connection with error (gh-142)");
+	fail_unless(conn.hasError());
+	client.close(conn);
 }
 
 /** Single connection, wait response from closed connection. */