mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-11-07 03:32:03 +01:00
Code Issues Projects Releases Wiki Activity

Executor initialization moved to activate() method

Browse Source 
Change-Id: I91922b467794d25405c2c11cf2fc626efbaa4f22
This commit is contained in:
Michal Mach 2017-06-21 09:12:24 +02:00 committed by Andrea Campanella
parent 7b821709a3
commit 13072e2370
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
providers/rest/device/src/main/java/org/onosproject/provider/rest/device/impl/RestDeviceProvider.java
View File

@ -130,8 +130,7 @@ public class RestDeviceProvider extends AbstractProvider
private DeviceProviderService providerService; private DeviceProviderService providerService;
private ApplicationId appId; private ApplicationId appId;
private final ExecutorService executor = private ExecutorService executor;
Executors.newFixedThreadPool(5, groupedThreads("onos/restsbprovider", "device-installer-%d", log));
private SharedScheduledExecutorService portStatisticsExecutor = SharedScheduledExecutors.getPoolThreadExecutor(); private SharedScheduledExecutorService portStatisticsExecutor = SharedScheduledExecutors.getPoolThreadExecutor();
protected final List<ConfigFactory> factories = ImmutableList.of( protected final List<ConfigFactory> factories = ImmutableList.of(
@ -164,6 +163,7 @@ public class RestDeviceProvider extends AbstractProvider
appId = coreService.registerApplication(APP_NAME); appId = coreService.registerApplication(APP_NAME);
providerService = providerRegistry.register(this); providerService = providerRegistry.register(this);
factories.forEach(cfgService::registerConfigFactory); factories.forEach(cfgService::registerConfigFactory);
executor = Executors.newFixedThreadPool(5, groupedThreads("onos/restsbprovider", "device-installer-%d", log));
cfgService.addListener(cfgLister); cfgService.addListener(cfgLister);
executor.execute(RestDeviceProvider.this::createAndConnectDevices); executor.execute(RestDeviceProvider.this::createAndConnectDevices);
executor.execute(RestDeviceProvider.this::createDevices); executor.execute(RestDeviceProvider.this::createDevices);