Skip to content

Commit 74d2cc9

Browse files
committed
wip: fix mqtt3 compile error
1 parent 082aae6 commit 74d2cc9

4 files changed

Lines changed: 10 additions & 14 deletions

File tree

include/aws/mqtt/private/client_impl_shared.h

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -134,10 +134,7 @@ struct aws_mqtt_client_connection {
134134
void *impl;
135135
};
136136

137-
struct aws_mqtt_metadata_entry_storage {
138-
struct aws_string *key;
139-
struct aws_string *value;
140-
} struct aws_mqtt_iot_sdk_metrics_storage {
137+
struct aws_mqtt_iot_sdk_metrics_storage {
141138
struct aws_allocator *allocator;
142139

143140
struct aws_mqtt_iot_sdk_metrics storage_view;
@@ -187,6 +184,6 @@ int aws_mqtt_append_sdk_metrics_to_username(
187184
struct aws_allocator *allocator,
188185
const struct aws_byte_cursor *original_username,
189186
const struct aws_mqtt_iot_sdk_metrics *metrics,
190-
struct aws_byte_buf *output_username)
187+
struct aws_byte_buf *output_username);
191188

192189
#endif /* AWS_MQTT_PRIVATE_CLIENT_IMPL_SHARED_H */

source/client.c

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -636,7 +636,8 @@ static void s_mqtt_client_init(
636636

637637
/* Apply metrics to username if configured */
638638
if (connection->metrics) {
639-
if (aws_mqtt_append_sdk_metrics_to_username(&username_cur, connection->metrics, &metrics_username_buf) ==
639+
if (aws_mqtt_append_sdk_metrics_to_username(
640+
connection->allocator, &username_cur, &connection->metrics->storage_view, &metrics_username_buf) ==
640641
AWS_OP_SUCCESS) {
641642
username_cur = aws_byte_cursor_from_buf(&metrics_username_buf);
642643
} else {
@@ -872,10 +873,7 @@ static void s_mqtt_client_connection_destroy_final(struct aws_mqtt_client_connec
872873

873874
/* Clean up metrics */
874875
if (connection->metrics) {
875-
if (connection->metrics->metadata_entries) {
876-
aws_mem_release(connection->allocator, connection->metrics->metadata_entries);
877-
}
878-
aws_mem_release(connection->allocator, connection->metrics);
876+
aws_mqtt_iot_sdk_metrics_storage_clean_up(connection->metrics);
879877
}
880878

881879
aws_mqtt_client_release(connection->client);

source/client_impl_shared.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,8 @@ int aws_mqtt_iot_sdk_metrics_storage_init(
318318
}
319319

320320
return AWS_OP_SUCCESS;
321-
storage_error:
321+
322+
metrics_storage_error:
322323
aws_mqtt_iot_sdk_metrics_storage_clean_up(metrics_storage);
323324
return AWS_OP_ERR;
324325
}

source/mqtt_iot_sdk_metrics.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ int aws_mqtt_append_sdk_metrics_to_username(
116116

117117
return AWS_OP_SUCCESS;
118118

119-
error:
120-
aws_byte_buf_clean_up(output_username);
121-
return AWS_OP_ERR;
119+
// error:
120+
// aws_byte_buf_clean_up(output_username);
121+
// return AWS_OP_ERR;
122122
}

0 commit comments

Comments
 (0)