FD.io VPP  v20.09-64-g4f7b92f0a
Vector Packet Processing
vpp_echo_proto_udp.c
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2019 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:
6  *
7  * http://www.apache.org/licenses/LICENSE-2.0
8  *
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.
14  */
15 
16 #include <stdio.h>
17 #include <signal.h>
18 
20 
21 static void
23 {
24  echo_main_t *em = &echo_main;
25  echo_session_t *ls;
26  ASSERT (s->session_state < ECHO_SESSION_STATE_CLOSED);
27  if (parent_died)
30  {
33  }
34 
36  s->session_state = ECHO_SESSION_STATE_CLOSED;
37  if (!em->n_clients_connected)
38  em->state = STATE_DATA_DONE;
39 }
40 
41 static void
43  u32 session_index, u8 is_failed)
44 {
45  static u32 client_index = 0;
46  echo_main_t *em = &echo_main;
47  echo_session_t *session = pool_elt_at_index (em->sessions, session_index);
48  if (is_failed)
49  {
50  ECHO_FAIL (ECHO_FAIL_UDP_BAPI_CONNECT,
51  "Bapi connect errored on session %u", session_index);
52  return; /* Dont handle bapi connect errors for now */
53  }
54 
55  session->accepted_session_count = 0;
56  session->session_type = ECHO_SESSION_TYPE_STREAM;
57 
58  session->bytes_to_send = em->bytes_to_send;
59  session->bytes_to_receive = em->bytes_to_receive;
60  session->session_state = ECHO_SESSION_STATE_READY;
61  session->is_dgram = 1;
62 
63  em->data_thread_args[client_index++] = session->session_index;
64 
66  if (em->n_clients_connected == em->n_clients && em->state < STATE_READY)
67  {
69  em->state = STATE_READY;
70  }
71 }
72 
73 static void
75 {
76  static u32 client_index = 0;
77  echo_main_t *em = &echo_main;
78  echo_session_t *ls;
79 
81  ls = pool_elt_at_index (em->sessions, session->listener_index);
82  session->session_type = ECHO_SESSION_TYPE_STREAM;
86 
87  session->bytes_to_send = em->bytes_to_send;
88  session->bytes_to_receive = em->bytes_to_receive;
89  session->is_dgram = 1;
90  em->data_thread_args[client_index++] = session->session_index;
91  session->session_state = ECHO_SESSION_STATE_READY;
92 
93  if (em->n_clients_connected == em->n_clients && em->state < STATE_READY)
94  {
96  em->state = STATE_READY;
97  }
98 }
99 
100 static void
102 {
103  s->session_state = ECHO_SESSION_STATE_CLOSING;
104 }
105 
106 static void
108 {
109  echo_main_t *em = &echo_main;
110  echo_session_print_stats (em, s);
111  if (s->bytes_to_receive || s->bytes_to_send)
112  s->session_state = ECHO_SESSION_STATE_AWAIT_DATA;
113  else
114  s->session_state = ECHO_SESSION_STATE_CLOSING;
116 }
117 
118 static void
120 {
121  echo_main_t *em = &echo_main;
123  s->session_state = ECHO_SESSION_STATE_CLOSING;
124 }
125 
126 static void
128 {
129  svm_fifo_t *rx_fifo, *tx_fifo;
130  echo_main_t *em = &echo_main;
131  u32 session_index = session->session_index;
132  if (!em->i_am_master || em->uri_elts.transport_proto != TRANSPORT_PROTO_UDP)
133  return;
134 
135  rx_fifo = uword_to_pointer (mp->rx_fifo, svm_fifo_t *);
136  tx_fifo = uword_to_pointer (mp->tx_fifo, svm_fifo_t *);
137  rx_fifo->client_session_index = session_index;
138  tx_fifo->client_session_index = session_index;
139 
140  session->rx_fifo = rx_fifo;
141  session->tx_fifo = tx_fifo;
142  session->transport.is_ip4 = mp->lcl_is_ip4;
143  clib_memcpy_fast (&session->transport.lcl_ip, mp->lcl_ip,
144  sizeof (ip46_address_t));
145  session->transport.lcl_port = mp->lcl_port;
146  session->vpp_evt_q = uword_to_pointer (mp->vpp_evt_q, svm_msg_q_t *);
147 
149  session->session_type = ECHO_SESSION_TYPE_STREAM;
152 
153  session->bytes_to_send = em->bytes_to_send;
154  session->bytes_to_receive = em->bytes_to_receive;
155  session->is_dgram = 1;
156  em->data_thread_args[0] = session_index;
157  session->session_state = ECHO_SESSION_STATE_READY;
158 
160  em->state = STATE_READY;
161 }
162 
163 
164 echo_proto_cb_vft_t echo_udp_proto_cb_vft = {
166  .connected_cb = udp_echo_connected_cb,
167  .accepted_cb = udp_echo_accepted_cb,
168  .reset_cb = udp_echo_reset_cb,
169  .sent_disconnect_cb = udp_echo_sent_disconnect_cb,
170  .cleanup_cb = udp_echo_cleanup_cb,
171  .bound_uri_cb = udp_echo_bound_uri_cb,
172 };
173 
174 ECHO_REGISTER_PROTO (TRANSPORT_PROTO_UDP, echo_udp_proto_cb_vft);
175 
176 /*
177  * fd.io coding-style-patch-verification: ON
178  *
179  * Local Variables:
180  * eval: (c-set-style "gnu")
181  * End:
182  */
volatile u64 accepted_session_count
teardown_stat_t clean_count
echo_session_t * sessions
#define clib_memcpy_fast(a, b, c)
Definition: string.h:81
static void udp_echo_disconnected_cb(session_disconnected_msg_t *mp, echo_session_t *s)
echo_main_t echo_main
Definition: vpp_echo.c:24
volatile connection_state_t state
static void udp_echo_connected_cb(session_connected_bundled_msg_t *mp, u32 session_index, u8 is_failed)
static void udp_echo_accepted_cb(session_accepted_msg_t *mp, echo_session_t *session)
unsigned char u8
Definition: types.h:56
ECHO_REGISTER_PROTO(TRANSPORT_PROTO_UDP, echo_udp_proto_cb_vft)
volatile u32 n_clients_connected
static void udp_echo_reset_cb(session_reset_msg_t *mp, echo_session_t *s)
#define ECHO_FAIL(fail, _fmt, _args...)
unsigned int u32
Definition: types.h:88
static void udp_echo_sent_disconnect_cb(echo_session_t *s)
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
Definition: pool.h:534
#define SESSION_INVALID_INDEX
Definition: session_types.h:22
#define clib_atomic_sub_fetch(a, b)
Definition: atomics.h:31
void echo_notify_event(echo_main_t *em, echo_test_evt_t e)
u32 *volatile data_thread_args
struct echo_main_t::@665 uri_elts
#define uword_to_pointer(u, type)
Definition: types.h:136
#define ASSERT(truth)
teardown_stat_t close_count
#define clib_atomic_fetch_add(a, b)
Definition: atomics.h:23
volatile u64 bytes_to_receive
echo_stats_t stats
static void udp_echo_cleanup_cb(echo_session_t *s, u8 parent_died)
static void udp_echo_bound_uri_cb(session_bound_msg_t *mp, echo_session_t *session)
void echo_session_print_stats(echo_main_t *em, echo_session_t *session)
struct _svm_fifo svm_fifo_t
teardown_stat_t reset_count
void(* disconnected_cb)(session_disconnected_msg_t *mp, echo_session_t *s)