You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xy...@apache.org on 2022/12/28 00:23:12 UTC
[pulsar-client-cpp] branch main updated: Format .c suffix file. (#159)
This is an automated email from the ASF dual-hosted git repository.
xyz pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
The following commit(s) were added to refs/heads/main by this push:
new 5d5ed2a Format .c suffix file. (#159)
5d5ed2a is described below
commit 5d5ed2acc2e89aed90b593343369f360644440e7
Author: Baodi Shi <wu...@icloud.com>
AuthorDate: Wed Dec 28 08:23:06 2022 +0800
Format .c suffix file. (#159)
---
build-support/run_clang_format.py | 2 +-
examples/SampleAsyncConsumerCApi.c | 2 +-
examples/SampleConsumerCApi.c | 7 ++++---
examples/SampleConsumerListenerCApi.c | 9 +++++----
examples/SampleProducerCApi.c | 7 +++----
examples/SampleReaderCApi.c | 8 ++++----
6 files changed, 18 insertions(+), 17 deletions(-)
diff --git a/build-support/run_clang_format.py b/build-support/run_clang_format.py
index 3c99494..776e5d8 100755
--- a/build-support/run_clang_format.py
+++ b/build-support/run_clang_format.py
@@ -46,7 +46,7 @@ for source_dir in SOURCE_DIRS:
for directory, subdirs, files in os.walk(source_dir):
for name in files:
name = os.path.join(directory, name)
- if not (name.endswith('.h') or name.endswith('.cc')):
+ if not (name.endswith('.h') or name.endswith('.cc') or name.endswith('.c')):
continue
excluded = False
diff --git a/examples/SampleAsyncConsumerCApi.c b/examples/SampleAsyncConsumerCApi.c
index c6ecc90..9cf9719 100644
--- a/examples/SampleAsyncConsumerCApi.c
+++ b/examples/SampleAsyncConsumerCApi.c
@@ -17,8 +17,8 @@
* under the License.
*/
-#include <stdio.h>
#include <pulsar/c/client.h>
+#include <stdio.h>
static void receive_callback(pulsar_result result, pulsar_message_t *message, void *ctx) {
pulsar_consumer_t *consumer = (pulsar_consumer_t *)ctx;
diff --git a/examples/SampleConsumerCApi.c b/examples/SampleConsumerCApi.c
index ade7fb9..83be119 100644
--- a/examples/SampleConsumerCApi.c
+++ b/examples/SampleConsumerCApi.c
@@ -17,8 +17,8 @@
* under the License.
*/
-#include <stdio.h>
#include <pulsar/c/client.h>
+#include <stdio.h>
int main() {
pulsar_client_configuration_t *conf = pulsar_client_configuration_create();
@@ -28,7 +28,8 @@ int main() {
pulsar_consumer_configuration_set_consumer_type(consumer_conf, pulsar_ConsumerShared);
pulsar_consumer_t *consumer;
- pulsar_result res = pulsar_client_subscribe(client, "my-topic", "my-subscrition", consumer_conf, &consumer);
+ pulsar_result res =
+ pulsar_client_subscribe(client, "my-topic", "my-subscrition", consumer_conf, &consumer);
if (res != pulsar_result_Ok) {
printf("Failed to create subscribe to topic: %s\n", pulsar_result_str(res));
return 1;
@@ -43,7 +44,7 @@ int main() {
}
printf("Received message with payload: '%.*s'\n", pulsar_message_get_length(message),
- (const char*)pulsar_message_get_data(message));
+ (const char *)pulsar_message_get_data(message));
pulsar_consumer_acknowledge(consumer, message);
pulsar_message_free(message);
diff --git a/examples/SampleConsumerListenerCApi.c b/examples/SampleConsumerListenerCApi.c
index 1b04980..b54b4ee 100644
--- a/examples/SampleConsumerListenerCApi.c
+++ b/examples/SampleConsumerListenerCApi.c
@@ -17,12 +17,12 @@
* under the License.
*/
-#include <stdio.h>
#include <pulsar/c/client.h>
+#include <stdio.h>
-static void listener_callback(pulsar_consumer_t* consumer, pulsar_message_t* message, void* ctx) {
+static void listener_callback(pulsar_consumer_t *consumer, pulsar_message_t *message, void *ctx) {
printf("Received message with payload: '%.*s'\n", pulsar_message_get_length(message),
- (const char*)pulsar_message_get_data(message));
+ (const char *)pulsar_message_get_data(message));
pulsar_consumer_acknowledge(consumer, message);
pulsar_message_free(message);
@@ -37,7 +37,8 @@ int main() {
pulsar_consumer_configuration_set_message_listener(consumer_conf, listener_callback, NULL);
pulsar_consumer_t *consumer;
- pulsar_result res = pulsar_client_subscribe(client, "my-topic", "my-subscrition", consumer_conf, &consumer);
+ pulsar_result res =
+ pulsar_client_subscribe(client, "my-topic", "my-subscrition", consumer_conf, &consumer);
if (res != pulsar_result_Ok) {
printf("Failed to create subscribe to topic: %s\n", pulsar_result_str(res));
return 1;
diff --git a/examples/SampleProducerCApi.c b/examples/SampleProducerCApi.c
index 4d75d2c..5f3ac5c 100644
--- a/examples/SampleProducerCApi.c
+++ b/examples/SampleProducerCApi.c
@@ -18,18 +18,17 @@
*/
#include <pulsar/c/client.h>
-
#include <stdio.h>
#include <string.h>
int main() {
- pulsar_client_configuration_t *conf = pulsar_client_configuration_create();
+ pulsar_client_configuration_t* conf = pulsar_client_configuration_create();
pulsar_client_configuration_set_memory_limit(conf, 64 * 1024 * 1024);
- pulsar_client_t *client = pulsar_client_create("pulsar://localhost:6650", conf);
+ pulsar_client_t* client = pulsar_client_create("pulsar://localhost:6650", conf);
pulsar_producer_configuration_t* producer_conf = pulsar_producer_configuration_create();
pulsar_producer_configuration_set_batching_enabled(producer_conf, 1);
- pulsar_producer_t *producer;
+ pulsar_producer_t* producer;
pulsar_result err = pulsar_client_create_producer(client, "my-topic", producer_conf, &producer);
if (err != pulsar_result_Ok) {
diff --git a/examples/SampleReaderCApi.c b/examples/SampleReaderCApi.c
index 7510ffa..39e4280 100644
--- a/examples/SampleReaderCApi.c
+++ b/examples/SampleReaderCApi.c
@@ -17,8 +17,8 @@
* under the License.
*/
-#include <stdio.h>
#include <pulsar/c/client.h>
+#include <stdio.h>
int main() {
pulsar_client_configuration_t *conf = pulsar_client_configuration_create();
@@ -27,8 +27,8 @@ int main() {
pulsar_reader_configuration_t *reader_conf = pulsar_reader_configuration_create();
pulsar_reader_t *reader;
- pulsar_result res = pulsar_client_create_reader(client, "my-topic", pulsar_message_id_earliest(), reader_conf,
- &reader);
+ pulsar_result res =
+ pulsar_client_create_reader(client, "my-topic", pulsar_message_id_earliest(), reader_conf, &reader);
if (res != pulsar_result_Ok) {
printf("Failed to create reader: %s\n", pulsar_result_str(res));
return 1;
@@ -43,7 +43,7 @@ int main() {
}
printf("Received message with payload: '%.*s'\n", pulsar_message_get_length(message),
- (const char*)pulsar_message_get_data(message));
+ (const char *)pulsar_message_get_data(message));
pulsar_message_free(message);
}