Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .semaphore/semaphore.yml
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ global_job_config:
- mkdir dest
env_vars:
- name: CACHE_TAG
value: '7'
value: '9'
- name: CI
value: 'true'
- name: KAFKA_VERSION
Expand Down
2 changes: 1 addition & 1 deletion packaging/tools/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ ARG UID
RUN NEEDRESTART_MODE=a apt-get update && apt-get install -y \
wget curl python3 git openjdk-21-jdk-headless python3-venv \
python3-setuptools build-essential libssl-dev libcurl4-openssl-dev \
zlib1g-dev libsasl2-dev libzstd-dev clang-format-18 doxygen graphviz
zlib1g-dev libsasl2-dev libzstd-dev doxygen graphviz

RUN wget -O rapidjson-dev.deb https://launchpad.net/ubuntu/+archive/primary/+files/rapidjson-dev_1.1.0+dfsg2-3_all.deb && \
dpkg -i rapidjson-dev.deb && \
Expand Down
1 change: 1 addition & 0 deletions packaging/tools/requirements.txt
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
clang-format==18.1.8
flake8
autopep8
10 changes: 5 additions & 5 deletions packaging/tools/style-format.sh
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@



# Requires clang-format version 18 (apt install clang-format-18).
CLANG_FORMAT=${CLANG_FORMAT:-clang-format-18}
CLANG_FORMAT_REQUIRED_VERSION=18
# Requires clang-format version 18 (pip install clang-format==18.1.8).
CLANG_FORMAT=${CLANG_FORMAT:-clang-format}
CLANG_FORMAT_REQUIRED_VERSION=18.1.8

set -e

Expand All @@ -27,9 +27,9 @@ else
fix=0
fi

clang_format_version=$(${CLANG_FORMAT} --version | sed -Ee 's/.*version ([[:digit:]]+)\.[[:digit:]]+\.[[:digit:]]+.*/\1/')
clang_format_version=$(${CLANG_FORMAT} --version | sed -Ee 's/.*version ([[:digit:]]+\.[[:digit:]]+\.[[:digit:]]+).*/\1/')
if [[ $clang_format_version != "$CLANG_FORMAT_REQUIRED_VERSION" ]] ; then
echo "$0: clang-format version ${CLANG_FORMAT_REQUIRED_VERSION}, '$clang_format_version' detected"
echo "$0: clang-format version ${CLANG_FORMAT_REQUIRED_VERSION} required, '$clang_format_version' detected"
exit 1
fi

Expand Down
3 changes: 1 addition & 2 deletions src/rdhdrhistogram.c
Original file line number Diff line number Diff line change
Expand Up @@ -275,8 +275,7 @@ typedef struct rd_hdr_iter_s {
int64_t highestEquivalentValue;
} rd_hdr_iter_t;

#define RD_HDR_ITER_INIT(hdr) \
{ .hdr = hdr, .subBucketIdx = -1 }
#define RD_HDR_ITER_INIT(hdr) {.hdr = hdr, .subBucketIdx = -1}

static int rd_hdr_iter_next(rd_hdr_iter_t *it) {
const rd_hdr_histogram_t *hdr = it->hdr;
Expand Down
2 changes: 1 addition & 1 deletion src/rdkafka_msg.h
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ typedef struct rd_kafka_msgq_s {
} rd_kafka_msgq_t;

#define RD_KAFKA_MSGQ_INITIALIZER(rkmq) \
{ .rkmq_msgs = TAILQ_HEAD_INITIALIZER((rkmq).rkmq_msgs) }
{.rkmq_msgs = TAILQ_HEAD_INITIALIZER((rkmq).rkmq_msgs)}

#define RD_KAFKA_MSGQ_FOREACH(elm, head) \
TAILQ_FOREACH(elm, &(head)->rkmq_msgs, rkm_link)
Expand Down
9 changes: 3 additions & 6 deletions src/rdkafka_proto.h
Original file line number Diff line number Diff line change
Expand Up @@ -281,11 +281,9 @@ typedef struct rd_kafkap_str_s {
/* strndup() a Kafka string */
#define RD_KAFKAP_STR_DUP(kstr) rd_strndup((kstr)->str, RD_KAFKAP_STR_LEN(kstr))

#define RD_KAFKAP_STR_INITIALIZER \
{ .len = RD_KAFKAP_STR_LEN_NULL, .str = NULL }
#define RD_KAFKAP_STR_INITIALIZER {.len = RD_KAFKAP_STR_LEN_NULL, .str = NULL}

#define RD_KAFKAP_STR_INITIALIZER_EMPTY \
{ .len = 0, .str = "" }
#define RD_KAFKAP_STR_INITIALIZER_EMPTY {.len = 0, .str = ""}
/**
* Frees a Kafka string previously allocated with `rd_kafkap_str_new()`
*/
Expand Down Expand Up @@ -661,8 +659,7 @@ typedef struct rd_kafka_pid_s {
int16_t epoch; /**< Producer Epoch */
} rd_kafka_pid_t;

#define RD_KAFKA_PID_INITIALIZER \
{ -1, -1 }
#define RD_KAFKA_PID_INITIALIZER {-1, -1}

/**
* @returns true if \p PID is valid
Expand Down
6 changes: 2 additions & 4 deletions src/rdsysqueue.h
Original file line number Diff line number Diff line change
Expand Up @@ -94,8 +94,7 @@
*/

#ifndef TAILQ_HEAD_INITIALIZER
#define TAILQ_HEAD_INITIALIZER(head) \
{ NULL, &(head).tqh_first }
#define TAILQ_HEAD_INITIALIZER(head) {NULL, &(head).tqh_first}
#endif

#ifndef TAILQ_INSERT_BEFORE
Expand Down Expand Up @@ -391,8 +390,7 @@
#endif

#ifndef SIMPLEQ_HEAD_INITIALIZER
#define SIMPLEQ_HEAD_INITIALIZER(head) \
{ NULL, &(head).sqh_first }
#define SIMPLEQ_HEAD_INITIALIZER(head) {NULL, &(head).sqh_first}
#endif

#ifndef SIMPLEQ_EMPTY
Expand Down
3 changes: 1 addition & 2 deletions src/rdwin32.h
Original file line number Diff line number Diff line change
Expand Up @@ -231,8 +231,7 @@ static RD_INLINE RD_UNUSED const char *rd_getenv(const char *env,
/**
* Empty struct initializer
*/
#define RD_ZERO_INIT \
{ 0 }
#define RD_ZERO_INIT {0}

#ifndef __cplusplus
/**
Expand Down
2 changes: 1 addition & 1 deletion tests/test.c
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ static const char *test_states[] = {

#define _TEST_DECL(NAME) extern int main_##NAME(int, char **)
#define _TEST(NAME, FLAGS, ...) \
{ .name = #NAME, .mainfunc = main_##NAME, .flags = FLAGS, __VA_ARGS__ }
{.name = #NAME, .mainfunc = main_##NAME, .flags = FLAGS, __VA_ARGS__}


/**
Expand Down