proto_detail_work.c File Reference

Detail handler for files. More...

#include <netdb.h>
#include <freeradius-devel/server/protocol.h>
#include <freeradius-devel/server/pair.h>
#include <freeradius-devel/server/main_loop.h>
#include <freeradius-devel/io/application.h>
#include <freeradius-devel/io/listen.h>
#include <freeradius-devel/util/syserror.h>
#include "proto_detail.h"
#include <fcntl.h>
#include <sys/stat.h>

Include dependency graph for proto_detail_work.c:

Go to the source code of this file.

Data Structures
struct	fr_detail_entry_t

Macros
#define	MPRINT   DEBUG3

Functions
static int	mod_close (fr_listen_t *li)
	Close a detail listener.
static int	mod_close_internal (proto_detail_work_thread_t *thread)
static int	mod_decode (void const *instance, request_t *request, UNUSED uint8_t *const data, UNUSED size_t data_len)
static void	mod_event_list_set (fr_listen_t *li, fr_event_list_t *el, void *nr)
	Set the event list for a new IO instance.
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 detail 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, void *packet_ctx, UNUSED fr_time_t request_time, uint8_t *buffer, size_t buffer_len, UNUSED size_t written)
static void	work_retransmit (UNUSED fr_timer_list_t *tl, UNUSED fr_time_t now, void *uctx)

Variables
static fr_dict_attr_t const *	attr_packet_transmit_counter
static fr_dict_t const *	dict_freeradius
static const conf_parser_t	file_listen_config []
static conf_parser_t	limit_config []
static fr_event_update_t	pause_read []
fr_app_io_t	proto_detail_work
	Private interface for use by proto_detail_file.
fr_dict_autoload_t	proto_detail_work_dict []
fr_dict_attr_autoload_t	proto_detail_work_dict_attr []
static fr_event_update_t	resume_read []

Detailed Description

Detail handler for files.

Id

c9509d2ac3a09a7687b27727c60413d2c4563167

Copyright

2017 The FreeRADIUS server project.

2017 Alan DeKok (aland.nosp@m.@dep.nosp@m.loyin.nosp@m.grad.nosp@m.ius.c.nosp@m.om)

Definition in file proto_detail_work.c.

---

Data Structure Documentation

fr_detail_entry_t

struct fr_detail_entry_t

Definition at line 52 of file proto_detail_work.c.

Collaboration diagram for fr_detail_entry_t:

Data Fields
off_t	done_offset	where we're tracking the status
fr_dlist_t	entry	for the retransmission list
fr_timer_t *	ev	retransmission timer
int	id	for retransmission counters
uint8_t *	packet	for retransmissions
size_t	packet_len	for retransmissions
proto_detail_work_thread_t *	parent	talloc_parent is SLOW!
fr_retry_t	retry	our retry timers
fr_time_t	timestamp	when we read the entry.

Macro Definition Documentation

MPRINT

#define MPRINT   DEBUG3

Definition at line 45 of file proto_detail_work.c.

Function Documentation

mod_close()

static int mod_close ( fr_listen_t *  li )

static

Close a detail listener.

Definition at line 782 of file proto_detail_work.c.

Here is the call graph for this function:

mod_close_internal()

static int mod_close_internal ( proto_detail_work_thread_t *  thread )

static

Definition at line 737 of file proto_detail_work.c.

Here is the call graph for this function:

Here is the caller graph for this function:

mod_decode()

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

static

Definition at line 115 of file proto_detail_work.c.

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 IO instance.

Parameters

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

Definition at line 810 of file proto_detail_work.c.

mod_instantiate()

static int mod_instantiate ( module_inst_ctx_t const *  mctx )

static

Definition at line 837 of file proto_detail_work.c.

Here is the call graph for this function:

mod_name()

static char const * mod_name ( fr_listen_t *  li )

static

Definition at line 830 of file proto_detail_work.c.

mod_open()

static int mod_open ( fr_listen_t *  li )

static

Open a detail listener.

Definition at line 678 of file proto_detail_work.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 144 of file proto_detail_work.c.

Here is the call graph for this function:

mod_write()

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

static

Definition at line 572 of file proto_detail_work.c.

Here is the call graph for this function:

work_retransmit()

static void work_retransmit ( UNUSED fr_timer_list_t *  tl, UNUSED fr_time_t  now, void *  uctx  )

static

Definition at line 542 of file proto_detail_work.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

attr_packet_transmit_counter

fr_dict_attr_t const* attr_packet_transmit_counter

static

Definition at line 104 of file proto_detail_work.c.

dict_freeradius

fr_dict_t const* dict_freeradius

static

Definition at line 95 of file proto_detail_work.c.

file_listen_config

const conf_parser_t file_listen_config[]

static

Initial value:

= {
        { FR_CONF_OFFSET_FLAGS("filename", CONF_FLAG_REQUIRED, proto_detail_work_t, filename_work ) },
 
        { FR_CONF_OFFSET("track", proto_detail_work_t, track_progress ) },
 
        { FR_CONF_OFFSET("retransmit", proto_detail_work_t, retransmit ), .dflt = "yes" },
 
        { FR_CONF_POINTER("limit", 0, CONF_FLAG_SUBSECTION, NULL), .subcs = (void const *) limit_config },
        CONF_PARSER_TERMINATOR
}

Definition at line 84 of file proto_detail_work.c.

limit_config

conf_parser_t limit_config[]

static

Initial value:

= {
        { FR_CONF_OFFSET("initial_rtx_time", proto_detail_work_t, retry_config.irt), .dflt = STRINGIFY(2) },
        { FR_CONF_OFFSET("max_rtx_time", proto_detail_work_t, retry_config.mrt), .dflt = STRINGIFY(16) },
 
        
        { FR_CONF_OFFSET("max_rtx_count", proto_detail_work_t, retry_config.mrc), .dflt = STRINGIFY(0) },
        
        { FR_CONF_OFFSET("max_rtx_duration", proto_detail_work_t, retry_config.mrd), .dflt = STRINGIFY(0) },
        { FR_CONF_OFFSET("max_outstanding", proto_detail_work_t, max_outstanding), .dflt = STRINGIFY(1) },
        CONF_PARSER_TERMINATOR
}

Definition at line 67 of file proto_detail_work.c.

pause_read

fr_event_update_t pause_read[]

static

Initial value:

= {
        FR_EVENT_SUSPEND(fr_event_io_func_t, read),
        { 0 }
}

Definition at line 134 of file proto_detail_work.c.

proto_detail_work

fr_app_io_t proto_detail_work

Initial value:

= {
        .common = {
                .magic                  = MODULE_MAGIC_INIT,
                .name                   = "detail_work",
                .config                 = file_listen_config,
                .inst_size              = sizeof(proto_detail_work_t),
                .thread_inst_size       = sizeof(proto_detail_work_thread_t),
                .instantiate            = mod_instantiate
        },
        .default_message_size   = 65536,
        .default_reply_size     = 32,
 
        .open                   = mod_open,
        .close                  = mod_close,
        .read                   = mod_read,
        .decode                 = mod_decode,
        .write                  = mod_write,
        .event_list_set         = mod_event_list_set,
        .get_name               = mod_name,
}

Private interface for use by proto_detail_file.

Definition at line 889 of file proto_detail_work.c.

proto_detail_work_dict

fr_dict_autoload_t proto_detail_work_dict

Initial value:

= {
        { .out = &dict_freeradius, .proto = "freeradius" },
 
        DICT_AUTOLOAD_TERMINATOR
}

Definition at line 98 of file proto_detail_work.c.

proto_detail_work_dict_attr

fr_dict_attr_autoload_t proto_detail_work_dict_attr

Initial value:

= {
        { .out = &attr_packet_transmit_counter, .name = "Packet-Transmit-Counter", .type = FR_TYPE_UINT32, .dict = &dict_freeradius },
        DICT_AUTOLOAD_TERMINATOR
}

Definition at line 107 of file proto_detail_work.c.

resume_read

fr_event_update_t resume_read[]

static

Initial value:

= {
        FR_EVENT_RESUME(fr_event_io_func_t, read),
        { 0 }
}

Definition at line 139 of file proto_detail_work.c.