Searched refs:mFuturesQueue (Results 1 – 2 of 2) sorted by relevance
157 private final LinkedBlockingQueue<SettableFuture<Byte>> mFuturesQueue = field in AttributionSourceService.AttributionSourceServiceConnection.ReplyHandler170 if (!mFuturesQueue.offer(report)) { in addFuture()181 SettableFuture<Byte> task = mFuturesQueue.poll(); in handleMessage()
375 private final LinkedBlockingQueue<SettableFuture<List<LogEvent>>> mFuturesQueue = field in ErrorLoggingService.ErrorServiceConnection.ReplyHandler387 mFuturesQueue.drainTo(logFutures); in cancelAll()399 mFuturesQueue.remove(report); in cancel()409 if (!mFuturesQueue.offer(report)) { in addFuture()419 SettableFuture<List<LogEvent>> task = mFuturesQueue.poll(); in handleMessage()