@Test public void testFailureOnAllPollThatSends() throws Exception { requestAndResultsList.clear(); requestAndResultsList.add(new RequestAndResult(chunkSize * 5)); mockSelectorState.set(MockSelectorState.ThrowExceptionOnSend); Exception expectedException = new RouterException("", RouterErrorCode.OperationTimedOut); submitPutsAndAssertFailure(expectedException, true, true, true); Assert.assertFalse("Router should be closed", router.isOpen()); assertEquals("No ChunkFiller threads should be running after the router is closed", 0, TestUtils.numThreadsByThisName("ChunkFillerThread")); assertEquals("No RequestResponseHandler threads should be running after the router is closed", 0, TestUtils.numThreadsByThisName("RequestResponseHandlerThread")); assertEquals("All operations should have completed", 0, router.getOperationsCount()); }
boolean isOpen() { return isOpen.get(); }
PutManager { boolean isOpen() { return isOpen.get(); } }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass); }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass);  }
PutManager { boolean isOpen() { return isOpen.get(); } PutManager(ClusterMap clusterMap, ResponseHandler responseHandler, NotificationSystem notificationSystem,
      RouterConfig routerConfig, NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, String suffix,
      KeyManagementService kms, CryptoService cryptoService, CryptoJobHandler cryptoJobHandler,
      AccountService accountService, Time time, String defaultPartitionClass);   }