17121713171417151716171717181719172017211722
} } }, 5000, PRUDPPacketHandler.PRIORITY_HIGH ); sem.reserve( 5000 ); return( result[0] ); }catch( Throwable e ){
24112412241324142415241624172418241924202421
sem.release(); } }); sem.reserve(); return( res[0] ); } // read request
33743375337633773378337933803381338233833384
this_mon.exit(); } writeTransfer( listener, target, handler_key, call_key, data, timeout ); if ( call_sem.reserve( timeout )){ try{ this_mon.enter(); Object res = call_transfers.remove( wrapped_key );
232233234235236237238239240241242
}.start(); } for (int i=0;i<num_threads;i++){ sem.reserve(); } listener.log( "Searching complete, " + ok[0] + " targets found" ); } }else{
355356357358359360361362363364365
return( null ); } }); sem.reserve(); if ( listener != null ){ listener.resultsComplete( this ); }
435436437438439440441442443444445
}; try{ addListener( listener ); xcode_sem.reserve(); }finally{ removeListener( listener ); }
13391340134113421343134413451346134713481349
}; try{ addListener( analysis_q_listener ); analysis_sem.reserve(); }finally{ removeListener( analysis_q_listener ); }
868869870871872873874875876877878
}.start(); } for (int i=0;i<to_do.size();i++){ sem.reserve(); } } for ( String excess: existing_checked ){
803804805806807808809810811812813
while( remaining > 0 ){ long wait_start = SystemTime.getMonotonousTime(); boolean got_sem = potential_contacts_sem.reserve( 1000 ); long now = SystemTime.getMonotonousTime(); remaining -= ( now - wait_start );
266267268269270271272273274275276
} } } }); sem.reserve(); action_listener.actionComplete( result[0] ); return( result[0] instanceof Boolean );