String key = scope.getPartition() + ":" + scope.getState();
firstCounts.putIfAbsent(key, new AtomicInteger());
firstCounts.get(key).incrementAndGet();
}
});
firstIPC.start();
// Start second IPC Service w/ counter
final ConcurrentMap<String, AtomicInteger> secondCounts =
new ConcurrentHashMap<String, AtomicInteger>();
final HelixIPCService secondIPC =