Merge with master

1 files changed, 267 insertions, 0 deletions

diff --git a/test/core/iomgr/resolve_address_test.cc b/test/core/iomgr/resolve_address_test.cc
new file mode 100644
index 0000000000..1eb753dc85
--- /dev/null
+++ b/test/core/iomgr/resolve_address_test.cc
@@ -0,0 +1,267 @@
+/*
+ *
+ * Copyright 2015 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+#include "src/core/lib/iomgr/resolve_address.h"
+#include <grpc/grpc.h>
+#include <grpc/support/alloc.h>
+#include <grpc/support/log.h>
+#include <grpc/support/sync.h>
+#include <grpc/support/time.h>
+#include "src/core/lib/iomgr/executor.h"
+#include "src/core/lib/iomgr/iomgr.h"
+#include "test/core/util/test_config.h"
+
+static gpr_timespec test_deadline(void) {
+  return grpc_timeout_seconds_to_deadline(100);
+}
+
+typedef struct args_struct {
+  gpr_event ev;
+  grpc_resolved_addresses* addrs;
+  gpr_atm done_atm;
+  gpr_mu* mu;
+  grpc_pollset* pollset;
+  grpc_pollset_set* pollset_set;
+} args_struct;
+
+static void do_nothing(void* arg, grpc_error* error) {}
+
+void args_init(args_struct* args) {
+  gpr_event_init(&args->ev);
+  args->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size()));
+  grpc_pollset_init(args->pollset, &args->mu);
+  args->pollset_set = grpc_pollset_set_create();
+  grpc_pollset_set_add_pollset(args->pollset_set, args->pollset);
+  args->addrs = NULL;
+  gpr_atm_rel_store(&args->done_atm, 0);
+}
+
+void args_finish(args_struct* args) {
+  GPR_ASSERT(gpr_event_wait(&args->ev, test_deadline()));
+  grpc_resolved_addresses_destroy(args->addrs);
+  grpc_pollset_set_del_pollset(args->pollset_set, args->pollset);
+  grpc_pollset_set_destroy(args->pollset_set);
+  grpc_closure do_nothing_cb;
+  GRPC_CLOSURE_INIT(&do_nothing_cb, do_nothing, NULL,
+                    grpc_schedule_on_exec_ctx);
+  gpr_mu_lock(args->mu);
+  grpc_pollset_shutdown(args->pollset, &do_nothing_cb);
+  gpr_mu_unlock(args->mu);
+  // exec_ctx needs to be flushed before calling grpc_pollset_destroy()
+  grpc_exec_ctx_flush();
+  grpc_pollset_destroy(args->pollset);
+  gpr_free(args->pollset);
+}
+
+static grpc_millis n_sec_deadline(int seconds) {
+  return grpc_timespec_to_millis_round_up(
+      grpc_timeout_seconds_to_deadline(seconds));
+}
+
+static void poll_pollset_until_request_done(args_struct* args) {
+  ExecCtx _local_exec_ctx;
+  grpc_millis deadline = n_sec_deadline(10);
+  while (true) {
+    bool done = gpr_atm_acq_load(&args->done_atm) != 0;
+    if (done) {
+      break;
+    }
+    grpc_millis time_left = deadline - grpc_exec_ctx_now();
+    gpr_log(GPR_DEBUG, "done=%d, time_left=%" PRIdPTR, done, time_left);
+    GPR_ASSERT(time_left >= 0);
+    grpc_pollset_worker* worker = NULL;
+    gpr_mu_lock(args->mu);
+    GRPC_LOG_IF_ERROR("pollset_work", grpc_pollset_work(args->pollset, &worker,
+                                                        n_sec_deadline(1)));
+    gpr_mu_unlock(args->mu);
+    grpc_exec_ctx_flush();
+  }
+  gpr_event_set(&args->ev, (void*)1);
+  grpc_exec_ctx_finish();
+}
+
+static void must_succeed(void* argsp, grpc_error* err) {
+  args_struct* args = static_cast<args_struct*>(argsp);
+  GPR_ASSERT(err == GRPC_ERROR_NONE);
+  GPR_ASSERT(args->addrs != NULL);
+  GPR_ASSERT(args->addrs->naddrs > 0);
+  gpr_atm_rel_store(&args->done_atm, 1);
+  gpr_mu_lock(args->mu);
+  GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, NULL));
+  gpr_mu_unlock(args->mu);
+}
+
+static void must_fail(void* argsp, grpc_error* err) {
+  args_struct* args = static_cast<args_struct*>(argsp);
+  GPR_ASSERT(err != GRPC_ERROR_NONE);
+  gpr_atm_rel_store(&args->done_atm, 1);
+  gpr_mu_lock(args->mu);
+  GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(args->pollset, NULL));
+  gpr_mu_unlock(args->mu);
+}
+
+static void test_localhost(void) {
+  ExecCtx _local_exec_ctx;
+  args_struct args;
+  args_init(&args);
+  grpc_resolve_address(
+      "localhost:1", NULL, args.pollset_set,
+      GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx),
+      &args.addrs);
+  grpc_exec_ctx_flush();
+  poll_pollset_until_request_done(&args);
+  args_finish(&args);
+  grpc_exec_ctx_finish();
+}
+
+static void test_default_port(void) {
+  ExecCtx _local_exec_ctx;
+  args_struct args;
+  args_init(&args);
+  grpc_resolve_address(
+      "localhost", "1", args.pollset_set,
+      GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx),
+      &args.addrs);
+  grpc_exec_ctx_flush();
+  poll_pollset_until_request_done(&args);
+  args_finish(&args);
+  grpc_exec_ctx_finish();
+}
+
+static void test_non_numeric_default_port(void) {
+  ExecCtx _local_exec_ctx;
+  args_struct args;
+  args_init(&args);
+  grpc_resolve_address(
+      "localhost", "https", args.pollset_set,
+      GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx),
+      &args.addrs);
+  grpc_exec_ctx_flush();
+  poll_pollset_until_request_done(&args);
+  args_finish(&args);
+  grpc_exec_ctx_finish();
+}
+
+static void test_missing_default_port(void) {
+  ExecCtx _local_exec_ctx;
+  args_struct args;
+  args_init(&args);
+  grpc_resolve_address(
+      "localhost", NULL, args.pollset_set,
+      GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx),
+      &args.addrs);
+  grpc_exec_ctx_flush();
+  poll_pollset_until_request_done(&args);
+  args_finish(&args);
+  grpc_exec_ctx_finish();
+}
+
+static void test_ipv6_with_port(void) {
+  ExecCtx _local_exec_ctx;
+  args_struct args;
+  args_init(&args);
+  grpc_resolve_address(
+      "[2001:db8::1]:1", NULL, args.pollset_set,
+      GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx),
+      &args.addrs);
+  grpc_exec_ctx_flush();
+  poll_pollset_until_request_done(&args);
+  args_finish(&args);
+  grpc_exec_ctx_finish();
+}
+
+static void test_ipv6_without_port(void) {
+  const char* const kCases[] = {
+      "2001:db8::1",
+      "2001:db8::1.2.3.4",
+      "[2001:db8::1]",
+  };
+  unsigned i;
+  for (i = 0; i < sizeof(kCases) / sizeof(*kCases); i++) {
+    ExecCtx _local_exec_ctx;
+    args_struct args;
+    args_init(&args);
+    grpc_resolve_address(
+        kCases[i], "80", args.pollset_set,
+        GRPC_CLOSURE_CREATE(must_succeed, &args, grpc_schedule_on_exec_ctx),
+        &args.addrs);
+    grpc_exec_ctx_flush();
+    poll_pollset_until_request_done(&args);
+    args_finish(&args);
+    grpc_exec_ctx_finish();
+  }
+}
+
+static void test_invalid_ip_addresses(void) {
+  const char* const kCases[] = {
+      "293.283.1238.3:1",
+      "[2001:db8::11111]:1",
+  };
+  unsigned i;
+  for (i = 0; i < sizeof(kCases) / sizeof(*kCases); i++) {
+    ExecCtx _local_exec_ctx;
+    args_struct args;
+    args_init(&args);
+    grpc_resolve_address(
+        kCases[i], NULL, args.pollset_set,
+        GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx),
+        &args.addrs);
+    grpc_exec_ctx_flush();
+    poll_pollset_until_request_done(&args);
+    args_finish(&args);
+    grpc_exec_ctx_finish();
+  }
+}
+
+static void test_unparseable_hostports(void) {
+  const char* const kCases[] = {
+      "[", "[::1", "[::1]bad", "[1.2.3.4]", "[localhost]", "[localhost]:1",
+  };
+  unsigned i;
+  for (i = 0; i < sizeof(kCases) / sizeof(*kCases); i++) {
+    ExecCtx _local_exec_ctx;
+    args_struct args;
+    args_init(&args);
+    grpc_resolve_address(
+        kCases[i], "1", args.pollset_set,
+        GRPC_CLOSURE_CREATE(must_fail, &args, grpc_schedule_on_exec_ctx),
+        &args.addrs);
+    grpc_exec_ctx_flush();
+    poll_pollset_until_request_done(&args);
+    args_finish(&args);
+    grpc_exec_ctx_finish();
+  }
+}
+
+int main(int argc, char** argv) {
+  grpc_test_init(argc, argv);
+  grpc_init();
+  ExecCtx _local_exec_ctx;
+  test_localhost();
+  test_default_port();
+  test_non_numeric_default_port();
+  test_missing_default_port();
+  test_ipv6_with_port();
+  test_ipv6_without_port();
+  test_invalid_ip_addresses();
+  test_unparseable_hostports();
+  grpc_executor_shutdown();
+  grpc_exec_ctx_finish();
+  grpc_shutdown();
+  return 0;
+}