112113114115116117118119120121122123
}); } } }; final DiskManagerListener disk_listener = new DiskManagerListener() { public void stateChanged( int oldState, int newState )
642643644645646647648649650651652
final AESemaphore sem = new AESemaphore( "waiter" ); final Throwable[] error = {null}; current_request.addListener( new DiskManagerListener() { private int write_pos = pos; private int rem = len; public void
433434435436437438439440441442443
}else{ using_delegate = true; delegate_request.addListener( new DiskManagerListener() { public void eventOccurred( DiskManagerEvent event ) {