Changeset 1060 for trunk/libtransmission/peer.c

Timestamp:

Nov 9, 2006, 4:45:14 AM (16 years ago)

Author:

titer

Message:

Saves a list of peers when you pause a torrent, and tries to reconnect to them next time you resume it

File:

• trunk/libtransmission/peer.c (modified) (2 diffs)

trunk/libtransmission/peer.c

@@ -152 +152 @@
 
 /***********************************************************************
+ * tr_peerAddCompactMany
+ ***********************************************************************
+ * Adds several peers in compact form
+ **********************************************************************/
+void tr_peerAddCompactMany( tr_torrent_t * tor, uint8_t * buf, int len )
+{
+    struct in_addr addr;
+    in_port_t port;
+    int i;
+
+    len /= 6;
+    for( i = 0; i < len; i++ )
+    {
+        memcpy( &addr, buf, 4 ); buf += 4;
+        memcpy( &port, buf, 2 ); buf += 2;
+        tr_peerAddCompact( tor, addr, port );
+    }
+}
+
+/***********************************************************************
  * tr_peerInit
  ***********************************************************************
@@ -617 +637 @@
     tr_bitfieldRem( peer->blamefield, piece );
 }
+
+int tr_peerGetConnectable( tr_torrent_t * tor, uint8_t ** _buf )
+{
+    int count = 0;
+    uint8_t * buf = malloc( 6 * tor->peerCount );
+    tr_peer_t * peer;
+    int i;
+
+    for( i = 0; i < tor->peerCount; i++ )
+    {
+        peer = tor->peers[i];
+
+        /* Skip peers for which the connection isn't established,
+         * and peers that came from incoming connections */
+        if( peer->status < PEER_STATUS_CONNECTED )
+            continue;
+        if( peer->incoming )
+            continue;
+
+        memcpy( &buf[count*6], &peer->addr, 4 );
+        memcpy( &buf[count*6+4], &peer->port, 2 );
+        count++;
+    }
+
+    if( count < 1 )
+    {
+        free( buf );
+        *_buf = NULL;
+    }
+    else
+    {
+        *_buf = buf;
+    }
+
+    return count * 6;
+}