- long delay = enqueueEntry(new ConnectionEntry(request, callback, now), now);
- try {
- if (delay >= DEBUG_DELAY_NANOS) {
- if (delay > MAX_DELAY_NANOS) {
- LOG.info("Capping {} throttle delay from {} to {} seconds", this,
- TimeUnit.NANOSECONDS.toSeconds(delay), MAX_DELAY_SECONDS);
- delay = MAX_DELAY_NANOS;
- }
- if (LOG.isDebugEnabled()) {
- LOG.debug("Sleeping for {}ms", TimeUnit.NANOSECONDS.toMillis(delay));
- }
- }
- TimeUnit.NANOSECONDS.sleep(delay);
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- LOG.debug("Interrupted after sleeping {}ns", e, currentTime() - now);
- }
+ sendEntry(new ConnectionEntry(request, callback, now), now);