opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/VersionedNormalizedNodeDataInput.java

   1 /*
   2  * Copyright (c) 2019 PANTHEON.tech, s.r.o. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.cluster.datastore.node.utils.stream;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import java.io.DataInput;
  13 import java.io.IOException;
  14
  15 final class VersionedNormalizedNodeDataInput extends ForwardingNormalizedNodeDataInput {
  16     private DataInput input;
  17     private NormalizedNodeDataInput delegate;
  18
  19     VersionedNormalizedNodeDataInput(final DataInput input) {
  20         this.input = requireNonNull(input);
  21     }
  22
  23     @Override
  24     NormalizedNodeDataInput delegate() throws IOException {
  25         if (delegate != null) {
  26             return delegate;
  27         }
  28
  29         final byte marker = input.readByte();
  30         if (marker != TokenTypes.SIGNATURE_MARKER) {
  31             throw defunct("Invalid signature marker: %d", marker);
  32         }
  33
  34         final short version = input.readShort();
  35         final NormalizedNodeDataInput ret;
  36         switch (version) {
  37             case TokenTypes.LITHIUM_VERSION:
  38                 ret = new LithiumNormalizedNodeInputStreamReader(input);
  39                 break;
  40             case TokenTypes.SODIUM_VERSION:
  41                 ret = new SodiumNormalizedNodeInputStreamReader(input);
  42                 break;
  43             default:
  44                 throw defunct("Unhandled stream version %s", version);
  45         }
  46
  47         setDelegate(ret);
  48         return ret;
  49     }
  50
  51     private InvalidNormalizedNodeStreamException defunct(final String format, final Object... args) {
  52         final InvalidNormalizedNodeStreamException ret = new InvalidNormalizedNodeStreamException(
  53             String.format(format, args));
  54         // Make sure the stream is not touched
  55         setDelegate(new ForwardingNormalizedNodeDataInput() {
  56             @Override
  57             NormalizedNodeDataInput delegate() throws IOException {
  58                 throw new InvalidNormalizedNodeStreamException("Stream is not usable", ret);
  59             }
  60         });
  61         return ret;
  62     }
  63
  64     private void setDelegate(final NormalizedNodeDataInput delegate) {
  65         this.delegate = requireNonNull(delegate);
  66         input = null;
  67     }
  68 }