Changeset 9434 for trunk/libtransmission/peer-msgs.c

Timestamp:

Oct 29, 2009, 4:10:03 PM (13 years ago)

Author:

charles

Message:

(trunk libT) #2508 atom->port never updated

File:

• trunk/libtransmission/peer-msgs.c (modified) (4 diffs)

trunk/libtransmission/peer-msgs.c

@@ -413 +413 @@
 **/
 
-static const tr_peer_event blankEvent = { 0, 0, 0, 0, 0.0f, 0, 0, 0 };
+static const tr_peer_event blankEvent = { 0, 0, 0, 0, 0.0f, 0, 0, 0, 0 };
 
 static void
@@ -489 +489 @@
     e.eventType = TR_PEER_CLIENT_GOT_SUGGEST;
     e.pieceIndex = pieceIndex;
+    publish( msgs, &e );
+}
+
+static void
+fireClientGotPort( tr_peermsgs * msgs, tr_port port )
+{
+    tr_peer_event e = blankEvent;
+    e.eventType = TR_PEER_CLIENT_GOT_PORT;
+    e.port = port;
     publish( msgs, &e );
 }
@@ -1060 +1069 @@
     /* get peer's listening port */
     if( tr_bencDictFindInt( &val, "p", &i ) ) {
-        msgs->peer->port = htons( (uint16_t)i );
-        dbgmsg( msgs, "msgs->port is now %hu", msgs->peer->port );
+        fireClientGotPort( msgs, (tr_port)i );
+        dbgmsg( msgs, "peer's port is now %d", (int)i );
     }
 
@@ -1456 +1465 @@
             tr_peerIoReadUint16( msgs->peer->io, inbuf, &msgs->peer->dht_port );
             if( msgs->peer->dht_port > 0 )
-                tr_dhtAddNode( getSession(msgs), &msgs->peer->addr, msgs->peer->dht_port, 0 );
+                tr_dhtAddNode( getSession(msgs),
+                               tr_peerAddress( msgs->peer ),
+                               msgs->peer->dht_port, 0 );
             break;