Add ODL honeycomb VPP agent extensions to vppjapi jni java library.
Change-Id: I084ffcf36fbac55c2862035d10b028e35e1e648d
Signed-off-by: Dave Wallace <dwallacelf@gmail.com>
diff --git a/vpp-japi/Makefile.am b/vpp-japi/Makefile.am
index c501ace..a9fe355 100644
--- a/vpp-japi/Makefile.am
+++ b/vpp-japi/Makefile.am
@@ -21,8 +21,8 @@
CLEANFILES =
lib_LTLIBRARIES =
-nobase_include_HEADERS = \
- japi/org_openvpp_vppjapi_vppApi.h \
+nobase_include_HEADERS = \
+ japi/org_openvpp_vppjapi_vppApi.h \
japi/org_openvpp_vppjapi_vppConn.h
lib_LTLIBRARIES += libvppjni.la
@@ -41,34 +41,47 @@
BUILT_SOURCES += japi/org_openvpp_vppjapi_vppConn.h japi/vppapi.c
-japi/org_openvpp_vppjapi_vppConn.h: \
- japi/org/openvpp/vppjapi/vppVersion.java \
- japi/org/openvpp/vppjapi/vppInterfaceCounters.java \
- japi/org/openvpp/vppjapi/vppBridgeDomainDetails.java \
- japi/org/openvpp/vppjapi/vppBridgeDomainInterfaceDetails.java \
- japi/org/openvpp/vppjapi/vppL2Fib.java \
- japi/org/openvpp/vppjapi/vppConn.java \
+japi/org_openvpp_vppjapi_vppConn.h: \
+ japi/org/openvpp/vppjapi/vppVersion.java \
+ japi/org/openvpp/vppjapi/vppInterfaceDetails.java \
+ japi/org/openvpp/vppjapi/vppInterfaceCounters.java \
+ japi/org/openvpp/vppjapi/vppBridgeDomainDetails.java \
+ japi/org/openvpp/vppjapi/vppBridgeDomainInterfaceDetails.java \
+ japi/org/openvpp/vppjapi/vppL2Fib.java \
+ japi/org/openvpp/vppjapi/vppIPv4Address.java \
+ japi/org/openvpp/vppjapi/vppIPv6Address.java \
+ japi/org/openvpp/vppjapi/vppVxlanTunnelDetails.java \
+ japi/org/openvpp/vppjapi/vppConn.java \
+ japi/org/openvpp/vppjapi/vppApiCallbacks.java \
../vpp/api/vpe.api.h
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppVersion.java ;\
- $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppVersion ; \
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppInterfaceCounters.java ;\
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppVersion.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppVersion ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppInterfaceDetails.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppInterfaceDetails ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppInterfaceCounters.java ; \
$(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppInterfaceCounters ; \
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppBridgeDomainInterfaceDetails.java ;\
- $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppBridgeDomainInterfaceDetails ; \
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppBridgeDomainDetails.java ;\
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppBridgeDomainInterfaceDetails.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppBridgeDomainInterfaceDetails ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppBridgeDomainDetails.java ; \
$(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppBridgeDomainDetails ; \
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppL2Fib.java ;\
- $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppL2Fib ; \
- $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppConn.java ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppL2Fib.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppL2Fib ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppIPv4Address.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppIPv4Address ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppIPv6Address.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppIPv6Address ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppVxlanTunnelDetails.java ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppVxlanTunnelDetails ; \
+ $(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppConn.java ; \
$(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppConn ;
-japi/vppapi.c: japi/org_openvpp_vppjapi_vppConn.h japi/org/openvpp/vppjapi/vppApiCallbacks.java
- pushd .. ; dir=`pwd` ; popd ; \
- instdir=`echo $${dir} | sed -e 's:build-root/build:build-root/install:'` ; \
- vppapigen --input $${instdir}/vpp/api/vpe.api --jni japi/vppapi.c --app vpe ; \
+japi/vppapi.c: japi/org_openvpp_vppjapi_vppConn.h
+ pushd .. ; dir=`pwd` ; popd ; \
+ instdir=`echo $${dir} | sed -e 's:build-root/build:build-root/install:'` ; \
+ vppapigen --input $${instdir}/vpp/api/vpe.api --jni japi/vppapi.c --app vpe ; \
vppapigen --input $${instdir}/vpp/api/vpe.api --java japi/vppApi.java --app vpe ; \
$(JAVAC) -classpath . -d . japi/vppApi.java ; \
- $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppApi ; \
+ $(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppApi ; \
$(JAVAC) -classpath . -d . @srcdir@/japi/org/openvpp/vppjapi/vppApiCallbacks.java ; \
$(JAVAH) -classpath . -d japi org.openvpp.vppjapi.vppApiCallbacks ;
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppApiCallbacks.java b/vpp-japi/japi/org/openvpp/vppjapi/vppApiCallbacks.java
index 38c7c4e..5c35897 100644
--- a/vpp-japi/japi/org/openvpp/vppjapi/vppApiCallbacks.java
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppApiCallbacks.java
@@ -17,11 +17,14 @@
import org.openvpp.vppjapi.vppApi;
public abstract class vppApiCallbacks extends vppApi {
- public abstract void interfaceDetails(
+/* Disabled!
+ *
+ * public abstract void interfaceDetails(
int ifIndex, String interfaceName, int supIfIndex, byte[] physAddr,
byte adminUp, byte linkUp, byte linkDuplex, byte linkSpeed,
int subId, byte subDot1ad, byte subNumberOfTags, int subOuterVlanId, int subInnerVlanId,
byte subExactMatch, byte subDefault, byte subOuterVlanIdAny, byte subInnerVlanIdAny,
int vtrOp, int vtrPushDot1q, int vtrTag1, int vtrTag2);
+ */
}
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppConn.java b/vpp-japi/japi/org/openvpp/vppjapi/vppConn.java
index 12a3f17..cd95780 100644
--- a/vpp-japi/japi/org/openvpp/vppjapi/vppConn.java
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppConn.java
@@ -25,9 +25,12 @@
import java.util.Set;
import org.openvpp.vppjapi.vppVersion;
+import org.openvpp.vppjapi.vppInterfaceDetails;
import org.openvpp.vppjapi.vppInterfaceCounters;
import org.openvpp.vppjapi.vppBridgeDomainDetails;
-import org.openvpp.vppjapi.vppL2Fib;
+import org.openvpp.vppjapi.vppIPv4Address;
+import org.openvpp.vppjapi.vppIPv6Address;
+import org.openvpp.vppjapi.vppVxlanTunnelDetails;
public class vppConn {
private static final String LIBNAME = "libvppjni.so.0.0.0";
@@ -43,7 +46,6 @@
private static void loadStream(final InputStream is) throws IOException {
final Set<PosixFilePermission> perms = PosixFilePermissions.fromString("rwxr-x---");
final Path p = Files.createTempFile(LIBNAME, null, PosixFilePermissions.asFileAttribute(perms));
-
try {
Files.copy(is, p, StandardCopyOption.REPLACE_EXISTING);
@@ -77,7 +79,7 @@
public native int swIfIndexFromName (String interfaceName);
public native String interfaceNameFromSwIfIndex (int swIfIndex);
public native void clearInterfaceTable ();
- public native int swInterfaceDump (byte nameFilterValid, byte [] nameFilter);
+ public native vppInterfaceDetails[] swInterfaceDump (byte nameFilterValid, byte [] nameFilter);
public native int bridgeDomainIdFromName(String bridgeDomain);
public native int findOrAddBridgeDomainId(String bridgeDomain);
public native vppVersion getVppVersion();
@@ -86,4 +88,9 @@
public native vppBridgeDomainDetails getBridgeDomainDetails(int bdId);
public native vppL2Fib[] l2FibTableDump(int bdId);
public native int bridgeDomainIdFromInterfaceName(String interfaceName);
+ public native vppIPv4Address[] ipv4AddressDump(String interfaceName);
+ public native vppIPv6Address[] ipv6AddressDump(String interfaceName);
+ public native vppVxlanTunnelDetails[] vxlanTunnelDump(int swIfIndex);
+ public native int setInterfaceDescription (String ifName, String ifDesc);
+ public native String getInterfaceDescription (String ifName);
}
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppIPv4Address.java b/vpp-japi/japi/org/openvpp/vppjapi/vppIPv4Address.java
new file mode 100644
index 0000000..cd60e71
--- /dev/null
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppIPv4Address.java
@@ -0,0 +1,26 @@
+/*
+ * Copyright (c) 2015 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.
+ */
+
+package org.openvpp.vppjapi;
+
+public class vppIPv4Address {
+ public int ip;
+ public byte prefixLength;
+
+ public vppIPv4Address(int _ip, byte _prefixLength) {
+ ip = _ip;
+ prefixLength = _prefixLength;
+ }
+}
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppIPv6Address.java b/vpp-japi/japi/org/openvpp/vppjapi/vppIPv6Address.java
new file mode 100644
index 0000000..efaa89c
--- /dev/null
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppIPv6Address.java
@@ -0,0 +1,26 @@
+/*
+ * Copyright (c) 2015 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.
+ */
+
+package org.openvpp.vppjapi;
+
+public class vppIPv6Address {
+ public byte[] ip;
+ public byte prefixLength;
+
+ public vppIPv6Address(byte[] _ip, byte _prefixLength) {
+ ip = _ip;
+ prefixLength = _prefixLength;
+ }
+}
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppInterfaceDetails.java b/vpp-japi/japi/org/openvpp/vppjapi/vppInterfaceDetails.java
new file mode 100644
index 0000000..8bc94d2
--- /dev/null
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppInterfaceDetails.java
@@ -0,0 +1,68 @@
+/*
+ * Copyright (c) 2015 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.
+ */
+
+package org.openvpp.vppjapi;
+
+public class vppInterfaceDetails {
+ public int ifIndex;
+ public String interfaceName;
+ public int supIfIndex;
+ public byte[] physAddr;
+ public byte adminUp;
+ public byte linkUp;
+ public byte linkDuplex;
+ public byte linkSpeed;
+ public int subId;
+ public byte subDot1ad;
+ public byte subNumberOfTags;
+ public int subOuterVlanId;
+ public int subInnerVlanId;
+ public byte subExactMatch;
+ public byte subDefault;
+ public byte subOuterVlanIdAny;
+ public byte subInnerVlanIdAny;
+ public int vtrOp;
+ public int vtrPushDot1q;
+ public int vtrTag1;
+ public int vtrTag2;
+
+ public vppInterfaceDetails(int ifIndex, String interfaceName, int supIfIndex, byte[] physAddr, byte adminUp,
+ byte linkUp, byte linkDuplex, byte linkSpeed, int subId, byte subDot1ad, byte subNumberOfTags,
+ int subOuterVlanId, int subInnerVlanId, byte subExactMatch, byte subDefault, byte subOuterVlanIdAny,
+ byte subInnerVlanIdAny, int vtrOp, int vtrPushDot1q, int vtrTag1, int vtrTag2)
+ {
+ this.ifIndex = ifIndex;
+ this.interfaceName = interfaceName;
+ this.supIfIndex = supIfIndex;
+ this.physAddr = physAddr;
+ this.adminUp = adminUp;
+ this.linkUp = linkUp;
+ this.linkDuplex = linkDuplex;
+ this.linkSpeed = linkSpeed;
+ this.subId = subId;
+ this.subDot1ad = subDot1ad;
+ this.subNumberOfTags = subNumberOfTags;
+ this.subOuterVlanId = subOuterVlanId;
+ this.subInnerVlanId = subInnerVlanId;
+ this.subExactMatch = subExactMatch;
+ this.subDefault = subDefault;
+ this.subOuterVlanIdAny = subOuterVlanIdAny;
+ this.subInnerVlanIdAny = subInnerVlanIdAny;
+ this.vtrOp = vtrOp;
+ this.vtrPushDot1q = vtrPushDot1q;
+ this.vtrTag1 = vtrTag1;
+ this.vtrTag2 = vtrTag2;
+ }
+}
diff --git a/vpp-japi/japi/org/openvpp/vppjapi/vppVxlanTunnelDetails.java b/vpp-japi/japi/org/openvpp/vppjapi/vppVxlanTunnelDetails.java
new file mode 100644
index 0000000..a90e933
--- /dev/null
+++ b/vpp-japi/japi/org/openvpp/vppjapi/vppVxlanTunnelDetails.java
@@ -0,0 +1,33 @@
+/*
+ * Copyright (c) 2015 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.
+ */
+
+package org.openvpp.vppjapi;
+
+public class vppVxlanTunnelDetails {
+ public int srcAddress;
+ public int dstAddress;
+ public int encapVrfId;
+ public int vni;
+ public int decap_next_index;
+
+ public vppVxlanTunnelDetails(int _srcAddress, int _dstAddress,
+ int _encapVrfId, int _vni, int _decap_next_index) {
+ srcAddress = _srcAddress;
+ dstAddress = _dstAddress;
+ encapVrfId = _encapVrfId;
+ vni = _vni;
+ decap_next_index = _decap_next_index;
+ }
+}
diff --git a/vpp-japi/japi/vppjni.c b/vpp-japi/japi/vppjni.c
index 4274c31..5747d9a 100644
--- a/vpp-japi/japi/vppjni.c
+++ b/vpp-japi/japi/vppjni.c
@@ -39,6 +39,14 @@
#include <api/vpe_all_api_h.h>
#undef vl_printfun
+#define VPPJNI_DEBUG 0
+
+#if VPPJNI_DEBUG == 1
+ #define DEBUG_LOG(...) clib_warning(__VA_ARGS__)
+#else
+ #define DEBUG_LOG(...)
+#endif
+
static int connect_to_vpe(char *name);
/*
@@ -197,6 +205,80 @@
return rv;
}
+JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_setInterfaceDescription
+ (JNIEnv *env, jobject obj, jstring ifName, jstring ifDesc)
+{
+ int rv = 0;
+ vppjni_main_t * jm = &vppjni_main;
+ uword * p;
+ u32 sw_if_index = ~0;
+ sw_if_config_t *cfg;
+
+ const char *if_name_str = (*env)->GetStringUTFChars (env, ifName, 0);
+ const char *if_desc_str = (*env)->GetStringUTFChars (env, ifDesc, 0);
+
+ vppjni_lock (jm, 23);
+
+ p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name_str);
+ if (p == 0) {
+ rv = -1;
+ goto out;
+ }
+ sw_if_index = (jint) p[0];
+
+ u8 *if_desc = 0;
+ vec_validate_init_c_string (if_desc, if_desc_str, strlen(if_desc_str));
+ (*env)->ReleaseStringUTFChars (env, ifDesc, if_desc_str);
+
+ p = hash_get (jm->sw_if_config_by_sw_if_index, sw_if_index);
+ if (p != 0) {
+ cfg = (sw_if_config_t *) (p[0]);
+ if (cfg->desc)
+ vec_free(cfg->desc);
+ }
+ else {
+ cfg = (sw_if_config_t *) clib_mem_alloc(sizeof(sw_if_config_t));
+ hash_set (jm->sw_if_config_by_sw_if_index, sw_if_index, cfg);
+ }
+
+ cfg->desc = if_desc;
+
+out:
+ (*env)->ReleaseStringUTFChars (env, ifName, if_name_str);
+ vppjni_unlock (jm);
+ return rv;
+}
+
+JNIEXPORT jstring JNICALL Java_org_openvpp_vppjapi_vppConn_getInterfaceDescription
+(JNIEnv * env, jobject obj, jstring ifName)
+{
+ vppjni_main_t * jm = &vppjni_main;
+ u32 sw_if_index = ~0;
+ uword * p;
+ const char *if_name_str = (*env)->GetStringUTFChars (env, ifName, 0);
+ jstring ifDesc = NULL;
+
+ vppjni_lock (jm, 24);
+ p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name_str);
+ if (p == 0)
+ goto out;
+
+ sw_if_index = (jint) p[0];
+
+ p = hash_get (jm->sw_if_config_by_sw_if_index, sw_if_index);
+ if (p == 0)
+ goto out;
+
+ sw_if_config_t *cfg = (sw_if_config_t *) (p[0]);
+ u8 * s = format (0, "%s%c", cfg->desc, 0);
+ ifDesc = (*env)->NewStringUTF(env, (char *)s);
+
+out:
+ vppjni_unlock (jm);
+
+ return ifDesc;
+}
+
JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_clientConnect
(JNIEnv *env, jobject obj, jstring clientName)
{
@@ -243,12 +325,14 @@
h->flags |= MHEAP_FLAG_THREAD_SAFE;
jm->reply_hash = hash_create (0, sizeof (uword));
- jm->callback_hash = hash_create (0, sizeof (uword));
- jm->ping_hash = hash_create (0, sizeof (uword));
+ //jm->callback_hash = hash_create (0, sizeof (uword));
+ //jm->ping_hash = hash_create (0, sizeof (uword));
jm->api_main = am;
vjbd_main_init(&jm->vjbd_main);
jm->sw_if_index_by_interface_name =
hash_create_string (0, sizeof (uword));
+ jm->sw_if_config_by_sw_if_index =
+ hash_create (0, sizeof (uword));
{
// call control ping first to attach rx thread to java thread
@@ -271,7 +355,7 @@
if (rv != 0)
clib_warning ("unable to subscribe to stats (rv: %d)", rv);
}
- clib_warning ("clientConnect result: %d", rv);
+ DEBUG_LOG ("clientConnect result: %d", rv);
return rv;
}
@@ -308,7 +392,7 @@
jm->context_id_received = context;
- clib_warning("Received generic reply for msg id %d", msg_id);
+ DEBUG_LOG ("Received generic reply for msg id %d", msg_id);
/* A generic reply, successful, we're done */
if (retval >= 0 && total_bytes == sizeof(*mp))
@@ -518,15 +602,16 @@
{
vppjni_main_t * jm = &vppjni_main;
- vppjni_lock (jm, 10);
+ vppjni_lock (jm, 21);
vec_reset_length(jm->sw_if_table);
vppjni_unlock (jm);
}
+static jobjectArray sw_if_dump_get_interfaces ();
-JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_swInterfaceDump
+JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_swInterfaceDump
(JNIEnv * env, jobject obj, jbyte name_filter_valid, jbyteArray name_filter)
{
vppjni_main_t *jm = &vppjni_main;
@@ -535,7 +620,11 @@
u32 my_context_id;
int rv;
rv = vppjni_sanity_check (jm);
- if (rv) return rv;
+ if (rv) {
+ clib_warning("swInterfaceDump sanity_check rv = %d", rv);
+ return NULL;
+ }
+
vppjni_lock (jm, 7);
my_context_id = vppjni_get_context_id (jm);
jbyte * name_filterP = (*env)->GetByteArrayElements (env, name_filter, NULL);
@@ -551,9 +640,8 @@
memcpy ((char *) mp->name_filter, name_filterP, cnt);
(*env)->ReleaseByteArrayElements (env, name_filter, name_filterP, 0);
- clib_warning("interface filter (%d, %s, len: %d)", mp->name_filter_valid, (char *)mp->name_filter, cnt);
+ DEBUG_LOG ("interface filter (%d, %s, len: %d)", mp->name_filter_valid, (char *)mp->name_filter, cnt);
- hash_set (jm->callback_hash, my_context_id, (*env)->NewGlobalRef(env, obj));
jm->collect_indices = 1;
S;
@@ -563,26 +651,29 @@
M(CONTROL_PING, control_ping);
mp->context = clib_host_to_net_u32 (my_context_id);
- // this control ping will mark end of interface dump
- hash_set (jm->ping_hash, my_context_id, VL_API_SW_INTERFACE_DUMP);
-
S;
}
vppjni_unlock (jm);
WNR;
- return my_context_id;
+
+ vppjni_lock (jm, 7);
+ jobjectArray result = sw_if_dump_get_interfaces(env);
+ vppjni_unlock (jm);
+ return result;
}
-static int sw_if_dump_call_all_callbacks (jobject obj)
+static jobjectArray sw_if_dump_get_interfaces (JNIEnv * env)
{
vppjni_main_t * jm = &vppjni_main;
sw_interface_details_t *sw_if_details;
- int rc = 0;
u32 i;
- JNIEnv *env = jm->jenv;
+ int len = vec_len(jm->sw_if_dump_if_indices);
+ jmethodID jmtdIfDetails = jm->jmtdIfDetails;
- for (i = 0; i < vec_len(jm->sw_if_dump_if_indices); i++) {
+ jobjectArray ifArray = (*env)->NewObjectArray(env, len, jm->jcls, NULL);
+
+ for (i = 0; i < len; i++) {
u32 sw_if_index = jm->sw_if_dump_if_indices[i];
ASSERT(sw_if_index < vec_len(jm->sw_if_table));
sw_if_details = &jm->sw_if_table[sw_if_index];
@@ -606,8 +697,6 @@
jint vtrTag1 = sw_if_details->vtr_tag1;
jint vtrTag2 = sw_if_details->vtr_tag2;
- jmethodID jmtdIfDetails = jm->jmtdIfDetails;
-
jbyte adminUpDown = sw_if_details->admin_up_down;
jbyte linkUpDown = sw_if_details->link_up_down;
jbyte linkDuplex = sw_if_details->link_duplex;
@@ -619,51 +708,37 @@
jbyte subOuterVlanIdAny = sw_if_details->sub_outer_vlan_id_any;
jbyte subInnerVlanIdAny = sw_if_details->sub_inner_vlan_id_any;
- clib_warning("Method: %p, Calling method", jm->jmtdIfDetails);
- (*env)->CallVoidMethod(env, obj, jmtdIfDetails, ifIndex, ifname,
+ jobject ifObj = (*env)->NewObject(env, jm->jcls, jmtdIfDetails,
+ ifIndex, ifname,
supIfIndex, physAddr, adminUpDown, linkUpDown,
linkDuplex, linkSpeed, subId, subDot1ad,
subNumberOfTags, subOuterVlanId, subInnerVlanId,
subExactMatch, subDefault, subOuterVlanIdAny,
subInnerVlanIdAny, vtrOp, vtrPushDot1q, vtrTag1, vtrTag2);
- if ((*env)->ExceptionCheck(env)) {
- (*env)->ExceptionDescribe(env);
- rc = 1;
- goto out;
- }
- }
- clib_warning("Method: %p, Calling method (null arg)", jm->jmtdIfDetails);
- jmethodID jmtdIfDetails = jm->jmtdIfDetails;
- (*env)->CallVoidMethod(env, obj, jmtdIfDetails, -1, NULL, -1, NULL, 0, 0, 0, 0, -1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
- if ((*env)->ExceptionCheck(env)) {
- (*env)->ExceptionDescribe(env);
- rc = 1;
- goto out;
+ (*env)->SetObjectArrayElement(env, ifArray, i, ifObj);
}
- clib_warning("Done");
-
-out:
jm->collect_indices = 0;
vec_reset_length(jm->sw_if_dump_if_indices);
- return rc;
+ return ifArray;
}
JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_findOrAddBridgeDomainId
(JNIEnv * env, jobject obj, jstring bridgeDomain)
{
vppjni_main_t * jm = &vppjni_main;
+ static u8 * bd_name = 0;
jint rv = -1;
- const char * bd_name = (*env)->GetStringUTFChars (env, bridgeDomain, NULL);
+ const char * bdName = (*env)->GetStringUTFChars (env, bridgeDomain, NULL);
+
+ vec_validate_init_c_string (bd_name, bdName, strlen(bdName));
+ (*env)->ReleaseStringUTFChars (env, bridgeDomain, bdName);
vppjni_lock (jm, 6);
-
- rv = (jint)vjbd_find_or_add_bd (&jm->vjbd_main, (u8 *)bd_name);
-
+ rv = (jint)vjbd_find_or_add_bd (&jm->vjbd_main, bd_name);
vppjni_unlock (jm);
- (*env)->ReleaseStringUTFChars (env, bridgeDomain, bd_name);
-
+ _vec_len(bd_name) = 0;
return rv;
}
@@ -671,16 +746,18 @@
(JNIEnv * env, jobject obj, jstring bridgeDomain)
{
vppjni_main_t * jm = &vppjni_main;
+ static u8 * bd_name = 0;
jint rv = -1;
- const char * bd_name = (*env)->GetStringUTFChars(env, bridgeDomain, NULL);
+ const char * bdName = (*env)->GetStringUTFChars (env, bridgeDomain, NULL);
- vppjni_lock(jm, 7);
+ vec_validate_init_c_string (bd_name, bdName, strlen(bdName));
+ (*env)->ReleaseStringUTFChars (env, bridgeDomain, bdName);
+ vppjni_lock (jm, 20);
rv = (jint)vjbd_id_from_name(&jm->vjbd_main, (u8 *)bd_name);
+ vppjni_unlock (jm);
- vppjni_unlock(jm);
-
- (*env)->ReleaseStringUTFChars(env, bridgeDomain, bd_name);
+ _vec_len(bd_name) = 0;
return rv;
}
@@ -772,7 +849,7 @@
sw_if_details->sub_inner_vlan_id_any = mp->sub_inner_vlan_id_any;
hash_set_mem (jm->sw_if_index_by_interface_name, s, sw_if_index);
- clib_warning("Got interface %s", (char *)s);
+ DEBUG_LOG ("Got interface %s", (char *)s);
/* In sub interface case, fill the sub interface table entry */
if (mp->sw_if_index != mp->sup_sw_if_index) {
@@ -909,7 +986,7 @@
bd_oper->flood = mp->flood != 0;
bd_oper->forward = mp->forward != 0;
bd_oper->learn = mp->learn != 0;
- bd_oper->uu_flood = mp->flood != 0;
+ bd_oper->uu_flood = mp->uu_flood != 0;
bd_oper->arp_term = mp->arp_term != 0;
bd_oper->bvi_sw_if_index = ntohl (mp->bvi_sw_if_index);
bd_oper->n_sw_ifs = ntohl (mp->n_sw_ifs);
@@ -1266,14 +1343,10 @@
l2FibArray = (*env)->NewObjectArray(env, count, l2FibClass, NULL);
- u32 pos = 0;
for (i = 0; i < count; i++) {
bd_l2fib_oper_t *l2_fib = &l2fib_oper[i];
- if (1) {
- jobject l2FibObj = l2_fib_create_object(env, l2_fib);
- (*env)->SetObjectArrayElement(env, l2FibArray, pos, l2FibObj);
- pos++;
- }
+ jobject l2FibObj = l2_fib_create_object(env, l2_fib);
+ (*env)->SetObjectArrayElement(env, l2FibArray, i, l2FibObj);
}
done:
@@ -1322,6 +1395,269 @@
l2fib_oper->bvi = mp->bvi_mac;
}
+static int ipAddressDump
+(JNIEnv * env, jobject obj, jstring interfaceName, jboolean isIPv6)
+{
+ vppjni_main_t *jm = &vppjni_main;
+ vl_api_ip_address_dump_t * mp;
+ const char *if_name;
+ u32 my_context_id;
+ u32 sw_if_index;
+ f64 timeout;
+ uword *p;
+ int rv = 0;
+
+ if (NULL == interfaceName) {
+ return -1;
+ }
+
+ if_name = (*env)->GetStringUTFChars (env, interfaceName, NULL);
+ p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name);
+ (*env)->ReleaseStringUTFChars (env, interfaceName, if_name);
+ if (p == 0) {
+ return -1;
+ }
+ sw_if_index = (u32) p[0];
+
+ rv = vppjni_sanity_check (jm);
+ if (0 != rv) {
+ return rv;
+ }
+
+ my_context_id = vppjni_get_context_id (jm);
+ M(IP_ADDRESS_DUMP, ip_address_dump);
+ mp->context = clib_host_to_net_u32 (my_context_id);
+ mp->sw_if_index = clib_host_to_net_u32(sw_if_index);
+ mp->is_ipv6 = isIPv6;
+ jm->is_ipv6 = isIPv6;
+ S;
+
+ /* Use a control ping for synchronization */
+ {
+ vl_api_control_ping_t * mp;
+ M(CONTROL_PING, control_ping);
+ S;
+ }
+
+ WNR;
+
+ return rv;
+}
+
+JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_ipv4AddressDump
+(JNIEnv * env, jobject obj, jstring interfaceName)
+{
+ vppjni_main_t *jm = &vppjni_main;
+ jobject returnArray = NULL;
+ int i;
+
+ vppjni_lock (jm, 18);
+
+ vec_reset_length(jm->ipv4_addresses);
+
+ if (0 != ipAddressDump(env, obj, interfaceName, 0)) {
+ goto done;
+ }
+
+ u32 count = vec_len(jm->ipv4_addresses);
+ ipv4_address_t *ipv4_address = jm->ipv4_addresses;
+
+ jclass IPv4AddressClass = (*env)->FindClass(env, "org/openvpp/vppjapi/vppIPv4Address");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jmethodID midIPv4AddressInit = (*env)->GetMethodID(env, IPv4AddressClass, "<init>", "(IB)V");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jobjectArray ipv4AddressArray = (*env)->NewObjectArray(env, count, IPv4AddressClass, NULL);
+
+ for (i = 0; i < count; i++) {
+ ipv4_address_t *address = &ipv4_address[i];
+
+ jint ip = address->ip;
+ jbyte prefixLength = address->prefix_length;
+
+ jobject ipv4AddressObj = (*env)->NewObject(env, IPv4AddressClass, midIPv4AddressInit,
+ ip, prefixLength);
+
+ (*env)->SetObjectArrayElement(env, ipv4AddressArray, i, ipv4AddressObj);
+ }
+
+ returnArray = ipv4AddressArray;
+
+done:
+ vppjni_unlock (jm);
+ return returnArray;
+}
+
+JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_ipv6AddressDump
+(JNIEnv * env, jobject obj, jstring interfaceName)
+{
+ vppjni_main_t *jm = &vppjni_main;
+ jobject returnArray = NULL;
+ int i;
+
+ vppjni_lock (jm, 19);
+
+ vec_reset_length(jm->ipv6_addresses);
+
+ if (0 != ipAddressDump(env, obj, interfaceName, 1)) {
+ goto done;
+ }
+
+ u32 count = vec_len(jm->ipv6_addresses);
+ ipv6_address_t *ipv6_address = jm->ipv6_addresses;
+
+ jclass IPv6AddressClass = (*env)->FindClass(env, "org/openvpp/vppjapi/vppIPv6Address");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jmethodID midIPv6AddressInit = (*env)->GetMethodID(env, IPv6AddressClass, "<init>", "([BB)V");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jobjectArray ipv6AddressArray = (*env)->NewObjectArray(env, count, IPv6AddressClass, NULL);
+
+ for (i = 0; i < count; i++) {
+ ipv6_address_t *address = &ipv6_address[i];
+
+ jbyteArray ip = (*env)->NewByteArray(env, 16);
+ (*env)->SetByteArrayRegion(env, ip, 0, 16,
+ (signed char*)address->ip);
+
+ jbyte prefixLength = address->prefix_length;
+
+ jobject ipv6AddressObj = (*env)->NewObject(env, IPv6AddressClass, midIPv6AddressInit,
+ ip, prefixLength);
+
+ (*env)->SetObjectArrayElement(env, ipv6AddressArray, i, ipv6AddressObj);
+ }
+
+ returnArray = ipv6AddressArray;
+
+done:
+ vppjni_unlock (jm);
+ return returnArray;
+}
+
+static void vl_api_ip_address_details_t_handler (vl_api_ip_address_details_t * mp)
+{
+ vppjni_main_t * jm = &vppjni_main;
+
+ if (!jm->is_ipv6) {
+ ipv4_address_t *address = 0;
+ vec_add2(jm->ipv4_addresses, address, 1);
+ address->ip = *(u32*)mp->ip;
+ address->prefix_length = mp->prefix_length;
+ } else {
+ ipv6_address_t *address = 0;
+ vec_add2(jm->ipv6_addresses, address, 1);
+ memcpy(address->ip, mp->ip, 16);
+ address->prefix_length = mp->prefix_length;
+ }
+}
+
+#define VXLAN_TUNNEL_INTERFACE_NAME_PREFIX "vxlan_tunnel"
+
+JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_vxlanTunnelDump
+(JNIEnv * env, jobject obj, jint swIfIndex)
+{
+ vppjni_main_t *jm = &vppjni_main;
+ vl_api_vxlan_tunnel_dump_t * mp;
+ jobjectArray returnArray = NULL;
+ u32 my_context_id;
+ f64 timeout;
+ int rv = 0;
+ int i;
+
+ vppjni_lock (jm, 22);
+
+ vec_reset_length(jm->vxlan_tunnel_details);
+
+ my_context_id = vppjni_get_context_id (jm);
+ M(VXLAN_TUNNEL_DUMP, vxlan_tunnel_dump);
+ mp->context = clib_host_to_net_u32 (my_context_id);
+ mp->sw_if_index = clib_host_to_net_u32 (swIfIndex);
+ S;
+
+ /* Use a control ping for synchronization */
+ {
+ vl_api_control_ping_t * mp;
+ M(CONTROL_PING, control_ping);
+ S;
+ }
+
+ WNR;
+ if (0 != rv) {
+ goto done;
+ }
+
+ u32 count = vec_len(jm->vxlan_tunnel_details);
+
+ jclass VxlanTunnelDetailsClass = (*env)->FindClass(env,
+ "org/openvpp/vppjapi/vppVxlanTunnelDetails");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jmethodID midVxlanTunnelDetailsInit = (*env)->GetMethodID(env,
+ VxlanTunnelDetailsClass, "<init>", "(IIIII)V");
+ if ((*env)->ExceptionCheck(env)) {
+ (*env)->ExceptionDescribe(env);
+ goto done;
+ }
+
+ jobjectArray vxlanTunnelDetailsArray = (*env)->NewObjectArray(env, count,
+ VxlanTunnelDetailsClass, NULL);
+
+ for (i = 0; i < count; i++) {
+ vxlan_tunnel_details_t *details = &jm->vxlan_tunnel_details[i];
+
+ jint src_address = details->src_address;
+ jint dst_address = details->dst_address;
+ jint encap_vrf_id = details->encap_vrf_id;
+ jint vni = details->vni;
+ jint decap_next_index = details->decap_next_index;
+
+ jobject vxlanTunnelDetailsObj = (*env)->NewObject(env,
+ VxlanTunnelDetailsClass, midVxlanTunnelDetailsInit,
+ src_address, dst_address, encap_vrf_id, vni, decap_next_index);
+
+ (*env)->SetObjectArrayElement(env, vxlanTunnelDetailsArray, i,
+ vxlanTunnelDetailsObj);
+ }
+
+ returnArray = vxlanTunnelDetailsArray;
+
+done:
+ vppjni_unlock (jm);
+ return returnArray;
+}
+
+static void vl_api_vxlan_tunnel_details_t_handler
+(vl_api_vxlan_tunnel_details_t * mp)
+{
+ vppjni_main_t * jm = &vppjni_main;
+ vxlan_tunnel_details_t *tunnel_details;
+
+ vec_add2(jm->vxlan_tunnel_details, tunnel_details, 1);
+ tunnel_details->src_address = ntohl(mp->src_address);
+ tunnel_details->dst_address = ntohl(mp->dst_address);
+ tunnel_details->encap_vrf_id = ntohl(mp->encap_vrf_id);
+ tunnel_details->vni = ntohl(mp->vni);
+ tunnel_details->decap_next_index = ntohl(mp->decap_next_index);
+}
+
/* cleanup handler for RX thread */
void cleanup_rx_thread(void *arg)
{
@@ -1348,7 +1684,7 @@
i32 retval = ntohl(mp->retval);
if (retval >= 0) {
- clib_warning ("show version request succeeded(%d)");
+ DEBUG_LOG ("show version request succeeded(%d)");
strncpy((char*)jm->program_name, (const char*)mp->program,
sizeof(jm->program_name)-1);
jm->program_name[sizeof(jm->program_name)-1] = 0;
@@ -1385,9 +1721,6 @@
{
vppjni_main_t * jm = &vppjni_main;
i32 retval = ntohl(mp->retval);
- u32 context = clib_host_to_net_u32 (mp->context);
- uword *p = NULL;
-
jm->retval = retval;
// attach to java thread if not attached
@@ -1408,8 +1741,11 @@
jm->retval = -999;
goto out;
}
- // jm->jenv is now stable global reference that can be reused
+ // jm->jenv is now stable global reference that can be reused (only within RX thread)
+#if 0
+ // ! callback system removed for now
+ //
// get issuer msg-id
p = hash_get (jm->ping_hash, context);
if (p != 0) { // ping marks end of some dump call
@@ -1444,6 +1780,8 @@
// delete global reference
(*env)->DeleteGlobalRef(env, obj);
}
+#endif
+
out:
jm->result_ready = 1;
}
@@ -1594,14 +1932,14 @@
return JNI_ERR;
}
- jclass cls = (*env)->FindClass(env, "org/openvpp/vppjapi/vppApiCallbacks");
+ jclass cls = (*env)->FindClass(env, "org/openvpp/vppjapi/vppInterfaceDetails");
if ((*env)->ExceptionCheck(env)) {
(*env)->ExceptionDescribe(env);
return JNI_ERR;
}
jm->jmtdIfDetails =
- (*env)->GetMethodID(env, cls, "interfaceDetails", "(ILjava/lang/String;I[BBBBBIBBIIBBBBIIII)V");
+ (*env)->GetMethodID(env, cls, "<init>", "(ILjava/lang/String;I[BBBBBIBBIIBBBBIIII)V");
if ((*env)->ExceptionCheck(env)) {
(*env)->ExceptionDescribe(env);
return JNI_ERR;
@@ -1640,7 +1978,9 @@
_(SW_INTERFACE_SET_FLAGS, sw_interface_set_flags) \
_(BRIDGE_DOMAIN_DETAILS, bridge_domain_details) \
_(BRIDGE_DOMAIN_SW_IF_DETAILS, bridge_domain_sw_if_details) \
-_(L2_FIB_TABLE_ENTRY, l2_fib_table_entry)
+_(L2_FIB_TABLE_ENTRY, l2_fib_table_entry) \
+_(IP_ADDRESS_DETAILS, ip_address_details) \
+_(VXLAN_TUNNEL_DETAILS, vxlan_tunnel_details)
static int connect_to_vpe(char *name)
{
diff --git a/vpp-japi/japi/vppjni.h b/vpp-japi/japi/vppjni.h
index c065016..4973c0a 100644
--- a/vpp-japi/japi/vppjni.h
+++ b/vpp-japi/japi/vppjni.h
@@ -84,6 +84,20 @@
} sw_interface_subif_t;
typedef struct {
+ u8 *desc;
+} sw_if_config_t;
+
+typedef struct {
+ u32 ip;
+ u8 prefix_length;
+} ipv4_address_t;
+
+typedef struct {
+ u8 ip[16];
+ u8 prefix_length;
+} ipv6_address_t;
+
+typedef struct {
u64 ip4;
u64 ip6;
u64 unicast;
@@ -108,6 +122,14 @@
if_counters_t tx;
} sw_interface_stats_t;
+typedef struct {
+ u32 src_address;
+ u32 dst_address;
+ u32 encap_vrf_id;
+ u32 vni;
+ u32 decap_next_index;
+} vxlan_tunnel_details_t;
+
typedef struct {
/* Context IDs */
@@ -152,6 +174,8 @@
/* interface table */
sw_interface_details_t * sw_if_table;
+ uword * sw_if_config_by_sw_if_index;
+
/* interface indices of responses to one sw_if_dump request */
u8 collect_indices;
u32 * sw_if_dump_if_indices;
@@ -165,6 +189,14 @@
/* subinterface table */
sw_interface_subif_t * sw_if_subif_table;
+ /* used in ip_address_dump request and response handling */
+ ipv4_address_t *ipv4_addresses;
+ ipv6_address_t *ipv6_addresses;
+ u8 is_ipv6;
+
+ /* used in vxlan_tunnel_dump request and response handling */
+ vxlan_tunnel_details_t *vxlan_tunnel_details;
+
/* main heap */
u8 * heap;