|
@@ -33,13 +33,13 @@ import org.apache.hadoop.ozone.container.common.helpers.ChunkInfo;
|
|
import org.apache.hadoop.ozone.container.common.impl.ContainerSet;
|
|
import org.apache.hadoop.ozone.container.common.impl.ContainerSet;
|
|
import org.apache.hadoop.ozone.container.common.statemachine.DatanodeStateMachine;
|
|
import org.apache.hadoop.ozone.container.common.statemachine.DatanodeStateMachine;
|
|
import org.apache.hadoop.ozone.container.common.statemachine.StateContext;
|
|
import org.apache.hadoop.ozone.container.common.statemachine.StateContext;
|
|
|
|
+import org.apache.hadoop.ozone.container.common.utils.ContainerCache;
|
|
import org.apache.hadoop.ozone.container.common.volume.HddsVolume;
|
|
import org.apache.hadoop.ozone.container.common.volume.HddsVolume;
|
|
import org.apache.hadoop.ozone.container.common.volume.RoundRobinVolumeChoosingPolicy;
|
|
import org.apache.hadoop.ozone.container.common.volume.RoundRobinVolumeChoosingPolicy;
|
|
import org.apache.hadoop.ozone.container.common.volume.VolumeSet;
|
|
import org.apache.hadoop.ozone.container.common.volume.VolumeSet;
|
|
import org.apache.hadoop.ozone.container.keyvalue.KeyValueContainer;
|
|
import org.apache.hadoop.ozone.container.keyvalue.KeyValueContainer;
|
|
import org.apache.hadoop.ozone.container.keyvalue.KeyValueContainerData;
|
|
import org.apache.hadoop.ozone.container.keyvalue.KeyValueContainerData;
|
|
import org.apache.hadoop.ozone.container.keyvalue.helpers.BlockUtils;
|
|
import org.apache.hadoop.ozone.container.keyvalue.helpers.BlockUtils;
|
|
-import org.apache.hadoop.utils.MetadataStore;
|
|
|
|
import org.junit.Before;
|
|
import org.junit.Before;
|
|
import org.junit.Rule;
|
|
import org.junit.Rule;
|
|
import org.junit.Test;
|
|
import org.junit.Test;
|
|
@@ -155,7 +155,7 @@ public class TestOzoneContainer {
|
|
|
|
|
|
long freeBytes = container.getContainerData().getMaxSize();
|
|
long freeBytes = container.getContainerData().getMaxSize();
|
|
long containerId = container.getContainerData().getContainerID();
|
|
long containerId = container.getContainerData().getContainerID();
|
|
- MetadataStore metadataStore = BlockUtils.getDB(container
|
|
|
|
|
|
+ ContainerCache.ReferenceCountedDB db = BlockUtils.getDB(container
|
|
.getContainerData(), conf);
|
|
.getContainerData(), conf);
|
|
|
|
|
|
for (int bi = 0; bi < blocks; bi++) {
|
|
for (int bi = 0; bi < blocks; bi++) {
|
|
@@ -173,7 +173,7 @@ public class TestOzoneContainer {
|
|
chunkList.add(info.getProtoBufMessage());
|
|
chunkList.add(info.getProtoBufMessage());
|
|
}
|
|
}
|
|
blockData.setChunks(chunkList);
|
|
blockData.setChunks(chunkList);
|
|
- metadataStore.put(Longs.toByteArray(blockID.getLocalID()),
|
|
|
|
|
|
+ db.getStore().put(Longs.toByteArray(blockID.getLocalID()),
|
|
blockData.getProtoBufMessage().toByteArray());
|
|
blockData.getProtoBufMessage().toByteArray());
|
|
}
|
|
}
|
|
|
|
|