+++ /dev/null
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at:
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
- /*
- * Modifications copyright (c) 2017 AT&T Intellectual Property
- */
-
-package io.fd.honeycomb.tutorial.write;
-
-import io.fd.honeycomb.translate.spi.write.ListWriterCustomizer;
-import io.fd.honeycomb.translate.v3po.util.NamingContext;
-import io.fd.honeycomb.translate.v3po.util.TranslateUtils;
-import io.fd.honeycomb.translate.write.WriteContext;
-import io.fd.honeycomb.translate.write.WriteFailedException;
-import javax.annotation.Nonnull;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.sample.plugin.rev160918.sample.plugin.params.pg.streams.PgStream;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.sample.plugin.rev160918.sample.plugin.params.pg.streams.PgStreamKey;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.openvpp.jvpp.VppBaseCallException;
-import org.openvpp.jvpp.core.dto.PgEnableDisable;
-import org.openvpp.jvpp.core.dto.PgEnableDisableReply;
-import org.openvpp.jvpp.core.future.FutureJVppCore;
-
-import java.util.Arrays;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-
-/**
- * Writer for {@link VxlanTunnel} list node from our YANG model.
- */
-public final class PgWriteCustomizer implements ListWriterCustomizer<PgStream, PgStreamKey> {
-
-
- private static final Logger LOG = LoggerFactory.getLogger(PgWriteCustomizer.class);
-
- /**
- * JVpp APIs
- */
- private final FutureJVppCore jvppCore;
- /**
- * Shared vxlan tunnel naming context
- */
- private final NamingContext pgStreamNamingContext;
-
- public PgWriteCustomizer(final FutureJVppCore jvppCore, final NamingContext pgStreamNamingContext) {
- this.jvppCore = jvppCore;
- this.pgStreamNamingContext = pgStreamNamingContext;
- }
-
- @Override
- public void writeCurrentAttributes(@Nonnull final InstanceIdentifier<PgStream> id,
- @Nonnull final PgStream dataAfter,
- @Nonnull final WriteContext writeContext) throws WriteFailedException {
- // Create and set vxlan tunnel add request
- final PgEnableDisable pgEnableDisable = new PgEnableDisable();
- // 1 for add, 0 for delete
- //look into this file: ~/vpp/build-root/build-vpp-native/vpp-api/java/jvpp-core/org/openvpp/jvpp/core/dto/PgEnableDisable.java
- pgEnableDisable.isEnabled = 1;//public byte
- String sName = dataAfter.getId();
- //pgEnableDisable.streamName = sName.getBytes();//public byte[]
- byte[] tempArray = sName.getBytes();
- LOG.info("Going to copy array!!!");
- String tempMsg = "";
- pgEnableDisable.streamName = new byte[tempArray.length+1];
- for(int i = 0; i < tempArray.length; i++){
- tempMsg = "copying: i= "+i+" value: "+tempArray[i];
- LOG.info(tempMsg);
- pgEnableDisable.streamName[i] = tempArray[i];
- }
-
- //System.arraycopy( sName.getBytes(), 0, pgEnableDisable.streamName, 0, sName.length());
- pgEnableDisable.streamNameLength = sName.length() + 1;//public int
- String logMsg = "######***** Enabling: "+sName+" len: "+sName.length()+" getBytes:" + Arrays.toString(pgEnableDisable.streamName);
- LOG.info(logMsg);
- // dataAfter is the new vxlanTunnel configuration
- //final boolean isIpv6 = dataAfter.getSrc().getIpv6Address() != null;
- //vxlanAddDelTunnel.isIpv6 = TranslateUtils.booleanToByte(isIpv6);
- //vxlanAddDelTunnel.srcAddress = TranslateUtils.ipAddressToArray(isIpv6, dataAfter.getSrc());
- //vxlanAddDelTunnel.dstAddress = TranslateUtils.ipAddressToArray(isIpv6, dataAfter.getDst());
- // There are other input parameters that are not exposed by our YANG model, default values will be used
-
- try {
- final PgEnableDisableReply replyForWrite = TranslateUtils
- .getReplyForWrite(jvppCore.pgEnableDisable(pgEnableDisable).toCompletableFuture(), id);
-
- // VPP returns the index of new vxlan tunnel
- //final int newVxlanTunnelIndex = replyForWrite.swIfIndex;
- // It's important to store it in context so that reader knows to which name a vxlan tunnel is mapped
- pgStreamNamingContext.addName(1, dataAfter.getId(), writeContext.getMappingContext());
- } catch (VppBaseCallException e) {
- throw new WriteFailedException.CreateFailedException(id, dataAfter, e);
- }
- }
-
- @Override
- public void updateCurrentAttributes(@Nonnull final InstanceIdentifier<PgStream> id,
- @Nonnull final PgStream dataBefore,
- @Nonnull final PgStream dataAfter, @Nonnull final WriteContext writeContext)
- throws WriteFailedException {
- // Not supported at VPP API level, throw exception
- throw new WriteFailedException.UpdateFailedException(id, dataBefore, dataAfter,
- new UnsupportedOperationException("Vxlan tunnel update is not supported by VPP"));
- }
-
- @Override
- public void deleteCurrentAttributes(@Nonnull final InstanceIdentifier<PgStream> id,
- @Nonnull final PgStream dataBefore,
- @Nonnull final WriteContext writeContext) throws WriteFailedException {
- // Create and set vxlan tunnel add request
- //final VxlanAddDelTunnel vxlanAddDelTunnel = new VxlanAddDelTunnel();
- final PgEnableDisable pgEnableDisable = new PgEnableDisable();
- // 1 for add, 0 for delete
- //vxlanAddDelTunnel.isAdd = 0;
- pgEnableDisable.isEnabled = 0;//public byte
-
- String sName = dataBefore.getId();
- pgEnableDisable.streamName = sName.getBytes();//public byte[]
- pgEnableDisable.streamNameLength = sName.length()+1;//public int
-
- String logMsg1 = "***** Disabling: "+sName+" len: "+sName.length()+" getBytes:" + Arrays.toString(pgEnableDisable.streamName);
- LOG.info(logMsg1);
- // Vxlan tunnel is identified by its attributes when deleting, not index, so set all attributes
- // dataBefore is the vxlan tunnel that's being deleted
- //final boolean isIpv6 = dataBefore.getSrc().getIpv6Address() != null;
- //vxlanAddDelTunnel.isIpv6 = TranslateUtils.booleanToByte(isIpv6);
- //vxlanAddDelTunnel.srcAddress = TranslateUtils.ipAddressToArray(isIpv6, dataBefore.getSrc());
- //vxlanAddDelTunnel.dstAddress = TranslateUtils.ipAddressToArray(isIpv6, dataBefore.getDst());
- // There are other input parameters that are not exposed by our YANG model, default values will be used
-
- try {
- // final VxlanAddDelTunnelReply replyForWrite = TranslateUtils
- // .getReplyForWrite(jvppCore.vxlanAddDelTunnel(vxlanAddDelTunnel).toCompletableFuture(), id);
- final PgEnableDisableReply replyForWrite = TranslateUtils
- .getReplyForWrite(jvppCore.pgEnableDisable(pgEnableDisable).toCompletableFuture(), id);
- // It's important to remove the mapping from context
- pgStreamNamingContext.removeName(dataBefore.getId(), writeContext.getMappingContext());
- } catch (VppBaseCallException e) {
- throw new WriteFailedException.DeleteFailedException(id, e);
- }
- }
-}
Code Review / demo.git / blobdiff