@Test public void checkLocalPartitionStatusTest() throws IOException { CloudStorageManager cloudStorageManager = createNewCloudStorageManager(); ReplicaId mockReplicaId = clusterMap.getReplicaIds(clusterMap.getDataNodeIds().get(0)).get(0); PartitionId partitionId = mockReplicaId.getPartitionId(); Assert.assertEquals( cloudStorageManager.checkLocalPartitionStatus(partitionId, new MockReplicaId(ReplicaType.DISK_BACKED)), ServerErrorCode.No_Error); Assert.assertTrue(cloudStorageManager.addBlobStore(mockReplicaId)); Assert.assertEquals( cloudStorageManager.checkLocalPartitionStatus(partitionId, new MockReplicaId(ReplicaType.DISK_BACKED)), ServerErrorCode.No_Error); Assert.assertTrue("Failed in stopping replica", cloudStorageManager.shutdownBlobStore(partitionId)); Assert.assertEquals(cloudStorageManager.checkLocalPartitionStatus(partitionId, mockReplicaId), ServerErrorCode.No_Error); Assert.assertTrue(cloudStorageManager.removeBlobStore(partitionId)); Assert.assertEquals( cloudStorageManager.checkLocalPartitionStatus(partitionId, new MockReplicaId(ReplicaType.DISK_BACKED)), ServerErrorCode.No_Error); }
@Override public ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica) { return ServerErrorCode.No_Error; }
CloudStorageManager implements StoreManager { @Override public ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica) { return ServerErrorCode.No_Error; } }
CloudStorageManager implements StoreManager { @Override public ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica) { return ServerErrorCode.No_Error; } CloudStorageManager(VerifiableProperties properties, VcrMetrics vcrMetrics, CloudDestination cloudDestination,
      ClusterMap clusterMap); }
CloudStorageManager implements StoreManager { @Override public ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica) { return ServerErrorCode.No_Error; } CloudStorageManager(VerifiableProperties properties, VcrMetrics vcrMetrics, CloudDestination cloudDestination,
      ClusterMap clusterMap); @Override boolean addBlobStore(ReplicaId replica); @Override boolean shutdownBlobStore(PartitionId id); @Override Store getStore(PartitionId id); @Override boolean scheduleNextForCompaction(PartitionId id); @Override boolean startBlobStore(PartitionId id); @Override boolean controlCompactionForBlobStore(PartitionId id, boolean enabled); @Override List<PartitionId> setBlobStoreStoppedState(List<PartitionId> partitionIds, boolean markStop); @Override ReplicaId getReplica(String partitionName); @Override Collection<PartitionId> getLocalPartitions(); @Override boolean removeBlobStore(PartitionId id); @Override ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica); }
CloudStorageManager implements StoreManager { @Override public ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica) { return ServerErrorCode.No_Error; } CloudStorageManager(VerifiableProperties properties, VcrMetrics vcrMetrics, CloudDestination cloudDestination,
      ClusterMap clusterMap); @Override boolean addBlobStore(ReplicaId replica); @Override boolean shutdownBlobStore(PartitionId id); @Override Store getStore(PartitionId id); @Override boolean scheduleNextForCompaction(PartitionId id); @Override boolean startBlobStore(PartitionId id); @Override boolean controlCompactionForBlobStore(PartitionId id, boolean enabled); @Override List<PartitionId> setBlobStoreStoppedState(List<PartitionId> partitionIds, boolean markStop); @Override ReplicaId getReplica(String partitionName); @Override Collection<PartitionId> getLocalPartitions(); @Override boolean removeBlobStore(PartitionId id); @Override ServerErrorCode checkLocalPartitionStatus(PartitionId partition, ReplicaId localReplica);  }