Ridbags are not created together with clusters in distributed storage

orientechnologies · Aug 1, 2019 · 12a2890 · 12a2890
1 parent f889302
commit 12a2890
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/.../java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java b/.../java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java
@@ -4969,7 +4969,7 @@ private int doAddCluster(String clusterName, final int clusterPos) throws IOExce
 
       ((OClusterBasedStorageConfiguration) configuration).updateCluster(cluster.generateClusterConfig());
 
-      sbTreeCollectionManager.createComponent(createdClusterId);
+      sbTreeCollectionManager.createComponentIfPossible(createdClusterId);
     }
 
     return createdClusterId;

diff --git a/...m/orientechnologies/orient/core/storage/ridbag/sbtree/OSBTreeCollectionManagerShared.java b/...m/orientechnologies/orient/core/storage/ridbag/sbtree/OSBTreeCollectionManagerShared.java
@@ -108,12 +108,13 @@ public void delete(OBonsaiCollectionPointer collectionPointer) {
     super.delete(collectionPointer);
   }
 
-  public void createComponent(final int clusterId) throws IOException {
-    checkAccess();
-
-    final OSBTreeBonsaiLocal<OIdentifiable, Integer> tree = new OSBTreeBonsaiLocal<>(FILE_NAME_PREFIX + clusterId,
-        DEFAULT_EXTENSION, storage);
-    tree.createComponent();
+  public void createComponentIfPossible(final int clusterId) throws IOException {
+    //ignore creation of ridbags in distributed storage
+    if (!prohibitAccess) {
+      final OSBTreeBonsaiLocal<OIdentifiable, Integer> tree = new OSBTreeBonsaiLocal<>(FILE_NAME_PREFIX + clusterId,
+          DEFAULT_EXTENSION, storage);
+      tree.createComponent();
+    }
   }
 
   public long createComponent(final String fileName) throws IOException {