Searched refs:retries (Results 1 – 2 of 2) sorted by relevance
413 BufferedSubscription<T> retries = null, rtail = null, next; in doOffer() local420 retries = b; in doOffer()431 if (retries != null || cleanMe) in doOffer()432 lag = retryOffer(item, nanos, onDrop, retries, lag, cleanMe); in doOffer()449 BufferedSubscription<T> retries, int lag, in retryOffer() argument451 for (BufferedSubscription<T> r = retries; r != null;) { in retryOffer()
456 int retries = -1; in openFiles() local458 while (channel == null && retries++ < 1) { in openFiles()