Gitiles
Code Review Sign In
gerrit.nordix.org / fdio / vpp / d72a034bf9e12aabdb1df21cab0a5c86a3dca8fa / . / src / vlibapi / vat_helper_macros.h
blob: 239e2091dc1ddb1c7b1147b098da43379eb9215b [file] [log] [blame]
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]1/*
2 *------------------------------------------------------------------
3 * vat_helper_macros.h - collect api client helper macros in one place
4 *
5 * Copyright (c) 2016 Cisco and/or its affiliates.
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at:
9 *
10 * http://www.apache.org/licenses/LICENSE-2.0
11 *
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
17 *------------------------------------------------------------------
18 */
19#ifndef __vat_helper_macros_h__
20#define __vat_helper_macros_h__
21
22/* M: construct, but don't yet send a message */
Jon Loeliger614e97d2017-01-31 13:47:08 -0600[diff] [blame]23#define M(T, mp) \
Dave Barach2d6b2d62017-01-25 16:32:08 -0500[diff] [blame]24do { \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]25 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barach2d6b2d62017-01-25 16:32:08 -0500[diff] [blame]26 vam->result_ready = 0; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]27 if (scm && scm->socket_enable) \
28 mp = vl_socket_client_msg_alloc (sizeof(*mp)); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]29 else \
30 mp = vl_msg_api_alloc_as_if_client(sizeof(*mp)); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]31 clib_memset (mp, 0, sizeof (*mp)); \
Dave Barach2d6b2d62017-01-25 16:32:08 -0500[diff] [blame]32 mp->_vl_msg_id = ntohs (VL_API_##T+__plugin_msg_base); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]33 mp->client_index = vam->my_client_index; \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]34} while(0);
35
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]36/* MPING: construct a control-ping message, don't send it yet */
37#define MPING(T, mp) \
38do { \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]39 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]40 vam->result_ready = 0; \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]41 if (scm && scm->socket_enable) \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]42 mp = vl_socket_client_msg_alloc (sizeof(*mp)); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]43 else \
44 mp = vl_msg_api_alloc_as_if_client(sizeof(*mp)); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]45 clib_memset (mp, 0, sizeof (*mp)); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]46 mp->_vl_msg_id = ntohs (VL_API_##T+__plugin_msg_base); \
47 mp->client_index = vam->my_client_index; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]48 if (scm) \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]49 scm->control_pings_outstanding++; \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]50} while(0);
51
Jon Loeliger614e97d2017-01-31 13:47:08 -0600[diff] [blame]52#define M2(T, mp, n) \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]53do { \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]54 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]55 vam->result_ready = 0; \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]56 if (scm && scm->socket_enable) \
57 mp = vl_socket_client_msg_alloc (sizeof(*mp) + n); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]58 else \
59 mp = vl_msg_api_alloc_as_if_client(sizeof(*mp) + n); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]60 clib_memset (mp, 0, sizeof (*mp)); \
Dave Barach2d6b2d62017-01-25 16:32:08 -0500[diff] [blame]61 mp->_vl_msg_id = ntohs (VL_API_##T+__plugin_msg_base); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]62 mp->client_index = vam->my_client_index; \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]63} while(0);
64
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]65/* S: send a message */
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]66#define S(mp) \
67do { \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]68 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]69 if (scm && scm->socket_enable) \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]70 vl_socket_client_write (); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]71 else \
72 vl_msg_api_send_shmem (vam->vl_input_queue, (u8 *)&mp); \
73 } while (0);
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]74
75/* W: wait for results, with timeout */
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]76#define W(ret) \
77do { \
78 f64 timeout = vat_time_now (vam) + 1.0; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]79 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]80 ret = -99; \
81 \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]82 if (scm && scm->socket_enable) \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]83 vl_socket_client_read (5); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]84 while (vat_time_now (vam) < timeout) { \
85 if (vam->result_ready == 1) { \
86 ret = vam->retval; \
87 break; \
88 } \
89 vat_suspend (vam->vlib_main, 1e-5); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]90 } \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]91} while(0);
92
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]93/* W2: wait for results, with timeout */ \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]94#define W2(ret, body) \
95do { \
96 f64 timeout = vat_time_now (vam) + 1.0; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]97 socket_client_main_t *scm = vam->socket_client_main; \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]98 ret = -99; \
99 \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]100 if (scm && scm->socket_enable) \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]101 vl_socket_client_read (5); \
Dave Barach59b25652017-09-10 15:04:27 -0400[diff] [blame]102 while (vat_time_now (vam) < timeout) { \
103 if (vam->result_ready == 1) { \
104 (body); \
105 ret = vam->retval; \
106 break; \
107 } \
108 vat_suspend (vam->vlib_main, 1e-5); \
Dave Barach69eeadc2020-04-14 09:52:26 -0400[diff] [blame]109 } \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]110} while(0);
111
Dave Barach21a43842019-07-09 10:04:18 -0400[diff] [blame]112#define VAT_PLUGIN_REGISTER(plug) \
113clib_error_t * vat_plugin_register (vat_main_t *vam) \
114{ \
115 plug##_test_main_t * mp = &plug##_test_main; \
116 u8 * name; \
117 \
118 mp->vat_main = vam; \
119 \
120 /* Ask the vpp engine for the first assigned message-id */ \
121 name = format (0, #plug "_%08x%c", api_version, 0); \
122 mp->msg_id_base = \
123 vl_client_get_first_plugin_msg_id ((char *) name); \
124 vec_free(name); \
125 \
126 if (mp->msg_id_base != (u16) ~0) \
127 plug##_api_hookup (vam); \
128 else \
129 return clib_error_return (0, #plug " plugin not loaded...");\
130 return 0; \
131}
132
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]133
134#endif /* __vat_helper_macros_h__ */