X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fsocket_client.cpp;h=a26b004cfacd5e33f0f8f8f28413738cab17f7d7;hp=1f5dccf63904251f2c273287d40bd16355c5864d;hb=4b995a82e29808cf8125889f83ec70fc7b5c77af;hpb=e1614a6d1d9c022b83c0aa8cdb948bd7dc98ff23

diff --git a/src/socket_client.cpp b/src/socket_client.cpp
index 1f5dccf..a26b004 100644
--- 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,11 +86,22 @@ 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);
 }
 
+/// establish a connection via tcp
 void socket_client_connection::tcp_connect(int max_retries)
 {
     struct sockaddr_in sock_addr;
@@ -114,10 +137,11 @@ 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");
     }
 }
 
+/// establish a connection via unix-socket
 void socket_client_connection::unix_connect(int max_retries)
 {
     struct sockaddr_un unix_addr;
@@ -142,10 +166,11 @@ 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");
     }
 }
 
+/// execute a connect on a prepared socket (tcp or unix) respecting timeouts
 void socket_client_connection::connect_with_timeout(struct sockaddr *sock_addr,unsigned int sockaddr_size)
 {
     set_socket_options(sock);
@@ -183,25 +208,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 +233,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 +250,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());
-
 }
 
 }