package org.apache.labs.bananadb.store.data;
   
   /*
    * Licensed to the Apache Software Foundation (ASF) under one or more
    * contributor license agreements.  See the NOTICE file distributed with
    * this work for additional information regarding copyright ownership.
    * The ASF licenses this file to You under the Apache License, Version 2.0
    * (the "License"); you may not use this file except in compliance with
    * the License.  You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  
  
  import org.apache.labs.bananadb.store.lock.LockFactory;
  
  import java.io.RandomAccessFile;
  import java.io.IOException;
  import java.io.File;
  
  /**
   * @author kalle
   * @since 2009-mar-16 14:16:39
   */
  public class Metadata extends FileHandler<Metadata.Header, FileHandler.Posting> {
  
    public Metadata(File directory, String access, LockFactory lockFactory) throws IOException {
      super(directory, 0, "md", access, lockFactory);
    }
  
    public static final int HEADER_BYTE_SIZE = 1024;
    public int getHeaderByteSize() {
      return HEADER_BYTE_SIZE;
    }
  
    public static class Header extends FileHandler.Header {
      /**
       * File format version.
       */
      private int fileFormatVersion;
  
      /**
       * Current hashtable file id. -- will change after rehash.
       */
      private int currentHashtableId;
  
      /** Current hash codes partition used for appending new postings */
      private int currentHashCodesPartition;
  
      /** Current keys partition used for appending new postings */
      private int currentKeysPartition;
  
      /** Current values partition used for appending new postings */
      private int currentValuesPartition;
  
      /**
       * Total number of value postings.
       */
      private long valuePostingsCount;
  
      /**
       * Commit version, will increase by one after each modification to the database.
       */
      private long storeRevision;
  
      public int getCurrentHashCodesPartition() {
        return currentHashCodesPartition;
      }
  
      public void setCurrentHashCodesPartition(int currentHashCodesPartition) {
        this.currentHashCodesPartition = currentHashCodesPartition;
      }
  
      public int getCurrentKeysPartition() {
        return currentKeysPartition;
      }
  
      public void setCurrentKeysPartition(int currentKeysPartition) {
        this.currentKeysPartition = currentKeysPartition;
      }
  
      public int getCurrentValuesPartition() {
        return currentValuesPartition;
      }
  
      public void setCurrentValuesPartition(int currentValuesPartition) {
        this.currentValuesPartition = currentValuesPartition;
      }
  
      public int getFileFormatVersion() {
        return fileFormatVersion;
      }
  
     public void setFileFormatVersion(int fileFormatVersion) {
       this.fileFormatVersion = fileFormatVersion;
     }
 
     public int getCurrentHashtableId() {
       return currentHashtableId;
     }
 
     public void setCurrentHashtableId(int currentHashtableId) {
       this.currentHashtableId = currentHashtableId;
     }
 
     public long getValuePostingsCount() {
       return valuePostingsCount;
     }
 
     public void setValuePostingsCount(long valuePostingsCount) {
       this.valuePostingsCount = valuePostingsCount;
     }
 
     public long getStoreRevision() {
       return storeRevision;
     }
 
     public void setStoreRevision(long storeRevision) {
       this.storeRevision = storeRevision;
     }
 
     public long increaseRevision(long value) {
       return storeRevision += value;
     }
 
     public long increaseValuePostingsCount(long value) {
       return valuePostingsCount += value;
     }
 
     public long decreaseValuePostingsCount(long value) {
       return valuePostingsCount -= value;
     }
 
   }
 
   public void readHeader(Header header, RandomAccessFile RAF) throws IOException {
     header.fileFormatVersion = RAF.readInt();
     header.storeRevision = RAF.readLong();
     header.currentHashtableId = RAF.readInt();
     header.currentHashCodesPartition = RAF.readInt();
     header.currentKeysPartition = RAF.readInt();
     header.currentValuesPartition = RAF.readInt();
     header.valuePostingsCount = RAF.readLong();
     System.currentTimeMillis();
   }
 
   public void writeHeader(Header header, RandomAccessFile RAF) throws IOException {
     RAF.writeInt(header.fileFormatVersion);
     RAF.writeLong(header.storeRevision);
     RAF.writeInt(header.currentHashtableId);
     RAF.writeInt(header.currentHashCodesPartition);
     RAF.writeInt(header.currentKeysPartition);
     RAF.writeInt(header.currentValuesPartition);
     RAF.writeLong(header.valuePostingsCount);
   }
 
   public void writePosting(Posting posting, RandomAccessFile RAF) throws IOException {
     throw new UnsupportedOperationException();
   }
 
   public void readPosting(Posting posting, RandomAccessFile RAF) throws IOException {
     throw new UnsupportedOperationException();
   }
 
   public void markPostingAsDeleted(int startOffset, RandomAccessFile RAF, long revision) throws IOException {
     throw new UnsupportedOperationException();
   }
 }