Changeset 3285
- Timestamp:
- Oct 4, 2007, 8:31:19 PM (15 years ago)
- Location:
- trunk/libtransmission
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/libtransmission/handshake.c
r3272 r3285 577 577 uint8_t reserved[HANDSHAKE_FLAGS_LEN]; 578 578 uint8_t hash[SHA_DIGEST_LENGTH]; 579 char * client; 579 580 580 581 /* FIXME: use readHandshake here */ … … 667 668 tr_peerIoSetPeersId( handshake->io, handshake->peer_id ); 668 669 handshake->havePeerID = TRUE; 669 dbgmsg( handshake, "peer-id is [%s]", tr_clientForId(handshake->peer_id) ); 670 client = tr_clientForId( handshake->peer_id ); 671 dbgmsg( handshake, "peer-id is [%s]", client ); 672 tr_free( client ); 670 673 if( !memcmp( handshake->peer_id, getPeerId(), PEER_ID_LEN ) ) { 671 674 dbgmsg( handshake, "streuth! we've connected to ourselves." ); -
trunk/libtransmission/peer-mgr.c
r3280 r3285 405 405 tr_ptrArrayFree( t->pool, (PtrArrayForeachFunc)tr_free ); 406 406 tr_ptrArrayFree( t->outgoingHandshakes, NULL ); 407 tr_ptrArrayFree( t->peers, NULL ); 407 408 408 409 tr_free( t ); -
trunk/libtransmission/tracker.c
r3284 r3285 738 738 torrentIsRunning( const Torrent * tor ) 739 739 { 740 return ( tor != NULL ) 741 && ( tor->lastRequest != NULL ) 742 && ( strcmp( tor->lastRequest, "stopped" ) ); 740 return tor && tor->isRunning; 743 741 } 744 742 … … 841 839 static int onReannounceNow( void * vtor ); 842 840 843 static void 844 onTrackerResponse( struct evhttp_request * req, void * vtor ) 841 struct response_user_data 842 { 843 tr_handle * handle; 844 uint8_t hash[SHA_DIGEST_LENGTH]; 845 }; 846 847 static struct response_user_data* 848 onTrackerResponseDataNew( Torrent * tor ) 849 { 850 struct response_user_data * data = tr_new( struct response_user_data, 1 ); 851 data->handle = tor->tracker->handle; 852 memcpy( data->hash, tor->hash, SHA_DIGEST_LENGTH ); 853 return data; 854 } 855 856 static void 857 onTrackerResponse( struct evhttp_request * req, void * vdata ) 845 858 { 846 859 char * errmsg; 847 Torrent * tor = (Torrent *) vtor;848 const int isStopped = !torrentIsRunning( tor );860 Torrent * tor; 861 int isStopped; 849 862 int reannounceInterval; 863 struct response_user_data * data; 864 tr_torrent * t; 865 866 data = vdata; 867 t = tr_torrentFindFromHash( data->handle, data->hash ); 868 tr_free( data ); 869 if( t == NULL ) /* torrent has been closed */ 870 return; 871 872 tor = t->tracker; 873 isStopped = !torrentIsRunning( tor ); 850 874 851 875 tr_inf( "Torrent \"%s\" tracker response: %s", … … 977 1001 t->lastRequest = tr_strdup( eventName ); 978 1002 evhttp_connection_set_timeout( evcon, REQ_TIMEOUT_INTERVAL_SEC ); 979 httpReq = evhttp_request_new( onTrackerResponse, t);1003 httpReq = evhttp_request_new( onTrackerResponse, onTrackerResponseDataNew(t) ); 980 1004 addCommonHeaders( t->tracker, httpReq ); 981 1005 tr_evhttp_make_request( t->tracker->handle, evcon, -
trunk/libtransmission/utils.c
r3164 r3285 686 686 } 687 687 688 void tr_free( void * p ) 688 void 689 tr_free( void * p ) 689 690 { 690 691 if( p )
Note: See TracChangeset
for help on using the changeset viewer.