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.protobuff.messages.cluster.raft.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<>();
39 org.opendaylight.controller.protobuff.messages.shard.CompositeModificationPayload.modification, this.modification);
43 @Override public Payload decode(
44 AppendEntriesMessages.AppendEntries.ReplicatedLogEntry.Payload payload) {
45 PersistentMessages.CompositeModification modification = payload
47 org.opendaylight.controller.protobuff.messages.shard.CompositeModificationPayload.modification);
51 // The extension was put in the unknown field.
52 // This is because extensions need to be registered
53 // see org.opendaylight.controller.mdsal.CompositeModificationPayload.registerAllExtensions
54 // also see https://developers.google.com/protocol-buffers/docs/reference/java/com/google/protobuf/ExtensionRegistry
55 // If that is not done then on the other end the extension shows up as an unknown field
56 // Need to figure out a better way to do this
57 if(payload.getUnknownFields().hasField(2)){
58 UnknownFieldSet.Field field =
59 payload.getUnknownFields().getField(2);
63 PersistentMessages.CompositeModification
64 .parseFrom(field.getLengthDelimitedList().get(0));
65 } catch (InvalidProtocolBufferException e) {
70 return new CompositeModificationPayload(modification);
73 public Object getModification(){
74 return this.modification;