Changeset 7133

Timestamp:

Nov 21, 2008, 4:32:55 PM (14 years ago)

Author:

charles

Message:

(libT) define peer connections' sockets' so_sndbuf size in the tr_session struct.

Location:

trunk/libtransmission

Files:

• net.c (modified) (3 diffs)
• net.h (modified) (2 diffs)
• peer-io.c (modified) (3 diffs)
• peer-io.h (modified) (1 diff)
• port-forwarding.c (modified) (7 diffs)
• session.c (modified) (1 diff)
• session.h (modified) (1 diff)

trunk/libtransmission/net.c

@@ -120 +120 @@
 createSocket( int type )
 {
-    const int fd = makeSocketNonBlocking( tr_fdSocketCreate( type ) );
-
-    if( fd >= 0 ) {
-        const int buffsize = 1500*3; /* 3x MTU for most ethernet/wireless */
-        setsockopt( fd, SOL_SOCKET, SO_SNDBUF, &buffsize, sizeof( buffsize ) );
-    }
-
-    return fd;
-}
-
-int
-tr_netOpenTCP( const struct in_addr * addr,
-               tr_port_t              port )
+    return makeSocketNonBlocking( tr_fdSocketCreate( type ) );
+}
+
+static void
+setSndBuf( tr_session * session, int fd )
+{
+    if( fd >= 0 )
+    {
+        const int sndbuf = session->so_sndbuf;
+        setsockopt( fd, SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof( sndbuf ) );
+    }
+}
+
+int
+tr_netOpenTCP( tr_session            * session,
+               const struct in_addr  * addr,
+               tr_port_t               port )
 {
     int                s;
@@ -140 +144 @@
     if( ( s = createSocket( type ) ) < 0 )
         return -1;
+
+    setSndBuf( session, s );
 
     memset( &sock, 0, sizeof( sock ) );
@@ -205 +211 @@
 
 int
-tr_netAccept( int              b,
-              struct in_addr * addr,
-              tr_port_t *      port )
-{
-    return makeSocketNonBlocking( tr_fdSocketAccept( b, addr, port ) );
+tr_netAccept( tr_session      * session,
+              int               b,
+              struct in_addr  * addr,
+              tr_port_t       * port )
+{
+    int fd = makeSocketNonBlocking( tr_fdSocketAccept( b, addr, port ) );
+    setSndBuf( session, fd );
+    return fd;
 }
 

trunk/libtransmission/net.h

@@ -59 +59 @@
 struct in_addr;
 struct sockaddr_in;
+struct tr_session;
 
 /***********************************************************************
@@ -70 +71 @@
  * Sockets
  **********************************************************************/
-int  tr_netOpenTCP( const struct in_addr * addr,
+int  tr_netOpenTCP( struct tr_handle     * session,
+                    const struct in_addr * addr,
                     tr_port_t              port );
 
 int  tr_netBindTCP( int port );
 
-int  tr_netAccept( int    s,
-                   struct in_addr *,
-                          tr_port_t * );
+int  tr_netAccept( struct tr_handle  * session,
+                   int                 bound,
+                   struct in_addr    * setme_addr,
+                   tr_port_t         * setme_port );
 
 int  tr_netSetTOS( int s,

trunk/libtransmission/peer-io.c

@@ -387 +387 @@
     assert( torrentHash );
 
-    socket = tr_netOpenTCP( in_addr, port );
+    socket = tr_netOpenTCP( session, in_addr, port );
 
     return socket < 0
@@ -493 +493 @@
         tr_netClose( io->socket );
 
-    io->socket = tr_netOpenTCP( &io->in_addr, io->port );
+    io->socket = tr_netOpenTCP( io->session, &io->in_addr, io->port );
 
     if( io->socket >= 0 )
@@ -716 +716 @@
 ***
 **/
-
-int
-tr_peerIoWantsBandwidth( const tr_peerIo * io,
-                         tr_direction      direction )
-{
-    assert( direction == TR_UP || direction == TR_DOWN );
-
-    if( direction == TR_DOWN )
-    {
-        return TRUE; /* FIXME -- is there a good way to test for this? */
-    }
-    else
-    {
-        return EVBUFFER_LENGTH( EVBUFFER_OUTPUT( io->bufev ) )
-               || EVBUFFER_LENGTH( io->output );
-    }
-}
 
 void

trunk/libtransmission/peer-io.h

@@ -129 +129 @@
 **/
 
-int     tr_peerIoWantsBandwidth ( const tr_peerIo   * io,
-                                  tr_direction        direction );
-
 void    tr_peerIoWrite          ( tr_peerIo         * io,
                                   const void        * writeme,

trunk/libtransmission/port-forwarding.c

@@ -43 +43 @@
     int                   publicPort;
 
-    tr_handle *           h;
-    tr_timer *            pulseTimer;
-
-    tr_upnp *             upnp;
-    tr_natpmp *           natpmp;
+    tr_timer            * pulseTimer;
+
+    tr_upnp             * upnp;
+    tr_natpmp           * natpmp;
+    tr_session          * session;
 };
 
@@ -146 +146 @@
             break;
 
-        socket = tr_netAccept( s->bindSocket, &addr, &port );
+        socket = tr_netAccept( s->session, s->bindSocket, &addr, &port );
         if( socket < 0 )
             break;
@@ -152 +152 @@
         tr_deepLog( __FILE__, __LINE__, NULL,
                    "New INCOMING connection %d (%s)",
-                   socket, tr_peerIoAddrStr( &addr,
-                                             port ) );
-
-        tr_peerMgrAddIncoming( s->h->peerMgr, &addr, port, socket );
+                   socket, tr_peerIoAddrStr( &addr, port ) );
+
+        tr_peerMgrAddIncoming( s->session->peerMgr, &addr, port, socket );
     }
 }
@@ -178 +177 @@
         tr_natpmpClose( shared->natpmp );
         tr_upnpClose( shared->upnp );
-        shared->h->shared = NULL;
+        shared->session->shared = NULL;
         tr_free( shared );
         keepPulsing = 0;
@@ -191 +190 @@
 
 tr_shared *
-tr_sharedInit( tr_handle * h,
-               int         isEnabled,
-               int         publicPort )
+tr_sharedInit( tr_session  * session,
+               int           isEnabled,
+               int           publicPort )
 {
     tr_shared * s = tr_new0( tr_shared, 1 );
 
-    s->h            = h;
+    s->session      = session;
     s->publicPort   = publicPort;
     s->bindPort     = -1;
@@ -203 +202 @@
     s->natpmp       = tr_natpmpInit( );
     s->upnp         = tr_upnpInit( );
-    s->pulseTimer   = tr_timerNew( h, sharedPulse, s, 1000 );
+    s->pulseTimer   = tr_timerNew( session, sharedPulse, s, 1000 );
     s->isEnabled    = isEnabled ? 1 : 0;
     s->upnpStatus   = TR_PORT_UNMAPPED;
@@ -225 +224 @@
     s->publicPort = port;
 
-    while( ( tor = tr_torrentNext( s->h, tor ) ) )
+    while( ( tor = tr_torrentNext( s->session, tor ) ) )
         tr_torrentChangeMyPort( tor );
 }

trunk/libtransmission/session.c

@@ -259 +259 @@
     h->rawSpeed[TR_PEER_TO_CLIENT] = tr_rcInit( );
     h->rawSpeed[TR_CLIENT_TO_PEER] = tr_rcInit( );
+    h->so_sndbuf = 1500 * 3; /* 3x MTU for most ethernet/wireless */
 
     if( configDir == NULL )

trunk/libtransmission/session.h

@@ -106 +106 @@
     int                          metainfoLookupCount;
 
+    /* the size of the output buffer for peer connections */
+    int so_sndbuf;
+
     /* the rate at which pieces are being transferred between client and peer.
      * protocol overhead is NOT included; this is only the piece data */