Searched refs:mFillRequests (Results 1 – 2 of 2) sorted by relevance
245 private final BlockingQueue<AugmentedFillRequest> mFillRequests = field in AugmentedReplier287 request = mFillRequests.poll(AUGMENTED_FILL_TIMEOUT.ms(), TimeUnit.MILLISECONDS); in getNextFillRequest()304 if (mFillRequests.isEmpty()) return; // Good job, test case! in assertNoUnhandledFillRequests()309 + "but logging just in case: " + mFillRequests); in assertNoUnhandledFillRequests()314 throw new AssertionError(mFillRequests.size() + " unhandled fill requests: " in assertNoUnhandledFillRequests()315 + mFillRequests); in assertNoUnhandledFillRequests()322 return mFillRequests.size(); in getNumberUnhandledFillRequests()330 mFillRequests.clear(); in reset()341 Helper.offer(mFillRequests, myRequest, AUGMENTED_CONNECTION_TIMEOUT.ms()); in handleOnFillRequest()
483 private final BlockingQueue<FillRequest> mFillRequests = new LinkedBlockingQueue<>(); field in Replier569 request = mFillRequests.poll(FILL_TIMEOUT.ms(), TimeUnit.MILLISECONDS); in getNextFillRequest()589 assertThat(mFillRequests).isEmpty(); in assertOnFillRequestNotCalled()599 if (mFillRequests.isEmpty()) return; // Good job, test case! in assertNoUnhandledFillRequests()604 + "but logging just in case: " + mFillRequests); in assertNoUnhandledFillRequests()609 throw new AssertionError(mFillRequests.size() + " unhandled fill requests: " in assertNoUnhandledFillRequests()610 + mFillRequests); in assertNoUnhandledFillRequests()617 return mFillRequests.size(); in getNumberUnhandledFillRequests()670 mFillRequests.clear(); in reset()779 Helper.offer(mFillRequests, in onFillRequest()[all …]