added TCP keep-alive, fixes #10

darkice/trunk/ChangeLog

@@ -1,5 +1,7 @@
 DarkIce next release
 
+    o improvements on reconnecting:
+      added TCP connection keep-alive to TCP sockets
     o added user-defined date formatting for the fileAddDate options,
       thanks to dsk <derrick@csociety.org>
     o added logging facility - [file-X] targets will cut the saved file

darkice/trunk/src/TcpSocket.cpp

@@ -192,6 +192,8 @@ TcpSocket :: operator= (  const TcpSocket &    ss )   throw ( Exception )
 bool
 TcpSocket :: open ( void )                       throw ( Exception )
 {
+    int                     optval;
+    socklen_t               optlen;
 #ifdef HAVE_ADDRINFO
     struct addrinfo         hints
     struct addrinfo       * ptr;
@@ -222,15 +224,24 @@ TcpSocket :: open ( void )                       throw ( Exception )
         throw Exception( __FILE__, __LINE__, "gethostbyname error", errno);
     }
     
-    if ( (sockfd = socket( AF_INET, SOCK_STREAM,  IPPROTO_TCP)) == -1 ) {
-        throw Exception( __FILE__, __LINE__, "socket error", errno);
-    }
-
     memset( &addr, 0, sizeof(addr));
     addr.sin_family      = AF_INET;
     addr.sin_port        = htons(port);
     addr.sin_addr.s_addr = *((long*) pHostEntry->h_addr_list[0]);
 #endif
+
+    if ( (sockfd = socket( AF_INET, SOCK_STREAM,  IPPROTO_TCP)) == -1 ) {
+        throw Exception( __FILE__, __LINE__, "socket error", errno);
+    }
+
+    // set TCP keep-alive
+    optval = 1;
+    optlen = sizeof(optval);
+    if (setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE, &optval, optlen) == -1) {  
+        reportEvent(5, "can't set TCP socket keep-alive mode", errno);
+    }
+
+    // connect
     if ( connect( sockfd, (struct sockaddr*)&addr, sizeof(addr)) == -1 ) {
         ::close( sockfd);
         sockfd = 0;

darkice/trunk/src/TcpSocket.h

@@ -38,6 +38,7 @@
 
 #include "Source.h"
 #include "Sink.h"
+#include "Reporter.h"
 
 
 /* ================================================================ constants */
@@ -54,7 +55,7 @@
  *  @author  $Author$
  *  @version $Revision$
  */
-class TcpSocket : public Source, public Sink
+class TcpSocket : public Source, public Sink, public virtual Reporter
 {
     private: