1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
/*
* 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);
}
}
}
|
