OPENDJ-2616 Support protection of pluggable backend data at rest

Fabio Pistolesi

22.30.2016 1a2cdfb5cf5f89348e8fee7ceeaa699d4aa54cea

 opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/IndexBuffer.java

@@ -47,7 +47,7 @@

    void writeTrustState(WriteableTransaction txn) throws StorageRuntimeException;

    void put(Index index, ByteString key, EntryID entryID);
    void put(DefaultIndex index, ByteString key, EntryID entryID);

    void put(VLVIndex index, ByteString sortKey);

@@ -223,7 +223,7 @@
    }

    @Override
    public void put(Index index, ByteString key, EntryID entryID)
    public void put(DefaultIndex index, ByteString key, EntryID entryID)
    {
      createOrGetBufferedIndexValues(index, key).addEntryID(entryID);
    }
@@ -272,20 +272,18 @@
  {
    private final WriteableTransaction txn;
    private final EntryID expectedEntryID;
    private final ByteString encodedEntryID;

    ImportIndexBuffer(WriteableTransaction txn, EntryID expectedEntryID)
    {
      this.txn = txn;
      this.expectedEntryID = expectedEntryID;
      this.encodedEntryID = ByteString.valueOfLong(expectedEntryID.longValue());
    }

    @Override
    public void put(Index index, ByteString key, EntryID entryID)
    public void put(DefaultIndex index, ByteString key, EntryID entryID)
    {
      Reject.ifFalse(this.expectedEntryID.equals(entryID), "Unexpected entryID");
      txn.put(index.getName(), key, encodedEntryID);
      txn.put(index.getName(), key, index.importToValue(entryID));
    }

    @Override
@@ -370,7 +368,7 @@
    impl.writeTrustState(txn);
  }

  void put(Index index, ByteString key, EntryID entryID)
  void put(DefaultIndex index, ByteString key, EntryID entryID)
  {
    impl.put(index, key, entryID);
  }