2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
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
9 package org.opendaylight.controller.cluster.datastore;
11 import com.google.common.base.Preconditions;
12 import com.google.protobuf.GeneratedMessage;
13 import com.google.protobuf.InvalidProtocolBufferException;
14 import com.google.protobuf.UnknownFieldSet;
15 import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload;
16 import org.opendaylight.controller.cluster.raft.protobuff.messages.AppendEntriesMessages;
17 import org.opendaylight.controller.protobuff.messages.persistent.PersistentMessages;
19 import java.io.Serializable;
20 import java.util.HashMap;
23 public class CompositeModificationPayload extends Payload implements
26 private final PersistentMessages.CompositeModification modification;
28 public CompositeModificationPayload(){
31 public CompositeModificationPayload(Object modification){
32 this.modification = (PersistentMessages.CompositeModification) Preconditions.checkNotNull(modification, "modification should not be null");
35 @Override public Map<GeneratedMessage.GeneratedExtension, PersistentMessages.CompositeModification> encode() {
36 Preconditions.checkState(modification!=null);
37 Map<GeneratedMessage.GeneratedExtension, PersistentMessages.CompositeModification> map = new HashMap<>();
38 map.put(org.opendaylight.controller.mdsal.CompositeModificationPayload.modification, this.modification);
42 @Override public Payload decode(
43 AppendEntriesMessages.AppendEntries.ReplicatedLogEntry.Payload payload) {
44 PersistentMessages.CompositeModification modification = payload
46 org.opendaylight.controller.mdsal.CompositeModificationPayload.modification);
50 // The extension was put in the unknown field.
51 // This is because extensions need to be registered
52 // see org.opendaylight.controller.mdsal.CompositeModificationPayload.registerAllExtensions
53 // also see https://developers.google.com/protocol-buffers/docs/reference/java/com/google/protobuf/ExtensionRegistry
54 // If that is not done then on the other end the extension shows up as an unknown field
55 // Need to figure out a better way to do this
56 if(payload.getUnknownFields().hasField(2)){
57 UnknownFieldSet.Field field =
58 payload.getUnknownFields().getField(2);
62 PersistentMessages.CompositeModification
63 .parseFrom(field.getLengthDelimitedList().get(0));
64 } catch (InvalidProtocolBufferException e) {
69 return new CompositeModificationPayload(modification);
72 public Object getModification(){
73 return this.modification;