aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/iomgr/combiner_test.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/core/iomgr/combiner_test.c')
-rw-r--r--test/core/iomgr/combiner_test.c34
1 files changed, 17 insertions, 17 deletions
diff --git a/test/core/iomgr/combiner_test.c b/test/core/iomgr/combiner_test.c
index 38f512de0e..063bcb6433 100644
--- a/test/core/iomgr/combiner_test.c
+++ b/test/core/iomgr/combiner_test.c
@@ -33,15 +33,15 @@ static void test_no_op(void) {
grpc_exec_ctx_finish(&exec_ctx);
}
-static void set_event_to_true(grpc_exec_ctx *exec_ctx, void *value,
- grpc_error *error) {
- gpr_event_set(value, (void *)1);
+static void set_event_to_true(grpc_exec_ctx* exec_ctx, void* value,
+ grpc_error* error) {
+ gpr_event_set(value, (void*)1);
}
static void test_execute_one(void) {
gpr_log(GPR_DEBUG, "test_execute_one");
- grpc_combiner *lock = grpc_combiner_create();
+ grpc_combiner* lock = grpc_combiner_create();
gpr_event done;
gpr_event_init(&done);
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@@ -58,29 +58,29 @@ static void test_execute_one(void) {
typedef struct {
size_t ctr;
- grpc_combiner *lock;
+ grpc_combiner* lock;
gpr_event done;
} thd_args;
typedef struct {
- size_t *ctr;
+ size_t* ctr;
size_t value;
} ex_args;
-static void check_one(grpc_exec_ctx *exec_ctx, void *a, grpc_error *error) {
- ex_args *args = a;
+static void check_one(grpc_exec_ctx* exec_ctx, void* a, grpc_error* error) {
+ ex_args* args = a;
GPR_ASSERT(*args->ctr == args->value - 1);
*args->ctr = args->value;
gpr_free(a);
}
-static void execute_many_loop(void *a) {
- thd_args *args = a;
+static void execute_many_loop(void* a) {
+ thd_args* args = a;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
size_t n = 1;
for (size_t i = 0; i < 10; i++) {
for (size_t j = 0; j < 10000; j++) {
- ex_args *c = gpr_malloc(sizeof(*c));
+ ex_args* c = gpr_malloc(sizeof(*c));
c->ctr = &args->ctr;
c->value = n++;
GRPC_CLOSURE_SCHED(&exec_ctx,
@@ -103,7 +103,7 @@ static void execute_many_loop(void *a) {
static void test_execute_many(void) {
gpr_log(GPR_DEBUG, "test_execute_many");
- grpc_combiner *lock = grpc_combiner_create();
+ grpc_combiner* lock = grpc_combiner_create();
gpr_thd_id thds[100];
thd_args ta[GPR_ARRAY_SIZE(thds)];
for (size_t i = 0; i < GPR_ARRAY_SIZE(thds); i++) {
@@ -126,11 +126,11 @@ static void test_execute_many(void) {
static gpr_event got_in_finally;
-static void in_finally(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
- gpr_event_set(&got_in_finally, (void *)1);
+static void in_finally(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) {
+ gpr_event_set(&got_in_finally, (void*)1);
}
-static void add_finally(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
+static void add_finally(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) {
GRPC_CLOSURE_SCHED(exec_ctx,
GRPC_CLOSURE_CREATE(in_finally, arg,
grpc_combiner_finally_scheduler(arg)),
@@ -140,7 +140,7 @@ static void add_finally(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
static void test_execute_finally(void) {
gpr_log(GPR_DEBUG, "test_execute_finally");
- grpc_combiner *lock = grpc_combiner_create();
+ grpc_combiner* lock = grpc_combiner_create();
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
gpr_event_init(&got_in_finally);
GRPC_CLOSURE_SCHED(
@@ -154,7 +154,7 @@ static void test_execute_finally(void) {
grpc_exec_ctx_finish(&exec_ctx);
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
grpc_init();
test_no_op();