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 #ifndef __included_vppjni_h__
16 #define __included_vppjni_h__
18 #include <vnet/vnet.h>
19 #include <vnet/ip/ip.h>
20 #include <vnet/api_errno.h>
21 #include <vlibapi/api.h>
22 #include <vlibmemory/api.h>
24 #include <japi/vppjni_bridge_domain.h>
32 u8 valid; // used in a vector of sw_interface_details_t
34 u8 interface_name[64];
37 u32 l2_address_length;
45 u8 sub_number_of_tags;
46 u16 sub_outer_vlan_id;
47 u16 sub_inner_vlan_id;
50 u8 sub_outer_vlan_id_any;
51 u8 sub_inner_vlan_id_any;
56 } sw_interface_details_t;
62 * Subinterface ID. A number 0-N to uniquely identify
63 * this subinterface under the super interface
67 /* 0 = dot1q, 1=dot1ad */
70 /* Number of tags 0-2 */
71 u8 sub_number_of_tags;
72 u16 sub_outer_vlan_id;
73 u16 sub_inner_vlan_id;
76 u8 sub_outer_vlan_id_any;
77 u8 sub_inner_vlan_id_any;
79 /* vlan tag rewrite */
84 } sw_interface_subif_t;
101 packet_counters_t pkts;
109 } sw_interface_stats_t;
114 volatile u32 context_id_sent;
115 volatile u32 context_id_received;
121 /* To recycle pseudo-synchronous message code from vpe_api_test... */
122 volatile u32 result_ready;
124 volatile u8 *shmem_result;
127 pthread_key_t cleanup_rx_thread_key;
128 /* attachment of rx thread to java thread */
132 jmethodID jmtdIfDetails; // interfaceDetails method
133 uword *callback_hash; // map context_id => jobject
134 uword *ping_hash; // map ping context_id => msg type called
137 clib_time_t clib_time;
139 /* connected indication */
142 /* context -> non-trivial reply hash */
144 u32 saved_reply_count;
146 /* interface name map */
147 uword * sw_if_index_by_interface_name;
149 /* interface counters */
150 sw_interface_stats_t * sw_if_stats_by_sw_if_index;
152 /* interface table */
153 sw_interface_details_t * sw_if_table;
155 /* interface indices of responses to one sw_if_dump request */
157 u32 * sw_if_dump_if_indices;
159 /* program name, build_dir, version */
161 u8 build_directory[256];
165 /* subinterface table */
166 sw_interface_subif_t * sw_if_subif_table;
172 unix_shared_memory_queue_t * vl_input_queue;
173 api_main_t * api_main;
176 vjbd_main_t vjbd_main;
179 vppjni_main_t vppjni_main __attribute__((aligned (64)));
182 static inline u32 vppjni_get_context_id (vppjni_main_t * jm)
185 my_context_id = __sync_add_and_fetch (&jm->context_id_sent, 1);
186 return my_context_id;
189 static inline void vppjni_lock (vppjni_main_t * jm, u32 tag)
191 while (__sync_lock_test_and_set (&jm->lock, 1))
196 static inline void vppjni_unlock (vppjni_main_t * jm)
199 CLIB_MEMORY_BARRIER();
203 static inline f64 vppjni_time_now (vppjni_main_t *jm)
205 return clib_time_now (&jm->clib_time);
208 static inline int vppjni_sanity_check (vppjni_main_t * jm)
210 if (!jm->is_connected)
211 return VNET_API_ERROR_NOT_CONNECTED;
215 #define __PACKED(x) x __attribute__((packed))
217 typedef __PACKED(struct _vl_api_generic_reply {
222 }) vl_api_generic_reply_t;
224 void vl_api_generic_reply_handler (vl_api_generic_reply_t *mp);
226 /* M: construct, but don't yet send a message */
230 jm->result_ready = 0; \
231 mp = vl_msg_api_alloc(sizeof(*mp)); \
232 memset (mp, 0, sizeof (*mp)); \
233 mp->_vl_msg_id = ntohs (VL_API_##T); \
234 mp->client_index = jm->my_client_index; \
239 jm->result_ready = 0; \
240 mp = vl_msg_api_alloc(sizeof(*mp)+(n)); \
241 memset (mp, 0, sizeof (*mp)); \
242 mp->_vl_msg_id = ntohs (VL_API_##T); \
243 mp->client_index = jm->my_client_index; \
247 /* S: send a message */
248 #define S (vl_msg_api_send_shmem (jm->vl_input_queue, (u8 *)&mp))
250 /* W: wait for results, with timeout */
253 timeout = vppjni_time_now (jm) + 1.0; \
255 while (vppjni_time_now (jm) < timeout) { \
256 if (jm->result_ready == 1) { \
257 return (jm->retval); \
263 /* WNR: wait for results, with timeout (without returning) */
266 timeout = vppjni_time_now (jm) + 1.0; \
269 while (vppjni_time_now (jm) < timeout) { \
270 if (jm->result_ready == 1) { \
277 #endif /* __included_vppjni_h__ */