Lines Matching refs:client
19 static int mqtt_handle_packet(struct mqtt_client *client, in mqtt_handle_packet() argument
33 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_CONNACK!", client); in mqtt_handle_packet()
36 err_code = connect_ack_decode(client, buf, &evt.param.connack); in mqtt_handle_packet()
38 NET_DBG("[CID %p]: return_code: %d", client, in mqtt_handle_packet()
47 MQTT_SET_STATE(client, MQTT_STATE_CONNECTED); in mqtt_handle_packet()
60 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PUBLISH", client); in mqtt_handle_packet()
63 err_code = publish_decode(client, type_and_flags, var_length, in mqtt_handle_packet()
67 client->internal.remaining_payload = in mqtt_handle_packet()
78 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PUBACK!", client); in mqtt_handle_packet()
81 err_code = publish_ack_decode(client, buf, &evt.param.puback); in mqtt_handle_packet()
86 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PUBREC!", client); in mqtt_handle_packet()
89 err_code = publish_receive_decode(client, buf, in mqtt_handle_packet()
95 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PUBREL!", client); in mqtt_handle_packet()
98 err_code = publish_release_decode(client, buf, in mqtt_handle_packet()
104 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PUBCOMP!", client); in mqtt_handle_packet()
107 err_code = publish_complete_decode(client, buf, in mqtt_handle_packet()
113 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_SUBACK!", client); in mqtt_handle_packet()
116 err_code = subscribe_ack_decode(client, buf, &evt.param.suback); in mqtt_handle_packet()
121 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_UNSUBACK!", client); in mqtt_handle_packet()
124 err_code = unsubscribe_ack_decode(client, buf, in mqtt_handle_packet()
130 NET_DBG("[CID %p]: Received MQTT_PKT_TYPE_PINGRSP!", client); in mqtt_handle_packet()
132 if (client->unacked_ping <= 0) { in mqtt_handle_packet()
134 client->unacked_ping = 0; in mqtt_handle_packet()
136 client->unacked_ping--; in mqtt_handle_packet()
145 err_code = disconnect_decode(client, buf, &evt.param.disconnect); in mqtt_handle_packet()
149 mqtt_client_disconnect(client, evt.result, false); in mqtt_handle_packet()
161 err_code = auth_decode(client, buf, &evt.param.auth); in mqtt_handle_packet()
178 event_notify(client, &evt); in mqtt_handle_packet()
184 static int mqtt_read_message_chunk(struct mqtt_client *client, in mqtt_read_message_chunk() argument
201 if ((buf->end + remaining > client->rx_buf + client->rx_buf_size) || in mqtt_read_message_chunk()
202 (buf->end + remaining < client->rx_buf)) { in mqtt_read_message_chunk()
204 client); in mqtt_read_message_chunk()
208 len = mqtt_transport_read(client, buf->end, remaining, false); in mqtt_read_message_chunk()
211 NET_ERR("[CID %p]: Transport read error: %d", client, len); in mqtt_read_message_chunk()
217 NET_ERR("[CID %p]: Connection closed.", client); in mqtt_read_message_chunk()
221 client->internal.rx_buf_datalen += len; in mqtt_read_message_chunk()
225 NET_ERR("[CID %p]: Message partially received.", client); in mqtt_read_message_chunk()
232 static int mqtt_read_publish_var_header(struct mqtt_client *client, in mqtt_read_publish_var_header() argument
241 err_code = mqtt_read_message_chunk(client, buf, sizeof(uint16_t)); in mqtt_read_publish_var_header()
257 if (mqtt_is_version_5_0(client)) { in mqtt_read_publish_var_header()
264 client, buf, variable_header_length + var_len); in mqtt_read_publish_var_header()
293 err_code = mqtt_read_message_chunk(client, buf, 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() argument
312 err_code = mqtt_read_message_chunk(client, buf, chunk_size); in mqtt_read_and_parse_fixed_header()
318 buf->cur = client->rx_buf; in mqtt_read_and_parse_fixed_header()
327 int mqtt_handle_rx(struct mqtt_client *client) in mqtt_handle_rx() argument
334 buf.cur = client->rx_buf; in mqtt_handle_rx()
335 buf.end = client->rx_buf + client->internal.rx_buf_datalen; in mqtt_handle_rx()
337 err_code = mqtt_read_and_parse_fixed_header(client, &type_and_flags, in mqtt_handle_rx()
344 err_code = mqtt_read_publish_var_header(client, type_and_flags, in mqtt_handle_rx()
347 err_code = mqtt_read_message_chunk(client, &buf, var_length); in mqtt_handle_rx()
355 err_code = mqtt_handle_packet(client, type_and_flags, var_length, &buf); in mqtt_handle_rx()
360 client->internal.rx_buf_datalen = 0U; in mqtt_handle_rx()