Changeset 7614 for trunk/libtransmission/peer-mgr.c
- Timestamp:
- Jan 4, 2009, 4:59:15 PM (12 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/libtransmission/peer-mgr.c
r7597 r7614 620 620 assert( torrentIsLocked( t ) ); 621 621 622 peers = (const tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );623 peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );622 peers = (const tr_peer**) tr_ptrArrayBase( &t->peers ); 623 peerCount = tr_ptrArraySize( &t->peers ); 624 624 625 625 /* make a list of the pieces that we want but don't have */ … … 791 791 peers = getPeersUploadingToClient( t, &peerCount ); 792 792 webseedCount = tr_ptrArraySize( &t->webseeds ); 793 webseeds = tr_memdup( TR_PTR_ARRAY_DATA( &t->webseeds ),793 webseeds = tr_memdup( tr_ptrArrayBase( &t->webseeds ), 794 794 webseedCount * sizeof( tr_webseed* ) ); 795 795 … … 874 874 tordbg( t, "got a block; cancelling any duplicate requests from peers %"PRIu32":%"PRIu32"->%"PRIu32, index, offset, length ); 875 875 876 peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );877 peers = (tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );876 peerCount = tr_ptrArraySize( &t->peers ); 877 peers = (tr_peer**) tr_ptrArrayBase( &t->peers ); 878 878 for( i=0; i<peerCount; ++i ) 879 879 if( peers[i]->msgs ) … … 1104 1104 { 1105 1105 int i; 1106 int peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );1107 tr_peer ** peers = (tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );1106 int peerCount = tr_ptrArraySize( &t->peers ); 1107 tr_peer ** peers = (tr_peer**) tr_ptrArrayBase( &t->peers ); 1108 1108 for( i=0; i<peerCount; ++i ) 1109 1109 tr_peerMsgsHave( peers[i]->msgs, p ); … … 1502 1502 { 1503 1503 int i; 1504 const tr_peer ** peers = (const tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );1505 const int peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );1504 const tr_peer ** peers = (const tr_peer**) tr_ptrArrayBase( &t->peers ); 1505 const int peerCount = tr_ptrArraySize( &t->peers ); 1506 1506 /* for now, this will waste memory on torrents that have both 1507 1507 * ipv6 and ipv4 peers */ … … 1662 1662 interval = tor->info.pieceCount / (float)tabCount; 1663 1663 isSeed = tor && ( tr_cpGetStatus ( &tor->completion ) == TR_SEED ); 1664 peers = (const tr_peer **) TR_PTR_ARRAY_DATA( &t->peers );1665 peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );1664 peers = (const tr_peer **) tr_ptrArrayBase( &t->peers ); 1665 peerCount = tr_ptrArraySize( &t->peers ); 1666 1666 1667 1667 memset( tab, 0, tabCount ); … … 1698 1698 t = getExistingTorrent( (tr_peerMgr*)manager, torrentHash ); 1699 1699 pieces = tr_bitfieldNew( t->tor->info.pieceCount ); 1700 peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );1701 peers = (const tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );1700 peerCount = tr_ptrArraySize( &t->peers ); 1701 peers = (const tr_peer**) tr_ptrArrayBase( &t->peers ); 1702 1702 for( i=0; i<peerCount; ++i ) 1703 1703 tr_bitfieldOr( pieces, peers[i]->have ); … … 1741 1741 1742 1742 t = getExistingTorrent( (tr_peerMgr*)manager, torrentHash ); 1743 peers = (const tr_peer **) TR_PTR_ARRAY_DATA( &t->peers );1744 size = TR_PTR_ARRAY_LENGTH( &t->peers );1743 peers = (const tr_peer **) tr_ptrArrayBase( &t->peers ); 1744 size = tr_ptrArraySize( &t->peers ); 1745 1745 1746 1746 *setmePeersKnown = tr_ptrArraySize( &t->pool ); … … 1776 1776 } 1777 1777 1778 webseeds = (const tr_webseed**) TR_PTR_ARRAY_DATA( &t->webseeds );1779 size = TR_PTR_ARRAY_LENGTH( &t->webseeds );1778 webseeds = (const tr_webseed**) tr_ptrArrayBase( &t->webseeds ); 1779 size = tr_ptrArraySize( &t->webseeds ); 1780 1780 for( i=0; i<size; ++i ) 1781 1781 if( tr_webseedIsActive( webseeds[i] ) ) … … 1799 1799 1800 1800 t = getExistingTorrent( (tr_peerMgr*)manager, torrentHash ); 1801 webseeds = (const tr_webseed**) TR_PTR_ARRAY_DATA( &t->webseeds );1802 webseedCount = TR_PTR_ARRAY_LENGTH( &t->webseeds );1801 webseeds = (const tr_webseed**) tr_ptrArrayBase( &t->webseeds ); 1802 webseedCount = tr_ptrArraySize( &t->webseeds ); 1803 1803 assert( webseedCount == t->tor->info.webseedCount ); 1804 1804 ret = tr_new0( float, webseedCount ); … … 1833 1833 1834 1834 t = getExistingTorrent( (tr_peerMgr*)manager, torrentHash ); 1835 size = TR_PTR_ARRAY_LENGTH( &t->peers );1836 peers = (const tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );1835 size = tr_ptrArraySize( &t->peers ); 1836 peers = (const tr_peer**) tr_ptrArrayBase( &t->peers ); 1837 1837 ret = tr_new0( tr_peer_stat, size ); 1838 1838 … … 1934 1934 { 1935 1935 int i, size, unchokedInterested; 1936 const int peerCount = TR_PTR_ARRAY_LENGTH( &t->peers );1937 tr_peer ** peers = (tr_peer**) TR_PTR_ARRAY_DATA( &t->peers );1936 const int peerCount = tr_ptrArraySize( &t->peers ); 1937 tr_peer ** peers = (tr_peer**) tr_ptrArrayBase( &t->peers ); 1938 1938 struct ChokeData * choke = tr_new0( struct ChokeData, peerCount ); 1939 1939 const int chokeAll = !tr_torrentIsPieceTransferAllowed( t->tor, TR_CLIENT_TO_PEER );
Note: See TracChangeset
for help on using the changeset viewer.