/* * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.controller.cluster.datastore.modification; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import org.opendaylight.controller.cluster.datastore.DataStoreVersions; import org.opendaylight.controller.cluster.datastore.util.InstanceIdentifierUtils; import org.opendaylight.controller.cluster.datastore.utils.SerializationUtils; import org.opendaylight.controller.protobuff.messages.persistent.PersistentMessages; import org.opendaylight.controller.sal.core.spi.data.DOMStoreWriteTransaction; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification; /** * DeleteModification store all the parameters required to delete a path from the data tree */ public class DeleteModification extends AbstractModification { private static final long serialVersionUID = 1L; public DeleteModification() { this(DataStoreVersions.CURRENT_VERSION); } public DeleteModification(short version) { super(version); } public DeleteModification(YangInstanceIdentifier path) { super(path); } @Override public void apply(DOMStoreWriteTransaction transaction) { transaction.delete(getPath()); } @Override public void apply(DataTreeModification transaction) { transaction.delete(getPath()); } @Override public byte getType() { return DELETE; } @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { setPath(SerializationUtils.deserializePath(in)); } @Override public void writeExternal(ObjectOutput out) throws IOException { SerializationUtils.serializePath(getPath(), out); } @Override @Deprecated public Object toSerializable() { return PersistentMessages.Modification.newBuilder().setType(this.getClass().toString()) .setPath(InstanceIdentifierUtils.toSerializable(getPath())).build(); } @Deprecated public static DeleteModification fromSerializable(Object serializable) { PersistentMessages.Modification o = (PersistentMessages.Modification) serializable; return new DeleteModification(InstanceIdentifierUtils.fromSerializable(o.getPath())); } public static DeleteModification fromStream(ObjectInput in, short version) throws ClassNotFoundException, IOException { DeleteModification mod = new DeleteModification(version); mod.readExternal(in); return mod; } }