Changeset 13947

Timestamp:

Feb 3, 2013, 10:40:00 PM (8 years ago)

Author:

jordan

Message:

(libT) move the tr_peer declaration from peer-mgr.h to peer-common.h

Location:

trunk/libtransmission

Files:

• peer-common.h (modified) (2 diffs)
• peer-mgr.h (modified) (2 diffs)
• peer-msgs.c (modified) (2 diffs)

trunk/libtransmission/peer-common.h

@@ -28 +28 @@
 
 #include "transmission.h"
-
-struct tr_bitfield;
+#include "bitfield.h"
+#include "history.h"
+#include "quark.h"
 
 enum
@@ -81 +82 @@
 extern const tr_peer_event TR_PEER_EVENT_INIT;
 
-struct tr_peer;
+/**
+ * State information about a connected peer.
+ *
+ * @see struct peer_atom
+ * @see tr_peermsgs
+ */
+typedef struct tr_peer
+{
+  /* whether or not we should free this peer soon.
+     NOTE: private to peer-mgr.c */
+  bool doPurge;
+
+  /* Whether or not we've choked this peer.
+     Only applies to BitTorrent peers */
+  bool peerIsChoked;
+
+  /* whether or not the peer has indicated it will download from us.
+     Only applies to BitTorrent peers */
+  bool peerIsInterested;
+
+  /* whether or the peer is choking us.
+     Only applies to BitTorrent peers */
+  bool clientIsChoked;
+
+  /* whether or not we've indicated to the peer that we would download from them if unchoked.
+     Only applies to BitTorrent peers */
+  bool clientIsInterested;
+
+  /* number of bad pieces they've contributed to */
+  uint8_t strikes;
+
+  uint8_t encryption_preference;
+
+  /* how many requests the peer has made that we haven't responded to yet */
+  int pendingReqsToClient;
+
+  /* how many requests we've made and are currently awaiting a response for */
+  int pendingReqsToPeer;
+
+  struct tr_peerIo * io;
+  struct peer_atom * atom;
+
+  /** how complete the peer's copy of the torrent is. [0.0...1.0] */
+  float progress;
+
+  struct tr_bitfield blame;
+  struct tr_bitfield have;
+
+  /* the client name.
+     For BitTorrent peers, this is the app name derived from the `v' string in LTEP's handshake dictionary */
+  tr_quark client;
+
+  time_t chokeChangedAt;
+
+  tr_recentHistory blocksSentToClient;
+  tr_recentHistory blocksSentToPeer;
+
+  tr_recentHistory cancelsSentToClient;
+  tr_recentHistory cancelsSentToPeer;
+
+  struct tr_peermsgs * msgs;
+}
+tr_peer;
 
 typedef void tr_peer_callback (struct tr_peer       * peer,

trunk/libtransmission/peer-mgr.h

@@ -24 +24 @@
 #endif
 
-#include "bitfield.h"
-#include "history.h"
 #include "net.h" /* tr_address */
-#include "peer-common.h" /* struct peer_request */
+#include "peer-common.h"
 #include "quark.h"
 
@@ -81 +79 @@
 /* opaque forward declaration */
 struct peer_atom;
-
-/**
- * State information about a connected peer.
- *
- * @see struct peer_atom
- * @see tr_peermsgs
- */
-typedef struct tr_peer
-{
-  bool peerIsChoked;
-  bool peerIsInterested;
-  bool clientIsChoked;
-  bool clientIsInterested;
-  bool doPurge;
-
-  /* number of bad pieces they've contributed to */
-  uint8_t strikes;
-
-  uint8_t encryption_preference;
-  tr_port dht_port;
-
-  /* how many requests the peer has made that we haven't responded to yet */
-  int pendingReqsToClient;
-
-  /* how many requests we've made and are currently awaiting a response for */
-  int pendingReqsToPeer;
-
-  struct tr_peerIo * io;
-  struct peer_atom * atom;
-
-  struct tr_bitfield blame;
-  struct tr_bitfield have;
-
-  /** how complete the peer's copy of the torrent is. [0.0...1.0] */
-  float progress;
-
-  /* the client name from the `v' string in LTEP's handshake dictionary */
-  tr_quark client;
-
-  time_t chokeChangedAt;
-
-  tr_recentHistory blocksSentToClient;
-  tr_recentHistory blocksSentToPeer;
-
-  tr_recentHistory cancelsSentToClient;
-  tr_recentHistory cancelsSentToPeer;
-
-  struct tr_peermsgs * msgs;
-}
-tr_peer;
 
 void tr_peerConstruct (struct tr_peer * peer);

trunk/libtransmission/peer-msgs.c

@@ -177 +177 @@
     uint16_t        pexCount;
     uint16_t        pexCount6;
+
+    tr_port         dht_port;
 
     size_t          metadata_size_hint;
@@ -1467 +1469 @@
         case BT_PORT:
             dbgmsg (msgs, "Got a BT_PORT");
-            tr_peerIoReadUint16 (msgs->peer->io, inbuf, &msgs->peer->dht_port);
-            if (msgs->peer->dht_port > 0)
+            tr_peerIoReadUint16 (msgs->peer->io, inbuf, &msgs->dht_port);
+            if (msgs->dht_port > 0)
                 tr_dhtAddNode (getSession (msgs),
                                tr_peerAddress (msgs->peer),
-                               msgs->peer->dht_port, 0);
+                               msgs->dht_port, 0);
             break;