FD.io VPP  v20.01-48-g3e0dafb74
Vector Packet Processing
pg_api.c
Go to the documentation of this file.
1 /*
2  *------------------------------------------------------------------
3  * pg_api.c - vnet pg api
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 
20 #include <vnet/vnet.h>
21 #include <vlibmemory/api.h>
22 
23 #include <vnet/pg/pg.h>
24 
25 #include <vnet/vnet_msg_enum.h>
26 
27 #define vl_typedefs /* define message structures */
28 #include <vnet/vnet_all_api_h.h>
29 #undef vl_typedefs
30 
31 #define vl_endianfun /* define message structures */
32 #include <vnet/vnet_all_api_h.h>
33 #undef vl_endianfun
34 
35 /* instantiate all the print functions we know about */
36 #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__)
37 #define vl_printfun
38 #include <vnet/vnet_all_api_h.h>
39 #undef vl_printfun
40 
42 
43 
44 #define foreach_pg_api_msg \
45 _(PG_CREATE_INTERFACE, pg_create_interface) \
46 _(PG_CAPTURE, pg_capture) \
47 _(PG_ENABLE_DISABLE, pg_enable_disable)
48 
49 static void
51 {
53  int rv = 0;
54 
55  pg_main_t *pg = &pg_main;
56  u32 pg_if_id = pg_interface_add_or_get (pg, ntohl (mp->interface_id),
57  mp->gso_enabled,
58  ntohl (mp->gso_size));
59  pg_interface_t *pi = pool_elt_at_index (pg->interfaces, pg_if_id);
60 
61  /* *INDENT-OFF* */
62  REPLY_MACRO2(VL_API_PG_CREATE_INTERFACE_REPLY,
63  ({
64  rmp->sw_if_index = ntohl(pi->sw_if_index);
65  }));
66  /* *INDENT-ON* */
67 }
68 
69 static void
71 {
72  vl_api_pg_capture_reply_t *rmp;
73  int rv = 0;
74 
75  vnet_main_t *vnm = vnet_get_main ();
78 
79  u8 *intf_name = format (0, "pg%d", ntohl (mp->interface_id), 0);
80  vec_terminate_c_string (intf_name);
81  u32 hw_if_index = ~0;
82  uword *p = hash_get_mem (im->hw_interface_by_name, intf_name);
83  if (p)
84  hw_if_index = *p;
85  vec_free (intf_name);
86 
87  if (hw_if_index != ~0)
88  {
89  pg_capture_args_t _a, *a = &_a;
90 
91  u32 len = ntohl (mp->pcap_name_length);
92  u8 *pcap_file_name = vec_new (u8, len);
93  clib_memcpy (pcap_file_name, mp->pcap_file_name, len);
94 
95  hi = vnet_get_sup_hw_interface (vnm, hw_if_index);
96  a->hw_if_index = hw_if_index;
97  a->dev_instance = hi->dev_instance;
98  a->is_enabled = mp->is_enabled;
99  a->pcap_file_name = pcap_file_name;
100  a->count = ntohl (mp->count);
101 
102  clib_error_t *e = pg_capture (a);
103  if (e)
104  {
105  clib_error_report (e);
106  rv = VNET_API_ERROR_CANNOT_CREATE_PCAP_FILE;
107  }
108 
109  vec_free (pcap_file_name);
110  }
111  REPLY_MACRO (VL_API_PG_CAPTURE_REPLY);
112 }
113 
114 static void
116 {
117  vl_api_pg_enable_disable_reply_t *rmp;
118  int rv = 0;
119 
120  pg_main_t *pg = &pg_main;
121  u32 stream_index = ~0;
122 
123  int is_enable = mp->is_enabled != 0;
124  u32 len = ntohl (mp->stream_name_length) - 1;
125 
126  if (len > 0)
127  {
128  u8 *stream_name = vec_new (u8, len);
129  clib_memcpy (stream_name, mp->stream_name, len);
130  uword *p = hash_get_mem (pg->stream_index_by_name, stream_name);
131  if (p)
132  stream_index = *p;
133  vec_free (stream_name);
134  }
135 
136  pg_enable_disable (stream_index, is_enable);
137 
138  REPLY_MACRO (VL_API_PG_ENABLE_DISABLE_REPLY);
139 }
140 
141 #define vl_msg_name_crc_list
142 #include <vnet/pg/pg.api.h>
143 #undef vl_msg_name_crc_list
144 
145 static void
147 {
148 #define _(id,n,crc) vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id);
149  foreach_vl_msg_name_crc_pg;
150 #undef _
151 }
152 
153 static clib_error_t *
155 {
156  api_main_t *am = vlibapi_get_main ();
157 
158 #define _(N,n) \
159  vl_msg_api_set_handlers(VL_API_##N, #n, \
160  vl_api_##n##_t_handler, \
161  vl_noop_handler, \
162  vl_api_##n##_t_endian, \
163  vl_api_##n##_t_print, \
164  sizeof(vl_api_##n##_t), 1);
166 #undef _
167 
168  /*
169  * Set up the (msg_name, crc, message-id) table
170  */
172 
173  return 0;
174 }
175 
177 
178 /*
179  * fd.io coding-style-patch-verification: ON
180  *
181  * Local Variables:
182  * eval: (c-set-style "gnu")
183  * End:
184  */
u32 sw_if_index
Definition: pg.h:300
#define foreach_pg_api_msg
Definition: pg_api.c:44
clib_error_t * pg_capture(pg_capture_args_t *a)
Definition: cli.c:81
a
Definition: bitmap.h:538
vnet_main_t * vnet_get_main(void)
Definition: misc.c:46
static vnet_hw_interface_t * vnet_get_sup_hw_interface(vnet_main_t *vnm, u32 sw_if_index)
Definition: pg.h:318
vnet_interface_main_t interface_main
Definition: vnet.h:56
#define REPLY_MACRO2(t, body)
uword * stream_index_by_name
Definition: pg.h:327
#define vec_terminate_c_string(V)
(If necessary) NULL terminate a vector containing a c-string.
Definition: vec.h:1017
VLIB_API_INIT_FUNCTION(pg_api_hookup)
u32 hw_if_index
Definition: pg.h:379
u8 * format(u8 *s, const char *fmt,...)
Definition: format.c:424
Enable / disable packet generator request.
Definition: pg.api:75
u32 pg_interface_add_or_get(pg_main_t *pg, uword stream_index, u8 gso_enabled, u32 gso_size)
Definition: stream.c:182
static void vl_api_pg_enable_disable_t_handler(vl_api_pg_enable_disable_t *mp)
Definition: pg_api.c:115
unsigned char u8
Definition: types.h:56
#define clib_memcpy(d, s, n)
Definition: string.h:180
u8 pcap_file_name[pcap_name_length]
Definition: pg.api:66
PacketGenerator capture packets on given interface request.
Definition: pg.api:58
#define vec_new(T, N)
Create new vector of given type and length (unspecified alignment, no header).
Definition: vec.h:312
unsigned int u32
Definition: types.h:88
static clib_error_t * pg_api_hookup(vlib_main_t *vm)
Definition: pg_api.c:154
u8 * pcap_file_name
Definition: pg.h:382
uword * hw_interface_by_name
Definition: interface.h:843
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
Definition: pool.h:519
u8 stream_name[stream_name_length]
Definition: pg.api:81
u32 pcap_name_length
Definition: pg.api:65
#define REPLY_MACRO(t)
vlib_main_t * vm
Definition: in2out_ed.c:1810
u8 len
Definition: ip_types.api:91
API main structure, used by both vpp and binary API clients.
Definition: api_common.h:225
PacketGenerator create interface request.
Definition: pg.api:30
#define vec_free(V)
Free vector&#39;s memory (no header).
Definition: vec.h:342
static void setup_message_id_table(api_main_t *am)
Definition: pg_api.c:146
void pg_enable_disable(u32 stream_index, int is_enable)
Definition: cli.c:58
static void vl_api_pg_create_interface_t_handler(vl_api_pg_create_interface_t *mp)
Definition: pg_api.c:50
#define clib_error_report(e)
Definition: error.h:113
vl_api_ip4_address_t hi
Definition: arp.api:37
u32 interface_id
Definition: pg.api:62
u64 uword
Definition: types.h:112
PacketGenerator create interface response.
Definition: pg.api:43
static void vl_api_pg_capture_t_handler(vl_api_pg_capture_t *mp)
Definition: pg_api.c:70
u32 dev_instance
Definition: pg.h:380
#define hash_get_mem(h, key)
Definition: hash.h:269
static api_main_t * vlibapi_get_main(void)
Definition: api_common.h:378
pg_main_t pg_main
Definition: init.c:44
u8 is_enabled
Definition: pg.h:381
pg_interface_t * interfaces
Definition: pg.h:330