| /external/guava/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 99 int concurrencyLevel = UNSET_INT; field in MapMaker
177 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
179 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
181 this.concurrencyLevel); in concurrencyLevel()
182 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
183 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
188 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
296 if (concurrencyLevel != UNSET_INT) { in toString()
297 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | Interners.java | 75 public InternerBuilder concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in Interners.InternerBuilder
76 this.mapMaker.concurrencyLevel(concurrencyLevel); in concurrencyLevel()
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 99 int concurrencyLevel = UNSET_INT; field in MapMaker
177 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
179 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
181 this.concurrencyLevel); in concurrencyLevel()
182 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
183 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
188 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
296 if (concurrencyLevel != UNSET_INT) { in toString()
297 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | Interners.java | 75 public InternerBuilder concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in Interners.InternerBuilder
76 this.mapMaker.concurrencyLevel(concurrencyLevel); in concurrencyLevel()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | InternersTest.java | 53 int concurrencyLevel = 42; in testStrong_builder() local
55 Interners.newBuilder().strong().concurrencyLevel(concurrencyLevel).build(); in testStrong_builder()
79 int concurrencyLevel = 42; in testWeak_builder() local
81 Interners.newBuilder().weak().concurrencyLevel(concurrencyLevel).build(); in testWeak_builder()
84 assertEquals(concurrencyLevel, internerImpl.map.concurrencyLevel); in testWeak_builder()
119 builder.concurrencyLevel(0); in testConcurrencyLevel_Zero()
128 builder.concurrencyLevel(-42); in testConcurrencyLevel_Negative()
|
| D | MapMakerInternalMapTest.java | 64 assertEquals(4, map.concurrencyLevel); in testDefaults()
105 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
107 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
146 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
149 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
180 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { in checkMaximumSize() argument
183 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkMaximumSize()
285 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentGetAndContains()
355 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentReplaceValue()
399 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentReplace()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | InternersTest.java | 53 int concurrencyLevel = 42; in testStrong_builder() local
55 Interners.newBuilder().strong().concurrencyLevel(concurrencyLevel).build(); in testStrong_builder()
79 int concurrencyLevel = 42; in testWeak_builder() local
81 Interners.newBuilder().weak().concurrencyLevel(concurrencyLevel).build(); in testWeak_builder()
84 assertEquals(concurrencyLevel, internerImpl.map.concurrencyLevel); in testWeak_builder()
119 builder.concurrencyLevel(0); in testConcurrencyLevel_Zero()
128 builder.concurrencyLevel(-42); in testConcurrencyLevel_Negative()
|
| D | MapMakerInternalMapTest.java | 64 assertEquals(4, map.concurrencyLevel); in testDefaults()
105 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
107 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
146 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
149 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
180 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { in checkMaximumSize() argument
183 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkMaximumSize()
285 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentGetAndContains()
355 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentReplaceValue()
399 makeMap(createMapMaker().concurrencyLevel(1).weakValues()); in testSegmentReplace()
[all …]
|
| /external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ |
| D | MapMaker.java | 42 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
44 concurrencyLevel >= 1, "concurrency level (%s) must be at least 1", concurrencyLevel); in concurrencyLevel()
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| D | OkHttpAsync.java | 43 private int concurrencyLevel; field in OkHttpAsync
47 concurrencyLevel = benchmark.concurrencyLevel; in prepare()
52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, in prepare()
53 benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()))); in prepare()
92 return requestsInFlight.get() < (concurrencyLevel + targetBacklog); in acceptingJobs()
|
| D | NettyHttpClient.java | 59 private int concurrencyLevel; field in NettyHttpClient
64 this.concurrencyLevel = benchmark.concurrencyLevel; in prepare()
85 bootstrap.group(new NioEventLoopGroup(concurrencyLevel)) in prepare()
96 } else if (totalChannels < concurrencyLevel) { in enqueue()
117 return activeChannels < concurrencyLevel; in hasFreeChannels()
|
| D | SynchronousHttpClient.java | 32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel, in prepare()
|
| /external/guava/android/guava-tests/test/com/google/common/cache/ |
| D | CacheBuilderSpecTest.java | 40 assertNull(spec.concurrencyLevel); in testParse_empty()
53 assertNull(spec.concurrencyLevel); in testParse_initialCapacity()
74 assertNull(spec.concurrencyLevel); in testParse_maximumSize()
95 assertNull(spec.concurrencyLevel); in testParse_maximumWeight()
125 assertEquals(32, spec.concurrencyLevel.intValue()); in testParse_concurrencyLevel()
131 CacheBuilder.newBuilder().concurrencyLevel(32), CacheBuilder.from(spec)); in testParse_concurrencyLevel()
147 assertNull(spec.concurrencyLevel); in testParse_weakKeys()
176 assertNull(spec.concurrencyLevel); in testParse_softValues()
197 assertNull(spec.concurrencyLevel); in testParse_weakValues()
244 assertNull(spec.concurrencyLevel); in testParse_writeExpirationDays()
[all …]
|
| D | CacheEvictionTest.java | 61 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(MAX_SIZE).build(loader); in testEviction_maxSizeOneSegment()
75 .concurrencyLevel(1) in testEviction_maxWeightOneSegment()
148 .concurrencyLevel(1) in testEviction_maxWeight_zero()
197 .concurrencyLevel(1) in testEviction_maxWeight_entryTooBig()
247 .concurrencyLevel(1) in testEviction_overflow()
276 CacheBuilder.newBuilder().maximumSize(MAX_SIZE).concurrencyLevel(1).build(loader); in testUpdateRecency_onInvalidate()
293 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(10).build(loader); in testEviction_lru()
324 .concurrencyLevel(1) in testEviction_weightedLru()
368 .concurrencyLevel(1) in testEviction_overweight()
391 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(10).build(loader); in testEviction_invalidateAll()
|
| D | LocalCacheTest.java | 113 new TestStringCacheGenerator(createCacheBuilder().concurrencyLevel(1))) in suite()
277 assertEquals(4, map.concurrencyLevel); in testDefaults()
344 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
346 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
385 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
389 .concurrencyLevel(concurrencyLevel) in checkInitialCapacity()
421 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
425 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
440 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
565 LocalCache<Object, Object> map = makeLocalCache(builder.concurrencyLevel(1)); in testRecordReadOnCompute()
[all …]
|
| D | CacheBuilderTest.java | 116 builder.concurrencyLevel(0); in testConcurrencyLevel_zero()
123 CacheBuilder<Object, Object> builder = CacheBuilder.newBuilder().concurrencyLevel(16); in testConcurrencyLevel_setTwice()
126 builder.concurrencyLevel(16); in testConcurrencyLevel_setTwice()
135 CacheBuilder.newBuilder().concurrencyLevel(1).build(identityLoader()); in testConcurrencyLevel_small()
141 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE); in testConcurrencyLevel_large()
420 .concurrencyLevel(1) in testRemovalNotification_clear()
482 .concurrencyLevel(20) in testRemovalNotification_clear_basher()
590 .concurrencyLevel(2) in testRemovalNotification_get_basher()
|
| D | CacheBuilderFactory.java | 161 Integer concurrencyLevel,
171 if (concurrencyLevel != null) {
172 builder.concurrencyLevel(concurrencyLevel);
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheBuilderSpecTest.java | 40 assertNull(spec.concurrencyLevel); in testParse_empty()
53 assertNull(spec.concurrencyLevel); in testParse_initialCapacity()
74 assertNull(spec.concurrencyLevel); in testParse_maximumSize()
95 assertNull(spec.concurrencyLevel); in testParse_maximumWeight()
125 assertEquals(32, spec.concurrencyLevel.intValue()); in testParse_concurrencyLevel()
131 CacheBuilder.newBuilder().concurrencyLevel(32), CacheBuilder.from(spec)); in testParse_concurrencyLevel()
147 assertNull(spec.concurrencyLevel); in testParse_weakKeys()
176 assertNull(spec.concurrencyLevel); in testParse_softValues()
197 assertNull(spec.concurrencyLevel); in testParse_weakValues()
244 assertNull(spec.concurrencyLevel); in testParse_writeExpirationDays()
[all …]
|
| D | CacheEvictionTest.java | 61 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(MAX_SIZE).build(loader); in testEviction_maxSizeOneSegment()
75 .concurrencyLevel(1) in testEviction_maxWeightOneSegment()
148 .concurrencyLevel(1) in testEviction_maxWeight_zero()
197 .concurrencyLevel(1) in testEviction_maxWeight_entryTooBig()
247 .concurrencyLevel(1) in testEviction_overflow()
276 CacheBuilder.newBuilder().maximumSize(MAX_SIZE).concurrencyLevel(1).build(loader); in testUpdateRecency_onInvalidate()
293 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(10).build(loader); in testEviction_lru()
324 .concurrencyLevel(1) in testEviction_weightedLru()
368 .concurrencyLevel(1) in testEviction_overweight()
391 CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(10).build(loader); in testEviction_invalidateAll()
|
| D | LocalCacheTest.java | 114 new TestStringCacheGenerator(createCacheBuilder().concurrencyLevel(1))) in suite()
274 assertEquals(4, map.concurrencyLevel); in testDefaults()
341 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
343 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
382 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
386 .concurrencyLevel(concurrencyLevel) in checkInitialCapacity()
418 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
422 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
437 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
562 LocalCache<Object, Object> map = makeLocalCache(builder.concurrencyLevel(1)); in testRecordReadOnCompute()
[all …]
|
| D | CacheBuilderFactory.java | 161 Integer concurrencyLevel,
171 if (concurrencyLevel != null) {
172 builder.concurrencyLevel(concurrencyLevel);
|
| /external/guava/android/guava/src/com/google/common/cache/ |
| D | CacheBuilder.java | 231 int concurrencyLevel = UNSET_INT; field in CacheBuilder
398 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
400 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
402 this.concurrencyLevel); in concurrencyLevel()
403 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
404 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
409 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
901 if (concurrencyLevel != UNSET_INT) { in toString()
902 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | CacheBuilderSpec.java | 113 @VisibleForTesting @NullableDecl Integer concurrencyLevel; field in CacheBuilderSpec
177 if (concurrencyLevel != null) { in toCacheBuilder()
178 builder.concurrencyLevel(concurrencyLevel); in toCacheBuilder()
241 concurrencyLevel, in hashCode()
262 && Objects.equal(concurrencyLevel, that.concurrencyLevel) in equals()
357 spec.concurrencyLevel == null, in parseInteger()
359 spec.concurrencyLevel); in parseInteger()
360 spec.concurrencyLevel = value; in parseInteger()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | CacheBuilder.java | 230 int concurrencyLevel = UNSET_INT; field in CacheBuilder
397 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
399 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
401 this.concurrencyLevel); in concurrencyLevel()
402 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
403 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
408 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
1001 if (concurrencyLevel != UNSET_INT) { in toString()
1002 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | CacheBuilderSpec.java | 113 @VisibleForTesting @Nullable Integer concurrencyLevel; field in CacheBuilderSpec
177 if (concurrencyLevel != null) { in toCacheBuilder()
178 builder.concurrencyLevel(concurrencyLevel); in toCacheBuilder()
241 concurrencyLevel, in hashCode()
262 && Objects.equal(concurrencyLevel, that.concurrencyLevel) in equals()
356 spec.concurrencyLevel == null, in parseInteger()
358 spec.concurrencyLevel); in parseInteger()
359 spec.concurrencyLevel = value; in parseInteger()
|