package org.apache.lucene.index;/** * 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. *//** * Class to write byte streams into slices of shared * byte[].  This is used by DocumentsWriter to hold the * posting list for many terms in RAM. */final class ByteSliceWriter {  private byte[] slice;  private int upto;  private final ByteBlockPool pool;  int offset0;  public ByteSliceWriter(ByteBlockPool pool) {    this.pool = pool;  }  /**   * Set up the writer to write at address.   */   public void init(int address) {    slice = pool.buffers[address >> DocumentsWriter.BYTE_BLOCK_SHIFT];    assert slice != null;    upto = address & DocumentsWriter.BYTE_BLOCK_MASK;    offset0 = address;    assert upto < slice.length;  }  /** Write byte into byte slice stream */  public void writeByte(byte b) {    assert slice != null;    if (slice[upto] != 0) {      upto = pool.allocSlice(slice, upto);      slice = pool.buffer;      offset0 = pool.byteOffset;      assert slice != null;    }    slice[upto++] = b;    assert upto != slice.length;  }  public void writeBytes(final byte[] b, int offset, final int len) {    final int offsetEnd = offset + len;    while(offset < offsetEnd) {      if (slice[upto] != 0) {        // End marker        upto = pool.allocSlice(slice, upto);        slice = pool.buffer;        offset0 = pool.byteOffset;      }      slice[upto++] = b[offset++];      assert upto != slice.length;    }  }  public int getAddress() {    return upto + (offset0 & DocumentsWriter.BYTE_BLOCK_NOT_MASK);  }  public void writeVInt(int i) {    while ((i & ~0x7F) != 0) {      writeByte((byte)((i & 0x7f) | 0x80));      i >>>= 7;    }    writeByte((byte) i);  }}