160161162163164165166167168169170
if (!registered) { ILatencyPublisher handler = (ILatencyPublisher)MessagingService.instance.getVerbHandler(StorageService.Verb.READ_RESPONSE); if (handler != null) { handler.register(this); registered = true; } } for (Map.Entry<InetAddress, AdaptiveLatencyTracker> entry: windows.entrySet())
156157158159160161162163164165166