static void
tau_scrape_request_free( struct tau_scrape_request * req )
{
- tr_free( req->payload );
tr_free( req->response.errmsg );
tr_free( req->response.url );
+ tr_free( req->payload );
tr_free( req );
}
}
static void
-on_scrape_response( tr_session * session,
- struct tau_scrape_request * request,
- tau_action_t action,
- struct evbuffer * buf )
+on_scrape_response( tr_session * session,
+ struct tau_scrape_request * request,
+ tau_action_t action,
+ struct evbuffer * buf )
{
request->response.did_connect = true;
request->response.did_timeout = false;
}
static void
-on_announce_response( tr_session * session,
- struct tau_announce_request * request,
- tau_action_t action,
- struct evbuffer * buf )
+on_announce_response( tr_session * session,
+ struct tau_announce_request * request,
+ tau_action_t action,
+ struct evbuffer * buf )
{
+ const size_t buflen = evbuffer_get_length( buf );
+
request->response.did_connect = true;
request->response.did_timeout = false;
- if( ( action == TAU_ACTION_ANNOUNCE )
- && ( evbuffer_get_length( buf ) >= 3*sizeof(uint32_t) ) )
+ if( ( action == TAU_ACTION_ANNOUNCE ) && ( buflen >= 3*sizeof(uint32_t) ) )
{
tr_announce_response * resp = &request->response;
resp->interval = evbuffer_read_ntoh_32( buf );
else
{
char * errmsg;
- const size_t buflen = evbuffer_get_length( buf );
if( ( action == TAU_ACTION_ERROR ) && ( buflen > 0 ) )
errmsg = tr_strndup( evbuffer_pullup( buf, -1 ), buflen );
tr_ptrArray * reqs;
const time_t now = tr_time( );
- assert( tracker->is_asking_dns == 0 );
+ assert( tracker->is_asking_dns == false );
assert( tracker->connecting_at == 0 );
assert( tracker->addr != NULL );
assert( tracker->connection_expiration_time > now );
dbgmsg( tracker->key, "sending scrape req %p", req );
req->sent_at = now;
tau_tracker_send_request( tracker, req->payload, req->payload_len );
- if( req->callback == NULL) {
+ if( req->callback == NULL ) {
tau_scrape_request_free( req );
tr_ptrArrayRemove( reqs, i );
--i;
}
static bool
-tau_tracker_is_empty( const struct tau_tracker * tracker )
+tau_tracker_is_idle( const struct tau_tracker * tracker )
{
return tr_ptrArrayEmpty( &tracker->announces )
&& tr_ptrArrayEmpty( &tracker->scrapes );
}
/* are there any requests pending? */
- if( tau_tracker_is_empty( tracker ) )
+ if( tau_tracker_is_idle( tracker ) )
return;
/* if we don't have an address yet, try & get one now. */
}
bool
-tr_tracker_udp_is_empty( const tr_session * session )
+tr_tracker_udp_is_idle( const tr_session * session )
{
int i;
int n;
if( tau != NULL )
for( i=0, n=tr_ptrArraySize(&tau->trackers); i<n; ++i )
- if( !tau_tracker_is_empty( tr_ptrArrayNth( &tau->trackers, i ) ) )
+ if( !tau_tracker_is_idle( tr_ptrArrayNth( &tau->trackers, i ) ) )
return false;
return true;