|
|
@ -173,7 +173,9 @@ static void livesync_handle_peersync( ssize_t datalen ) {
|
|
|
|
off += sizeof( ot_hash ) + sizeof( ot_peer );
|
|
|
|
off += sizeof( ot_hash ) + sizeof( ot_peer );
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
stats_issue_event(EVENT_SYNC, 0, datalen / ((ssize_t)sizeof( ot_hash ) + (ssize_t)sizeof( ot_peer )));
|
|
|
|
stats_issue_event(EVENT_SYNC, 0,
|
|
|
|
|
|
|
|
(datalen - sizeof( g_tracker_id ) - sizeof( uint32_t ) ) /
|
|
|
|
|
|
|
|
((ssize_t)sizeof( ot_hash ) + (ssize_t)sizeof( ot_peer )));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
#ifdef WANT_SYNC_SCRAPE
|
|
|
|
#ifdef WANT_SYNC_SCRAPE
|
|
|
@ -386,7 +388,7 @@ static void * livesync_worker( void * args ) {
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
switch( uint32_read_big( (char*)g_inbuffer ) ) {
|
|
|
|
switch( uint32_read_big( sizeof( g_tracker_id ) + (char*)g_inbuffer ) ) {
|
|
|
|
case OT_SYNC_PEER:
|
|
|
|
case OT_SYNC_PEER:
|
|
|
|
livesync_handle_peersync( datalen );
|
|
|
|
livesync_handle_peersync( datalen );
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|