1 files changed, 20 insertions, 20 deletions

diff --git a/test/core/support/mpscq_test.c b/test/core/support/mpscq_test.c
index 5e7dc9fca5..c71132bde9 100644
--- a/test/core/support/mpscq_test.c
+++ b/test/core/support/mpscq_test.c
@@ -30,11 +30,11 @@
 typedef struct test_node {
   gpr_mpscq_node node;
   size_t i;
-  size_t *ctr;
+  size_t* ctr;
 } test_node;
 
-static test_node *new_node(size_t i, size_t *ctr) {
-  test_node *n = gpr_malloc(sizeof(test_node));
+static test_node* new_node(size_t i, size_t* ctr) {
+  test_node* n = gpr_malloc(sizeof(test_node));
   n->i = i;
   n->ctr = ctr;
   return n;
@@ -48,7 +48,7 @@ static void test_serial(void) {
     gpr_mpscq_push(&q, &new_node(i, NULL)->node);
   }
   for (size_t i = 0; i < 10000000; i++) {
-    test_node *n = (test_node *)gpr_mpscq_pop(&q);
+    test_node* n = (test_node*)gpr_mpscq_pop(&q);
     GPR_ASSERT(n);
     GPR_ASSERT(n->i == i);
     gpr_free(n);
@@ -57,14 +57,14 @@ static void test_serial(void) {
 
 typedef struct {
   size_t ctr;
-  gpr_mpscq *q;
-  gpr_event *start;
+  gpr_mpscq* q;
+  gpr_event* start;
 } thd_args;
 
 #define THREAD_ITERATIONS 10000
 
-static void test_thread(void *args) {
-  thd_args *a = args;
+static void test_thread(void* args) {
+  thd_args* a = args;
   gpr_event_wait(a->start, gpr_inf_future(GPR_CLOCK_REALTIME));
   for (size_t i = 1; i <= THREAD_ITERATIONS; i++) {
     gpr_mpscq_push(a->q, &new_node(i, &a->ctr)->node);
@@ -89,13 +89,13 @@ static void test_mt(void) {
   }
   size_t num_done = 0;
   size_t spins = 0;
-  gpr_event_set(&start, (void *)1);
+  gpr_event_set(&start, (void*)1);
   while (num_done != GPR_ARRAY_SIZE(thds)) {
-    gpr_mpscq_node *n;
+    gpr_mpscq_node* n;
     while ((n = gpr_mpscq_pop(&q)) == NULL) {
       spins++;
     }
-    test_node *tn = (test_node *)n;
+    test_node* tn = (test_node*)n;
     GPR_ASSERT(*tn->ctr == tn->i - 1);
     *tn->ctr = tn->i;
     if (tn->i == THREAD_ITERATIONS) num_done++;
@@ -109,17 +109,17 @@ static void test_mt(void) {
 }
 
 typedef struct {
-  thd_args *ta;
+  thd_args* ta;
   size_t num_thds;
   gpr_mu mu;
   size_t num_done;
   size_t spins;
-  gpr_mpscq *q;
-  gpr_event *start;
+  gpr_mpscq* q;
+  gpr_event* start;
 } pull_args;
 
-static void pull_thread(void *arg) {
-  pull_args *pa = arg;
+static void pull_thread(void* arg) {
+  pull_args* pa = arg;
   gpr_event_wait(pa->start, gpr_inf_future(GPR_CLOCK_REALTIME));
 
   for (;;) {
@@ -128,11 +128,11 @@ static void pull_thread(void *arg) {
       gpr_mu_unlock(&pa->mu);
       return;
     }
-    gpr_mpscq_node *n;
+    gpr_mpscq_node* n;
     while ((n = gpr_mpscq_pop(pa->q)) == NULL) {
       pa->spins++;
     }
-    test_node *tn = (test_node *)n;
+    test_node* tn = (test_node*)n;
     GPR_ASSERT(*tn->ctr == tn->i - 1);
     *tn->ctr = tn->i;
     if (tn->i == THREAD_ITERATIONS) pa->num_done++;
@@ -171,7 +171,7 @@ static void test_mt_multipop(void) {
     gpr_thd_options_set_joinable(&options);
     GPR_ASSERT(gpr_thd_new(&pull_thds[i], pull_thread, &pa, &options));
   }
-  gpr_event_set(&start, (void *)1);
+  gpr_event_set(&start, (void*)1);
   for (size_t i = 0; i < GPR_ARRAY_SIZE(pull_thds); i++) {
     gpr_thd_join(pull_thds[i]);
   }
@@ -182,7 +182,7 @@ static void test_mt_multipop(void) {
   gpr_mpscq_destroy(&q);
 }
 
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
   grpc_test_init(argc, argv);
   test_serial();
   test_mt();