| commit | 9bdc24f542307b227c86cfde35faf3c4f9e11f57 | [log] [tgz] |
|---|---|---|
| author | Jordan Halterman <jordan@onlab.us> | Wed Apr 19 23:45:12 2017 -0700 |
| committer | Jordan Halterman <jordan@onlab.us> | Thu Apr 27 09:07:50 2017 +0000 |
| tree | 87a2626381d33a8db8d1e7c59e567b9033c4d501 | |
| parent | 59ca8310ee07aefe8ef5b811f7fc845272572a27 [diff] [blame] |
[ONOS-6267] Support configurable Executors for primitives - Support user-provided Executors in primitive builders - Implement default per-partition per-primitive serial executor using a shared thread pool - Implement Executor wrappers for all primitive types Change-Id: I53acfb173a9b49a992a9a388983791d9735ed54a
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultAtomicCounterMapBuilder.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultAtomicCounterMapBuilder.java index 309220a..c92ef22 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultAtomicCounterMapBuilder.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultAtomicCounterMapBuilder.java
@@ -33,7 +33,7 @@ @Override public AsyncAtomicCounterMap<K> buildAsyncMap() { - return primitiveCreator.newAsyncAtomicCounterMap(name(), serializer()); + return primitiveCreator.newAsyncAtomicCounterMap(name(), serializer(), executorSupplier()); } @Override