Changeset 6906

Timestamp:

Oct 14, 2008, 8:44:41 PM (13 years ago)

Author:

charles

Message:

(libT) dead code removal

Location:

trunk

Files:

• configure.ac (modified) (1 diff)
• libtransmission/fdlimit.c (modified) (12 diffs)
• libtransmission/fdlimit.h (modified) (1 diff)
• libtransmission/net.c (modified) (4 diffs)
• libtransmission/net.h (modified) (1 diff)
• libtransmission/peer-io.c (modified) (2 diffs)
• libtransmission/peer-mgr.c (modified) (1 diff)

trunk/configure.ac

@@ -61 +61 @@
 AC_HEADER_TIME
 AC_CHECK_FUNCS([lrintf strlcpy daemon dirname basename daemon strcasecmp])
-AC_CHECK_SIZEOF([void*])
 AC_PROG_INSTALL
 AC_PROG_MAKE_SET

trunk/libtransmission/fdlimit.c

@@ -53 +53 @@
 #include "utils.h"
 
-#if SIZEOF_VOIDP == 8
- #define TR_UINT_TO_PTR( i ) (void*)( (uint64_t)i )
-#else
- #define TR_UINT_TO_PTR( i ) ( (void*)( (uint32_t)i ) )
-#endif
-
 #define dbgmsg( ... ) tr_deepLog( __FILE__, __LINE__, NULL, __VA_ARGS__ )
 
@@ -85 +79 @@
 struct tr_fd_s
 {
-    int                   reserved;
-    int                   normal;
-    int                   normalMax;
+    int                   socketCount;
+    int                   socketMax;
     tr_lock *             lock;
     struct tr_openfile    open[TR_MAX_OPEN_FILES];
@@ -369 +362 @@
 ***/
 
-static tr_list * reservedSockets = NULL;
-
-static void
-setSocketPriority( int fd,
-                   int isReserved )
-{
-    if( isReserved )
-        tr_list_append( &reservedSockets, TR_UINT_TO_PTR( fd ) );
-}
-
-static int
-socketWasReserved( int fd )
-{
-    return tr_list_remove_data( &reservedSockets,
-                               TR_UINT_TO_PTR( fd ) ) != NULL;
-}
-
 static int
 getSocketMax( struct tr_fd_s * gFd )
 {
-    return gFd->normalMax;
+    return gFd->socketMax;
 }
 
 int
-tr_fdSocketCreate( int type,
-                   int isReserved )
+tr_fdSocketCreate( int type )
 {
     int s = -1;
@@ -400 +375 @@
     tr_lockLock( gFd->lock );
 
-    if( isReserved || ( gFd->normal < getSocketMax( gFd ) ) )
+    if( gFd->socketCount < getSocketMax( gFd ) )
         if( ( s = socket( AF_INET, type, 0 ) ) < 0 )
             tr_err( _( "Couldn't create socket: %s" ),
@@ -406 +381 @@
 
     if( s > -1 )
-    {
-        setSocketPriority( s, isReserved );
-
-        if( isReserved )
-            ++gFd->reserved;
-        else
-            ++gFd->normal;
-    }
-
-    assert( gFd->reserved >= 0 );
-    assert( gFd->normal >= 0 );
+        ++gFd->socketCount;
+
+    assert( gFd->socketCount >= 0 );
 
     tr_lockUnlock( gFd->lock );
@@ -435 +402 @@
 
     tr_lockLock( gFd->lock );
-    if( gFd->normal < getSocketMax( gFd ) )
+    if( gFd->socketCount < getSocketMax( gFd ) )
     {
         len = sizeof( sock );
@@ -442 +409 @@
     if( s > -1 )
     {
-        setSocketPriority( s, FALSE );
         *addr = sock.sin_addr;
         *port = sock.sin_port;
-        gFd->normal++;
+        ++gFd->socketCount;
     }
     tr_lockUnlock( gFd->lock );
@@ -470 +436 @@
     {
         socketClose( s );
-        if( socketWasReserved( s ) )
-            --gFd->reserved;
-        else
-            --gFd->normal;
-    }
-
-    assert( gFd->reserved >= 0 );
-    assert( gFd->normal >= 0 );
+        --gFd->socketCount;
+    }
+
+    assert( gFd->socketCount >= 0 );
 
     tr_lockUnlock( gFd->lock );
@@ -504 +466 @@
                             (rlim_t)( globalPeerLimit + NOFILE_BUFFER ) );
         setrlimit( RLIMIT_NOFILE, &rlim );
-        gFd->normalMax = rlim.rlim_cur - NOFILE_BUFFER;
+        gFd->socketMax = rlim.rlim_cur - NOFILE_BUFFER;
         tr_dbg( "setrlimit( RLIMIT_NOFILE, %d )", (int)rlim.rlim_cur );
     }
 #else
-    gFd->normalMax = globalPeerLimit;
+    gFd->socketMax = globalPeerLimit;
 #endif
     tr_dbg( "%d usable file descriptors", globalPeerLimit );
@@ -527 +489 @@
     tr_lockFree( gFd->lock );
 
-    tr_list_free( &reservedSockets, NULL );
     tr_free( gFd );
 }
@@ -535 +496 @@
 {
     assert( gFd != NULL && "tr_fdInit() must be called first!" );
-    gFd->normalMax = n;
+    gFd->socketMax = n;
 }
 
@@ -541 +502 @@
 tr_fdGetPeerLimit( void )
 {
-    return gFd ? gFd->normalMax : -1;
-}
-
+    return gFd ? gFd->socketMax : -1;
+}
+

trunk/libtransmission/fdlimit.h

@@ -80 +80 @@
  * Sockets
  **********************************************************************/
-int      tr_fdSocketCreate( int type,
-                            int priority );
+int      tr_fdSocketCreate( int type );
 
 int      tr_fdSocketAccept( int              b,

trunk/libtransmission/net.c

@@ -118 +118 @@
 
 static int
-createSocket( int type,
-              int priority )
-{
-    int fd;
-
-    fd = tr_fdSocketCreate( type, priority );
+createSocket( int type )
+{
+    int fd = tr_fdSocketCreate( type );
 
     if( fd >= 0 )
@@ -141 +138 @@
 int
 tr_netOpenTCP( const struct in_addr * addr,
-               tr_port_t              port,
-               int                    priority )
+               tr_port_t              port )
 {
     int                s;
@@ -148 +144 @@
     const int          type = SOCK_STREAM;
 
-    if( ( s = createSocket( type, priority ) ) < 0 )
+    if( ( s = createSocket( type ) ) < 0 )
         return -1;
 
@@ -188 +184 @@
 #endif
 
-    if( ( s = createSocket( type, 1 ) ) < 0 )
+    if( ( s = createSocket( type ) ) < 0 )
         return -1;
 

trunk/libtransmission/net.h

@@ -71 +71 @@
  **********************************************************************/
 int  tr_netOpenTCP( const struct in_addr * addr,
-                    tr_port_t              port,
-                    int                    priority );
+                    tr_port_t              port );
 
 int  tr_netBindTCP( int port );

trunk/libtransmission/peer-io.c

@@ -345 +345 @@
     assert( torrentHash );
 
-    socket = tr_netOpenTCP( in_addr, port, 0 );
+    socket = tr_netOpenTCP( in_addr, port );
 
     return socket < 0
@@ -452 +452 @@
         tr_netClose( io->socket );
 
-    io->socket = tr_netOpenTCP( &io->in_addr, io->port, 0 );
+    io->socket = tr_netOpenTCP( &io->in_addr, io->port );
 
     if( io->socket >= 0 )

trunk/libtransmission/peer-mgr.c

@@ -2505 +2505 @@
         Torrent *    t = torrents[i];
         const size_t used = countPeerBandwidth( t->peers, direction );
-        +countHandshakeBandwidth( t->outgoingHandshakes,
-                                  direction );
+        countHandshakeBandwidth( t->outgoingHandshakes, direction );
 
         /* add this torrent's bandwidth use to allBytesUsed */