### Question:
CloudStorageManager implements StoreManager { @Override public Store getStore(PartitionId id) { try { lock.readLock().lock(); if (partitionToStore.containsKey(id)) { return partitionToStore.get(id).isStarted() ? partitionToStore.get(id) : null; } } finally { lock.readLock().unlock(); } return createAndStartBlobStoreIfAbsent(id); } 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);  }### Answer:
@Test public void getStoreTest() throws IOException { CloudStorageManager cloudStorageManager = createNewCloudStorageManager(); ReplicaId mockReplicaId = clusterMap.getReplicaIds(clusterMap.getDataNodeIds().get(0)).get(0); PartitionId partitionId = mockReplicaId.getPartitionId(); Store store = cloudStorageManager.getStore(partitionId); Assert.assertNotNull(store); Assert.assertTrue(store.isStarted()); Assert.assertTrue(cloudStorageManager.addBlobStore(mockReplicaId)); store = cloudStorageManager.getStore(partitionId); Assert.assertNotNull(store); Assert.assertTrue(store.isStarted()); Assert.assertTrue(cloudStorageManager.removeBlobStore(partitionId)); store = cloudStorageManager.getStore(partitionId); Assert.assertNotNull(store); Assert.assertTrue(store.isStarted()); }