Gitiles
Code Review Sign In
gerrit.nordix.org / fdio / vpp / e8d7ff5f876c3950caf1bacf603d79b9ada8aef2 / . / src / vlibapi / vat_helper_macros.h
blob: 52fdcb1cb5a1cfdc5a2b632fec850bec97c35198 [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 Barach2d6b2d62017-01-25 16:32:08 -0500[diff] [blame]31 memset (mp, 0, sizeof (*mp)); \
32 mp->_vl_msg_id = ntohs (VL_API_##T+__plugin_msg_base); \
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; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]41 if (scm && scm->socket_enable) \
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)); \
45 memset (mp, 0, sizeof (*mp)); \
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) \
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; \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]56 if (scm && scm->socket_enable) \
57 mp = vl_socket_client_msg_alloc (sizeof(*mp)); \
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 Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]60 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 Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]62 mp->client_index = vam->my_client_index; \
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; \
69 if (scm && scm->socket_enable) \
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 \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]82 if (scm && scm->socket_enable) \
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); \
90 } \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]91} while(0);
92
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 \
Florin Coras90a63982017-12-19 04:50:01 -0800[diff] [blame]100 if (scm && scm->socket_enable) \
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); \
109 } \
Dave Barachfe6bdfd2017-01-20 19:50:09 -0500[diff] [blame]110} while(0);
111
112
113#endif /* __vat_helper_macros_h__ */