third-party/atomix/storage/src/main/java/io/atomix/storage/buffer/SwappedBuffer.java

   1 /*
   2  * Copyright 2015-present Open Networking Foundation
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package io.atomix.storage.buffer;
  17
  18 import io.atomix.utils.concurrent.ReferenceManager;
  19
  20 import java.nio.ByteOrder;
  21
  22 /**
  23  * Byte order swapped buffer.
  24  *
  25  * @author <a href="http://github.com/kuujo">Jordan Halterman</a>
  26  */
  27 public class SwappedBuffer extends AbstractBuffer {
  28   private final Buffer root;
  29
  30   SwappedBuffer(Buffer root, Bytes bytes, ReferenceManager<Buffer> referenceManager) {
  31     super(bytes, referenceManager);
  32     this.root = root;
  33   }
  34
  35   public SwappedBuffer(Buffer buffer, int offset, int initialCapacity, int maxCapacity, ReferenceManager<Buffer> referenceManager) {
  36     super(buffer.bytes().order(buffer.order() == ByteOrder.BIG_ENDIAN ? ByteOrder.LITTLE_ENDIAN : ByteOrder.BIG_ENDIAN), offset, initialCapacity, maxCapacity, referenceManager);
  37     this.root = buffer instanceof SwappedBuffer ? ((SwappedBuffer) buffer).root : buffer;
  38     root.acquire();
  39   }
  40
  41   /**
  42    * Returns the root buffer.
  43    *
  44    * @return The root buffer.
  45    */
  46   public Buffer root() {
  47     return root;
  48   }
  49
  50   @Override
  51   public boolean isDirect() {
  52     return root.isDirect();
  53   }
  54
  55   @Override
  56   public boolean isFile() {
  57     return root.isFile();
  58   }
  59
  60   @Override
  61   public boolean isReadOnly() {
  62     return root.isReadOnly();
  63   }
  64
  65   @Override
  66   protected void compact(int from, int to, int length) {
  67     if (root instanceof AbstractBuffer) {
  68       ((AbstractBuffer) root).compact(from, to, length);
  69     }
  70   }
  71
  72   @Override
  73   public Buffer duplicate() {
  74     return new SwappedBuffer(root, offset(), capacity(), maxCapacity(), referenceManager);
  75   }
  76
  77   @Override
  78   public Buffer acquire() {
  79     root.acquire();
  80     return this;
  81   }
  82
  83   @Override
  84   public boolean release() {
  85     return root.release();
  86   }
  87
  88   @Override
  89   public void close() {
  90     root.release();
  91   }
  92
  93 }