Searched refs:sourceIds (Results 1 – 2 of 2) sorted by relevance
67 private int[] sourceIds; field in SampleQueue115 sourceIds = new int[capacity]; in SampleQueue()238 return hasNextSample() ? sourceIds[relativeReadIndex] : upstreamSourceId; in peekSourceId()697 sourceIds[relativeEndIndex] = upstreamSourceId; in commitSample()718 System.arraycopy(sourceIds, relativeFirstIndex, newSourceIds, 0, beforeWrap); in commitSample()726 System.arraycopy(sourceIds, 0, newSourceIds, beforeWrap, afterWrap); in commitSample()733 sourceIds = newSourceIds; in commitSample()
268 Set<String> sourceIds = in addConfiguredDirectory() local270 if (!ids.containsAll(sourceIds)) { in addConfiguredDirectory()271 Set<String> missingIds = Sets.difference(sourceIds, ids); in addConfiguredDirectory()