clang-format all core files

1 files changed, 81 insertions, 96 deletions

diff --git a/src/core/iomgr/resolve_address_posix.c b/src/core/iomgr/resolve_address_posix.c
index 1017a788ff..aacd185548 100644
--- a/src/core/iomgr/resolve_address_posix.c
+++ b/src/core/iomgr/resolve_address_posix.c
@@ -51,8 +51,7 @@
 #include <grpc/support/thd.h>
 #include <grpc/support/time.h>
 
-typedef struct
-{
+typedef struct {
   char *name;
   char *default_port;
   grpc_resolve_cb cb;
@@ -60,9 +59,8 @@ typedef struct
   grpc_iomgr_object iomgr_object;
 } request;
 
-grpc_resolved_addresses *
-grpc_blocking_resolve_address (const char *name, const char *default_port)
-{
+grpc_resolved_addresses *grpc_blocking_resolve_address(
+    const char *name, const char *default_port) {
   struct addrinfo hints;
   struct addrinfo *result = NULL, *resp;
   char *host;
@@ -72,127 +70,114 @@ grpc_blocking_resolve_address (const char *name, const char *default_port)
   grpc_resolved_addresses *addrs = NULL;
   struct sockaddr_un *un;
 
-  if (name[0] == 'u' && name[1] == 'n' && name[2] == 'i' && name[3] == 'x' && name[4] == ':' && name[5] != 0)
-    {
-      addrs = gpr_malloc (sizeof (grpc_resolved_addresses));
-      addrs->naddrs = 1;
-      addrs->addrs = gpr_malloc (sizeof (grpc_resolved_address));
-      un = (struct sockaddr_un *) addrs->addrs->addr;
-      un->sun_family = AF_UNIX;
-      strcpy (un->sun_path, name + 5);
-      addrs->addrs->len = strlen (un->sun_path) + sizeof (un->sun_family) + 1;
-      return addrs;
-    }
+  if (name[0] == 'u' && name[1] == 'n' && name[2] == 'i' && name[3] == 'x' &&
+      name[4] == ':' && name[5] != 0) {
+    addrs = gpr_malloc(sizeof(grpc_resolved_addresses));
+    addrs->naddrs = 1;
+    addrs->addrs = gpr_malloc(sizeof(grpc_resolved_address));
+    un = (struct sockaddr_un *)addrs->addrs->addr;
+    un->sun_family = AF_UNIX;
+    strcpy(un->sun_path, name + 5);
+    addrs->addrs->len = strlen(un->sun_path) + sizeof(un->sun_family) + 1;
+    return addrs;
+  }
 
   /* parse name, splitting it into host and port parts */
-  gpr_split_host_port (name, &host, &port);
-  if (host == NULL)
-    {
-      gpr_log (GPR_ERROR, "unparseable host:port: '%s'", name);
+  gpr_split_host_port(name, &host, &port);
+  if (host == NULL) {
+    gpr_log(GPR_ERROR, "unparseable host:port: '%s'", name);
+    goto done;
+  }
+  if (port == NULL) {
+    if (default_port == NULL) {
+      gpr_log(GPR_ERROR, "no port in name '%s'", name);
       goto done;
     }
-  if (port == NULL)
-    {
-      if (default_port == NULL)
-	{
-	  gpr_log (GPR_ERROR, "no port in name '%s'", name);
-	  goto done;
-	}
-      port = gpr_strdup (default_port);
-    }
+    port = gpr_strdup(default_port);
+  }
 
   /* Call getaddrinfo */
-  memset (&hints, 0, sizeof (hints));
-  hints.ai_family = AF_UNSPEC;	/* ipv4 or ipv6 */
-  hints.ai_socktype = SOCK_STREAM;	/* stream socket */
-  hints.ai_flags = AI_PASSIVE;	/* for wildcard IP address */
-
-  s = getaddrinfo (host, port, &hints, &result);
-  if (s != 0)
-    {
-      /* Retry if well-known service name is recognized */
-      char *svc[][2] = { {"http", "80"}, {"https", "443"} };
-      int i;
-      for (i = 0; i < (int) (sizeof (svc) / sizeof (svc[0])); i++)
-	{
-	  if (strcmp (port, svc[i][0]) == 0)
-	    {
-	      s = getaddrinfo (host, svc[i][1], &hints, &result);
-	      break;
-	    }
-	}
+  memset(&hints, 0, sizeof(hints));
+  hints.ai_family = AF_UNSPEC;     /* ipv4 or ipv6 */
+  hints.ai_socktype = SOCK_STREAM; /* stream socket */
+  hints.ai_flags = AI_PASSIVE;     /* for wildcard IP address */
+
+  s = getaddrinfo(host, port, &hints, &result);
+  if (s != 0) {
+    /* Retry if well-known service name is recognized */
+    char *svc[][2] = {{"http", "80"}, {"https", "443"}};
+    int i;
+    for (i = 0; i < (int)(sizeof(svc) / sizeof(svc[0])); i++) {
+      if (strcmp(port, svc[i][0]) == 0) {
+        s = getaddrinfo(host, svc[i][1], &hints, &result);
+        break;
+      }
     }
+  }
 
-  if (s != 0)
-    {
-      gpr_log (GPR_ERROR, "getaddrinfo: %s", gai_strerror (s));
-      goto done;
-    }
+  if (s != 0) {
+    gpr_log(GPR_ERROR, "getaddrinfo: %s", gai_strerror(s));
+    goto done;
+  }
 
   /* Success path: set addrs non-NULL, fill it in */
-  addrs = gpr_malloc (sizeof (grpc_resolved_addresses));
+  addrs = gpr_malloc(sizeof(grpc_resolved_addresses));
   addrs->naddrs = 0;
-  for (resp = result; resp != NULL; resp = resp->ai_next)
-    {
-      addrs->naddrs++;
-    }
-  addrs->addrs = gpr_malloc (sizeof (grpc_resolved_address) * addrs->naddrs);
+  for (resp = result; resp != NULL; resp = resp->ai_next) {
+    addrs->naddrs++;
+  }
+  addrs->addrs = gpr_malloc(sizeof(grpc_resolved_address) * addrs->naddrs);
   i = 0;
-  for (resp = result; resp != NULL; resp = resp->ai_next)
-    {
-      memcpy (&addrs->addrs[i].addr, resp->ai_addr, resp->ai_addrlen);
-      addrs->addrs[i].len = resp->ai_addrlen;
-      i++;
-    }
+  for (resp = result; resp != NULL; resp = resp->ai_next) {
+    memcpy(&addrs->addrs[i].addr, resp->ai_addr, resp->ai_addrlen);
+    addrs->addrs[i].len = resp->ai_addrlen;
+    i++;
+  }
 
 done:
-  gpr_free (host);
-  gpr_free (port);
-  if (result)
-    {
-      freeaddrinfo (result);
-    }
+  gpr_free(host);
+  gpr_free(port);
+  if (result) {
+    freeaddrinfo(result);
+  }
   return addrs;
 }
 
 /* Thread function to asynch-ify grpc_blocking_resolve_address */
-static void
-do_request_thread (void *rp)
-{
+static void do_request_thread(void *rp) {
   request *r = rp;
   grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
-  grpc_resolved_addresses *resolved = grpc_blocking_resolve_address (r->name, r->default_port);
+  grpc_resolved_addresses *resolved =
+      grpc_blocking_resolve_address(r->name, r->default_port);
   void *arg = r->arg;
   grpc_resolve_cb cb = r->cb;
-  gpr_free (r->name);
-  gpr_free (r->default_port);
-  cb (&exec_ctx, arg, resolved);
-  grpc_iomgr_unregister_object (&r->iomgr_object);
-  gpr_free (r);
-  grpc_exec_ctx_finish (&exec_ctx);
+  gpr_free(r->name);
+  gpr_free(r->default_port);
+  cb(&exec_ctx, arg, resolved);
+  grpc_iomgr_unregister_object(&r->iomgr_object);
+  gpr_free(r);
+  grpc_exec_ctx_finish(&exec_ctx);
 }
 
-void
-grpc_resolved_addresses_destroy (grpc_resolved_addresses * addrs)
-{
-  gpr_free (addrs->addrs);
-  gpr_free (addrs);
+void grpc_resolved_addresses_destroy(grpc_resolved_addresses *addrs) {
+  gpr_free(addrs->addrs);
+  gpr_free(addrs);
 }
 
-void
-grpc_resolve_address (const char *name, const char *default_port, grpc_resolve_cb cb, void *arg)
-{
-  request *r = gpr_malloc (sizeof (request));
+void grpc_resolve_address(const char *name, const char *default_port,
+                          grpc_resolve_cb cb, void *arg) {
+  request *r = gpr_malloc(sizeof(request));
   gpr_thd_id id;
   char *tmp;
-  gpr_asprintf (&tmp, "resolve_address:name='%s':default_port='%s'", name, default_port);
-  grpc_iomgr_register_object (&r->iomgr_object, tmp);
-  gpr_free (tmp);
-  r->name = gpr_strdup (name);
-  r->default_port = gpr_strdup (default_port);
+  gpr_asprintf(&tmp, "resolve_address:name='%s':default_port='%s'", name,
+               default_port);
+  grpc_iomgr_register_object(&r->iomgr_object, tmp);
+  gpr_free(tmp);
+  r->name = gpr_strdup(name);
+  r->default_port = gpr_strdup(default_port);
   r->cb = cb;
   r->arg = arg;
-  gpr_thd_new (&id, do_request_thread, r, NULL);
+  gpr_thd_new(&id, do_request_thread, r, NULL);
 }
 
 #endif