proto_load_step.c File Reference

Generic protocol load generator. More...

#include <netdb.h>
#include <fcntl.h>
#include <freeradius-devel/server/protocol.h>
#include <freeradius-devel/io/application.h>
#include <freeradius-devel/io/listen.h>
#include <freeradius-devel/io/schedule.h>
#include <freeradius-devel/io/load.h>
#include "proto_load.h"

Include dependency graph for proto_load_step.c:

Go to the source code of this file.

Data Structures
struct	proto_load_step_s
struct	proto_load_step_thread_t

Typedefs
typedef struct proto_load_step_s	proto_load_step_t

Functions
static fr_client_t *	mod_client_find (fr_listen_t *li, UNUSED fr_ipaddr_t const *ipaddr, UNUSED int ipproto)
static int	mod_decode (void const *instance, request_t *request, UNUSED uint8_t *const data, UNUSED size_t data_len)
	Decode the packet.
static void	mod_event_list_set (fr_listen_t *li, fr_event_list_t *el, void *nr)
	Set the event list for a new socket.
static int	mod_generate (fr_time_t now, void *uctx)
	Generate traffic.
static int	mod_instantiate (module_inst_ctx_t const *mctx)
static char const *	mod_name (fr_listen_t *li)
static int	mod_open (fr_listen_t *li)
	Open a load listener.
static ssize_t	mod_read (fr_listen_t *li, void **packet_ctx, fr_time_t *recv_time_p, uint8_t *buffer, size_t buffer_len, size_t *leftover)
static ssize_t	mod_write (fr_listen_t *li, UNUSED void *packet_ctx, fr_time_t request_time, UNUSED uint8_t *buffer, size_t buffer_len, UNUSED size_t written)
static void	write_stats (fr_timer_list_t *tl, fr_time_t now, void *uctx)

Variables
static const conf_parser_t	load_listen_config []
fr_app_io_t	proto_load_step

Detailed Description

Generic protocol load generator.

Id

1bd4b368dae0ef38582661641ae150ecae1ddc96

Copyright

2019 The FreeRADIUS server project.

2019 Network RADIUS SAS (legal.nosp@m.@net.nosp@m.workr.nosp@m.adiu.nosp@m.s.com)

Definition in file proto_load_step.c.

---

Data Structure Documentation

proto_load_step_s

struct proto_load_step_s

Definition at line 60 of file proto_load_step.c.

Collaboration diagram for proto_load_step_s:

Data Fields
fr_client_t *	client	static client
int	code
CONF_SECTION *	cs	our configuration
char const *	csv	, do we repeat the load generation where to write CSV stats
fr_dict_t const *	dict	Our namespace.
char const *	filename	where to read input packet from
fr_load_config_t	load	load configuration
uint32_t	max_attributes	Limit maximum decodable attributes.
fr_pair_list_t	pair_list	for input packet
proto_load_t *	parent
bool	repeat

proto_load_step_thread_t

struct proto_load_step_thread_t

Definition at line 39 of file proto_load_step.c.

Collaboration diagram for proto_load_step_thread_t:

Data Fields
bool	done
fr_event_list_t *	el	event list
fr_timer_t *	ev	for writing statistics
int	fd	for CSV files
proto_load_step_t const *	inst
fr_load_t *	l	load generation handler
fr_load_config_t	load	load configuration
char const *	name	socket name
fr_network_t *	nr	network handler
fr_listen_t *	parent	master IO handler
fr_time_t	recv_time	recv time of the last packet
fr_stats_t	stats	statistics for this socket
bool	suspended

Typedef Documentation

proto_load_step_t

typedef struct proto_load_step_s proto_load_step_t

Definition at line 37 of file proto_load_step.c.

Function Documentation

mod_client_find()

static fr_client_t * mod_client_find ( fr_listen_t *  li, UNUSED fr_ipaddr_t const *  ipaddr, UNUSED int  ipproto  )

static

Definition at line 407 of file proto_load_step.c.

mod_decode()

static int mod_decode ( void const *  instance, request_t *  request, UNUSED uint8_t *const  data, UNUSED size_t  data_len  )

static

Decode the packet.

Definition at line 256 of file proto_load_step.c.

Here is the call graph for this function:

mod_event_list_set()

static void mod_event_list_set ( fr_listen_t *  li, fr_event_list_t *  el, void *  nr  )

static

Set the event list for a new socket.

Parameters

[in]	li	the listener
[in]	el	the event list
[in]	nr	context from the network side

Definition at line 293 of file proto_load_step.c.

Here is the call graph for this function:

mod_generate()

static int mod_generate ( fr_time_t  now, void *  uctx  )

static

Generate traffic.

Definition at line 222 of file proto_load_step.c.

Here is the call graph for this function:

Here is the caller graph for this function:

mod_instantiate()

static int mod_instantiate ( module_inst_ctx_t const *  mctx )

static

Definition at line 333 of file proto_load_step.c.

Here is the call graph for this function:

mod_name()

static char const * mod_name ( fr_listen_t *  li )

static

Definition at line 326 of file proto_load_step.c.

mod_open()

static int mod_open ( fr_listen_t *  li )

static

Open a load listener.

Definition at line 193 of file proto_load_step.c.

Here is the call graph for this function:

mod_read()

static ssize_t mod_read ( fr_listen_t *  li, void **  packet_ctx, fr_time_t *  recv_time_p, uint8_t *  buffer, size_t  buffer_len, size_t *  leftover  )

static

Definition at line 99 of file proto_load_step.c.

mod_write()

static ssize_t mod_write ( fr_listen_t *  li, UNUSED void *  packet_ctx, fr_time_t  request_time, UNUSED uint8_t *  buffer, size_t  buffer_len, UNUSED size_t  written  )

static

Definition at line 158 of file proto_load_step.c.

Here is the call graph for this function:

write_stats()

static void write_stats ( fr_timer_list_t *  tl, fr_time_t  now, void *  uctx  )

static

Definition at line 238 of file proto_load_step.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

load_listen_config

const conf_parser_t load_listen_config[]

static

Initial value:

= {
        { FR_CONF_OFFSET_FLAGS("filename", CONF_FLAG_FILE_READABLE | CONF_FLAG_REQUIRED | CONF_FLAG_NOT_EMPTY, proto_load_step_t, filename) },
        { FR_CONF_OFFSET("csv", proto_load_step_t, csv) },
 
        { FR_CONF_OFFSET("max_attributes", proto_load_step_t, max_attributes), .dflt = STRINGIFY(RADIUS_MAX_ATTRIBUTES) } ,
 
        { FR_CONF_OFFSET("start_pps", proto_load_step_t, load.start_pps) },
        { FR_CONF_OFFSET("max_pps", proto_load_step_t, load.max_pps) },
        { FR_CONF_OFFSET("duration", proto_load_step_t, load.duration) },
        { FR_CONF_OFFSET("step", proto_load_step_t, load.step) },
        { FR_CONF_OFFSET("max_backlog", proto_load_step_t, load.milliseconds) },
        { FR_CONF_OFFSET("parallel", proto_load_step_t, load.parallel) },
        { FR_CONF_OFFSET("repeat", proto_load_step_t, repeat) },
 
        CONF_PARSER_TERMINATOR
}

Definition at line 81 of file proto_load_step.c.

proto_load_step

fr_app_io_t proto_load_step

Initial value:

= {
        .common = {
                .magic                  = MODULE_MAGIC_INIT,
                .name                   = "load_step",
                .config                 = load_listen_config,
                .inst_size              = sizeof(proto_load_step_t),
                .thread_inst_size       = sizeof(proto_load_step_thread_t),
                .instantiate            = mod_instantiate
        },
        .default_message_size   = 4096,
        .track_duplicates       = false,
 
        .open                   = mod_open,
        .read                   = mod_read,
        .write                  = mod_write,
        .event_list_set         = mod_event_list_set,
        .client_find            = mod_client_find,
        .get_name               = mod_name,
 
        .decode                 = mod_decode,
}

Definition at line 414 of file proto_load_step.c.