Skip to content

Commit b5fe084

Browse files
committed
Address comments
1 parent 4fa605c commit b5fe084

File tree

4 files changed

+10
-11
lines changed

4 files changed

+10
-11
lines changed

src/rdkafka.c

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5084,12 +5084,12 @@ rd_kafka_Uuid_t *rd_kafka_Uuid_copy(const rd_kafka_Uuid_t *uuid) {
50845084
*
50855085
* @remark Must be freed after use using rd_kafka_Uuid_destroy().
50865086
*/
5087-
rd_kafka_Uuid_t *rd_kafka_Uuid_random() {
5087+
rd_kafka_Uuid_t rd_kafka_Uuid_random() {
50885088
int i;
5089-
unsigned char rand_values_bytes[16] = {};
5089+
unsigned char rand_values_bytes[16] = {0};
50905090
uint64_t *rand_values_uint64 = (uint64_t *)rand_values_bytes;
50915091
unsigned char *rand_values_app;
5092-
rd_kafka_Uuid_t *ret = rd_kafka_Uuid_copy(&RD_KAFKA_UUID_ZERO);
5092+
rd_kafka_Uuid_t ret = RD_KAFKA_UUID_ZERO;
50935093
for (i = 0; i < 16; i += 2) {
50945094
uint16_t rand_uint16 = (uint16_t)rd_jitter(0, INT16_MAX - 1);
50955095
/* No need to convert endianess here because it's still only
@@ -5104,8 +5104,8 @@ rd_kafka_Uuid_t *rd_kafka_Uuid_random() {
51045104
rand_values_bytes[8] &= 0x3f; /* clear variant */
51055105
rand_values_bytes[8] |= 0x80; /* IETF variant */
51065106

5107-
ret->most_significant_bits = be64toh(rand_values_uint64[0]);
5108-
ret->least_significant_bits = be64toh(rand_values_uint64[1]);
5107+
ret.most_significant_bits = be64toh(rand_values_uint64[0]);
5108+
ret.least_significant_bits = be64toh(rand_values_uint64[1]);
51095109
return ret;
51105110
}
51115111

src/rdkafka_int.h

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1056,8 +1056,5 @@ rd_kafka_resp_err_t rd_kafka_background_thread_create(rd_kafka_t *rk,
10561056
char *errstr,
10571057
size_t errstr_size);
10581058

1059-
RD_EXPORT rd_kafka_Uuid_t *rd_kafka_Uuid_random();
1060-
1061-
RD_EXPORT const char *rd_kafka_Uuid_str(const rd_kafka_Uuid_t *uuid);
10621059

10631060
#endif /* _RDKAFKA_INT_H_ */

src/rdkafka_mock.c

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -616,15 +616,13 @@ rd_kafka_mock_topic_new(rd_kafka_mock_cluster_t *mcluster,
616616
int partition_cnt,
617617
int replication_factor) {
618618
rd_kafka_mock_topic_t *mtopic;
619-
rd_kafka_Uuid_t *random_uuid = rd_kafka_Uuid_random();
620619
int i;
621620

622621
mtopic = rd_calloc(1, sizeof(*mtopic));
623622
/* Assign random topic id */
624-
mtopic->id = *random_uuid;
623+
mtopic->id = rd_kafka_Uuid_random();
625624
mtopic->name = rd_strdup(topic);
626625
mtopic->cluster = mcluster;
627-
rd_kafka_Uuid_destroy(random_uuid);
628626

629627
mtopic->partition_cnt = partition_cnt;
630628
mtopic->partitions =

src/rdkafka_proto.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -599,6 +599,10 @@ static RD_INLINE RD_UNUSED int rd_kafka_Uuid_cmp(rd_kafka_Uuid_t a,
599599
(a.least_significant_bits - b.least_significant_bits);
600600
}
601601

602+
rd_kafka_Uuid_t rd_kafka_Uuid_random();
603+
604+
const char *rd_kafka_Uuid_str(const rd_kafka_Uuid_t *uuid);
605+
602606
/**
603607
* @name Producer ID and Epoch for the Idempotent Producer
604608
* @{

0 commit comments

Comments
 (0)