opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendShardDataTreeSnapshotMetadata.java

   1 /*
   2  * Copyright (c) 2016 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 package org.opendaylight.controller.cluster.datastore.persisted;
   9
  10 import com.google.common.base.MoreObjects;
  11 import com.google.common.collect.ImmutableList;
  12 import java.io.Externalizable;
  13 import java.io.IOException;
  14 import java.io.ObjectInput;
  15 import java.io.ObjectOutput;
  16 import java.util.ArrayList;
  17 import java.util.Collection;
  18 import java.util.List;
  19
  20 public final class FrontendShardDataTreeSnapshotMetadata extends
  21         ShardDataTreeSnapshotMetadata<FrontendShardDataTreeSnapshotMetadata> {
  22
  23     private static final class Proxy implements Externalizable {
  24         private static final long serialVersionUID = 1L;
  25
  26         private List<FrontendClientMetadata> clients;
  27
  28         public Proxy() {
  29             // For Externalizable
  30         }
  31
  32         Proxy(final FrontendShardDataTreeSnapshotMetadata metadata) {
  33             this.clients = metadata.getClients();
  34         }
  35
  36         @Override
  37         public void writeExternal(final ObjectOutput out) throws IOException {
  38             out.writeInt(clients.size());
  39             for (final FrontendClientMetadata c : clients) {
  40                 c.writeTo(out);
  41             }
  42         }
  43
  44         @Override
  45         public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
  46             final int size = in.readInt();
  47             final List<FrontendClientMetadata> readedClients = new ArrayList<>(size);
  48             for (int i = 0; i < size ; ++i) {
  49                 readedClients.add(FrontendClientMetadata.readFrom(in));
  50             }
  51             this.clients = ImmutableList.copyOf(readedClients);
  52         }
  53
  54         private Object readResolve() {
  55             return new FrontendShardDataTreeSnapshotMetadata(clients);
  56         }
  57     }
  58
  59     private static final long serialVersionUID = 1L;
  60
  61     private final List<FrontendClientMetadata> clients;
  62
  63     public FrontendShardDataTreeSnapshotMetadata(final Collection<FrontendClientMetadata> clients) {
  64         this.clients = ImmutableList.copyOf(clients);
  65     }
  66
  67     public List<FrontendClientMetadata> getClients() {
  68         return clients;
  69     }
  70
  71     @Override
  72     protected Externalizable externalizableProxy() {
  73         return new Proxy(this);
  74     }
  75
  76     @Override
  77     public Class<FrontendShardDataTreeSnapshotMetadata> getType() {
  78         return FrontendShardDataTreeSnapshotMetadata.class;
  79     }
  80
  81     @Override
  82     public String toString() {
  83         return MoreObjects.toStringHelper(FrontendShardDataTreeSnapshotMetadata.class).add("clients", clients)
  84                 .toString();
  85     }
  86 }