libt2n: (gerd) fix client-connection-logic, finish wrappers, all tests are working...

[libt2n] / src / socket_client.cpp

diff --git a/src/socket_client.cpp b/src/socket_client.cpp
index 1f5dccf..6b5b481 100644 (file)
--- a/src/socket_client.cpp
+++ b/src/socket_client.cpp
@@ -44,6 +44,7 @@ using namespace std;
 namespace libt2n
 {
 
+/// returns a closed connection if connection could not be established, call get_last_error_msg() for details
 socket_client_connection::socket_client_connection(int _port, const std::string& _server, 
             long long _connect_timeout_usec, int _max_retries,
             std::ostream *_logstream, log_level_values _log_level)
@@ -57,11 +58,22 @@ socket_client_connection::socket_client_connection(int _port, const std::string&
 
     set_logging(_logstream,_log_level);
 
-    tcp_connect(max_retries);
+    try
+    {
+        tcp_connect(max_retries);
+    }
+    catch (t2n_communication_error &e)
+    {
+        lastErrorMsg=e.what();
+        LOGSTREAM(debug,"tcp connect error: " << lastErrorMsg);
+        close();
+    }
 
-    do_callbacks(new_connection);
+    if (!connection::is_closed())
+        do_callbacks(new_connection);
 }
 
+/// returns a closed connection if connection could not be established, call get_last_error_msg() for details
 socket_client_connection::socket_client_connection(const std::string& _path,
             long long _connect_timeout_usec, int _max_retries,
             std::ostream *_logstream, log_level_values _log_level)
@@ -74,9 +86,19 @@ socket_client_connection::socket_client_connection(const std::string& _path,
 
     set_logging(_logstream,_log_level);
 
-    unix_connect(max_retries);
+    try
+    {
+        unix_connect(max_retries);
+    }
+    catch (t2n_communication_error &e)
+    {
+        lastErrorMsg=e.what();
+        LOGSTREAM(debug,"unix connect error: " << lastErrorMsg);
+        close();
+    }
 
-    do_callbacks(new_connection);
+    if (!connection::is_closed())
+        do_callbacks(new_connection);
 }
 
 void socket_client_connection::tcp_connect(int max_retries)
@@ -114,7 +136,7 @@ void socket_client_connection::tcp_connect(int max_retries)
             tcp_connect(max_retries-1);
         }
         else
-            LOGSTREAM(debug,"no more retries left after connect error");
+            throw t2n_connect_error("no more retries left after connect error");
     }
 }
 
@@ -142,7 +164,7 @@ void socket_client_connection::unix_connect(int max_retries)
             unix_connect(max_retries-1);
         }
         else
-            LOGSTREAM(debug,"no more retries left after connect error");
+            throw t2n_connect_error("no more retries left after connect error");
     }
 }
 
@@ -183,25 +205,16 @@ void socket_client_connection::connect_with_timeout(struct sockaddr *sock_addr,u
                     ret < 0 && errno==EINTR);
 
             if (ret < 0)
-            {
-                LOGSTREAM(debug,"connect_with_timeout(): select error: " << strerror(errno));
                 throw t2n_connect_error(string("connect() error (select): ")+strerror(errno));
-            }
 
             socklen_t sopt=sizeof(int);
             int valopt;
             ret=getsockopt(sock, SOL_SOCKET, SO_ERROR, (void*)(&valopt), &sopt);
             if (ret < 0 || valopt)
-            {
-                LOGSTREAM(debug,"connect_with_timeout(): getsockopt error: " << strerror(errno));
                 throw t2n_connect_error(string("connect() error (getsockopt): ")+strerror(errno));
-            }
         }
         else
-        {
-            LOGSTREAM(debug,"connect_with_timeout(): error: " << strerror(errno));
             throw t2n_connect_error(string("connect() error: ")+strerror(errno));
-        }
     }
 
     LOGSTREAM(debug,"connect_with_timeout(): success");
@@ -217,6 +230,8 @@ void socket_client_connection::close()
 }
 
 /** @brief try to reconnect the current connection with the same connection credentials (host and port or path)
+
+    @note will throw an exeption if reconnecting not possible
 */
 void socket_client_connection::reconnect()
 {
@@ -232,12 +247,10 @@ void socket_client_connection::reconnect()
     else if (type == unix_s)
         unix_connect(max_retries);
 
-    LOGSTREAM(debug,"reconnect(): basic connection established");
-
+    // connection is open now, otherwise an execption would have been thrown
     reopen();
 
     LOGSTREAM(debug,"reconnect() done, client_connection::is_closed() now " << client_connection::is_closed());
-
 }
 
 }