Ignore:
Timestamp:
Dec 22, 2008, 12:52:44 AM (12 years ago)
Author:
charles
Message:

(trunk libT) minor cleanups found while diffing for backport to 1.4x in r7455

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/libtransmission/peer-mgr.c

    r7448 r7456  
    199199
    200200static int
    201 handshakeCompareToAddr( const void * va,
    202                         const void * vb )
     201handshakeCompareToAddr( const void * va, const void * vb )
    203202{
    204203    const tr_handshake * a = va;
     
    208207
    209208static int
    210 handshakeCompare( const void * a,
    211                   const void * b )
     209handshakeCompare( const void * a, const void * b )
    212210{
    213211    return handshakeCompareToAddr( a, tr_handshakeGetAddr( b, NULL ) );
     
    535533
    536534tr_bool
    537 tr_peerMgrPeerIsSeed( const tr_peerMgr   * mgr,
    538                       const uint8_t      * torrentHash,
    539                       const tr_address   * addr )
     535tr_peerMgrPeerIsSeed( const tr_peerMgr  * mgr,
     536                      const uint8_t     * torrentHash,
     537                      const tr_address  * addr )
    540538{
    541539    tr_bool isSeed = FALSE;
     
    633631
    634632static tr_piece_index_t *
    635 getPreferredPieces( Torrent * t, tr_piece_index_t  * pieceCount )
     633getPreferredPieces( Torrent * t, tr_piece_index_t * pieceCount )
    636634{
    637635    const tr_torrent  * tor = t->tor;
     
    831829        for( j=0; !handled && j<peerCount; )
    832830        {
    833             const tr_addreq_t val = tr_peerMsgsAddRequest( peers[j]->msgs, index, offset, length, FALSE );
     831            const tr_addreq_t val = tr_peerMsgsAddRequest( peers[j]->msgs, index, offset, length );
    834832            switch( val )
    835833            {
     
    858856        for( j=0; !handled && j<webseedCount; )
    859857        {
    860             const tr_addreq_t val = tr_webseedAddRequest( webseeds[j],
    861                                                           index, offset, length );
     858            const tr_addreq_t val = tr_webseedAddRequest( webseeds[j], index, offset, length );
    862859            switch( val )
    863860            {
     
    942939
    943940static void
    944 peerSuggestedPiece( Torrent            * t,
    945                     tr_peer            * peer,
    946                     tr_piece_index_t     pieceIndex,
    947                     int                  isFastAllowed )
    948 {
     941peerSuggestedPiece( Torrent            * t UNUSED,
     942                    tr_peer            * peer UNUSED,
     943                    tr_piece_index_t     pieceIndex UNUSED,
     944                    int                  isFastAllowed UNUSED )
     945{
     946#if 0
    949947    assert( t );
    950948    assert( peer );
     
    980978                const uint32_t offset = getBlockOffsetInPiece( tor, block );
    981979                const uint32_t length = tr_torBlockCountBytes( tor, block );
    982                 tr_peerMsgsAddRequest( peer->msgs, pieceIndex, offset, length, TRUE );
     980                tr_peerMsgsAddRequest( peer->msgs, pieceIndex, offset, length );
    983981                incrementPieceRequests( t, pieceIndex );
    984982            }
    985983        }
    986984    }
     985#endif
    987986}
    988987
    989988static void
    990 peerCallbackFunc( void * vpeer,
    991                   void * vevent,
    992                   void * vt )
    993 {
    994     tr_peer             * peer = vpeer; /* may be NULL if peer is a webseed */
    995     Torrent             * t = vt;
     989peerCallbackFunc( void * vpeer, void * vevent, void * vt )
     990{
     991    tr_peer * peer = vpeer; /* may be NULL if peer is a webseed */
     992    Torrent * t = vt;
    996993    const tr_peer_event * e = vevent;
    997994
     
    12041201/* FIXME: this is kind of a mess. */
    12051202static tr_bool
    1206 myHandshakeDoneCB( tr_handshake  *  handshake,
     1203myHandshakeDoneCB( tr_handshake  * handshake,
    12071204                   tr_peerIo     * io,
    12081205                   int             isConnected,
     
    13441341}
    13451342
    1346 static int
     1343static tr_bool
    13471344tr_isPex( const tr_pex * pex )
    13481345{
     
    13611358        managerLock( manager );
    13621359
    1363 
    13641360        t = getExistingTorrent( manager, torrentHash );
    13651361        if( !tr_sessionIsAddressBlocked( t->manager->session, &pex->addr ) )
    13661362            ensureAtomExists( t, &pex->addr, pex->port, pex->flags, from );
    1367    
     1363
    13681364        managerUnlock( manager );
    13691365    }
     
    15391535            {
    15401536                const struct peer_atom * atom = getExistingAtom( t, &peer->addr );
     1537
    15411538                assert( tr_isAddress( &peer->addr ) );
    15421539                walk->addr = peer->addr;
     
    15451542                if( peerPrefersCrypto( peer ) )
    15461543                    walk->flags |= ADDED_F_ENCRYPTION_FLAG;
    1547                 if( ( atom->uploadOnly == UPLOAD_ONLY_YES ) ||
    1548                     ( peer->progress >= 1.0 ) )
     1544                if( ( atom->uploadOnly == UPLOAD_ONLY_YES ) || ( peer->progress >= 1.0 ) )
    15491545                    walk->flags |= ADDED_F_SEED_FLAG;
    15501546                ++peersReturning;
     
    15551551        assert( ( walk - pex ) == peersReturning );
    15561552        qsort( pex, peersReturning, sizeof( tr_pex ), tr_pexCompare );
    1557 
    15581553        *setme_pex = pex;
    15591554    }
     
    16781673    const tr_torrent * tor;
    16791674    float              interval;
    1680     int                isSeed;
     1675    tr_bool            isSeed;
    16811676    int                peerCount;
    16821677    const tr_peer **   peers;
     
    16981693        if( isSeed || tr_cpPieceIsComplete( tor->completion, piece ) )
    16991694            tab[i] = -1;
    1700         else if( peerCount )
    1701         {
     1695        else if( peerCount ) {
    17021696            int j;
    17031697            for( j = 0; j < peerCount; ++j )
     
    18021796    webseeds = (const tr_webseed **) tr_ptrArrayPeek( t->webseeds, &size );
    18031797    for( i=0; i<size; ++i )
    1804     {
    18051798        if( tr_webseedIsActive( webseeds[i] ) )
    18061799            ++*setmeWebseedsSendingToUs;
    1807     }
    18081800
    18091801    managerUnlock( manager );
     
    18721864        tr_address               norm_addr;
    18731865
    1874         memcpy( &norm_addr, &peer->addr, sizeof( tr_address ) );
     1866        norm_addr = peer->addr;
    18751867        tr_normalizeV4Mapped( &norm_addr );
    18761868        tr_ntop( &norm_addr, stat->addr, sizeof( stat->addr ) );
     
    20482040    }
    20492041
    2050     for( i = 0; i < size; ++i )
     2042    for( i=0; i<size; ++i )
    20512043        tr_peerMsgsSetChoke( choke[i].peer->msgs, !choke[i].doUnchoke );
    20522044
     
    21052097            tr_bitfieldFree( tmp );
    21062098        }
    2107         if( peerHasEverything && ( !tr_torrentAllowsPex(tor) || (now-atom->time>=30 ))) {
     2099
     2100        if( peerHasEverything && ( !tr_torrentAllowsPex(tor) || (now-atom->time>=30 )))
     2101        {
    21082102            tordbg( t, "purging peer %s because we're both seeds",
    2109                    tr_peerIoAddrStr( &atom->addr, atom->port ) );
     2103                    tr_peerIoAddrStr( &atom->addr, atom->port ) );
    21102104            return TRUE;
    21112105        }
     
    23032297        if( nBad || nCandidates )
    23042298            tordbg( t, "reconnect pulse for [%s]: %d bad connections, "
    2305                    "%d connection candidates, %d atoms, max per pulse is %d",
    2306                    t->tor->info.name, nBad, nCandidates,
    2307                    tr_ptrArraySize( t->pool ),
    2308                    (int)MAX_RECONNECTIONS_PER_PULSE );
     2299                    "%d connection candidates, %d atoms, max per pulse is %d",
     2300                    t->tor->info.name, nBad, nCandidates,
     2301                    tr_ptrArraySize( t->pool ),
     2302                    (int)MAX_RECONNECTIONS_PER_PULSE );
    23092303
    23102304        /* disconnect some peers.
     
    23192313            else
    23202314                ++atom->numFails;
    2321              
    23222315            tordbg( t, "removing bad peer %s", tr_peerIoGetAddrStr( peer->io ) );
    23232316            removePeer( t, peer );
Note: See TracChangeset for help on using the changeset viewer.