Skip to content

Commit

Permalink
move mod_open() to using thread_instance
Browse files Browse the repository at this point in the history
  • Loading branch information
alandekok committed Sep 25, 2018
1 parent 3193f47 commit 0fe3b46
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/modules/proto_detail/proto_detail_file.c
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ static void mod_vnode_extend(fr_listen_t *li, UNUSED uint32_t fflags)
*/
static int mod_open(fr_listen_t *li)
{
proto_detail_file_t *inst = talloc_get_type_abort(li->app_io_instance, proto_detail_file_t);
proto_detail_file_t *inst = talloc_get_type_abort(li->thread_instance, proto_detail_file_t);
int oflag;

#ifdef O_EVTONLY
Expand Down
2 changes: 1 addition & 1 deletion src/modules/proto_detail/proto_detail_work.c
Original file line number Diff line number Diff line change
Expand Up @@ -672,7 +672,7 @@ static ssize_t mod_write(fr_listen_t *li, void *packet_ctx, fr_time_t request_ti
*/
static int mod_open(fr_listen_t *li)
{
proto_detail_work_t *inst = talloc_get_type_abort(li->app_io_instance, proto_detail_work_t);
proto_detail_work_t *inst = talloc_get_type_abort(li->thread_instance, proto_detail_work_t);

/*
* Open the file if we haven't already been given one.
Expand Down
2 changes: 1 addition & 1 deletion src/modules/proto_dhcpv4/proto_dhcpv4_udp.c
Original file line number Diff line number Diff line change
Expand Up @@ -459,7 +459,7 @@ static void mod_network_get(void *instance, int *ipproto, bool *dynamic_clients,
*/
static int mod_open(fr_listen_t *li)
{
proto_dhcpv4_udp_t *inst = talloc_get_type_abort(li->app_io_instance, proto_dhcpv4_udp_t);
proto_dhcpv4_udp_t *inst = talloc_get_type_abort(li->thread_instance, proto_dhcpv4_udp_t);

int sockfd;
uint16_t port = inst->port;
Expand Down
2 changes: 1 addition & 1 deletion src/modules/proto_radius/proto_radius_tcp.c
Original file line number Diff line number Diff line change
Expand Up @@ -290,7 +290,7 @@ static void mod_network_get(void *instance, int *ipproto, bool *dynamic_clients,
*/
static int mod_open(fr_listen_t *li)
{
proto_radius_tcp_t *inst = talloc_get_type_abort(li->app_io_instance, proto_radius_tcp_t);
proto_radius_tcp_t *inst = talloc_get_type_abort(li->thread_instance, proto_radius_tcp_t);

int sockfd;
uint16_t port = inst->port;
Expand Down
2 changes: 1 addition & 1 deletion src/modules/proto_radius/proto_radius_udp.c
Original file line number Diff line number Diff line change
Expand Up @@ -298,7 +298,7 @@ static void mod_network_get(void *instance, int *ipproto, bool *dynamic_clients,
*/
static int mod_open(fr_listen_t *li)
{
proto_radius_udp_t *inst = talloc_get_type_abort(li->app_io_instance, proto_radius_udp_t);
proto_radius_udp_t *inst = talloc_get_type_abort(li->thread_instance, proto_radius_udp_t);

int sockfd;
uint16_t port = inst->port;
Expand Down
2 changes: 1 addition & 1 deletion src/modules/proto_vmps/proto_vmps_udp.c
Original file line number Diff line number Diff line change
Expand Up @@ -297,7 +297,7 @@ static void mod_network_get(void *instance, int *ipproto, bool *dynamic_clients,
*/
static int mod_open(fr_listen_t *li)
{
proto_vmps_udp_t *inst = talloc_get_type_abort(li->app_io_instance, proto_vmps_udp_t);
proto_vmps_udp_t *inst = talloc_get_type_abort(li->thread_instance, proto_vmps_udp_t);

int sockfd;
uint16_t port = inst->port;
Expand Down

0 comments on commit 0fe3b46

Please sign in to comment.