FD.io VPP  v17.04.2-2-ga8f93f8
Vector Packet Processing
main.c
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2017 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 <vnet/vnet.h>
17 #include <vnet/plugin/plugin.h>
18 #include <dpdk/device/dpdk.h>
19 #include <vpp/app/version.h>
20 
21 /*
22  * Called by the dpdk driver's rte_delay_us() function.
23  * Return 0 to have the dpdk do a regular delay loop.
24  * Return 1 if to skip the delay loop because we are suspending
25  * the calling vlib process instead.
26  */
27 int
28 rte_delay_us_override (unsigned us)
29 {
30  vlib_main_t *vm;
31 
32  /* Don't bother intercepting for short delays */
33  if (us < 10)
34  return 0;
35 
36  /*
37  * Only intercept if we are in a vlib process.
38  * If we are called from a vlib worker thread or the vlib main
39  * thread then do not intercept. (Must not be called from an
40  * independent pthread).
41  */
42  if (os_get_cpu_number () == 0)
43  {
44  /*
45  * We're in the vlib main thread or a vlib process. Make sure
46  * the process is running and we're not still initializing.
47  */
48  vm = vlib_get_main ();
49  if (vlib_in_process_context (vm))
50  {
51  /* Only suspend for the admin_down_process */
53  if (!(proc->flags & VLIB_PROCESS_IS_RUNNING) ||
55  return 0;
56 
57  f64 delay = 1e-6 * us;
58  vlib_process_suspend (vm, delay);
59  return 1;
60  }
61  }
62  return 0; // no override
63 }
64 
65 static void
67 {
68  if (rte_delay_us_override (us) == 0)
69  rte_delay_us_block (us);
70 }
71 
73 {
74  dpdk_main_t * dm = &dpdk_main;
75  clib_error_t * error = 0;
76 
77  dm->vlib_main = vm;
78  dm->vnet_main = vnet_get_main ();
79 
80  if ((error = vlib_call_init_function (vm, dpdk_init)))
81  return error;
82 
83  /* register custom delay function */
84  rte_delay_us_callback_register (rte_delay_us_override_cb);
85 
86  return error;
87 }
88 
90 
91 /* *INDENT-OFF* */
93  .version = VPP_BUILD_VER,
94  .description = "Data Plane Development Kit (DPDK)",
95 };
96 /* *INDENT-ON* */
VLIB_PLUGIN_REGISTER()
vlib_node_runtime_t node_runtime
Definition: node.h:494
dpdk_main_t dpdk_main
Definition: dpdk.h:422
vnet_main_t * vnet_get_main(void)
Definition: misc.c:46
static uword vlib_process_suspend(vlib_main_t *vm, f64 dt)
Suspend a vlib cooperative multi-tasking thread for a period of time.
Definition: node_funcs.h:432
vlib_node_function_t * function
Node function to call.
Definition: node.h:416
#define VLIB_INIT_FUNCTION(x)
Definition: init.h:111
#define vlib_call_init_function(vm, x)
Definition: init.h:162
uword os_get_cpu_number(void)
Definition: unix-misc.c:224
clib_error_t * dpdk_init(vlib_main_t *vm)
Definition: init.c:2001
static vlib_process_t * vlib_get_current_process(vlib_main_t *vm)
Definition: node_funcs.h:397
vlib_main_t * vm
Definition: buffer.c:276
int rte_delay_us_override(unsigned us)
Definition: main.c:28
uword admin_up_down_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
Definition: device.c:795
static vlib_main_t * vlib_get_main(void)
Definition: global_funcs.h:23
static void rte_delay_us_override_cb(unsigned us)
Definition: main.c:66
double f64
Definition: types.h:142
static clib_error_t * dpdk_main_init(vlib_main_t *vm)
Definition: main.c:72
u16 flags
Definition: node.h:507
static uword vlib_in_process_context(vlib_main_t *vm)
Definition: node_funcs.h:404
vnet_main_t * vnet_main
Definition: dpdk.h:412
#define VLIB_PROCESS_IS_RUNNING
Definition: node.h:514
vlib_main_t * vlib_main
Definition: dpdk.h:411