@Test public void testRangeRequestStitchDifferentSizedBlobs() throws Exception { if (metadataContentVersion > 2) { testGetSuccessStitch(LARGE_BLOB_SIZE, new GetBlobOptionsBuilder().operationType(GetBlobOptions.OperationType.Data) .range(ByteRanges.fromOffsetRange(CHUNK_SIZE * 2 + 3, CHUNK_SIZE * 5 + 4)) .build()); } else { router = getNonBlockingRouter(); router.close(); } }
void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time); }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time);  }
GetManager { void close() { for (GetOperation op : getOperations) { removeAndAbort(op, new RouterException("Aborted operation because Router is closed", RouterErrorCode.RouterClosed)); } } GetManager(ClusterMap clusterMap, ResponseHandler responseHandler, RouterConfig routerConfig,
      NonBlockingRouterMetrics routerMetrics, RouterCallback routerCallback, KeyManagementService kms,
      CryptoService cryptoService, CryptoJobHandler cryptoJobHandler, Time time);   }