36 #define get_idx(svc) (*(svc->idx))  argument
40 	STRUCT_SECTION_FOREACH(net_socket_service_desc, svc) {  in net_socket_service_foreach()
41 		cb(svc, user_data);  in net_socket_service_foreach()
45 static void cleanup_svc_events(const struct net_socket_service_desc *svc)  in cleanup_svc_events()  argument
47 	for (int i = 0; i < svc->pev_len; i++) {  in cleanup_svc_events()
48 		svc->pev[i].event.fd = -1;  in cleanup_svc_events()
49 		svc->pev[i].event.events = 0;  in cleanup_svc_events()
53 int z_impl_net_socket_service_register(const struct net_socket_service_desc *svc,  in z_impl_net_socket_service_register()  argument
64 		NET_ERR("Socket service thread not running, service %p register fails.", svc);  in z_impl_net_socket_service_register()
69 	if (STRUCT_SECTION_START(net_socket_service_desc) > svc ||  in z_impl_net_socket_service_register()
70 	    STRUCT_SECTION_END(net_socket_service_desc) <= svc) {  in z_impl_net_socket_service_register()
75 		cleanup_svc_events(svc);  in z_impl_net_socket_service_register()
77 		if (len > svc->pev_len) {  in z_impl_net_socket_service_register()
80 				svc->pev_len, svc);  in z_impl_net_socket_service_register()
86 			svc->pev[i].event = fds[i];  in z_impl_net_socket_service_register()
87 			svc->pev[i].user_data = user_data;  in z_impl_net_socket_service_register()
105 	STRUCT_SECTION_FOREACH(net_socket_service_desc, svc) {  in find_svc_and_event()
106 		for (int i = 0; i < svc->pev_len; i++) {  in find_svc_and_event()
107 			if (svc->pev[i].event.fd == pev->fd) {  in find_svc_and_event()
108 				*event = &svc->pev[i];  in find_svc_and_event()
109 				return svc;  in find_svc_and_event()
151 	struct net_socket_service_desc *svc;  in trigger_work()  local
153 	svc = find_svc_and_event(pev, &event);  in trigger_work()
154 	if (svc == NULL) {  in trigger_work()
158 	event->svc = svc;  in trigger_work()
180 	STRUCT_SECTION_FOREACH(net_socket_service_desc, svc) {  in socket_service_thread()
183 				    (svc->owner), ("")),  in socket_service_thread()
184 			svc->pev_len);  in socket_service_thread()
185 		get_idx(svc) = count + 1;  in socket_service_thread()
186 		count += svc->pev_len;  in socket_service_thread()
222 	STRUCT_SECTION_FOREACH(net_socket_service_desc, svc) {  in socket_service_thread()
223 		for (int j = 0; j < svc->pev_len; j++) {  in socket_service_thread()
224 			ctx.events[get_idx(svc) + j] = svc->pev[j].event;  in socket_service_thread()