Package com.orientechnologies.orient.core.exception

Examples of com.orientechnologies.orient.core.exception.OStorageException

548
549
550
551
552
553
554
555
556
557
558
    }
  }

  public long[] getClusterDataRange(final int iClusterId) {
    if (iClusterId == -1)
      throw new OStorageException("Cluster Id is invalid: " + iClusterId);

    checkOpeness();

    final boolean locked = lock.acquireSharedLock();
View Full Code Here
569
570
571
572
573
574
575
576
577
578
579
    }
  }

  public long count(final int iClusterId) {
    if (iClusterId == -1)
      throw new OStorageException("Cluster Id is invalid: " + iClusterId);

    // COUNT PHYSICAL CLUSTER IF ANY
    checkOpeness();

    final boolean locked = lock.acquireSharedLock();
View Full Code Here
709
710
711
712
713
714
715
716
717
718
719
      for (ODataLocal data : dataSegments)
        data.synch();

    } catch (IOException e) {
      throw new OStorageException("Error on synch", e);
    } finally {
      lock.releaseSharedLock(locked);

      OProfiler.getInstance().stopChrono("storage." + name + ".synch", timer);
    }
View Full Code Here
100
101
102
103
104
105
106
107
108
      // ALREADY OPENED: THIS IS THE CASE WHEN A STORAGE INSTANCE IS
      // REUSED
      return;

    if (!exists())
      throw new OStorageException("Can't open the storage '" + name + "' because it not exists in path: " + url);

    open = true;
  }
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
      final OCluster cluster = getClusterById(iRid.clusterId);

      iRid.clusterPosition = cluster.addPhysicalPosition(0, offset, iRecordType);
      return iRid.clusterPosition;
    } catch (IOException e) {
      throw new OStorageException("Error on create record in cluster: " + iRid.clusterId, e);

    } finally {
      lock.releaseSharedLock(locked);
      OProfiler.getInstance().stopChrono("OStorageMemory.createRecord", timer);
    }
View Full Code Here
207
208
209
210
211
212
213
214
215
216
217
      if (ppos == null)
        return null;

      return new ORawBuffer(data.readRecord(ppos.dataPosition), ppos.version, ppos.type);
    } catch (IOException e) {
      throw new OStorageException("Error on read record in cluster: " + iClusterSegment.getId(), e);

    } finally {
      lock.releaseSharedLock(locked);
      OProfiler.getInstance().stopChrono("OStorageMemory.readRecord", timer);
    }
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
      data.updateRecord(ppos.dataPosition, iContent);

      return ++(ppos.version);

    } catch (IOException e) {
      throw new OStorageException("Error on update record #" + iRid, e);

    } finally {
      lock.releaseSharedLock(locked);
      OProfiler.getInstance().stopChrono("OStorageMemory.updateRecord", timer);
    }
View Full Code Here
271
272
273
274
275
276
277
278
279
280
281
      data.deleteRecord(ppos.dataPosition);

      return true;

    } catch (IOException e) {
      throw new OStorageException("Error on delete record #" + iRid, e);

    } finally {
      lock.releaseSharedLock(locked);
      OProfiler.getInstance().stopChrono("OStorageMemory.deleteRecord", timer);
    }
View Full Code Here
300
301
302
303
304
305
306
307
308
309
310
    try {

      return new long[] { cluster.getFirstEntryPosition(), cluster.getLastEntryPosition() };
    } catch (IOException e) {

      throw new OStorageException("Error on getting last entry position in cluster: " + iClusterId, e);
    } finally {

      lock.releaseSharedLock(locked);
    }
  }
View Full Code Here
478
479
480
481
482
483
484
485
486
487
488
      // CHANGE THE POINTMENT OF CLUSTER TO THE NEW POSITION
      final OCluster cluster = storage.getClusterById(clusterId);
      final OPhysicalPosition ppos = cluster.getPhysicalPosition(clusterPosition, new OPhysicalPosition());

      if (ppos.dataPosition != iSourcePosition)
        throw new OStorageException("Found corrupted record hole for rid " + clusterId + ":" + clusterPosition
            + ": data position is wrong: " + ppos.dataPosition + "<->" + iSourcePosition);

      cluster.setPhysicalPosition(clusterPosition, iDestinationPosition);
    }
View Full Code Here
TOP

Related Classes of com.orientechnologies.orient.core.exception.OStorageException

  • com.orientechnologies.orient.client.remote.OServerAdmin
  • com.orientechnologies.orient.client.remote.OStorageRemote
  • com.orientechnologies.orient.core.config.OStorageConfiguration
  • com.orientechnologies.orient.core.index.hashindex.local.cache.OReadWriteDiskCache
  • com.orientechnologies.orient.core.index.hashindex.local.cache.OWOWCache
  • com.orientechnologies.orient.core.index.hashindex.local.OHashTableDirectory
  • com.orientechnologies.orient.core.index.hashindex.local.OLocalHashTable
  • com.orientechnologies.orient.core.index.sbtreebonsai.local.OSBTreeBonsaiLocal
  • com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage
  • com.orientechnologies.orient.core.storage.impl.local.ODataLocal
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.