- IOException x = new IOException("DEBUG timeout");
- LOG.warn("Blocked too long (please report!!!) "+this, x);
- _state=x;
+ // Wait a little bit longer than expected callback idle timeout
+ if (!_complete.await(idle+idle/2,TimeUnit.MILLISECONDS))
+ // The callback has not arrived in sufficient time.
+ // We will synthesize a TimeoutException
+ _state=new BlockerTimeoutException();