2 * Copyright (c) 2015 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
15 #define _GNU_SOURCE /* for strcasestr(3) */
16 #include <vnet/vnet.h>
18 #define vl_api_version(n,v) static u32 vpe_api_version = (v);
19 #include <api/vpe.api.h>
23 #include <japi/vppjni.h>
24 #include <japi/vppjni_bridge_domain.h>
25 #include <japi/vppjni_env.h>
26 #include <japi/org_openvpp_vppjapi_vppConn.h>
27 #include <japi/org_openvpp_vppjapi_vppApi.h>
29 #include <api/vpe_msg_enum.h>
30 #define vl_typedefs /* define message structures */
31 #include <api/vpe_all_api_h.h>
35 #include <api/vpe_all_api_h.h>
38 /* instantiate all the print functions we know about */
39 #define vl_print(handle, ...)
41 #include <api/vpe_all_api_h.h>
44 #define VPPJNI_DEBUG 0
47 #define DEBUG_LOG(...) clib_warning(__VA_ARGS__)
49 #define DEBUG_LOG(...)
52 static int connect_to_vpe(char *name);
55 * The Java runtime isn't compile w/ -fstack-protector,
56 * so we have to supply missing external references for the
57 * regular vpp libraries. Weak reference in case folks get religion
60 void __stack_chk_guard (void) __attribute__((weak));
61 void __stack_chk_guard (void) { }
63 BIND_JAPI_CLASS(vppBridgeDomainDetails, "()V");
64 BIND_JAPI_BOOL_FIELD(vppBridgeDomainDetails, arpTerm);
65 BIND_JAPI_BOOL_FIELD(vppBridgeDomainDetails, flood);
66 BIND_JAPI_BOOL_FIELD(vppBridgeDomainDetails, forward);
67 BIND_JAPI_BOOL_FIELD(vppBridgeDomainDetails, learn);
68 BIND_JAPI_BOOL_FIELD(vppBridgeDomainDetails, uuFlood);
69 BIND_JAPI_INT_FIELD(vppBridgeDomainDetails, bdId);
70 BIND_JAPI_STRING_FIELD(vppBridgeDomainDetails, name);
71 BIND_JAPI_STRING_FIELD(vppBridgeDomainDetails, bviInterfaceName);
72 BIND_JAPI_OBJ_FIELD(vppBridgeDomainDetails, interfaces, "[Lorg/openvpp/vppjapi/vppBridgeDomainInterfaceDetails;");
74 BIND_JAPI_CLASS(vppBridgeDomainInterfaceDetails, "()V");
75 BIND_JAPI_BYTE_FIELD(vppBridgeDomainInterfaceDetails, splitHorizonGroup);
76 BIND_JAPI_STRING_FIELD(vppBridgeDomainInterfaceDetails, interfaceName);
78 BIND_JAPI_CLASS(vppInterfaceCounters, "(JJJJJJJJJJJJJJJJJJJJJJ)V");
79 BIND_JAPI_CLASS(vppInterfaceDetails, "(ILjava/lang/String;I[BBBBBIBBIIBBBBIIIII)V");
80 BIND_JAPI_CLASS(vppIPv4Address, "(IB)V");
81 BIND_JAPI_CLASS(vppIPv6Address, "([BB)V");
82 BIND_JAPI_CLASS(vppL2Fib, "([BZLjava/lang/String;ZZ)V");
83 BIND_JAPI_CLASS(vppVersion, "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V");
84 BIND_JAPI_CLASS(vppVxlanTunnelDetails, "(IIIII)V");
86 void vl_client_add_api_signatures (vl_api_memclnt_create_t *mp)
89 * Send the main API signature in slot 0. This bit of code must
90 * match the checks in ../vpe/api/api.c: vl_msg_api_version_check().
92 mp->api_versions[0] = clib_host_to_net_u32 (vpe_api_version);
95 /* Note: non-static, called once to set up the initial intfc table */
96 static int sw_interface_dump (vppjni_main_t * jm)
98 vl_api_sw_interface_dump_t *mp;
101 name_sort_t * nses = 0, * ns;
102 sw_interface_subif_t * sub = NULL;
104 /* Toss the old name table */
105 hash_foreach_pair (p, jm->sw_if_index_by_interface_name,
107 vec_add2 (nses, ns, 1);
108 ns->name = (u8 *)(p->key);
109 ns->value = (u32) p->value[0];
112 hash_free (jm->sw_if_index_by_interface_name);
114 vec_foreach (ns, nses)
119 vec_foreach (sub, jm->sw_if_subif_table) {
120 vec_free (sub->interface_name);
122 vec_free (jm->sw_if_subif_table);
124 /* recreate the interface name hash table */
125 jm->sw_if_index_by_interface_name
126 = hash_create_string (0, sizeof(uword));
128 /* Get list of ethernets */
129 M(SW_INTERFACE_DUMP, sw_interface_dump);
130 mp->name_filter_valid = 1;
131 strncpy ((char *) mp->name_filter, "Ether", sizeof(mp->name_filter)-1);
134 /* and local / loopback interfaces */
135 M(SW_INTERFACE_DUMP, sw_interface_dump);
136 mp->name_filter_valid = 1;
137 strncpy ((char *) mp->name_filter, "lo", sizeof(mp->name_filter)-1);
140 /* and vxlan tunnel interfaces */
141 M(SW_INTERFACE_DUMP, sw_interface_dump);
142 mp->name_filter_valid = 1;
143 strncpy ((char *) mp->name_filter, "vxlan", sizeof(mp->name_filter)-1);
146 /* and tap tunnel interfaces */
147 M(SW_INTERFACE_DUMP, sw_interface_dump);
148 mp->name_filter_valid = 1;
149 strncpy ((char *) mp->name_filter, "tap", sizeof(mp->name_filter)-1);
152 /* and host (af_packet) interfaces */
153 M(SW_INTERFACE_DUMP, sw_interface_dump);
154 mp->name_filter_valid = 1;
155 strncpy ((char *) mp->name_filter, "host", sizeof(mp->name_filter)-1);
158 /* and l2tpv3 tunnel interfaces */
159 M(SW_INTERFACE_DUMP, sw_interface_dump);
160 mp->name_filter_valid = 1;
161 strncpy ((char *) mp->name_filter, "l2tpv3_tunnel",
162 sizeof(mp->name_filter)-1);
165 /* Use a control ping for synchronization */
167 vl_api_control_ping_t * mp;
168 M(CONTROL_PING, control_ping);
174 JNIEXPORT jobject JNICALL Java_org_openvpp_vppjapi_vppConn_getVppVersion0
175 (JNIEnv *env, jobject obj)
177 vppjni_main_t * jm = &vppjni_main;
179 vppjni_lock (jm, 11);
180 jstring progName = (*env)->NewStringUTF(env, (char *)jm->program_name);
181 jstring buildDir = (*env)->NewStringUTF(env, (char *)jm->build_directory);
182 jstring version = (*env)->NewStringUTF(env, (char *)jm->version);
183 jstring buildDate = (*env)->NewStringUTF(env, (char *)jm->build_date);
186 return vppVersionObject(env, progName, buildDir, version, buildDate);
189 static int jm_show_version (vppjni_main_t *jm)
192 vl_api_show_version_t *mp;
195 vppjni_lock (jm, 10);
196 M(SHOW_VERSION, show_version);
204 static int jm_stats_enable_disable (vppjni_main_t *jm, u8 enable)
206 vl_api_want_stats_t * mp;
210 vppjni_lock (jm, 13);
212 M(WANT_STATS, want_stats);
214 mp->enable_disable = enable;
220 // already subscribed / already disabled (it's ok)
221 if (rv == -2 || rv == -3)
226 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_setInterfaceDescription0
227 (JNIEnv *env, jobject obj, jstring ifName, jstring ifDesc)
230 vppjni_main_t * jm = &vppjni_main;
232 u32 sw_if_index = ~0;
235 const char *if_name_str = (*env)->GetStringUTFChars (env, ifName, 0);
236 const char *if_desc_str = (*env)->GetStringUTFChars (env, ifDesc, 0);
238 vppjni_lock (jm, 23);
240 p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name_str);
245 sw_if_index = (jint) p[0];
248 vec_validate_init_c_string (if_desc, if_desc_str, strlen(if_desc_str));
249 (*env)->ReleaseStringUTFChars (env, ifDesc, if_desc_str);
251 p = hash_get (jm->sw_if_config_by_sw_if_index, sw_if_index);
253 cfg = (sw_if_config_t *) (p[0]);
257 cfg = (sw_if_config_t *) clib_mem_alloc(sizeof(sw_if_config_t));
258 hash_set (jm->sw_if_config_by_sw_if_index, sw_if_index, cfg);
264 (*env)->ReleaseStringUTFChars (env, ifName, if_name_str);
269 JNIEXPORT jstring JNICALL Java_org_openvpp_vppjapi_vppConn_getInterfaceDescription0
270 (JNIEnv * env, jobject obj, jstring ifName)
272 vppjni_main_t * jm = &vppjni_main;
273 u32 sw_if_index = ~0;
275 jstring ifDesc = NULL;
276 const char *if_name_str = (*env)->GetStringUTFChars (env, ifName, 0);
280 vppjni_lock (jm, 24);
281 p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name_str);
285 sw_if_index = (jint) p[0];
287 p = hash_get (jm->sw_if_config_by_sw_if_index, sw_if_index);
291 sw_if_config_t *cfg = (sw_if_config_t *) (p[0]);
292 u8 * s = format (0, "%s%c", cfg->desc, 0);
293 ifDesc = (*env)->NewStringUTF(env, (char *)s);
301 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_clientConnect
302 (JNIEnv *env, jobject obj, jstring clientName)
305 const char *client_name;
306 void vl_msg_reply_handler_hookup(void);
307 vppjni_main_t * jm = &vppjni_main;
308 api_main_t * am = &api_main;
314 * Bail out now if we're not running as root
319 if (jm->is_connected)
322 client_name = (*env)->GetStringUTFChars(env, clientName, 0);
327 clib_mem_init (0, 128<<20);
329 heap = clib_mem_get_per_cpu_heap();
330 h = mheap_header (heap);
332 clib_time_init (&jm->clib_time);
334 rv = connect_to_vpe ((char *) client_name);
337 clib_warning ("connection failed, rv %d", rv);
339 (*env)->ReleaseStringUTFChars (env, clientName, client_name);
342 vl_msg_reply_handler_hookup ();
343 jm->is_connected = 1;
344 /* make the main heap thread-safe */
345 h->flags |= MHEAP_FLAG_THREAD_SAFE;
347 jm->reply_hash = hash_create (0, sizeof (uword));
348 //jm->callback_hash = hash_create (0, sizeof (uword));
349 //jm->ping_hash = hash_create (0, sizeof (uword));
351 vjbd_main_init(&jm->vjbd_main);
352 jm->sw_if_index_by_interface_name =
353 hash_create_string (0, sizeof (uword));
354 jm->sw_if_config_by_sw_if_index =
355 hash_create (0, sizeof (uword));
358 // call control ping first to attach rx thread to java thread
359 vl_api_control_ping_t * mp;
360 M(CONTROL_PING, control_ping);
365 clib_warning ("first control ping failed: %d", rv);
368 rv = jm_show_version(jm);
370 clib_warning ("unable to retrieve vpp version (rv: %d)", rv);
371 rv = sw_interface_dump(jm);
373 clib_warning ("unable to retrieve interface list (rv: %d)", rv);
374 rv = jm_stats_enable_disable(jm, 1);
376 clib_warning ("unable to subscribe to stats (rv: %d)", rv);
378 DEBUG_LOG ("clientConnect result: %d", rv);
383 JNIEXPORT void JNICALL Java_org_openvpp_vppjapi_vppConn_clientDisconnect
384 (JNIEnv *env, jobject obj)
387 vppjni_main_t * jm = &vppjni_main;
388 vl_client_disconnect_from_vlib();
390 save_heap = jm->heap;
391 memset (jm, 0, sizeof (*jm));
392 jm->heap = save_heap;
395 void vl_api_generic_reply_handler (vl_api_generic_reply_t *mp)
397 api_main_t * am = &api_main;
398 u16 msg_id = clib_net_to_host_u16 (mp->_vl_msg_id);
400 i32 retval = clib_net_to_host_u32 (mp->retval);
401 int total_bytes = sizeof(mp);
402 vppjni_main_t * jm = &vppjni_main;
403 u8 * saved_reply = 0;
404 u32 context = clib_host_to_net_u32 (mp->context);
406 cfgp = am->api_trace_cfg + msg_id;
409 clib_warning ("msg id %d: no trace configuration\n", msg_id);
411 total_bytes = cfgp->size;
413 jm->context_id_received = context;
415 DEBUG_LOG ("Received generic reply for msg id %d", msg_id);
417 /* A generic reply, successful, we're done */
418 if (retval >= 0 && total_bytes == sizeof(*mp))
422 vec_validate (saved_reply, total_bytes - 1);
423 clib_memcpy (saved_reply, mp, total_bytes);
426 hash_set (jm->reply_hash, context, saved_reply);
427 jm->saved_reply_count ++;
431 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_getRetval0
432 (JNIEnv * env, jobject obj, jint context, jint release)
434 vppjni_main_t * jm = &vppjni_main;
435 vl_api_generic_reply_t * mp;
440 if (context > jm->context_id_received)
441 return (VNET_API_ERROR_RESPONSE_NOT_READY);
444 p = hash_get (jm->reply_hash, context);
447 * Two cases: a generic "yes" reply - won't be in the hash table
448 * or "no", or "more data" which will be in the table.
453 mp = (vl_api_generic_reply_t *) (p[0]);
454 rv = clib_net_to_host_u32 (mp->retval);
457 u8 * free_me = (u8 *) mp;
459 hash_unset (jm->reply_hash, context);
460 jm->saved_reply_count --;
469 name_sort_cmp (void * a1, void * a2)
471 name_sort_t * n1 = a1;
472 name_sort_t * n2 = a2;
474 return strcmp ((char *)n1->name, (char *)n2->name);
477 JNIEXPORT jstring JNICALL Java_org_openvpp_vppjapi_vppConn_getInterfaceList0
478 (JNIEnv * env, jobject obj, jstring name_filter)
480 vppjni_main_t * jm = &vppjni_main;
483 name_sort_t * nses = 0, * ns;
484 const char *this_name;
486 const char * nf = (*env)->GetStringUTFChars (env, name_filter, NULL);
492 hash_foreach_pair (p, jm->sw_if_index_by_interface_name,
494 this_name = (const char *)(p->key);
495 if (strlen (nf) == 0 || strcasestr (this_name, nf)) {
496 vec_add2 (nses, ns, 1);
497 ns->name = (u8 *)(p->key);
498 ns->value = (u32) p->value[0];
502 vec_sort_with_function (nses, name_sort_cmp);
504 vec_foreach (ns, nses)
505 s = format (s, "%s: %d, ", ns->name, ns->value);
507 _vec_len (s) = vec_len (s) - 2;
508 vec_terminate_c_string (s);
513 (*env)->ReleaseStringUTFChars (env, name_filter, nf);
515 rv = (*env)->NewStringUTF (env, (char *) s);
521 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_swIfIndexFromName0
522 (JNIEnv * env, jobject obj, jstring interfaceName)
524 vppjni_main_t * jm = &vppjni_main;
526 const char * if_name = (*env)->GetStringUTFChars (env, interfaceName, NULL);
532 p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name);
539 (*env)->ReleaseStringUTFChars (env, interfaceName, if_name);
545 JNIEXPORT jobject JNICALL Java_org_openvpp_vppjapi_vppConn_getInterfaceCounters0
546 (JNIEnv * env, jobject obj, jint swIfIndex)
548 vppjni_main_t * jm = &vppjni_main;
549 sw_interface_stats_t *s;
550 u32 sw_if_index = swIfIndex;
551 jobject result = NULL;
553 vppjni_lock (jm, 16);
555 if (sw_if_index >= vec_len(jm->sw_if_stats_by_sw_if_index)) {
558 s = &jm->sw_if_stats_by_sw_if_index[sw_if_index];
563 result = vppInterfaceCountersObject(env,
564 s->rx.octets, s->rx.pkts.ip4, s->rx.pkts.ip6, s->rx.pkts.unicast,
565 s->rx.pkts.multicast, s->rx.pkts.broadcast, s->rx.pkts.discard,
566 s->rx.pkts.fifo_full, s->rx.pkts.error, s->rx.pkts.unknown_proto,
568 s->tx.octets, s->tx.pkts.ip4, s->tx.pkts.ip6, s->tx.pkts.unicast,
569 s->tx.pkts.multicast, s->tx.pkts.broadcast, s->tx.pkts.discard,
570 s->tx.pkts.fifo_full, s->tx.pkts.error, s->tx.pkts.unknown_proto,
578 JNIEXPORT jstring JNICALL Java_org_openvpp_vppjapi_vppConn_interfaceNameFromSwIfIndex0
579 (JNIEnv * env, jobject obj, jint swIfIndex)
581 vppjni_main_t * jm = &vppjni_main;
582 sw_interface_details_t *sw_if_details;
584 jstring ifname = NULL;
588 sw_if_index = swIfIndex;
590 if (sw_if_index >= vec_len(jm->sw_if_table)) {
593 sw_if_details = &jm->sw_if_table[sw_if_index];
594 if (!sw_if_details->valid) {
598 u8 * s = format (0, "%s%c", sw_if_details->interface_name, 0);
599 ifname = (*env)->NewStringUTF(env, (char *)s);
607 JNIEXPORT void JNICALL Java_org_openvpp_vppjapi_vppConn_clearInterfaceTable0
608 (JNIEnv * env, jobject obj)
610 vppjni_main_t * jm = &vppjni_main;
612 vppjni_lock (jm, 21);
614 vec_reset_length(jm->sw_if_table);
619 static jobjectArray sw_if_dump_get_interfaces ();
621 JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_swInterfaceDump0
622 (JNIEnv * env, jobject obj, jbyte name_filter_valid, jbyteArray name_filter)
624 vppjni_main_t *jm = &vppjni_main;
626 vl_api_sw_interface_dump_t * mp;
629 rv = vppjni_sanity_check (jm);
631 clib_warning("swInterfaceDump sanity_check rv = %d", rv);
636 my_context_id = vppjni_get_context_id (jm);
637 jsize cnt = (*env)->GetArrayLength (env, name_filter);
639 M(SW_INTERFACE_DUMP, sw_interface_dump);
640 mp->context = clib_host_to_net_u32 (my_context_id);
641 mp->name_filter_valid = name_filter_valid;
643 if (cnt > sizeof(mp->name_filter))
644 cnt = sizeof(mp->name_filter);
646 (*env)->GetByteArrayRegion(env, name_filter, 0, cnt, (jbyte *)mp->name_filter);
648 DEBUG_LOG ("interface filter (%d, %s, len: %d)", mp->name_filter_valid, (char *)mp->name_filter, cnt);
650 jm->collect_indices = 1;
654 // now send control ping so we know when it ends
655 vl_api_control_ping_t * mp;
656 M(CONTROL_PING, control_ping);
657 mp->context = clib_host_to_net_u32 (my_context_id);
665 jobjectArray result = sw_if_dump_get_interfaces(env);
670 static jobjectArray sw_if_dump_get_interfaces (JNIEnv * env)
672 vppjni_main_t * jm = &vppjni_main;
673 sw_interface_details_t *sw_if_details;
676 int len = vec_len(jm->sw_if_dump_if_indices);
678 jobjectArray ifArray = vppInterfaceDetailsArray(env, len);
680 for (i = 0; i < len; i++) {
681 u32 sw_if_index = jm->sw_if_dump_if_indices[i];
682 ASSERT(sw_if_index < vec_len(jm->sw_if_table));
683 sw_if_details = &jm->sw_if_table[sw_if_index];
684 ASSERT(sw_if_details->valid);
686 u8 * s = format (0, "%s%c", sw_if_details->interface_name, 0);
688 jstring ifname = (*env)->NewStringUTF(env, (char *)s);
689 jint ifIndex = sw_if_details->sw_if_index;
690 jint supIfIndex = sw_if_details->sup_sw_if_index;
691 jbyteArray physAddr = (*env)->NewByteArray(env,
692 sw_if_details->l2_address_length);
693 (*env)->SetByteArrayRegion(env, physAddr, 0,
694 sw_if_details->l2_address_length,
695 (signed char*)sw_if_details->l2_address);
696 jint subId = sw_if_details->sub_id;
697 jint subOuterVlanId = sw_if_details->sub_outer_vlan_id;
698 jint subInnerVlanId = sw_if_details->sub_inner_vlan_id;
699 jint vtrOp = sw_if_details->vtr_op;
700 jint vtrPushDot1q = sw_if_details->vtr_push_dot1q;
701 jint vtrTag1 = sw_if_details->vtr_tag1;
702 jint vtrTag2 = sw_if_details->vtr_tag2;
703 jint linkMtu = sw_if_details->link_mtu;
705 jbyte adminUpDown = sw_if_details->admin_up_down;
706 jbyte linkUpDown = sw_if_details->link_up_down;
707 jbyte linkDuplex = sw_if_details->link_duplex;
708 jbyte linkSpeed = sw_if_details->link_speed;
709 jbyte subDot1ad = sw_if_details->sub_dot1ad;
710 jbyte subNumberOfTags = sw_if_details->sub_number_of_tags;
711 jbyte subExactMatch = sw_if_details->sub_exact_match;
712 jbyte subDefault = sw_if_details->sub_default;
713 jbyte subOuterVlanIdAny = sw_if_details->sub_outer_vlan_id_any;
714 jbyte subInnerVlanIdAny = sw_if_details->sub_inner_vlan_id_any;
716 jobject ifObj = vppInterfaceDetailsObject(env,
718 supIfIndex, physAddr, adminUpDown, linkUpDown,
719 linkDuplex, linkSpeed, subId, subDot1ad,
720 subNumberOfTags, subOuterVlanId, subInnerVlanId,
721 subExactMatch, subDefault, subOuterVlanIdAny,
722 subInnerVlanIdAny, vtrOp, vtrPushDot1q, vtrTag1, vtrTag2, linkMtu);
723 (*env)->SetObjectArrayElement(env, ifArray, i, ifObj);
726 jm->collect_indices = 0;
727 vec_reset_length(jm->sw_if_dump_if_indices);
731 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_findOrAddBridgeDomainId0
732 (JNIEnv * env, jobject obj, jstring bridgeDomain)
734 vppjni_main_t * jm = &vppjni_main;
736 const char * bdName = (*env)->GetStringUTFChars (env, bridgeDomain, NULL);
738 static u8 * bd_name = 0;
740 vec_validate_init_c_string (bd_name, bdName, strlen(bdName));
741 (*env)->ReleaseStringUTFChars (env, bridgeDomain, bdName);
744 rv = (jint)vjbd_find_or_add_bd (&jm->vjbd_main, bd_name);
747 _vec_len(bd_name) = 0;
752 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_bridgeDomainIdFromName0
753 (JNIEnv * env, jobject obj, jstring bridgeDomain)
755 vppjni_main_t * jm = &vppjni_main;
757 const char * bdName = (*env)->GetStringUTFChars (env, bridgeDomain, NULL);
759 static u8 * bd_name = 0;
761 vec_validate_init_c_string (bd_name, bdName, strlen(bdName));
762 (*env)->ReleaseStringUTFChars (env, bridgeDomain, bdName);
764 vppjni_lock (jm, 20);
765 rv = (jint)vjbd_id_from_name(&jm->vjbd_main, (u8 *)bd_name);
768 _vec_len(bd_name) = 0;
774 JNIEXPORT jint JNICALL Java_org_openvpp_vppjapi_vppConn_bridgeDomainIdFromInterfaceName0
775 (JNIEnv * env, jobject obj, jstring interfaceName)
777 vppjni_main_t * jm = &vppjni_main;
778 vjbd_main_t * bdm = &jm->vjbd_main;
781 const char * if_name;
784 if_name = (*env)->GetStringUTFChars (env, interfaceName, NULL);
786 vppjni_lock (jm, 14);
788 p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name);
791 sw_if_index = (jint) p[0];
792 p = hash_get (bdm->bd_id_by_sw_if_index, sw_if_index);
800 (*env)->ReleaseStringUTFChars (env, interfaceName, if_name);
806 * Special-case: build the interface table, maintain
807 * the next loopback sw_if_index vbl.
809 static void vl_api_sw_interface_details_t_handler
810 (vl_api_sw_interface_details_t * mp)
812 vppjni_main_t * jm = &vppjni_main;
813 static sw_interface_details_t empty_sw_if_details = {0,};
814 sw_interface_details_t *sw_if_details;
819 sw_if_index = ntohl (mp->sw_if_index);
821 u8 * s = format (0, "%s%c", mp->interface_name, 0);
823 if (jm->collect_indices) {
824 u32 pos = vec_len(jm->sw_if_dump_if_indices);
825 vec_validate(jm->sw_if_dump_if_indices, pos);
826 jm->sw_if_dump_if_indices[pos] = sw_if_index;
829 vec_validate_init_empty(jm->sw_if_table, sw_if_index, empty_sw_if_details);
830 sw_if_details = &jm->sw_if_table[sw_if_index];
831 sw_if_details->valid = 1;
833 snprintf((char *)sw_if_details->interface_name,
834 sizeof(sw_if_details->interface_name), "%s", (char *)s);
835 sw_if_details->sw_if_index = sw_if_index;
836 sw_if_details->sup_sw_if_index = ntohl(mp->sup_sw_if_index);
837 sw_if_details->l2_address_length = ntohl (mp->l2_address_length);
838 ASSERT(sw_if_details->l2_address_length <= sizeof(sw_if_details->l2_address));
839 clib_memcpy(sw_if_details->l2_address, mp->l2_address,
840 sw_if_details->l2_address_length);
841 sw_if_details->sub_id = ntohl (mp->sub_id);
842 sw_if_details->sub_outer_vlan_id = ntohl (mp->sub_outer_vlan_id);
843 sw_if_details->sub_inner_vlan_id = ntohl (mp->sub_inner_vlan_id);
844 sw_if_details->vtr_op = ntohl (mp->vtr_op);
845 sw_if_details->vtr_push_dot1q = ntohl (mp->vtr_push_dot1q);
846 sw_if_details->vtr_tag1 = ntohl (mp->vtr_tag1);
847 sw_if_details->vtr_tag2 = ntohl (mp->vtr_tag2);
849 sw_if_details->admin_up_down = mp->admin_up_down;
850 sw_if_details->link_up_down = mp->link_up_down;
851 sw_if_details->link_duplex = mp->link_duplex;
852 sw_if_details->link_speed = mp->link_speed;
853 sw_if_details->sub_dot1ad = mp->sub_dot1ad;
854 sw_if_details->sub_number_of_tags = mp->sub_number_of_tags;
855 sw_if_details->sub_exact_match = mp->sub_exact_match;
856 sw_if_details->sub_default = mp->sub_default;
857 sw_if_details->sub_outer_vlan_id_any = mp->sub_outer_vlan_id_any;
858 sw_if_details->sub_inner_vlan_id_any = mp->sub_inner_vlan_id_any;
860 hash_set_mem (jm->sw_if_index_by_interface_name, s, sw_if_index);
861 DEBUG_LOG ("Got interface %s", (char *)s);
863 /* In sub interface case, fill the sub interface table entry */
864 if (mp->sw_if_index != mp->sup_sw_if_index) {
865 sw_interface_subif_t * sub = NULL;
867 vec_add2(jm->sw_if_subif_table, sub, 1);
869 vec_validate(sub->interface_name, strlen((char *)s) + 1);
870 strncpy((char *)sub->interface_name, (char *)s,
871 vec_len(sub->interface_name));
872 sub->sw_if_index = ntohl(mp->sw_if_index);
873 sub->sub_id = ntohl(mp->sub_id);
875 sub->sub_dot1ad = mp->sub_dot1ad;
876 sub->sub_number_of_tags = mp->sub_number_of_tags;
877 sub->sub_outer_vlan_id = ntohs(mp->sub_outer_vlan_id);
878 sub->sub_inner_vlan_id = ntohs(mp->sub_inner_vlan_id);
879 sub->sub_exact_match = mp->sub_exact_match;
880 sub->sub_default = mp->sub_default;
881 sub->sub_outer_vlan_id_any = mp->sub_outer_vlan_id_any;
882 sub->sub_inner_vlan_id_any = mp->sub_inner_vlan_id_any;
884 /* vlan tag rewrite */
885 sub->vtr_op = ntohl(mp->vtr_op);
886 sub->vtr_push_dot1q = ntohl(mp->vtr_push_dot1q);
887 sub->vtr_tag1 = ntohl(mp->vtr_tag1);
888 sub->vtr_tag2 = ntohl(mp->vtr_tag2);
893 static void vl_api_sw_interface_set_flags_t_handler
894 (vl_api_sw_interface_set_flags_t * mp)
896 /* $$$ nothing for the moment */
899 static jintArray create_array_of_bd_ids(JNIEnv * env, jint bd_id)
901 vppjni_main_t *jm = &vppjni_main;
902 vjbd_main_t * bdm = &jm->vjbd_main;
907 vec_add1(buf, bd_id);
909 for (i = 0; i < vec_len(bdm->bd_oper); i++) {
910 u32 bd_id = bdm->bd_oper[i].bd_id;
911 vec_add1(buf, bd_id);
915 jintArray bdidArray = (*env)->NewIntArray(env, vec_len(buf));
920 (*env)->SetIntArrayRegion(env, bdidArray, 0, vec_len(buf), (int*)buf);
927 static void bridge_domain_oper_free(void)
929 vppjni_main_t *jm = &vppjni_main;
930 vjbd_main_t *bdm = &jm->vjbd_main;
933 for (i = 0; i < vec_len(bdm->bd_oper); i++) {
934 vec_free(bdm->bd_oper->l2fib_oper);
936 vec_reset_length(bdm->bd_oper);
937 hash_free(bdm->bd_id_by_sw_if_index);
938 hash_free(bdm->oper_bd_index_by_bd_id);
941 JNIEXPORT jintArray JNICALL Java_org_openvpp_vppjapi_vppConn_bridgeDomainDump0
942 (JNIEnv * env, jobject obj, jint bd_id)
944 vppjni_main_t *jm = &vppjni_main;
945 vl_api_bridge_domain_dump_t * mp;
949 rv = vppjni_sanity_check (jm);
952 vppjni_lock (jm, 15);
955 bridge_domain_oper_free();
958 my_context_id = vppjni_get_context_id (jm);
959 M(BRIDGE_DOMAIN_DUMP, bridge_domain_dump);
960 mp->context = clib_host_to_net_u32 (my_context_id);
961 mp->bd_id = clib_host_to_net_u32(bd_id);
964 /* Use a control ping for synchronization */
966 vl_api_control_ping_t * mp;
967 M(CONTROL_PING, control_ping);
976 jintArray ret = create_array_of_bd_ids(env, bd_id);
984 vl_api_bridge_domain_details_t_handler (vl_api_bridge_domain_details_t * mp)
986 vppjni_main_t *jm = &vppjni_main;
987 vjbd_main_t * bdm = &jm->vjbd_main;
988 vjbd_oper_t * bd_oper;
991 bd_id = ntohl (mp->bd_id);
993 bd_index = vec_len(bdm->bd_oper);
994 vec_validate (bdm->bd_oper, bd_index);
995 bd_oper = vec_elt_at_index(bdm->bd_oper, bd_index);
997 hash_set(bdm->oper_bd_index_by_bd_id, bd_id, bd_index);
999 bd_oper->bd_id = bd_id;
1000 bd_oper->flood = mp->flood != 0;
1001 bd_oper->forward = mp->forward != 0;
1002 bd_oper->learn = mp->learn != 0;
1003 bd_oper->uu_flood = mp->uu_flood != 0;
1004 bd_oper->arp_term = mp->arp_term != 0;
1005 bd_oper->bvi_sw_if_index = ntohl (mp->bvi_sw_if_index);
1006 bd_oper->n_sw_ifs = ntohl (mp->n_sw_ifs);
1008 bd_oper->bd_sw_if_oper = 0;
1012 vl_api_bridge_domain_sw_if_details_t_handler
1013 (vl_api_bridge_domain_sw_if_details_t * mp)
1015 vppjni_main_t *jm = &vppjni_main;
1016 vjbd_main_t * bdm = &jm->vjbd_main;
1017 bd_sw_if_oper_t * bd_sw_if_oper;
1018 u32 bd_id, sw_if_index;
1020 bd_id = ntohl (mp->bd_id);
1021 sw_if_index = ntohl (mp->sw_if_index);
1024 p = hash_get (bdm->oper_bd_index_by_bd_id, bd_id);
1026 clib_warning("Invalid bd_id %d in bridge_domain_sw_if_details_t_handler", bd_id);
1029 u32 oper_bd_index = (jint) p[0];
1030 vjbd_oper_t *bd_oper = vec_elt_at_index(bdm->bd_oper, oper_bd_index);
1032 u32 len = vec_len(bd_oper->bd_sw_if_oper);
1033 vec_validate(bd_oper->bd_sw_if_oper, len);
1034 bd_sw_if_oper = &bd_oper->bd_sw_if_oper[len];
1035 bd_sw_if_oper->bd_id = bd_id;
1036 bd_sw_if_oper->sw_if_index = sw_if_index;
1037 bd_sw_if_oper->shg = mp->shg;
1039 hash_set(bdm->bd_id_by_sw_if_index, sw_if_index, bd_id);
1042 static const char* interface_name_from_sw_if_index(u32 sw_if_index)
1044 vppjni_main_t *jm = &vppjni_main;
1046 if (sw_if_index >= vec_len(jm->sw_if_table)) {
1049 if (!jm->sw_if_table[sw_if_index].valid) {
1052 return (const char*)jm->sw_if_table[sw_if_index].interface_name;
1055 JNIEXPORT jobject JNICALL Java_org_openvpp_vppjapi_vppConn_getBridgeDomainDetails0
1056 (JNIEnv * env, jobject obj, jint bdId)
1058 vppjni_main_t *jm = &vppjni_main;
1059 vjbd_main_t * bdm = &jm->vjbd_main;
1065 vppjni_lock (jm, 16);
1067 p = hash_get (bdm->oper_bd_index_by_bd_id, bd_id);
1072 oper_bd_index = (jint) p[0];
1074 vjbd_oper_t *bd_oper = vec_elt_at_index(bdm->bd_oper, oper_bd_index);
1077 /* setting BridgeDomainDetails */
1079 jobject bddObj = vppBridgeDomainDetailsObject(env);
1081 u8 *vec_bd_name = vjbd_oper_name_from_id(bdm, bd_id);
1082 if (NULL == vec_bd_name) {
1086 char *str_bd_name = (char*)format (0, "%s%c", vec_bd_name, 0);
1087 vec_free(vec_bd_name);
1088 jstring bdName = (*env)->NewStringUTF(env, str_bd_name);
1089 vec_free(str_bd_name);
1090 if (NULL == bdName) {
1095 set_vppBridgeDomainDetails_name(env, bddObj, bdName);
1096 set_vppBridgeDomainDetails_bdId(env, bddObj, bdId);
1097 set_vppBridgeDomainDetails_flood(env, bddObj, (jboolean)bd_oper->flood);
1098 set_vppBridgeDomainDetails_uuFlood(env, bddObj, (jboolean)bd_oper->uu_flood);
1099 set_vppBridgeDomainDetails_forward(env, bddObj, (jboolean)bd_oper->forward);
1100 set_vppBridgeDomainDetails_learn(env, bddObj, (jboolean)bd_oper->learn);
1101 set_vppBridgeDomainDetails_arpTerm(env, bddObj, (jboolean)bd_oper->arp_term);
1103 jstring bviInterfaceName = NULL;
1104 if (~0 != bd_oper->bvi_sw_if_index) {
1105 const char *str_if_name = interface_name_from_sw_if_index(bd_oper->bvi_sw_if_index);
1106 if (NULL == str_if_name) {
1107 clib_warning("Could not get interface name for sw_if_index %d", bd_oper->bvi_sw_if_index);
1111 bviInterfaceName = (*env)->NewStringUTF(env, str_if_name);
1112 if (NULL == bviInterfaceName) {
1118 set_vppBridgeDomainDetails_bviInterfaceName(env, bddObj, bviInterfaceName);
1120 /* setting BridgeDomainInterfaceDetails */
1122 u32 len = vec_len(bd_oper->bd_sw_if_oper);
1123 ASSERT(len == bd_oper->n_sw_ifs);
1125 jobjectArray bdidArray = vppBridgeDomainInterfaceDetailsArray(env, len);
1128 for (i = 0; i < len; i++) {
1129 bd_sw_if_oper_t *sw_if_oper = &bd_oper->bd_sw_if_oper[i];
1131 jobject bdidObj = vppBridgeDomainInterfaceDetailsObject(env);
1132 (*env)->SetObjectArrayElement(env, bdidArray, i, bdidObj);
1134 u32 sw_if_index = sw_if_oper->sw_if_index;
1135 const char *str_if_name = interface_name_from_sw_if_index(sw_if_index);
1136 if (NULL == str_if_name) {
1140 jstring interfaceName = (*env)->NewStringUTF(env, str_if_name);
1141 if (NULL == interfaceName) {
1146 set_vppBridgeDomainInterfaceDetails_interfaceName(env, bdidObj, interfaceName);
1147 set_vppBridgeDomainInterfaceDetails_splitHorizonGroup(env, bdidObj, (jbyte)sw_if_oper->shg);
1150 set_vppBridgeDomainDetails_interfaces(env, bddObj, bdidArray);
1161 static jobject l2_fib_create_object(JNIEnv *env, bd_l2fib_oper_t *l2_fib)
1163 u32 sw_if_index = l2_fib->sw_if_index;
1164 const char *str_if_name = interface_name_from_sw_if_index(sw_if_index);
1165 if (NULL == str_if_name) {
1168 jstring interfaceName = (*env)->NewStringUTF(env, str_if_name);
1169 if (NULL == interfaceName) {
1173 jbyteArray physAddr = (*env)->NewByteArray(env, 6);
1174 (*env)->SetByteArrayRegion(env, physAddr, 0, 6,
1175 (signed char*)l2_fib->mac_addr.fields.mac);
1176 jboolean staticConfig = !l2_fib->learned;
1177 jstring outgoingInterface = interfaceName;
1178 jboolean filter = l2_fib->filter;
1179 jboolean bridgedVirtualInterface = l2_fib->bvi;
1181 return vppL2FibObject(env, physAddr, staticConfig, outgoingInterface, filter, bridgedVirtualInterface);
1184 JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_l2FibTableDump0
1185 (JNIEnv * env, jobject obj, jint bd_id)
1187 vppjni_main_t *jm = &vppjni_main;
1188 vjbd_main_t * bdm = &jm->vjbd_main;
1189 vl_api_l2_fib_table_dump_t *mp;
1190 jobjectArray l2FibArray = NULL;
1191 vjbd_oper_t *bd_oper;
1198 vppjni_lock (jm, 17);
1200 //vjbd_l2fib_oper_reset (bdm);
1202 p = hash_get (bdm->oper_bd_index_by_bd_id, bd_id);
1206 oper_bd_index = p[0];
1207 bd_oper = vec_elt_at_index(bdm->bd_oper, oper_bd_index);
1208 vec_reset_length (bd_oper->l2fib_oper);
1210 /* Get list of l2 fib table entries */
1211 M(L2_FIB_TABLE_DUMP, l2_fib_table_dump);
1212 mp->bd_id = ntohl(bd_id);
1215 /* Use a control ping for synchronization */
1217 vl_api_control_ping_t * mp;
1218 M(CONTROL_PING, control_ping);
1227 u32 count = vec_len(bd_oper->l2fib_oper);
1228 bd_l2fib_oper_t *l2fib_oper = bd_oper->l2fib_oper;
1230 l2FibArray = vppL2FibArray(env, count);
1231 for (i = 0; i < count; i++) {
1232 bd_l2fib_oper_t *l2_fib = &l2fib_oper[i];
1233 jobject l2FibObj = l2_fib_create_object(env, l2_fib);
1234 (*env)->SetObjectArrayElement(env, l2FibArray, i, l2FibObj);
1244 vl_api_l2_fib_table_entry_t_handler (vl_api_l2_fib_table_entry_t * mp)
1246 //static u8 * mac_addr;
1247 vppjni_main_t *jm = &vppjni_main;
1248 vjbd_main_t * bdm = &jm->vjbd_main;
1249 vjbd_oper_t * bd_oper;
1250 u32 bd_id, oper_bd_index;
1251 //uword mhash_val_l2fi;
1252 bd_l2fib_oper_t * l2fib_oper;
1253 l2fib_u64_mac_t * l2fe_u64_mac = (l2fib_u64_mac_t *)&mp->mac;
1255 bd_id = ntohl (mp->bd_id);
1257 uword *p = hash_get (bdm->oper_bd_index_by_bd_id, bd_id);
1261 oper_bd_index = (jint) p[0];
1262 bd_oper = vec_elt_at_index(bdm->bd_oper, oper_bd_index);
1265 vec_validate (mac_addr, MAC_ADDRESS_SIZE);
1266 clib_memcpy (mac_addr, l2fe_u64_mac->fields.mac, MAC_ADDRESS_SIZE);
1267 mhash_val_l2fi = vec_len (bd_oper->l2fib_oper);
1268 if (mhash_elts (&bd_oper->l2fib_index_by_mac) == 0)
1269 mhash_init (&bd_oper->l2fib_index_by_mac, sizeof (u32), MAC_ADDRESS_SIZE);
1270 mhash_set_mem (&bd_oper->l2fib_index_by_mac, mac_addr, &mhash_val_l2fi, 0);
1273 vec_add2 (bd_oper->l2fib_oper, l2fib_oper, 1);
1275 l2fib_oper->bd_id = bd_id;
1276 l2fib_oper->mac_addr.raw = l2fib_mac_to_u64 (l2fe_u64_mac->fields.mac);
1277 l2fib_oper->sw_if_index = ntohl (mp->sw_if_index);
1278 l2fib_oper->learned = !mp->static_mac;
1279 l2fib_oper->filter = mp->filter_mac;
1280 l2fib_oper->bvi = mp->bvi_mac;
1283 static int ipAddressDump
1284 (JNIEnv * env, jobject obj, jstring interfaceName, jboolean isIPv6)
1286 vppjni_main_t *jm = &vppjni_main;
1287 vl_api_ip_address_dump_t * mp;
1288 const char *if_name;
1295 if (NULL == interfaceName) {
1299 if_name = (*env)->GetStringUTFChars (env, interfaceName, NULL);
1304 p = hash_get_mem (jm->sw_if_index_by_interface_name, if_name);
1305 (*env)->ReleaseStringUTFChars (env, interfaceName, if_name);
1309 sw_if_index = (u32) p[0];
1311 rv = vppjni_sanity_check (jm);
1316 my_context_id = vppjni_get_context_id (jm);
1317 M(IP_ADDRESS_DUMP, ip_address_dump);
1318 mp->context = clib_host_to_net_u32 (my_context_id);
1319 mp->sw_if_index = clib_host_to_net_u32(sw_if_index);
1320 mp->is_ipv6 = isIPv6;
1321 jm->is_ipv6 = isIPv6;
1324 /* Use a control ping for synchronization */
1326 vl_api_control_ping_t * mp;
1327 M(CONTROL_PING, control_ping);
1336 JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_ipv4AddressDump0
1337 (JNIEnv * env, jobject obj, jstring interfaceName)
1339 vppjni_main_t *jm = &vppjni_main;
1340 jobject returnArray = NULL;
1343 vppjni_lock (jm, 18);
1345 vec_reset_length(jm->ipv4_addresses);
1347 if (0 != ipAddressDump(env, obj, interfaceName, 0)) {
1351 u32 count = vec_len(jm->ipv4_addresses);
1352 ipv4_address_t *ipv4_address = jm->ipv4_addresses;
1354 jobjectArray ipv4AddressArray = vppIPv4AddressArray(env, count);
1356 for (i = 0; i < count; i++) {
1357 ipv4_address_t *address = &ipv4_address[i];
1359 jint ip = address->ip;
1360 jbyte prefixLength = address->prefix_length;
1362 jobject ipv4AddressObj = vppIPv4AddressObject(env, ip, prefixLength);
1364 (*env)->SetObjectArrayElement(env, ipv4AddressArray, i, ipv4AddressObj);
1367 returnArray = ipv4AddressArray;
1374 JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_ipv6AddressDump0
1375 (JNIEnv * env, jobject obj, jstring interfaceName)
1377 vppjni_main_t *jm = &vppjni_main;
1378 jobject returnArray = NULL;
1381 vppjni_lock (jm, 19);
1383 vec_reset_length(jm->ipv6_addresses);
1385 if (0 != ipAddressDump(env, obj, interfaceName, 1)) {
1389 u32 count = vec_len(jm->ipv6_addresses);
1390 ipv6_address_t *ipv6_address = jm->ipv6_addresses;
1392 jobjectArray ipv6AddressArray = vppIPv6AddressArray(env, count);
1394 for (i = 0; i < count; i++) {
1395 ipv6_address_t *address = &ipv6_address[i];
1397 jbyteArray ip = (*env)->NewByteArray(env, 16);
1398 (*env)->SetByteArrayRegion(env, ip, 0, 16,
1399 (signed char*)address->ip);
1401 jbyte prefixLength = address->prefix_length;
1403 jobject ipv6AddressObj = vppIPv6AddressObject(env, ip, prefixLength);
1405 (*env)->SetObjectArrayElement(env, ipv6AddressArray, i, ipv6AddressObj);
1408 returnArray = ipv6AddressArray;
1415 static void vl_api_ip_address_details_t_handler (vl_api_ip_address_details_t * mp)
1417 vppjni_main_t * jm = &vppjni_main;
1420 ipv4_address_t *address = 0;
1421 vec_add2(jm->ipv4_addresses, address, 1);
1422 clib_memcpy(&address->ip, mp->ip, 4);
1423 address->prefix_length = mp->prefix_length;
1425 ipv6_address_t *address = 0;
1426 vec_add2(jm->ipv6_addresses, address, 1);
1427 clib_memcpy(address->ip, mp->ip, 16);
1428 address->prefix_length = mp->prefix_length;
1432 #define VXLAN_TUNNEL_INTERFACE_NAME_PREFIX "vxlan_tunnel"
1434 JNIEXPORT jobjectArray JNICALL Java_org_openvpp_vppjapi_vppConn_vxlanTunnelDump0
1435 (JNIEnv * env, jobject obj, jint swIfIndex)
1437 vppjni_main_t *jm = &vppjni_main;
1438 vl_api_vxlan_tunnel_dump_t * mp;
1439 jobjectArray returnArray = NULL;
1445 vppjni_lock (jm, 22);
1447 vec_reset_length(jm->vxlan_tunnel_details);
1449 my_context_id = vppjni_get_context_id (jm);
1450 M(VXLAN_TUNNEL_DUMP, vxlan_tunnel_dump);
1451 mp->context = clib_host_to_net_u32 (my_context_id);
1452 mp->sw_if_index = clib_host_to_net_u32 (swIfIndex);
1455 /* Use a control ping for synchronization */
1457 vl_api_control_ping_t * mp;
1458 M(CONTROL_PING, control_ping);
1467 u32 count = vec_len(jm->vxlan_tunnel_details);
1469 jobjectArray vxlanTunnelDetailsArray = vppVxlanTunnelDetailsArray(env, count);
1471 for (i = 0; i < count; i++) {
1472 vxlan_tunnel_details_t *details = &jm->vxlan_tunnel_details[i];
1474 jint src_address = details->src_address;
1475 jint dst_address = details->dst_address;
1476 jint encap_vrf_id = details->encap_vrf_id;
1477 jint vni = details->vni;
1478 jint decap_next_index = details->decap_next_index;
1480 jobject vxlanTunnelDetailsObj = vppVxlanTunnelDetailsObject(env,
1481 src_address, dst_address, encap_vrf_id, vni, decap_next_index);
1483 (*env)->SetObjectArrayElement(env, vxlanTunnelDetailsArray, i,
1484 vxlanTunnelDetailsObj);
1487 returnArray = vxlanTunnelDetailsArray;
1494 static void vl_api_vxlan_tunnel_details_t_handler
1495 (vl_api_vxlan_tunnel_details_t * mp)
1497 vppjni_main_t * jm = &vppjni_main;
1498 vxlan_tunnel_details_t *tunnel_details;
1500 vec_add2(jm->vxlan_tunnel_details, tunnel_details, 1);
1501 tunnel_details->src_address = ntohl(mp->src_address);
1502 tunnel_details->dst_address = ntohl(mp->dst_address);
1503 tunnel_details->encap_vrf_id = ntohl(mp->encap_vrf_id);
1504 tunnel_details->vni = ntohl(mp->vni);
1505 tunnel_details->decap_next_index = ntohl(mp->decap_next_index);
1508 /* cleanup handler for RX thread */
1509 static void cleanup_rx_thread(void *arg)
1511 vppjni_main_t * jm = &vppjni_main;
1513 vppjni_lock (jm, 99);
1515 int getEnvStat = (*jm->jvm)->GetEnv(jm->jvm, (void **)&(jm->jenv), JNI_VERSION_1_6);
1516 if (getEnvStat == JNI_EVERSION) {
1517 clib_warning ("Unsupported JNI version\n");
1520 } else if (getEnvStat != JNI_EDETACHED) {
1521 (*jm->jvm)->DetachCurrentThread(jm->jvm);
1528 vl_api_show_version_reply_t_handler (vl_api_show_version_reply_t * mp)
1530 vppjni_main_t * jm = &vppjni_main;
1531 i32 retval = ntohl(mp->retval);
1534 DEBUG_LOG ("show version request succeeded(%d)");
1535 strncpy((char*)jm->program_name, (const char*)mp->program,
1536 sizeof(jm->program_name)-1);
1537 jm->program_name[sizeof(jm->program_name)-1] = 0;
1539 strncpy((char*)jm->build_directory, (const char*)mp->build_directory,
1540 sizeof(jm->build_directory)-1);
1541 jm->build_directory[sizeof(jm->build_directory)-1] = 0;
1543 strncpy((char*)jm->version, (const char*)mp->version,
1544 sizeof(jm->version)-1);
1545 jm->version[sizeof(jm->version)-1] = 0;
1547 strncpy((char*)jm->build_date, (const char*)mp->build_date,
1548 sizeof(jm->build_date)-1);
1549 jm->build_date[sizeof(jm->build_date)-1] = 0;
1551 clib_error ("show version request failed(%d)", retval);
1553 jm->retval = retval;
1554 jm->result_ready = 1;
1557 static void vl_api_want_stats_reply_t_handler (vl_api_want_stats_reply_t * mp)
1559 vppjni_main_t * jm = &vppjni_main;
1560 jm->retval = mp->retval; // FIXME: vpp api does not do ntohl on this retval
1561 jm->result_ready = 1;
1564 // control ping needs to be very first thing called
1565 // to attach rx thread to java thread
1566 static void vl_api_control_ping_reply_t_handler
1567 (vl_api_control_ping_reply_t * mp)
1569 vppjni_main_t * jm = &vppjni_main;
1570 i32 retval = ntohl(mp->retval);
1571 jm->retval = retval;
1573 // attach to java thread if not attached
1574 int getEnvStat = (*jm->jvm)->GetEnv(jm->jvm, (void **)&(jm->jenv), JNI_VERSION_1_6);
1575 if (getEnvStat == JNI_EDETACHED) {
1576 if ((*jm->jvm)->AttachCurrentThread(jm->jvm, (void **)&(jm->jenv), NULL) != 0) {
1577 clib_warning("Failed to attach thread\n");
1582 // workaround as we can't use pthread_cleanup_push
1583 pthread_key_create(&jm->cleanup_rx_thread_key, cleanup_rx_thread);
1584 // destructor is only called if the value of key is non null
1585 pthread_setspecific(jm->cleanup_rx_thread_key, (void *)1);
1586 } else if (getEnvStat == JNI_EVERSION) {
1587 clib_warning ("Unsupported JNI version\n");
1591 // jm->jenv is now stable global reference that can be reused (only within RX thread)
1594 // ! callback system removed for now
1596 // get issuer msg-id
1597 p = hash_get (jm->ping_hash, context);
1598 if (p != 0) { // ping marks end of some dump call
1599 JNIEnv *env = jm->jenv;
1600 u16 msg_id = (u16)p[0];
1602 // we will no longer need this
1603 hash_unset (jm->ping_hash, context);
1605 // get original caller obj
1606 p = hash_get (jm->callback_hash, context);
1608 if (p == 0) // don't have callback stored
1611 jobject obj = (jobject)p[0]; // object that called original call
1614 case VL_API_SW_INTERFACE_DUMP:
1615 if (0 != sw_if_dump_call_all_callbacks(obj)) {
1620 clib_warning("Unhandled control ping issuer msg-id: %d", msg_id);
1625 // free the saved obj
1626 hash_unset (jm->callback_hash, context);
1627 // delete global reference
1628 (*env)->DeleteGlobalRef(env, obj);
1633 jm->result_ready = 1;
1636 #define VPPJNI_DEBUG_COUNTERS 0
1638 static void vl_api_vnet_interface_counters_t_handler
1639 (vl_api_vnet_interface_counters_t *mp)
1641 vppjni_main_t *jm = &vppjni_main;
1642 CLIB_UNUSED(char *counter_name);
1643 u32 count, sw_if_index;
1645 static sw_interface_stats_t empty_stats = {0, };
1647 vppjni_lock (jm, 12);
1648 count = ntohl (mp->count);
1649 sw_if_index = ntohl (mp->first_sw_if_index);
1650 if (mp->is_combined == 0) {
1652 vp = (u64 *) mp->data;
1654 for (i = 0; i < count; i++) {
1655 sw_interface_details_t *sw_if = NULL;
1657 v = clib_mem_unaligned (vp, u64);
1658 v = clib_net_to_host_u64 (v);
1661 if (sw_if_index < vec_len(jm->sw_if_table))
1662 sw_if = vec_elt_at_index(jm->sw_if_table, sw_if_index);
1664 if (sw_if /* && (sw_if->admin_up_down == 1)*/ && sw_if->interface_name[0] != 0) {
1665 vec_validate_init_empty(jm->sw_if_stats_by_sw_if_index, sw_if_index, empty_stats);
1666 sw_interface_stats_t * s = vec_elt_at_index(jm->sw_if_stats_by_sw_if_index, sw_if_index);
1668 s->sw_if_index = sw_if_index;
1671 switch (mp->vnet_counter_type) {
1672 case VNET_INTERFACE_COUNTER_DROP:
1673 counter_name = "drop";
1674 s->rx.pkts.discard = v;
1676 case VNET_INTERFACE_COUNTER_PUNT:
1677 counter_name = "punt";
1678 s->rx.pkts.unknown_proto = v;
1680 case VNET_INTERFACE_COUNTER_IP4:
1681 counter_name = "ip4";
1684 case VNET_INTERFACE_COUNTER_IP6:
1685 counter_name = "ip6";
1688 case VNET_INTERFACE_COUNTER_RX_NO_BUF:
1689 counter_name = "rx-no-buf";
1690 s->rx.pkts.fifo_full = v;
1692 case VNET_INTERFACE_COUNTER_RX_MISS:
1693 counter_name = "rx-miss";
1694 s->rx.pkts.miss = v;
1696 case VNET_INTERFACE_COUNTER_RX_ERROR:
1697 counter_name = "rx-error";
1698 s->rx.pkts.error = v;
1700 case VNET_INTERFACE_COUNTER_TX_ERROR:
1701 counter_name = "tx-error (fifo-full)";
1702 s->tx.pkts.fifo_full = v;
1705 counter_name = "bogus";
1709 #if VPPJNI_DEBUG_COUNTERS == 1
1710 clib_warning ("%s (%d): %s (%lld)\n", sw_if->interface_name, s->sw_if_index,
1719 vp = (vlib_counter_t *) mp->data;
1721 for (i = 0; i < count; i++) {
1722 sw_interface_details_t *sw_if = NULL;
1724 packets = clib_mem_unaligned (&vp->packets, u64);
1725 packets = clib_net_to_host_u64 (packets);
1726 bytes = clib_mem_unaligned (&vp->bytes, u64);
1727 bytes = clib_net_to_host_u64 (bytes);
1730 if (sw_if_index < vec_len(jm->sw_if_table))
1731 sw_if = vec_elt_at_index(jm->sw_if_table, sw_if_index);
1733 if (sw_if /* && (sw_if->admin_up_down == 1) */ && sw_if->interface_name[0] != 0) {
1734 vec_validate_init_empty(jm->sw_if_stats_by_sw_if_index, sw_if_index, empty_stats);
1735 sw_interface_stats_t * s = vec_elt_at_index(jm->sw_if_stats_by_sw_if_index, sw_if_index);
1738 s->sw_if_index = sw_if_index;
1740 switch (mp->vnet_counter_type) {
1741 case VNET_INTERFACE_COUNTER_RX:
1742 s->rx.pkts.unicast = packets;
1743 s->rx.octets = bytes;
1744 counter_name = "rx";
1747 case VNET_INTERFACE_COUNTER_TX:
1748 s->tx.pkts.unicast = packets;
1749 s->tx.octets = bytes;
1750 counter_name = "tx";
1754 counter_name = "bogus";
1758 #if VPPJNI_DEBUG_COUNTERS == 1
1759 clib_warning ("%s (%d): %s.packets %lld\n",
1760 sw_if->interface_name,
1761 sw_if_index, counter_name, packets);
1762 clib_warning ("%s (%d): %s.bytes %lld\n",
1763 sw_if->interface_name,
1764 sw_if_index, counter_name, bytes);
1773 jint JNI_OnLoad(JavaVM *vm, void *reserved) {
1774 vppjni_main_t * jm = &vppjni_main;
1776 if ((*vm)->GetEnv(vm, (void**) &env, JNI_VERSION_1_6) != JNI_OK) {
1780 if (vppjni_init(env) != 0) {
1785 return JNI_VERSION_1_6;
1788 void JNI_OnUnload(JavaVM *vm, void *reserved) {
1789 vppjni_main_t * jm = &vppjni_main;
1791 if ((*vm)->GetEnv(vm, (void**) &env, JNI_VERSION_1_6) != JNI_OK) {
1801 #define foreach_vpe_api_msg \
1802 _(CONTROL_PING_REPLY, control_ping_reply) \
1803 _(SW_INTERFACE_DETAILS, sw_interface_details) \
1804 _(SHOW_VERSION_REPLY, show_version_reply) \
1805 _(WANT_STATS_REPLY, want_stats_reply) \
1806 _(VNET_INTERFACE_COUNTERS, vnet_interface_counters) \
1807 _(SW_INTERFACE_SET_FLAGS, sw_interface_set_flags) \
1808 _(BRIDGE_DOMAIN_DETAILS, bridge_domain_details) \
1809 _(BRIDGE_DOMAIN_SW_IF_DETAILS, bridge_domain_sw_if_details) \
1810 _(L2_FIB_TABLE_ENTRY, l2_fib_table_entry) \
1811 _(IP_ADDRESS_DETAILS, ip_address_details) \
1812 _(VXLAN_TUNNEL_DETAILS, vxlan_tunnel_details)
1814 static int connect_to_vpe(char *name)
1816 vppjni_main_t * jm = &vppjni_main;
1817 api_main_t * am = &api_main;
1819 if (vl_client_connect_to_vlib("/vpe-api", name, 32) < 0)
1822 jm->my_client_index = am->my_client_index;
1823 jm->vl_input_queue = am->shmem_hdr->vl_input_queue;
1826 vl_msg_api_set_handlers(VL_API_##N, #n, \
1827 vl_api_##n##_t_handler, \
1829 vl_api_##n##_t_endian, \
1830 vl_api_##n##_t_print, \
1831 sizeof(vl_api_##n##_t), 1);
1832 foreach_vpe_api_msg;
1838 /* Format an IP6 address. */
1839 u8 * format_ip6_address (u8 * s, va_list * args)
1841 ip6_address_t * a = va_arg (*args, ip6_address_t *);
1842 u32 max_zero_run = 0, this_zero_run = 0;
1843 int max_zero_run_index = -1, this_zero_run_index=0;
1844 int in_zero_run = 0, i;
1845 int last_double_colon = 0;
1847 /* Ugh, this is a pain. Scan forward looking for runs of 0's */
1848 for (i = 0; i < ARRAY_LEN (a->as_u16); i++) {
1849 if (a->as_u16[i] == 0) {
1855 this_zero_run_index = i;
1859 /* offer to compress the biggest run of > 1 zero */
1860 if (this_zero_run > max_zero_run && this_zero_run > 1) {
1861 max_zero_run_index = this_zero_run_index;
1862 max_zero_run = this_zero_run;
1871 if (this_zero_run > max_zero_run && this_zero_run > 1) {
1872 max_zero_run_index = this_zero_run_index;
1873 max_zero_run = this_zero_run;
1877 for (i = 0; i < ARRAY_LEN (a->as_u16); i++) {
1878 if (i == max_zero_run_index) {
1879 s = format (s, "::");
1880 i += max_zero_run - 1;
1881 last_double_colon = 1;
1883 s = format (s, "%s%x",
1884 (last_double_colon || i == 0) ? "" : ":",
1885 clib_net_to_host_u16 (a->as_u16[i]));
1886 last_double_colon = 0;
1893 /* Format an IP4 address. */
1894 u8 * format_ip4_address (u8 * s, va_list * args)
1896 u8 * a = va_arg (*args, u8 *);
1897 return format (s, "%d.%d.%d.%d", a[0], a[1], a[2], a[3]);