| /subsys/net/lib/mqtt/ |
| A D | mqtt.c | 21 static void client_reset(struct mqtt_client *client) in client_reset()
163 static int client_read(struct mqtt_client *client) in client_read()
226 void mqtt_client_init(struct mqtt_client *client) in mqtt_client_init()
261 int mqtt_connect(struct mqtt_client *client) in mqtt_connect()
296 int mqtt_publish(struct mqtt_client *client, in mqtt_publish()
498 int mqtt_disconnect(struct mqtt_client *client, in mqtt_disconnect()
533 int mqtt_subscribe(struct mqtt_client *client, in mqtt_subscribe()
602 int mqtt_ping(struct mqtt_client *client) in mqtt_ping()
689 int mqtt_abort(struct mqtt_client *client) in mqtt_abort()
704 int mqtt_live(struct mqtt_client *client) in mqtt_live()
[all …]
|
| A 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()
|
| A D | mqtt_transport_socket_tcp.c | 21 int mqtt_client_tcp_connect(struct mqtt_client *client) in mqtt_client_tcp_connect()
84 int mqtt_client_tcp_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tcp_write()
103 int mqtt_client_tcp_write_msg(struct mqtt_client *client, in mqtt_client_tcp_write_msg()
143 int mqtt_client_tcp_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tcp_read()
161 int mqtt_client_tcp_disconnect(struct mqtt_client *client) in mqtt_client_tcp_disconnect()
|
| A D | mqtt_transport_socket_tls.c | 21 int mqtt_client_tls_connect(struct mqtt_client *client) in mqtt_client_tls_connect()
141 int mqtt_client_tls_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tls_write()
160 int mqtt_client_tls_write_msg(struct mqtt_client *client, in mqtt_client_tls_write_msg()
199 int mqtt_client_tls_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tls_read()
217 int mqtt_client_tls_disconnect(struct mqtt_client *client) in mqtt_client_tls_disconnect()
|
| A 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()
|
| A D | mqtt_rx.c | 19 static int mqtt_handle_packet(struct mqtt_client *client, in mqtt_handle_packet()
184 static int mqtt_read_message_chunk(struct mqtt_client *client, in mqtt_read_message_chunk()
232 static int mqtt_read_publish_var_header(struct mqtt_client *client, in mqtt_read_publish_var_header()
302 static int mqtt_read_and_parse_fixed_header(struct mqtt_client *client, in mqtt_read_and_parse_fixed_header()
327 int mqtt_handle_rx(struct mqtt_client *client) in mqtt_handle_rx()
|
| A 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()
|
| A D | mqtt_decoder.c | 666 int connect_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in connect_ack_decode()
753 static int publish_topic_alias_check(struct mqtt_client *client, in publish_topic_alias_check()
814 static int publish_topic_alias_check(struct mqtt_client *client, in publish_topic_alias_check()
824 int publish_decode(struct mqtt_client *client, uint8_t flags, in publish_decode()
943 int publish_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in publish_ack_decode()
959 int publish_receive_decode(const struct mqtt_client *client, struct buf_ctx *buf, in publish_receive_decode()
975 int publish_release_decode(const struct mqtt_client *client, struct buf_ctx *buf, in publish_release_decode()
1024 int subscribe_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in subscribe_ack_decode()
1068 int unsubscribe_ack_decode(const struct mqtt_client *client, struct buf_ctx *buf, in unsubscribe_ack_decode()
1115 int disconnect_decode(const struct mqtt_client *client, struct buf_ctx *buf, in disconnect_decode()
[all …]
|
| A D | mqtt_encoder.c | 639 static int will_properties_encode(const struct mqtt_client *client, in will_properties_encode()
708 static int will_properties_encode(const struct mqtt_client *client, in will_properties_encode()
718 int connect_request_encode(const struct mqtt_client *client, in connect_request_encode()
940 int publish_encode(const struct mqtt_client *client, in publish_encode()
1098 int publish_ack_encode(const struct mqtt_client *client, in publish_ack_encode()
1118 int publish_receive_encode(const struct mqtt_client *client, in publish_receive_encode()
1138 int publish_release_encode(const struct mqtt_client *client, in publish_release_encode()
1158 int publish_complete_encode(const struct mqtt_client *client, in publish_complete_encode()
1294 int disconnect_encode(const struct mqtt_client *client, in disconnect_encode()
1351 int subscribe_encode(const struct mqtt_client *client, in subscribe_encode()
[all …]
|
| /subsys/net/lib/mqtt_sn/ |
| A D | mqtt_sn.c | 568 static void mqtt_sn_do_searchgw(struct mqtt_sn_client *client) in mqtt_sn_do_searchgw()
582 static void mqtt_sn_do_gwinfo(struct mqtt_sn_client *client) in mqtt_sn_do_gwinfo()
608 static void mqtt_sn_do_ping(struct mqtt_sn_client *client) in mqtt_sn_do_ping()
958 struct mqtt_sn_client *client; in process_work() local
1036 void mqtt_sn_client_deinit(struct mqtt_sn_client *client) in mqtt_sn_client_deinit()
1115 int mqtt_sn_disconnect(struct mqtt_sn_client *client) in mqtt_sn_disconnect()
1380 static void handle_willtopicreq(struct mqtt_sn_client *client) in handle_willtopicreq()
1392 static void handle_willmsgreq(struct mqtt_sn_client *client) in handle_willmsgreq()
1551 static void handle_pingreq(struct mqtt_sn_client *client) in handle_pingreq()
1558 static void handle_pingresp(struct mqtt_sn_client *client) in handle_pingresp()
[all …]
|
| A D | mqtt_sn_transport_udp.c | 148 static int tp_udp_sendto(struct mqtt_sn_client *client, void *buf, size_t sz, const void *dest_addr, in tp_udp_sendto()
190 static ssize_t tp_udp_recvfrom(struct mqtt_sn_client *client, void *buffer, size_t length, in tp_udp_recvfrom()
218 static int tp_udp_poll(struct mqtt_sn_client *client) in tp_udp_poll()
|
| /subsys/net/lib/http/ |
| A D | http_server_http2.c | 42 static void print_http_frames(struct http_client_ctx *client) in print_http_frames()
68 struct http_client_ctx *client, uint32_t stream_id) in find_http_stream_context()
80 struct http_client_ctx *client, uint32_t stream_id) in allocate_http_stream_context()
321 static int send_http2_404(struct http_client_ctx *client, in send_http2_404()
343 static int send_http2_405(struct http_client_ctx *client, in send_http2_405()
359 static int send_http2_409(struct http_client_ctx *client, in send_http2_409()
373 static void send_http2_500(struct http_client_ctx *client, in send_http2_500()
456 struct http_client_ctx *client) in handle_http2_static_fs_resource()
620 struct http_client_ctx *client) in dynamic_get_del_req_v2()
672 struct http_client_ctx *client, bool headers_only) in dynamic_post_put_req_v2()
[all …]
|
| A D | http_server_http1.c | 41 static int send_http1_error_common(struct http_client_ctx *client, in send_http1_error_common()
57 static int send_http1_404(struct http_client_ctx *client) in send_http1_404()
63 static int send_http1_405(struct http_client_ctx *client) in send_http1_405()
69 static int send_http1_409(struct http_client_ctx *client) in send_http1_409()
122 struct http_client_ctx *client) in handle_http1_static_resource()
341 struct http_client_ctx *client) in dynamic_get_del_req()
385 struct http_client_ctx *client) in dynamic_post_put_req()
470 struct http_client_ctx *client) in handle_http1_static_fs_resource()
591 struct http_client_ctx *client) in handle_http1_dynamic_resource()
891 int enter_http1_request(struct http_client_ctx *client) in enter_http1_request()
[all …]
|
| A D | http_server_core.c | 300 struct http_client_ctx *client = in close_all_sockets() local
314 static void client_release_resources(struct http_client_ctx *client) in client_release_resources()
353 void http_server_release_client(struct http_client_ctx *client) in http_server_release_client()
382 static void close_client_connection(struct http_client_ctx *client) in close_client_connection()
394 struct http_client_ctx *client = in client_timeout() local
405 void http_client_timer_restart(struct http_client_ctx *client) in http_client_timer_restart()
447 static int handle_http_preface(struct http_client_ctx *client) in handle_http_preface()
469 static int handle_http_done(struct http_client_ctx *client) in handle_http_done()
478 int enter_http_done_state(struct http_client_ctx *client) in enter_http_done_state()
487 static int handle_http_request(struct http_client_ctx *client) in handle_http_request()
[all …]
|
| /subsys/net/lib/coap/ |
| A D | coap_client.c | 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()
197 static int coap_client_init_request(struct coap_client *client, in coap_client_init_request()
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
723 struct coap_client *client, const struct coap_packet *resp) in get_request_with_token()
1038 void coap_client_cancel_requests(struct coap_client *client) in coap_client_cancel_requests()
1103 int coap_client_init(struct coap_client *client, const char *info) in coap_client_init()
[all …]
|
| /subsys/bluetooth/audio/ |
| A D | csip_set_coordinator.c | 112 struct bt_csip_set_coordinator_inst *client = in active_members_reset() local
125 struct bt_csip_set_coordinator_inst *client; in lookup_instance_by_handle() local
147 struct bt_csip_set_coordinator_inst *client; in bt_csip_set_coordinator_lookup_instance_by_index() local
413 struct bt_csip_set_coordinator_inst *client; in sirk_notify_func() local
484 struct bt_csip_set_coordinator_inst *client; in size_notify_func() local
530 struct bt_csip_set_coordinator_inst *client; in lock_notify_func() local
1405 struct bt_csip_set_coordinator_inst *client; in bt_csip_set_coordinator_csis_inst_by_handle() local
1418 struct bt_csip_set_coordinator_inst *client; in bt_csip_set_coordinator_set_member_by_conn() local
1451 struct bt_csip_set_coordinator_inst *client; in bt_csip_set_coordinator_discover() local
1566 struct bt_csip_set_coordinator_inst *client = in check_and_set_members_busy() local
[all …]
|
| A D | cap_common.c | 98 struct bt_cap_common_client *client; in bt_cap_common_get_member_conn() local
240 struct bt_cap_common_client *client = bt_cap_common_get_client_by_acl(conn); in bt_cap_common_disconnected() local
273 struct bt_cap_common_client *client = &bt_cap_common_clients[i]; in bt_cap_common_get_client_by_csis() local
287 struct bt_cap_common_client *client; in cap_common_discover_complete() local
302 struct bt_cap_common_client *client; in csis_client_discover_cb() local
336 struct bt_cap_common_client *client = in bt_cap_common_discover_included_cb() local
386 struct bt_cap_common_client *client = in bt_cap_common_discover_cas_cb() local
421 struct bt_cap_common_client *client; in bt_cap_common_discover() local
|
| A D | ccp_call_control_client.c | 83 struct bt_ccp_call_control_client *client = get_client_by_conn(conn); in disconnected_cb() local
97 static void populate_bearers(struct bt_ccp_call_control_client *client, in populate_bearers()
122 struct bt_ccp_call_control_client *client = get_client_by_conn(conn); in tbs_client_discover_cb() local
166 struct bt_ccp_call_control_client *client; in bt_ccp_call_control_client_discover() local
244 int bt_ccp_call_control_client_get_bearers(struct bt_ccp_call_control_client *client, in bt_ccp_call_control_client_get_bearers()
|
| A D | has.c | 260 static void client_free(struct has_client *client) in client_free()
285 struct has_client *client = NULL; in client_alloc() local
363 struct has_client *client; in security_changed() local
396 struct has_client *client; in disconnected() local
409 struct has_client *client; in identity_resolved() local
728 struct has_client *client = client_find_by_conn(conn); in control_point_ntf_complete() local
793 struct has_client *client = NULL; in control_point_send_all() local
980 static int read_preset_response(struct has_client *client) in read_preset_response()
1089 static int preset_list_changed(struct has_client *client) in preset_list_changed()
1163 struct has_client *client; in handle_read_preset_req() local
[all …]
|
| A D | mcs.c | 105 struct client_state *client = &clients[bt_conn_index(conn)]; in read_player_name() local
150 struct client_state *client = &clients[bt_conn_index(conn)]; in read_icon_url() local
177 struct client_state *client = &clients[bt_conn_index(conn)]; in read_track_title() local
206 struct client_state *client = &clients[bt_conn_index(conn)]; in read_track_duration() local
228 struct client_state *client = &clients[bt_conn_index(conn)]; in read_track_position() local
276 struct client_state *client = &clients[bt_conn_index(conn)]; in read_playback_speed() local
318 struct client_state *client = &clients[bt_conn_index(conn)]; in read_seeking_speed() local
361 struct client_state *client = &clients[bt_conn_index(conn)]; in read_current_track_id() local
416 struct client_state *client = &clients[bt_conn_index(conn)]; in read_next_track_id() local
481 struct client_state *client = &clients[bt_conn_index(conn)]; in read_parent_group_id() local
[all …]
|
| /subsys/bluetooth/mesh/ |
| A D | proxy_srv.c | 103 static int filter_set(struct bt_mesh_proxy_client *client, in filter_set()
227 struct bt_mesh_proxy_client *client; in proxy_filter_recv() local
317 static int beacon_send(struct bt_mesh_proxy_client *client, in beacon_send()
341 struct bt_mesh_proxy_client *client = cb_data; in send_beacon_cb() local
348 struct bt_mesh_proxy_client *client; in proxy_send_beacons() local
921 struct bt_mesh_proxy_client *client; in proxy_ccc_write() local
1001 struct bt_mesh_proxy_client *client = &clients[i]; in bt_mesh_proxy_gatt_disconnect() local
1030 struct bt_mesh_proxy_client *client; in bt_mesh_proxy_addr_add() local
1085 struct bt_mesh_proxy_client *client = &clients[i]; in bt_mesh_proxy_relay() local
1115 struct bt_mesh_proxy_client *client; in gatt_connected() local
[all …]
|
| /subsys/mgmt/mcumgr/grp/os_mgmt_client/src/ |
| A 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()
|
| /subsys/mgmt/mcumgr/grp/img_mgmt_client/src/ |
| A 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()
|
| /subsys/net/lib/tftp/ |
| A 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()
|
| /subsys/logging/backends/ |
| A D | log_backend_mqtt.c | 33 struct mqtt_client *client = (struct mqtt_client *)output_ctx; in log_output_func() local
95 int log_backend_mqtt_client_set(struct mqtt_client *client) in log_backend_mqtt_client_set()
|