Changeset 12237
- Timestamp:
- Mar 26, 2011, 10:22:25 AM (12 years ago)
- Location:
- trunk/libtransmission
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/libtransmission/announcer-udp.c
r12226 r12237 195 195 tau_scrape_request_free( struct tau_scrape_request * req ) 196 196 { 197 tr_free( req->payload );198 197 tr_free( req->response.errmsg ); 199 198 tr_free( req->response.url ); 199 tr_free( req->payload ); 200 200 tr_free( req ); 201 201 } … … 223 223 224 224 static void 225 on_scrape_response( tr_session 226 227 228 225 on_scrape_response( tr_session * session, 226 struct tau_scrape_request * request, 227 tau_action_t action, 228 struct evbuffer * buf ) 229 229 { 230 230 request->response.did_connect = true; … … 378 378 379 379 static void 380 on_announce_response( tr_session * session, 381 struct tau_announce_request * request, 382 tau_action_t action, 383 struct evbuffer * buf ) 384 { 380 on_announce_response( tr_session * session, 381 struct tau_announce_request * request, 382 tau_action_t action, 383 struct evbuffer * buf ) 384 { 385 const size_t buflen = evbuffer_get_length( buf ); 386 385 387 request->response.did_connect = true; 386 388 request->response.did_timeout = false; 387 389 388 if( ( action == TAU_ACTION_ANNOUNCE ) 389 && ( evbuffer_get_length( buf ) >= 3*sizeof(uint32_t) ) ) 390 if( ( action == TAU_ACTION_ANNOUNCE ) && ( buflen >= 3*sizeof(uint32_t) ) ) 390 391 { 391 392 tr_announce_response * resp = &request->response; … … 402 403 { 403 404 char * errmsg; 404 const size_t buflen = evbuffer_get_length( buf );405 405 406 406 if( ( action == TAU_ACTION_ERROR ) && ( buflen > 0 ) ) … … 532 532 const time_t now = tr_time( ); 533 533 534 assert( tracker->is_asking_dns == 0);534 assert( tracker->is_asking_dns == false ); 535 535 assert( tracker->connecting_at == 0 ); 536 536 assert( tracker->addr != NULL ); … … 560 560 req->sent_at = now; 561 561 tau_tracker_send_request( tracker, req->payload, req->payload_len ); 562 if( req->callback == NULL ) {562 if( req->callback == NULL ) { 563 563 tau_scrape_request_free( req ); 564 564 tr_ptrArrayRemove( reqs, i ); … … 646 646 647 647 static bool 648 tau_tracker_is_ empty( const struct tau_tracker * tracker )648 tau_tracker_is_idle( const struct tau_tracker * tracker ) 649 649 { 650 650 return tr_ptrArrayEmpty( &tracker->announces ) … … 665 665 666 666 /* are there any requests pending? */ 667 if( tau_tracker_is_ empty( tracker ) )667 if( tau_tracker_is_idle( tracker ) ) 668 668 return; 669 669 … … 805 805 806 806 bool 807 tr_tracker_udp_is_ empty( const tr_session * session )807 tr_tracker_udp_is_idle( const tr_session * session ) 808 808 { 809 809 int i; … … 813 813 if( tau != NULL ) 814 814 for( i=0, n=tr_ptrArraySize(&tau->trackers); i<n; ++i ) 815 if( !tau_tracker_is_ empty( tr_ptrArrayNth( &tau->trackers, i ) ) )815 if( !tau_tracker_is_idle( tr_ptrArrayNth( &tau->trackers, i ) ) ) 816 816 return false; 817 817 -
trunk/libtransmission/announcer.h
r12204 r12237 113 113 void tr_tracker_udp_close( tr_session * session ); 114 114 115 bool tr_tracker_udp_is_ empty( const tr_session * session );115 bool tr_tracker_udp_is_idle( const tr_session * session ); 116 116 117 117 -
trunk/libtransmission/session.c
r12229 r12237 1773 1773 /* gotta keep udp running long enough to send out all 1774 1774 the &event=stopped UDP tracker messages */ 1775 while( !tr_tracker_udp_is_ empty( session ) ) {1775 while( !tr_tracker_udp_is_idle( session ) ) { 1776 1776 tr_tracker_udp_upkeep( session ); 1777 1777 tr_wait_msec( 100 );
Note: See TracChangeset
for help on using the changeset viewer.