| /external/guava/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 100 int concurrencyLevel = UNSET_INT; field in MapMaker
178 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in MapMaker
180 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
182 this.concurrencyLevel); in concurrencyLevel()
183 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
184 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
189 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
297 if (concurrencyLevel != UNSET_INT) { in toString()
298 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | Interners.java | 75 public InternerBuilder concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
76 this.mapMaker.concurrencyLevel(concurrencyLevel); in concurrencyLevel()
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 100 int concurrencyLevel = UNSET_INT; field in MapMaker
178 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in MapMaker
180 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
182 this.concurrencyLevel); in concurrencyLevel()
183 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
184 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
189 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
297 if (concurrencyLevel != UNSET_INT) { in toString()
298 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | Interners.java | 75 public InternerBuilder concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
76 this.mapMaker.concurrencyLevel(concurrencyLevel); in concurrencyLevel()
|
| /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()
120 builder.concurrencyLevel(0); in testConcurrencyLevel_Zero()
129 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-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()
120 builder.concurrencyLevel(0); in testConcurrencyLevel_Zero()
129 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/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 | 115 new TestStringCacheGenerator(createCacheBuilder().concurrencyLevel(1))) in suite()
275 assertEquals(4, map.concurrencyLevel); in testDefaults()
342 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
344 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
383 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
387 .concurrencyLevel(concurrencyLevel) in checkInitialCapacity()
419 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
423 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
438 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
563 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-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()
278 assertEquals(4, map.concurrencyLevel); in testDefaults()
345 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
347 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
386 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
390 .concurrencyLevel(concurrencyLevel) in checkInitialCapacity()
422 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
426 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
441 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
566 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()
423 .concurrencyLevel(1) in testRemovalNotification_clear()
485 .concurrencyLevel(20) in testRemovalNotification_clear_basher()
593 .concurrencyLevel(2) in testRemovalNotification_get_basher()
|
| 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 | 271 int concurrencyLevel = UNSET_INT; field in CacheBuilder
441 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in CacheBuilder
443 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
445 this.concurrencyLevel); in concurrencyLevel()
446 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
447 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
452 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
947 if (concurrencyLevel != UNSET_INT) { in toString()
948 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | CacheBuilderSpec.java | 116 @VisibleForTesting @CheckForNull Integer concurrencyLevel; field in CacheBuilderSpec
180 if (concurrencyLevel != null) { in toCacheBuilder()
181 builder.concurrencyLevel(concurrencyLevel); in toCacheBuilder()
244 concurrencyLevel, in hashCode()
265 && Objects.equal(concurrencyLevel, that.concurrencyLevel) in equals()
364 spec.concurrencyLevel == null, in parseInteger()
366 spec.concurrencyLevel); in parseInteger()
367 spec.concurrencyLevel = value; in parseInteger()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | CacheBuilder.java | 270 int concurrencyLevel = UNSET_INT; field in CacheBuilder
440 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in CacheBuilder
442 this.concurrencyLevel == UNSET_INT, in concurrencyLevel()
444 this.concurrencyLevel); in concurrencyLevel()
445 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
446 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
451 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
1048 if (concurrencyLevel != UNSET_INT) { in toString()
1049 s.add("concurrencyLevel", concurrencyLevel); in toString()
|
| D | CacheBuilderSpec.java | 116 @VisibleForTesting @CheckForNull Integer concurrencyLevel; field in CacheBuilderSpec
180 if (concurrencyLevel != null) { in toCacheBuilder()
181 builder.concurrencyLevel(concurrencyLevel); in toCacheBuilder()
244 concurrencyLevel, in hashCode()
265 && Objects.equal(concurrencyLevel, that.concurrencyLevel) in equals()
364 spec.concurrencyLevel == null, in parseInteger()
366 spec.concurrencyLevel); in parseInteger()
367 spec.concurrencyLevel = value; in parseInteger()
|