stream_receive_perf_core.c File Reference

#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <doca_argp.h>
#include <doca_ctx.h>
#include <doca_log.h>
#include <utils.h>
#include <samples/common.h>
#include "stream_receive_perf_core.h"

Include dependency graph for stream_receive_perf_core.c:

Go to the source code of this file.

Functions
	DOCA_LOG_REGISTER (STREAM_RECEIVE_PERF_CORE)
static void	handle_completion (struct doca_rmax_in_stream_event_rx_data *event_rx_data, union doca_data event_user_data)
static void	handle_error (struct doca_rmax_in_stream_event_rx_data *event_rx_data, union doca_data event_user_data)
bool	init_config (struct app_config *config)
void	destroy_config (struct app_config *config)
static doca_error_t	set_list_flag (void *param, void *opaque)
static doca_error_t	set_scatter_type_param (void *param, void *opaque)
static doca_error_t	set_tstamp_format_param (void *param, void *opaque)
static doca_error_t	set_ip_param (const char *label, const char *str, struct in_addr *out)
static doca_error_t	set_src_ip_param (void *param, void *opaque)
static doca_error_t	set_dst_ip_param (void *param, void *opaque)
static doca_error_t	set_dev_ip_param (void *param, void *opaque)
static doca_error_t	set_dst_port_param (void *param, void *opaque)
static doca_error_t	set_data_size_param (void *param, void *opaque)
static doca_error_t	set_hdr_size_param (void *param, void *opaque)
static doca_error_t	set_num_elements_param (void *param, void *opaque)
static doca_error_t	set_cpu_affinity_param (void *param, void *opaque)
static doca_error_t	set_sleep_param (void *param, void *opaque)
static doca_error_t	set_min_packets_param (void *param, void *opaque)
static doca_error_t	set_max_packets_param (void *param, void *opaque)
static doca_error_t	set_dump_flag (void *param, void *opaque)
bool	register_argp_params (void)
bool	mandatory_args_set (struct app_config *config)
void	list_devices (void)
struct doca_dev *	open_device (struct in_addr *dev_ip)
static void	free_callback (void *addr, size_t len, void *opaque)
doca_error_t	init_globals (struct app_config *config, struct doca_dev *dev, struct globals *globals)
bool	destroy_globals (struct globals *globals, struct doca_dev *dev)
doca_error_t	init_stream (struct app_config *config, struct doca_dev *dev, struct globals *globals, struct stream_data *data)
bool	destroy_stream (struct doca_dev *dev, struct globals *globals, struct stream_data *data)
static bool	print_statistics (struct stream_data *data)
bool	run_recv_loop (const struct app_config *config, struct globals *globals, struct stream_data *data)

Function Documentation

destroy_config()

void destroy_config

(

struct app_config *

config

)

Definition at line 94 of file stream_receive_perf_core.c.

destroy_globals()

bool destroy_globals	(	struct globals *	globals,
		struct doca_dev *	dev
	)

Definition at line 936 of file stream_receive_perf_core.c.

destroy_stream()

bool destroy_stream	(	struct doca_dev *	dev,
		struct globals *	globals,
		struct stream_data *	data
	)

Definition at line 1172 of file stream_receive_perf_core.c.

DOCA_LOG_REGISTER()

DOCA_LOG_REGISTER

(

STREAM_RECEIVE_PERF_CORE

)

free_callback()

static void free_callback ( void *  addr, size_t  len, void *  opaque  )

static

Definition at line 887 of file stream_receive_perf_core.c.

handle_completion()

static void handle_completion ( struct doca_rmax_in_stream_event_rx_data *  event_rx_data, union doca_data  event_user_data  )

static

Definition at line 1210 of file stream_receive_perf_core.c.

handle_error()

static void handle_error ( struct doca_rmax_in_stream_event_rx_data *  event_rx_data, union doca_data  event_user_data  )

static

Definition at line 1278 of file stream_receive_perf_core.c.

init_config()

bool init_config

(

struct app_config *

config

)

Definition at line 67 of file stream_receive_perf_core.c.

init_globals()

doca_error_t init_globals	(	struct app_config *	config,
		struct doca_dev *	dev,
		struct globals *	globals
	)

Definition at line 894 of file stream_receive_perf_core.c.

init_stream()

doca_error_t init_stream	(	struct app_config *	config,
		struct doca_dev *	dev,
		struct globals *	globals,
		struct stream_data *	data
	)

Definition at line 966 of file stream_receive_perf_core.c.

list_devices()

void list_devices

(

void

)

Definition at line 765 of file stream_receive_perf_core.c.

mandatory_args_set()

bool mandatory_args_set

(

struct app_config *

config

)

Definition at line 742 of file stream_receive_perf_core.c.

open_device()

struct doca_dev* open_device

(

struct in_addr *

dev_ip

)

Definition at line 843 of file stream_receive_perf_core.c.

print_statistics()

static bool print_statistics ( struct stream_data *  data )

static

Definition at line 1243 of file stream_receive_perf_core.c.

register_argp_params()

bool register_argp_params

(

void

)

Definition at line 462 of file stream_receive_perf_core.c.

run_recv_loop()

bool run_recv_loop	(	const struct app_config *	config,
		struct globals *	globals,
		struct stream_data *	data
	)

Definition at line 1291 of file stream_receive_perf_core.c.

set_cpu_affinity_param()

static doca_error_t set_cpu_affinity_param ( void *  param, void *  opaque  )

static

Definition at line 340 of file stream_receive_perf_core.c.

set_data_size_param()

static doca_error_t set_data_size_param ( void *  param, void *  opaque  )

static

Definition at line 275 of file stream_receive_perf_core.c.

set_dev_ip_param()

static doca_error_t set_dev_ip_param ( void *  param, void *  opaque  )

static

Definition at line 239 of file stream_receive_perf_core.c.

set_dst_ip_param()

static doca_error_t set_dst_ip_param ( void *  param, void *  opaque  )

static

Definition at line 224 of file stream_receive_perf_core.c.

set_dst_port_param()

static doca_error_t set_dst_port_param ( void *  param, void *  opaque  )

static

Definition at line 254 of file stream_receive_perf_core.c.

set_dump_flag()

static doca_error_t set_dump_flag ( void *  param, void *  opaque  )

static

Definition at line 452 of file stream_receive_perf_core.c.

set_hdr_size_param()

static doca_error_t set_hdr_size_param ( void *  param, void *  opaque  )

static

Definition at line 296 of file stream_receive_perf_core.c.

set_ip_param()

static doca_error_t set_ip_param ( const char *  label, const char *  str, struct in_addr *  out  )

static

Definition at line 179 of file stream_receive_perf_core.c.

set_list_flag()

static doca_error_t set_list_flag ( void *  param, void *  opaque  )

static

Definition at line 112 of file stream_receive_perf_core.c.

set_max_packets_param()

static doca_error_t set_max_packets_param ( void *  param, void *  opaque  )

static

Definition at line 428 of file stream_receive_perf_core.c.

set_min_packets_param()

static doca_error_t set_min_packets_param ( void *  param, void *  opaque  )

static

Definition at line 407 of file stream_receive_perf_core.c.

set_num_elements_param()

static doca_error_t set_num_elements_param ( void *  param, void *  opaque  )

static

Definition at line 317 of file stream_receive_perf_core.c.

set_scatter_type_param()

static doca_error_t set_scatter_type_param ( void *  param, void *  opaque  )

static

Definition at line 129 of file stream_receive_perf_core.c.

set_sleep_param()

static doca_error_t set_sleep_param ( void *  param, void *  opaque  )

static

Definition at line 386 of file stream_receive_perf_core.c.

set_src_ip_param()

static doca_error_t set_src_ip_param ( void *  param, void *  opaque  )

static

Definition at line 209 of file stream_receive_perf_core.c.

set_tstamp_format_param()

static doca_error_t set_tstamp_format_param ( void *  param, void *  opaque  )

static

Definition at line 152 of file stream_receive_perf_core.c.