470471472473474475476477478479480
} } while( pending_check_num > 0 ){ pending_checks_sem.reserve(); pending_check_num--; } if ( partialPieces != null ){
619620621622623624625626627628629
} } while( pending_check_num > 0 ){ pending_checks_sem.reserve(); pending_check_num--; } }
759760761762763764765766767768769
long bytes ) { } }); sem.reserve(); } } } } }finally{
954955956957958959960961962963964
}); con.connect(); sem.reserve(); Thread.sleep( 1000 ); } }catch( Throwable e ){
617618619620621622623624625626627
try{ services[i].initiateCheck( 60000 ); sem.reserve( 60000 ); }finally{ services[i].removeListener( listener ); }
681682683684685686687688689690691
sem.release(); } }); sem.reserve( 60000 ); return( res[0] ); }
247248249250251252253254255256257
} } }.start(); while( !done_sem.reserve( 60*1000 )){ if ( add_file_install_dispatcher.getQueueSize() > 0 ){ Debug.out( "File plugin install operation queued pending completion of previous" ); }
146147148149150151152153154155156
} }); if ( wait_until_done ){ sem.reserve(); if ( error[0] != null ){ throw( error[0] ); }
563564565566567568569570571572573
sendBeacon(); } }); }else{ start_sem.reserve( 5000 ); sendBeacon(); } log( "Initiated device search" );
268269270271272273274275276277278
error[0] = new NetworkAdminException( "Connect failed", e ); sem.release(); } if ( !sem.reserve(10000)){ result[0] = RES_CONNECT_FAILED; error[0] = new NetworkAdminException( "Connect timeout" ); }