Home
last modified time | relevance | path

Searched refs:fd (Results 1 – 25 of 48) sorted by relevance

12

/subsys/net/lib/lwm2m/
A Dlwm2m_rw_senml_json.c337 if (!fd) { in put_begin()
536 fd->json.obj.float_t_obj.name = fd->name_string; in json_float_object_write()
545 fd->json.obj.float_obj.name = fd->name_string; in json_float_object_write()
596 fd->json.obj.string_obj.name = fd->name_string; in json_string_object_write()
665 fd->json.obj.boolean_obj.name = fd->name_string; in json_boolean_object_write()
715 fd->json.obj.string_obj.name = fd->name_string; in json_objlnk_object_write()
961 fd->json.obj.opaque_obj.name = fd->name_string; in put_opaque()
1400 (void)memset(&fd, 0, sizeof(fd)); in do_read_op_senml_json()
1474 (void)memset(&fd, 0, sizeof(fd)); in do_write_op_senml_json()
1624 (void)memset(&fd, 0, sizeof(fd)); in do_composite_read_op_for_parsed_list_senml_json()
[all …]
A Dlwm2m_rw_json.c285 fd->json.obj.float_obj.name = fd->name_string; in json_float_object_write()
325 fd->json.obj.string_obj.name = fd->name_string; in json_string_object_write()
364 fd->json.obj.boolean_obj.name = fd->name_string; in json_boolean_object_write()
403 fd->json.obj.string_obj.name = fd->name_string; in json_objlnk_object_write()
471 if (!fd) { in put_begin_ri()
485 if (!fd) { in put_end_ri()
653 if (!fd || (fd->object_bit_field & JSON_V_TYPE) == 0) { in read_int()
719 if (!fd || (fd->object_bit_field & JSON_SV_TYPE) == 0) { in get_string()
747 if (!fd || (fd->object_bit_field & JSON_V_TYPE) == 0) { in get_float()
893 (void)memset(&fd, 0, sizeof(fd)); in do_read_op_json()
[all …]
A Dlwm2m_rw_senml_cbor.c81 #define GET_CBOR_FD_NAME(fd) ((fd)->names[(fd)->name_cnt]) argument
99 (void)memset(fd, 0, sizeof(*fd)); in setup_out_fmt_data()
119 (void)memset(fd, 0, sizeof(*fd)); in setup_in_fmt_data()
173 fd->name_cnt++; in put_basename()
547 if (!fd || !fd->current) { in get_opaque()
573 if (!fd || !fd->current) { in get_s32()
588 if (!fd || !fd->current) { in get_s64()
616 if (!fd || !fd->current) { in get_float()
642 if (!fd || !fd->current) { in get_string()
711 if (!fd || !fd->current) { in get_bool()
[all …]
A Dlwm2m_rw_oma_tlv.c131 if (!fd) { in oma_tlv_put_u8()
314 if (!fd) { in put_end_tlv()
343 if (!fd) { in put_begin_oi()
360 if (!fd) { in put_end_oi()
374 if (!fd) { in put_begin_ri()
388 if (!fd) { in put_end_ri()
411 if (!fd) { in put_s8()
435 if (!fd) { in put_s16()
460 if (!fd) { in put_s32()
486 if (!fd) { in put_s64()
[all …]
A Dlwm2m_rw_link_format.c53 fd = engine_get_out_user_data(out); in put_begin()
54 if (fd == NULL) { in put_begin()
58 switch (fd->mode) { in put_begin()
83 fd->is_first = false; in put_begin()
557 fd = engine_get_out_user_data(out); in put_corelink()
558 if (fd == NULL) { in put_corelink()
562 if (fd->is_first) { in put_corelink()
563 fd->is_first = false; in put_corelink()
632 fd.is_first = true; in do_discover_op_link_format()
635 fd.request_level = msg->path.level; in do_discover_op_link_format()
[all …]
/subsys/net/lib/sockets/
A Dsocket_dispatcher.c16 int fd; member
53 int new_fd, fd; in sock_dispatch_socket() local
71 fd = ctx->fd; in sock_dispatch_socket()
79 return fd; in sock_dispatch_socket()
142 int fd; in sock_dispatch_read_vmeth() local
147 if (fd < 0) { in sock_dispatch_read_vmeth()
162 int fd; in sock_dispatch_write_vmeth() local
182 int fd; in sock_dispatch_ioctl_vmeth() local
317 int fd; in sock_dispatch_setsockopt_vmeth() local
481 entry->fd = fd; in sock_dispatch_create()
[all …]
A Dsocket_obj_core.c25 .fd = -1,
44 static void set_fields(struct sock_obj *obj, int fd, in set_fields() argument
48 obj->fd = fd; in set_fields()
104 if (sock_objects[i].fd == sock) { in sock_obj_core_get_reg_and_proto()
135 if (sock_objects[i].fd < 0) { in sock_obj_core_alloc()
193 int sock_obj_core_dealloc(int fd) in sock_obj_core_dealloc() argument
200 if (sock_objects[i].fd == fd) { in sock_obj_core_dealloc()
201 sock_objects[i].fd = -1; in sock_obj_core_dealloc()
222 void sock_obj_core_update_send_stats(int fd, int bytes) in sock_obj_core_update_send_stats() argument
228 if (sock_objects[i].fd == fd) { in sock_obj_core_update_send_stats()
[all …]
A Dsockets_service.c48 svc->pev[i].event.fd = -1; in cleanup_svc_events()
107 if (svc->pev[i].event.fd == pev->fd) { in find_svc_and_event()
132 int fd = pev->fd; in call_work() local
137 pev->fd = -1; in call_work()
143 pev->fd = fd; in call_work()
174 int ret, i, fd, count = 0; in socket_service_thread() local
207 fd = zvfs_eventfd(0, 0); in socket_service_thread()
208 if (fd < 0) { in socket_service_thread()
209 fd = -errno; in socket_service_thread()
217 ctx.events[0].fd = fd; in socket_service_thread()
[all …]
A Dsockets_packet.c83 int fd; in zpacket_socket() local
86 fd = zvfs_reserve_fd(); in zpacket_socket()
87 if (fd < 0) { in zpacket_socket()
103 zvfs_free_fd(fd); in zpacket_socket()
121 zvfs_free_fd(fd); in zpacket_socket()
126 zvfs_finalize_typed_fd(fd, ctx, (const struct fd_op_vtable *)&packet_sock_fd_op_vtable, in zpacket_socket()
129 return fd; in zpacket_socket()
464 static int packet_sock_close2_vmeth(void *obj, int fd) in packet_sock_close2_vmeth() argument
466 return zsock_close_ctx(obj, fd); in packet_sock_close2_vmeth()
A Dsockets_net_mgmt.c57 int fd, i; in znet_mgmt_socket() local
72 fd = zvfs_reserve_fd(); in znet_mgmt_socket()
73 if (fd < 0) { in znet_mgmt_socket()
83 zvfs_finalize_typed_fd(fd, mgmt, (const struct fd_op_vtable *)&net_mgmt_sock_fd_op_vtable, in znet_mgmt_socket()
86 return fd; in znet_mgmt_socket()
/subsys/net/lib/http/
A Dhttp_server_core.c80 int fd, af, i; in http_server_init() local
102 if (fd < 0) { in http_server_init()
103 fd = -errno; in http_server_init()
105 return fd; in http_server_init()
108 ctx->fds[count].fd = fd; in http_server_init()
164 if (fd < 0) { in http_server_init()
245 *svc->fd = fd; in http_server_init()
246 ctx->fds[count].fd = fd; in http_server_init()
366 if (server_ctx.fds[i].fd == *client->service->fd) { in http_server_release_client()
372 if (server_ctx.fds[i].fd == client->fd) { in http_server_release_client()
[all …]
/subsys/net/lib/zperf/
A Dzperf_tcp_receiver.c111 if (fds[i].fd >= 0) { in tcp_receiver_cleanup()
112 zsock_close(fds[i].fd); in tcp_receiver_cleanup()
113 fds[i].fd = -1; in tcp_receiver_cleanup()
157 if (fds[SOCK_ID_IPV4_LISTEN].fd == pev->event.fd || in tcp_recv_data()
158 fds[SOCK_ID_IPV6_LISTEN].fd == pev->event.fd) { in tcp_recv_data()
172 if (fds[i].fd < 0) { in tcp_recv_data()
182 fds[i].fd = sock; in tcp_recv_data()
205 if (fds[i].fd == pev->event.fd) { in tcp_recv_data()
215 zsock_close(fds[i].fd); in tcp_recv_data()
216 fds[i].fd = -1; in tcp_recv_data()
[all …]
A Dzperf_udp_receiver.c302 if (fds[i].fd >= 0) { in udp_receiver_cleanup()
303 zperf_udp_leave_mcast(fds[i].fd); in udp_receiver_cleanup()
304 zsock_close(fds[i].fd); in udp_receiver_cleanup()
305 fds[i].fd = -1; in udp_receiver_cleanup()
330 (void)zsock_getsockopt(pev->event.fd, SOL_SOCKET, in udp_recv_data()
361 udp_received(pev->event.fd, &addr, buf, ret); in udp_recv_data()
389 fds[i].fd = -1; in zperf_udp_receiver_init()
401 if (fds[SOCK_ID_IPV4].fd < 0) { in zperf_udp_receiver_init()
435 ret = zsock_bind(fds[SOCK_ID_IPV4].fd, in zperf_udp_receiver_init()
455 if (fds[SOCK_ID_IPV6].fd < 0) { in zperf_udp_receiver_init()
[all …]
/subsys/shell/backends/
A Dshell_telnet.c55 sh_telnet->fds[SOCK_ID_CLIENT].fd = -1; in telnet_end_client_connection()
480 if (evt->event.fd == sh_telnet->fds[SOCK_ID_CLIENT].fd) { in telnet_server_cb()
492 if (evt->event.fd == sh_telnet->fds[SOCK_ID_IPV4_LISTEN].fd) { in telnet_server_cb()
495 } else if (evt->event.fd == sh_telnet->fds[SOCK_ID_IPV6_LISTEN].fd) { in telnet_server_cb()
498 } else if (evt->event.fd == sh_telnet->fds[SOCK_ID_CLIENT].fd) { in telnet_server_cb()
515 if (pollfd->fd < 0) { in telnet_setup_server()
529 if (zsock_listen(pollfd->fd, 1)) { in telnet_setup_server()
547 if (pollfd->fd >= 0) { in telnet_setup_server()
548 (void)zsock_close(pollfd->fd); in telnet_setup_server()
549 pollfd->fd = -1; in telnet_setup_server()
[all …]
A Dshell_websocket.c44 ws->fds[0].fd = -1; in ws_end_client_connection()
66 if (ws->fds[0].fd < 0) { in ws_send()
170 if (evt->event.fd == ws->fds[0].fd) { in ws_server_cb()
181 if (evt->event.fd == ws->fds[0].fd) { in ws_server_cb()
195 if (ctx->fds[0].fd >= 0) { in shell_ws_init()
202 ctx->fds[0].fd = ws_socket; in shell_ws_init()
218 if (ctx->fds[0].fd >= 0) { in shell_ws_init()
219 (void)zsock_close(ctx->fds[0].fd); in shell_ws_init()
220 ctx->fds[0].fd = -1; in shell_ws_init()
239 ws->fds[i].fd = -1; in init()
[all …]
/subsys/net/lib/dns/
A Ddispatcher.c132 dispatcher = table[pev->event.fd].ctx; in recv_data()
136 (void)zsock_getsockopt(pev->event.fd, SOL_SOCKET, in recv_data()
141 (void)zsock_getsockopt(pev->event.fd, SOL_SOCKET, in recv_data()
161 ret = zsock_recvfrom(pev->event.fd, dns_data->data, in recv_data()
173 ret = dns_dispatch(dispatcher, pev->event.fd, in recv_data()
265 if (ctx->fds[i].fd < 0) { in dns_dispatcher_register()
270 dispatch_table[ctx->fds[i].fd].ctx = ctx; in dns_dispatcher_register()
306 if (ctx->fds[i].fd < 0) { in dns_dispatcher_register()
311 dispatch_table[ctx->fds[i].fd].ctx = ctx; in dns_dispatcher_register()
348 if (ctx->fds[i].fd < 0) { in dns_dispatcher_unregister()
[all …]
A Dllmnr_responder.c525 (void)zsock_getsockopt(pev->event.fd, SOL_SOCKET, in recv_data()
527 (void)zsock_getsockopt(pev->event.fd, SOL_SOCKET, in recv_data()
541 ret = zsock_recvfrom(pev->event.fd, dns_data->data, in recv_data()
553 ret = dns_read(pev->event.fd, dns_data, len, in recv_data()
625 fds[j].fd = -1; in init_listener()
646 if (fds[j].fd == ipv6) { in init_listener()
651 if (fds[j].fd < 0) { in init_listener()
652 fds[j].fd = ipv6; in init_listener()
693 if (fds[j].fd == ipv4) { in init_listener()
698 if (fds[j].fd < 0) { in init_listener()
[all …]
/subsys/net/lib/shell/
A Dsockets.c32 char fd[5] = { 0 }; in walk_sockets() local
53 if (obj->fd < 0) { in walk_sockets()
58 fd[0] = 'C'; in walk_sockets()
59 fd[1] = '\0'; in walk_sockets()
64 snprintk(fd, sizeof(fd), "%d", obj->fd); in walk_sockets()
78 fd, lifetime, stats.sent, stats.received); in walk_sockets()
106 "%d,", svc->pev[i].event.fd); in walk_socket_services()
/subsys/net/lib/sntp/
A Dsntp.c165 ctx->sock.fd = zsock_socket(addr->sa_family, SOCK_DGRAM, IPPROTO_UDP); in sntp_init()
166 if (ctx->sock.fd < 0) { in sntp_init()
171 ret = zsock_connect(ctx->sock.fd, addr, addr_len); in sntp_init()
173 (void)zsock_close(ctx->sock.fd); in sntp_init()
178 ctx->sock.fds[ctx->sock.nfds].fd = ctx->sock.fd; in sntp_init()
200 return zsock_send(ctx->sock.fd, (uint8_t *)&tx_pkt, sizeof(tx_pkt), 0); in sntp_query_send()
237 rcvd = zsock_recv(ctx->sock.fd, (uint8_t *)&buf, sizeof(buf), 0); in sntp_recv_response()
255 (void)zsock_close(ctx->sock.fd); in sntp_close()
307 rcvd = zsock_recv(ctx->sock.fd, (uint8_t *)&buf, sizeof(buf), 0); in sntp_read_async()
326 (void)zsock_close(ctx->sock.fd); in sntp_close_async()
/subsys/net/lib/websocket/
A Dwebsocket.c257 fd = -1; in websocket_connect()
367 if (fd < 0) { in websocket_connect()
372 ctx->sock = fd; in websocket_connect()
400 return fd; in websocket_connect()
403 if (fd >= 0) { in websocket_connect()
570 pfd.fd = sock; in sendmsg_all()
902 .fd = sock, in wait_rx()
1171 int ret, fd; in websocket_register() local
1194 if (fd < 0) { in websocket_register()
1199 ctx->sock = fd; in websocket_register()
[all …]
/subsys/logging/backends/
A Dlog_backend_ws.c182 int log_backend_ws_register(int fd) in log_backend_ws_register() argument
186 ctx->sock = fd; in log_backend_ws_register()
191 int log_backend_ws_unregister(int fd) in log_backend_ws_unregister() argument
195 if (ctx->sock != fd) { in log_backend_ws_unregister()
196 LOG_DBG("Websocket sock mismatch (%d vs %d)", ctx->sock, fd); in log_backend_ws_unregister()
/subsys/net/lib/ptp/
A Dptp.c42 struct zsock_pollfd *fd; in ptp_thread() local
50 fd = ptp_clock_poll_sockets(); in ptp_thread()
72 for (int i = 0; i < PTP_SOCKET_CNT; i++, fd++) { in ptp_thread()
73 if (!(fd->revents & (ZSOCK_POLLIN | ZSOCK_POLLPRI))) { in ptp_thread()
A Dclock.c229 struct zsock_pollfd *fd = &ptp_clk.pollfd[1]; in clock_check_pollfd() local
237 fd->fd = port->socket[i]; in clock_check_pollfd()
238 fd->events = ZSOCK_POLLIN | ZSOCK_POLLPRI; in clock_check_pollfd()
239 fd++; in clock_check_pollfd()
289 ptp_clk.pollfd[0].fd = eventfd(0, EFD_NONBLOCK); in ptp_clock_init()
306 eventfd_read(ptp_clk.pollfd[0].fd, &value); in ptp_clock_poll_sockets()
661 eventfd_write(ptp_clk.pollfd[0].fd, 1); in ptp_clock_signal_timeout()
/subsys/net/lib/coap/
A Dcoap_client.c91 client->fd = sock; in coap_client_schedule_poll()
369 if (client->fd != sock && has_ongoing_request(client)) { in coap_client_req()
507 ret = send_request(client->fd, internal_req->request.data, in resend_request()
555 if (clients[i]->fd == sock) { in get_client()
579 fds[nfds].fd = clients[i]->fd; in handle_poll()
596 struct coap_client *client = get_client(fds[i].fd); in handle_poll()
599 LOG_ERR("No client found for socket %d", fds[i].fd); in handle_poll()
629 LOG_ERR("Error in poll for socket %d", fds[i].fd); in handle_poll()
633 LOG_ERR("Error in poll: POLLHUP for socket %d", fds[i].fd); in handle_poll()
862 ret = send_request(client->fd, internal_req->request.data, in handle_response()
[all …]
A Dcoap_server.c828 sock_fds[sock_nfds].fd = svc->data->sock_fd; in coap_server_thread()
836 sock_fds[sock_nfds].fd = control_sock; in coap_server_thread()
852 if (sock_fds[i].fd == control_sock && in coap_server_thread()
856 zvfs_eventfd_read(sock_fds[i].fd, &tmp); in coap_server_thread()
862 coap_server_process(sock_fds[i].fd); in coap_server_thread()
867 LOG_ERR("Poll error on %d", sock_fds[i].fd); in coap_server_thread()
870 LOG_DBG("Poll hup on %d", sock_fds[i].fd); in coap_server_thread()
873 LOG_ERR("Poll invalid on %d", sock_fds[i].fd); in coap_server_thread()

Completed in 70 milliseconds

12