| /Zephyr-latest/subsys/net/lib/mqtt/ |
| D | mqtt.c | 21 static void client_reset(struct mqtt_client *client) in client_reset()
31 static void tx_buf_init(struct mqtt_client *client, struct buf_ctx *buf) in tx_buf_init()
38 void event_notify(struct mqtt_client *client, const struct mqtt_evt *evt) in event_notify()
49 static void client_disconnect(struct mqtt_client *client, int result, in client_disconnect()
73 static int client_connect(struct mqtt_client *client) in client_connect()
112 static int client_read(struct mqtt_client *client) in client_read()
128 static int client_write(struct mqtt_client *client, const uint8_t *data, in client_write()
149 static int client_write_msg(struct mqtt_client *client, in client_write_msg()
170 void mqtt_client_init(struct mqtt_client *client) in mqtt_client_init()
185 int mqtt_client_set_proxy(struct mqtt_client *client, in mqtt_client_set_proxy()
[all …]
|
| D | mqtt_transport.c | 61 int mqtt_transport_connect(struct mqtt_client *client) in mqtt_transport_connect()
66 int mqtt_transport_write(struct mqtt_client *client, const uint8_t *data, in mqtt_transport_write()
73 int mqtt_transport_write_msg(struct mqtt_client *client, in mqtt_transport_write_msg()
79 int mqtt_transport_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_transport_read()
86 int mqtt_transport_disconnect(struct mqtt_client *client) in mqtt_transport_disconnect()
|
| D | mqtt_transport_socket_tcp.c | 21 int mqtt_client_tcp_connect(struct mqtt_client *client) in mqtt_client_tcp_connect()
66 int mqtt_client_tcp_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tcp_write()
85 int mqtt_client_tcp_write_msg(struct mqtt_client *client, in mqtt_client_tcp_write_msg()
125 int mqtt_client_tcp_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tcp_read()
143 int mqtt_client_tcp_disconnect(struct mqtt_client *client) in mqtt_client_tcp_disconnect()
|
| D | mqtt_transport_socket_tls.c | 21 int mqtt_client_tls_connect(struct mqtt_client *client) in mqtt_client_tls_connect()
123 int mqtt_client_tls_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tls_write()
142 int mqtt_client_tls_write_msg(struct mqtt_client *client, in mqtt_client_tls_write_msg()
181 int mqtt_client_tls_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tls_read()
199 int mqtt_client_tls_disconnect(struct mqtt_client *client) in mqtt_client_tls_disconnect()
|
| D | mqtt_transport_websocket.c | 24 int mqtt_client_websocket_connect(struct mqtt_client *client) in mqtt_client_websocket_connect()
89 int mqtt_client_websocket_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_websocket_write()
110 int mqtt_client_websocket_write_msg(struct mqtt_client *client, in mqtt_client_websocket_write_msg()
140 int mqtt_client_websocket_read(struct mqtt_client *client, uint8_t *data, in mqtt_client_websocket_read()
169 int mqtt_client_websocket_disconnect(struct mqtt_client *client) in mqtt_client_websocket_disconnect()
|
| D | mqtt_os.h | 37 static inline void mqtt_mutex_init(struct mqtt_client *client) in mqtt_mutex_init()
47 static inline void mqtt_mutex_lock(struct mqtt_client *client) in mqtt_mutex_lock()
57 static inline void mqtt_mutex_unlock(struct mqtt_client *client) in mqtt_mutex_unlock()
|
| D | mqtt_rx.c | 19 static int mqtt_handle_packet(struct mqtt_client *client, in mqtt_handle_packet()
148 static int mqtt_read_message_chunk(struct mqtt_client *client, in mqtt_read_message_chunk()
196 static int mqtt_read_publish_var_header(struct mqtt_client *client, in mqtt_read_publish_var_header()
231 static int mqtt_read_and_parse_fixed_header(struct mqtt_client *client, in mqtt_read_and_parse_fixed_header()
256 int mqtt_handle_rx(struct mqtt_client *client) in mqtt_handle_rx()
|
| /Zephyr-latest/subsys/net/lib/mqtt_sn/ |
| D | mqtt_sn.c | 80 static void mqtt_sn_set_state(struct mqtt_sn_client *client, enum mqtt_sn_client_state state) in mqtt_sn_set_state()
101 static int encode_and_send(struct mqtt_sn_client *client, struct mqtt_sn_param *p, in encode_and_send()
157 static void mqtt_sn_publish_destroy(struct mqtt_sn_client *client, struct mqtt_sn_publish *pub) in mqtt_sn_publish_destroy()
163 static void mqtt_sn_publish_destroy_all(struct mqtt_sn_client *client) in mqtt_sn_publish_destroy_all()
200 static struct mqtt_sn_publish *mqtt_sn_publish_find_msg_id(struct mqtt_sn_client *client, in mqtt_sn_publish_find_msg_id()
214 static struct mqtt_sn_publish *mqtt_sn_publish_find_topic(struct mqtt_sn_client *client, in mqtt_sn_publish_find_topic()
257 static struct mqtt_sn_topic *mqtt_sn_topic_find_name(struct mqtt_sn_client *client, in mqtt_sn_topic_find_name()
272 static struct mqtt_sn_topic *mqtt_sn_topic_find_msg_id(struct mqtt_sn_client *client, in mqtt_sn_topic_find_msg_id()
286 static void mqtt_sn_topic_destroy(struct mqtt_sn_client *client, struct mqtt_sn_topic *topic) in mqtt_sn_topic_destroy()
299 static void mqtt_sn_topic_destroy_all(struct mqtt_sn_client *client) in mqtt_sn_topic_destroy_all()
[all …]
|
| /Zephyr-latest/subsys/net/lib/http/ |
| D | http_server_http2.c | 41 static void print_http_frames(struct http_client_ctx *client) in print_http_frames()
67 struct http_client_ctx *client, uint32_t stream_id) in find_http_stream_context()
79 struct http_client_ctx *client, uint32_t stream_id) in allocate_http_stream_context()
96 static void release_http_stream_context(struct http_client_ctx *client, in release_http_stream_context()
109 static int add_header_field(struct http_client_ctx *client, uint8_t **buf, in add_header_field()
141 static int send_headers_frame(struct http_client_ctx *client, enum http_status status, in send_headers_frame()
214 static int send_data_frame(struct http_client_ctx *client, const char *payload, in send_data_frame()
240 int send_settings_frame(struct http_client_ctx *client, bool ack) in send_settings_frame()
283 int send_window_update_frame(struct http_client_ctx *client, in send_window_update_frame()
318 static int send_http2_404(struct http_client_ctx *client, in send_http2_404()
[all …]
|
| D | http_server_core.c | 294 struct http_client_ctx *client = in close_all_sockets() local
304 static void client_release_resources(struct http_client_ctx *client) in client_release_resources()
343 void http_server_release_client(struct http_client_ctx *client) in http_server_release_client()
366 static void close_client_connection(struct http_client_ctx *client) in close_client_connection()
378 struct http_client_ctx *client = in client_timeout() local
389 void http_client_timer_restart(struct http_client_ctx *client) in http_client_timer_restart()
396 static void init_client_ctx(struct http_client_ctx *client, int new_socket) in init_client_ctx()
418 static int handle_http_preface(struct http_client_ctx *client) in handle_http_preface()
440 static int handle_http_done(struct http_client_ctx *client) in handle_http_done()
449 int enter_http_done_state(struct http_client_ctx *client) in enter_http_done_state()
[all …]
|
| D | http_server_http1.c | 42 struct http_client_ctx *client) in handle_http1_static_resource()
119 static int http1_send_headers(struct http_client_ctx *client, enum http_status status, in http1_send_headers()
212 static int http1_dynamic_response(struct http_client_ctx *client, struct http_response_ctx *rsp, in http1_dynamic_response()
258 struct http_client_ctx *client) in dynamic_get_del_req()
302 struct http_client_ctx *client) in dynamic_post_put_req()
387 struct http_client_ctx *client) in handle_http1_static_fs_resource()
486 struct http_client_ctx *client) in handle_http1_dynamic_resource()
775 int enter_http1_request(struct http_client_ctx *client) in enter_http1_request()
801 int handle_http1_request(struct http_client_ctx *client) in handle_http1_request()
|
| /Zephyr-latest/samples/net/secure_mqtt_sensor_actuator/src/ |
| D | mqtt_client.c | 72 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
123 static void on_mqtt_publish(struct mqtt_client *const client, const struct mqtt_evt *evt) in on_mqtt_publish()
149 static void mqtt_event_handler(struct mqtt_client *const client, const struct mqtt_evt *evt) in mqtt_event_handler()
248 static int poll_mqtt_socket(struct mqtt_client *client, int timeout) in poll_mqtt_socket()
291 int app_mqtt_publish(struct mqtt_client *client) in app_mqtt_publish()
329 int app_mqtt_subscribe(struct mqtt_client *client) in app_mqtt_subscribe()
359 int app_mqtt_process(struct mqtt_client *client) in app_mqtt_process()
390 void app_mqtt_run(struct mqtt_client *client) in app_mqtt_run()
408 void app_mqtt_connect(struct mqtt_client *client) in app_mqtt_connect()
435 int app_mqtt_init(struct mqtt_client *client) in app_mqtt_init()
|
| /Zephyr-latest/subsys/net/lib/coap/ |
| D | coap_client.c | 87 static int coap_client_schedule_poll(struct coap_client *client, int sock, in coap_client_schedule_poll()
119 static bool has_ongoing_request(struct coap_client *client) in has_ongoing_request()
130 static bool has_ongoing_exchange(struct coap_client *client) in has_ongoing_exchange()
142 static bool has_timeout_expired(struct coap_client *client) in has_timeout_expired()
152 static struct coap_client_internal_request *get_free_request(struct coap_client *client) in get_free_request()
197 static int coap_client_init_request(struct coap_client *client, in coap_client_init_request()
348 int coap_client_req(struct coap_client *client, int sock, const struct sockaddr *addr, in coap_client_req()
483 static int resend_request(struct coap_client *client, in resend_request()
528 static void coap_client_resend_handler(struct coap_client *client) in coap_client_resend_handler()
596 struct coap_client *client = get_client(fds[i].fd); in handle_poll() local
[all …]
|
| /Zephyr-latest/subsys/bluetooth/audio/ |
| D | csip_set_coordinator.c | 113 struct bt_csip_set_coordinator_inst *client = in active_members_reset() local
126 struct bt_csip_set_coordinator_inst *client; in lookup_instance_by_handle() local
148 struct bt_csip_set_coordinator_inst *client; in bt_csip_set_coordinator_lookup_instance_by_index() local
362 static void discover_complete(struct bt_csip_set_coordinator_inst *client, in discover_complete()
407 struct bt_csip_set_coordinator_inst *client; in sirk_notify_func() local
476 struct bt_csip_set_coordinator_inst *client; in size_notify_func() local
522 struct bt_csip_set_coordinator_inst *client; in lock_notify_func() local
558 struct bt_csip_set_coordinator_inst *client = &client_insts[bt_conn_index(inst->conn)]; in csip_set_coordinator_write_set_lock() local
578 struct bt_csip_set_coordinator_inst *client = &client_insts[bt_conn_index(svc_inst->conn)]; in read_sirk() local
605 struct bt_csip_set_coordinator_inst *client = &client_insts[bt_conn_index(conn)]; in csip_set_coordinator_read_set_size() local
[all …]
|
| D | cap_common.c | 86 struct bt_cap_common_client *client; in bt_cap_common_get_member_conn() local
222 struct bt_cap_common_client *client = bt_cap_common_get_client_by_acl(conn); in bt_cap_common_disconnected() local
255 struct bt_cap_common_client *client = &bt_cap_common_clients[i]; in bt_cap_common_get_client_by_csis() local
269 struct bt_cap_common_client *client; in cap_common_discover_complete() local
284 struct bt_cap_common_client *client; in csis_client_discover_cb() local
318 struct bt_cap_common_client *client = in bt_cap_common_discover_included_cb() local
368 struct bt_cap_common_client *client = in bt_cap_common_discover_cas_cb() local
403 struct bt_cap_common_client *client; in bt_cap_common_discover() local
|
| D | has.c | 261 static void client_free(struct has_client *client) in client_free()
286 struct has_client *client = NULL; in client_alloc() local
346 static void notify_work_reschedule(struct has_client *client, k_timeout_t delay) in notify_work_reschedule()
364 struct has_client *client; in security_changed() local
397 struct has_client *client; in disconnected() local
410 struct has_client *client; in identity_resolved() local
431 struct has_client *client = CONTAINER_OF(dwork, struct has_client, notify_work); in notify_work_handler() local
506 static void notify(struct has_client *client, enum flag_internal flag) in notify()
729 struct has_client *client = client_find_by_conn(conn); in control_point_ntf_complete() local
751 static int control_point_send(struct has_client *client, struct net_buf_simple *buf) in control_point_send()
[all …]
|
| /Zephyr-latest/samples/subsys/modbus/tcp_gateway/src/ |
| D | main.c | 46 static int modbus_tcp_reply(int client, struct modbus_adu *adu) in modbus_tcp_reply()
62 static int modbus_tcp_connection(int client) in modbus_tcp_connection()
129 int client; in main() local
|
| /Zephyr-latest/subsys/mgmt/mcumgr/grp/os_mgmt_client/src/ |
| D | os_mgmt_client.c | 36 void os_mgmt_client_init(struct os_mgmt_client *client, struct smp_client_object *smp_client) in os_mgmt_client_init()
54 int os_mgmt_client_reset(struct os_mgmt_client *client) in os_mgmt_client_reset()
122 int os_mgmt_client_echo(struct os_mgmt_client *client, const char *echo_string, size_t max_len) in os_mgmt_client_echo()
|
| /Zephyr-latest/samples/net/cloud/mqtt_azure/src/ |
| D | main.c | 89 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
144 static void client_init(struct mqtt_client *client) in client_init()
198 static void mqtt_event_handler(struct mqtt_client *const client, in mqtt_event_handler()
273 static void subscribe(struct mqtt_client *client) in subscribe()
290 static int publish(struct mqtt_client *client, enum mqtt_qos qos) in publish()
350 static int try_to_connect(struct mqtt_client *client) in try_to_connect()
|
| /Zephyr-latest/samples/net/mqtt_publisher/src/ |
| D | main.c | 109 static void prepare_fds(struct mqtt_client *client) in prepare_fds()
143 void mqtt_evt_handler(struct mqtt_client *const client, in mqtt_evt_handler()
243 static int publish(struct mqtt_client *client, enum mqtt_qos qos) in publish()
298 static void client_init(struct mqtt_client *client) in client_init()
365 static int try_to_connect(struct mqtt_client *client) in try_to_connect()
398 static int process_mqtt_and_sleep(struct mqtt_client *client, int timeout) in process_mqtt_and_sleep()
|
| /Zephyr-latest/subsys/bluetooth/mesh/ |
| D | proxy_srv.c | 106 static int filter_set(struct bt_mesh_proxy_client *client, in filter_set()
136 static void filter_add(struct bt_mesh_proxy_client *client, uint16_t addr) in filter_add()
160 static void filter_remove(struct bt_mesh_proxy_client *client, uint16_t addr) in filter_remove()
178 static void send_filter_status(struct bt_mesh_proxy_client *client, in send_filter_status()
230 struct bt_mesh_proxy_client *client; in proxy_filter_recv() local
320 static int beacon_send(struct bt_mesh_proxy_client *client, in beacon_send()
344 struct bt_mesh_proxy_client *client = cb_data; in send_beacon_cb() local
351 struct bt_mesh_proxy_client *client; in proxy_send_beacons() local
921 struct bt_mesh_proxy_client *client; in proxy_ccc_write() local
1020 struct bt_mesh_proxy_client *client = &clients[i]; in bt_mesh_proxy_gatt_disconnect() local
[all …]
|
| /Zephyr-latest/arch/common/ |
| D | shared_irq.c | 23 const struct _isr_table_entry *client; in z_shared_isr() local
45 struct _isr_table_entry *client; in z_isr_install() local
165 struct _isr_table_entry *client; in z_isr_uninstall() local
|
| /Zephyr-latest/subsys/net/lib/tftp/ |
| D | tftp_client.c | 53 static int send_data(int sock, struct tftpc *client, uint32_t block_no, const uint8_t *data_buffer, in send_data()
145 static inline int send_err(int sock, struct tftpc *client, int err_code, char *err_msg) in send_err()
182 static int send_request(int sock, struct tftpc *client, in send_request()
244 int tftp_get(struct tftpc *client, const char *remote_file, const char *mode) in tftp_get()
372 int tftp_put(struct tftpc *client, const char *remote_file, const char *mode, in tftp_put()
|
| /Zephyr-latest/subsys/mgmt/mcumgr/grp/img_mgmt_client/src/ |
| D | img_mgmt_client.c | 296 void img_mgmt_client_init(struct img_mgmt_client *client, struct smp_client_object *smp_client, in img_mgmt_client_init()
304 int img_mgmt_client_upload_init(struct img_mgmt_client *client, size_t image_size, in img_mgmt_client_upload_init()
331 int img_mgmt_client_upload(struct img_mgmt_client *client, const uint8_t *data, size_t length, in img_mgmt_client_upload()
452 int img_mgmt_client_state_write(struct img_mgmt_client *client, char *hash, bool confirm, in img_mgmt_client_state_write()
518 int img_mgmt_client_state_read(struct img_mgmt_client *client, struct mcumgr_image_state *res_buf) in img_mgmt_client_state_read()
566 int img_mgmt_client_erase(struct img_mgmt_client *client, uint32_t slot) in img_mgmt_client_erase()
|
| /Zephyr-latest/tests/net/lib/mqtt_sn_client/src/ |
| D | mqtt_sn_client.c | 31 struct mqtt_sn_client *client; member
43 static int msg_sendto(struct mqtt_sn_client *client, void *buf, size_t sz, const void *dest_addr, in msg_sendto()
77 static void evt_cb(struct mqtt_sn_client *client, const struct mqtt_sn_evt *evt) in evt_cb()
101 static ssize_t tp_recvfrom(struct mqtt_sn_client *client, void *buffer, size_t length, in tp_recvfrom()
115 int tp_poll(struct mqtt_sn_client *client) in tp_poll()
142 static int input(struct mqtt_sn_client *client, void *buf, size_t sz, in input()
153 static void mqtt_sn_connect_no_will(struct mqtt_sn_client *client) in mqtt_sn_connect_no_will()
|
