move mod_open() to using thread_instance

diff --git a/src/modules/proto_detail/proto_detail_file.c b/src/modules/proto_detail/proto_detail_file.c
index a36ac61d3760161465626b78f13bbd14d495cf70..cffae74b5b558bf60e58df7a1c9ddea0f200d0ef 100644 (file)
--- a/src/modules/proto_detail/proto_detail_file.c
+++ b/src/modules/proto_detail/proto_detail_file.c
@@ -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

diff --git a/src/modules/proto_detail/proto_detail_work.c b/src/modules/proto_detail/proto_detail_work.c
index 7931a7b90d956216106f48f56bae7fd577820a4b..5aa290b7d2ef2a89eb0465f31dd210986079c898 100644 (file)
--- a/src/modules/proto_detail/proto_detail_work.c
+++ b/src/modules/proto_detail/proto_detail_work.c
@@ -672,7 +672,7 @@ free_track:
  */
 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.

diff --git a/src/modules/proto_dhcpv4/proto_dhcpv4_udp.c b/src/modules/proto_dhcpv4/proto_dhcpv4_udp.c
index ac3ca935fee3bb50e6314f64caa057fd0e998e43..4b7d5c9b8a094de42fcf70e65d93829cd3b59709 100644 (file)
--- a/src/modules/proto_dhcpv4/proto_dhcpv4_udp.c
+++ b/src/modules/proto_dhcpv4/proto_dhcpv4_udp.c
@@ -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;

diff --git a/src/modules/proto_radius/proto_radius_tcp.c b/src/modules/proto_radius/proto_radius_tcp.c
index 4e657eae1fec4922b8ce30405965954f050af9cf..4fe72f1f5c11d287871f979c6a54f5e4f6a5c9b0 100644 (file)
--- a/src/modules/proto_radius/proto_radius_tcp.c
+++ b/src/modules/proto_radius/proto_radius_tcp.c
@@ -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;

diff --git a/src/modules/proto_radius/proto_radius_udp.c b/src/modules/proto_radius/proto_radius_udp.c
index 8f7a0263fa3691b91ef54d7a49e6b096e6c910e3..769f961654e69e88e36336059b0531fb00bc7794 100644 (file)
--- a/src/modules/proto_radius/proto_radius_udp.c
+++ b/src/modules/proto_radius/proto_radius_udp.c
@@ -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;

diff --git a/src/modules/proto_vmps/proto_vmps_udp.c b/src/modules/proto_vmps/proto_vmps_udp.c
index 05f483c8e8b49d4aa7be0856d6d202b17390e0d2..35e35aad47457de776844e3b1656cdb927c381b7 100644 (file)
--- a/src/modules/proto_vmps/proto_vmps_udp.c
+++ b/src/modules/proto_vmps/proto_vmps_udp.c
@@ -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;