opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/raft/protobuff/client/messages/CompositeModificationByteStringPayload.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. 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
   9 package org.opendaylight.controller.cluster.raft.protobuff.client.messages;
  10
  11 import com.google.common.annotations.VisibleForTesting;
  12 import com.google.common.base.Preconditions;
  13 import com.google.protobuf.ByteString;
  14 import com.google.protobuf.InvalidProtocolBufferException;
  15 import java.io.IOException;
  16 import java.io.Serializable;
  17 import java.lang.ref.SoftReference;
  18 import org.opendaylight.controller.protobuff.messages.persistent.PersistentMessages;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 @Deprecated
  23 public class CompositeModificationByteStringPayload extends Payload implements
  24         Serializable {
  25     private static final long serialVersionUID = 1L;
  26
  27     private ByteString byteString;
  28     private SoftReference<PersistentMessages.CompositeModification> modificationReference;
  29     private static final Logger LOG = LoggerFactory.getLogger(CompositeModificationByteStringPayload.class);
  30
  31     public CompositeModificationByteStringPayload(){
  32         byteString = null;
  33     }
  34     public CompositeModificationByteStringPayload(Object modification){
  35         this(((PersistentMessages.CompositeModification) modification).toByteString());
  36         this.modificationReference = new SoftReference<>((PersistentMessages.CompositeModification) modification);
  37     }
  38
  39     private CompositeModificationByteStringPayload(ByteString byteString){
  40         this.byteString = Preconditions.checkNotNull(byteString, "byteString should not be null");
  41     }
  42
  43     public Object getModification(){
  44         return getModificationInternal();
  45     }
  46
  47     private PersistentMessages.CompositeModification getModificationInternal(){
  48         if(this.modificationReference != null && this.modificationReference.get() != null){
  49             return this.modificationReference.get();
  50         }
  51         try {
  52             PersistentMessages.CompositeModification compositeModification = PersistentMessages.CompositeModification.parseFrom(this.byteString);
  53             this.modificationReference = new SoftReference<>(compositeModification);
  54             return compositeModification;
  55         } catch (InvalidProtocolBufferException e) {
  56             LOG.error("Unexpected exception occurred when parsing byteString to CompositeModification", e);
  57         }
  58
  59         return null;
  60     }
  61
  62     @Override
  63     public int size(){
  64         return byteString.size();
  65     }
  66
  67     private void writeObject(java.io.ObjectOutputStream stream)
  68             throws IOException {
  69         byteString.writeTo(stream);
  70     }
  71
  72     private void readObject(java.io.ObjectInputStream stream)
  73             throws IOException, ClassNotFoundException {
  74         byteString = ByteString.readFrom(stream);
  75     }
  76
  77     @VisibleForTesting
  78     public void clearModificationReference(){
  79         if(this.modificationReference != null) {
  80             this.modificationReference.clear();
  81         }
  82     }
  83 }