grpc/test/core/http/httpcli_test.cc

/*
 *
 * 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/http/httpcli.h"

#include <string.h>

#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include <grpc/support/subprocess.h>
#include <grpc/support/sync.h>
#include "src/core/lib/iomgr/iomgr.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"

static int g_done = 0;
static grpc_httpcli_context g_context;
static gpr_mu *g_mu;
static grpc_polling_entity g_pops;

static grpc_millis n_seconds_time(int seconds) {
  return grpc_timespec_to_millis_round_up(
      grpc_timeout_seconds_to_deadline(seconds));
}

static void on_finish(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
  const char *expect =
      "<html><head><title>Hello world!</title></head>"
      "<body><p>This is a test</p></body></html>";
  grpc_http_response *response = static_cast<grpc_http_response *>(arg);
  GPR_ASSERT(response);
  GPR_ASSERT(response->status == 200);
  GPR_ASSERT(response->body_length == strlen(expect));
  GPR_ASSERT(0 == memcmp(expect, response->body, response->body_length));
  gpr_mu_lock(g_mu);
  g_done = 1;
  GPR_ASSERT(GRPC_LOG_IF_ERROR(
      "pollset_kick",
      grpc_pollset_kick(exec_ctx, grpc_polling_entity_pollset(&g_pops), NULL)));
  gpr_mu_unlock(g_mu);
}

static void test_get(int port) {
  grpc_httpcli_request req;
  char *host;
  grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;

  g_done = 0;
  gpr_log(GPR_INFO, "test_get");

  gpr_asprintf(&host, "localhost:%d", port);
  gpr_log(GPR_INFO, "requesting from %s", host);

  memset(&req, 0, sizeof(req));
  req.host = host;
  req.http.path = const_cast<char *>("/get");
  req.handshaker = &grpc_httpcli_plaintext;

  grpc_http_response response;
  memset(&response, 0, sizeof(response));
  grpc_resource_quota *resource_quota = grpc_resource_quota_create("test_get");
  grpc_httpcli_get(
      &exec_ctx, &g_context, &g_pops, resource_quota, &req, n_seconds_time(15),
      GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx),
      &response);
  grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);
  gpr_mu_lock(g_mu);
  while (!g_done) {
    grpc_pollset_worker *worker = NULL;
    GPR_ASSERT(GRPC_LOG_IF_ERROR(
        "pollset_work",
        grpc_pollset_work(&exec_ctx, grpc_polling_entity_pollset(&g_pops),
                          &worker, n_seconds_time(1))));
    gpr_mu_unlock(g_mu);
    grpc_exec_ctx_finish(&exec_ctx);
    gpr_mu_lock(g_mu);
  }
  gpr_mu_unlock(g_mu);
  gpr_free(host);
  grpc_http_response_destroy(&response);
}

static void test_post(int port) {
  grpc_httpcli_request req;
  char *host;
  grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;

  g_done = 0;
  gpr_log(GPR_INFO, "test_post");

  gpr_asprintf(&host, "localhost:%d", port);
  gpr_log(GPR_INFO, "posting to %s", host);

  memset(&req, 0, sizeof(req));
  req.host = host;
  req.http.path = const_cast<char *>("/post");
  req.handshaker = &grpc_httpcli_plaintext;

  grpc_http_response response;
  memset(&response, 0, sizeof(response));
  grpc_resource_quota *resource_quota = grpc_resource_quota_create("test_post");
  grpc_httpcli_post(
      &exec_ctx, &g_context, &g_pops, resource_quota, &req, "hello", 5,
      n_seconds_time(15),
      GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx),
      &response);
  grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);
  gpr_mu_lock(g_mu);
  while (!g_done) {
    grpc_pollset_worker *worker = NULL;
    GPR_ASSERT(GRPC_LOG_IF_ERROR(
        "pollset_work",
        grpc_pollset_work(&exec_ctx, grpc_polling_entity_pollset(&g_pops),
                          &worker, n_seconds_time(1))));
    gpr_mu_unlock(g_mu);
    grpc_exec_ctx_finish(&exec_ctx);
    gpr_mu_lock(g_mu);
  }
  gpr_mu_unlock(g_mu);
  gpr_free(host);
  grpc_http_response_destroy(&response);
}

static void destroy_pops(grpc_exec_ctx *exec_ctx, void *p, grpc_error *error) {
  grpc_pollset_destroy(exec_ctx, grpc_polling_entity_pollset(
                                     static_cast<grpc_polling_entity *>(p)));
}

int main(int argc, char **argv) {
  grpc_closure destroyed;
  grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
  gpr_subprocess *server;
  char *me = argv[0];
  char *lslash = strrchr(me, '/');
  char *args[4];
  int port = grpc_pick_unused_port_or_die();
  int arg_shift = 0;
  /* figure out where we are */
  char *root;
  if (lslash) {
    root = static_cast<char *>(gpr_malloc((size_t)(lslash - me + 1)));
    memcpy(root, me, (size_t)(lslash - me));
    root[lslash - me] = 0;
  } else {
    root = gpr_strdup(".");
  }

  GPR_ASSERT(argc <= 2);
  if (argc == 2) {
    args[0] = gpr_strdup(argv[1]);
  } else {
    arg_shift = 1;
    gpr_asprintf(&args[0], "%s/../../tools/distrib/python_wrapper.sh", root);
    gpr_asprintf(&args[1], "%s/../../test/core/http/test_server.py", root);
  }

  /* start the server */
  args[1 + arg_shift] = const_cast<char *>("--port");
  gpr_asprintf(&args[2 + arg_shift], "%d", port);
  server = gpr_subprocess_create(3 + arg_shift, (const char **)args);
  GPR_ASSERT(server);
  gpr_free(args[0]);
  if (arg_shift) gpr_free(args[1]);
  gpr_free(args[2 + arg_shift]);
  gpr_free(root);

  gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME),
                               gpr_time_from_seconds(5, GPR_TIMESPAN)));

  grpc_test_init(argc, argv);
  grpc_init();
  grpc_httpcli_context_init(&g_context);
  grpc_pollset *pollset =
      static_cast<grpc_pollset *>(gpr_zalloc(grpc_pollset_size()));
  grpc_pollset_init(pollset, &g_mu);
  g_pops = grpc_polling_entity_create_from_pollset(pollset);

  test_get(port);
  test_post(port);

  grpc_httpcli_context_destroy(&exec_ctx, &g_context);
  GRPC_CLOSURE_INIT(&destroyed, destroy_pops, &g_pops,
                    grpc_schedule_on_exec_ctx);
  grpc_pollset_shutdown(&exec_ctx, grpc_polling_entity_pollset(&g_pops),
                        &destroyed);
  grpc_exec_ctx_finish(&exec_ctx);
  grpc_shutdown();

  gpr_free(grpc_polling_entity_pollset(&g_pops));

  gpr_subprocess_destroy(server);

  return 0;
}
Initial import. 10 years ago			`/*`
			`*`
auto-fix most of licenses 8 years ago			`* Copyright 2015 gRPC authors.`
Initial import. 10 years ago			`*`
auto-fix most of licenses 8 years ago			`* 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`
Initial import. 10 years ago			`*`
auto-fix most of licenses 8 years ago			`* http://www.apache.org/licenses/LICENSE-2.0`
Initial import. 10 years ago			`*`
auto-fix most of licenses 8 years ago			`* 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.`
Initial import. 10 years ago			`*`
			`*/`

Fix includes 9 years ago			`#include "src/core/lib/http/httpcli.h"`
Initial import. 10 years ago
			`#include <string.h>`

Merge github.com:grpc/grpc into we-dont-need-no-backup Conflicts: test/core/bad_client/bad_client.c test/core/httpcli/httpcli_test.c 10 years ago			`#include <grpc/grpc.h>`
Add working tests for httpcli 10 years ago			`#include <grpc/support/alloc.h>`
Initial import. 10 years ago			`#include <grpc/support/log.h>`
Add working tests for httpcli 10 years ago			`#include <grpc/support/string_util.h>`
			`#include <grpc/support/subprocess.h>`
Introducing iomgr. Move eventmanager and platform dependent endpoint functionality into a single library called 'iomgr'. This is primarily to prepare for a Windows port - where posix socket semantics lead to poor quality code. Mostly this is a code movement CL, with some small changes to help prepare the way for porting: - em style fd objects can only be held internally in iomgr, and own their memory - added grpc_iomgr_create_endpoint_pair() to accomodate the common pattern of creating a tcp endpoint from the output of socketpair - this will help keep our tests portable - separated em alarm interface into a separate file, as this part of event manager is needed higher up the stack - made the eventmanager bits a true singleton, simplifying API's across the stack as there's no longer a reason to carry a pointer there. Initial design document is here: https://docs.google.com/document/d/1VmafcHvvrP5kwtQkz84R5yXF7u7fW-9Pn0bkSUQHDt8/edit?disco=AAAAARNByxg Change on 2014/12/09 by ctiller <ctiller@google.com> ------------- Created by MOE: http://code.google.com/p/moe-java MOE_MIGRATED_REVID=81716456 10 years ago			`#include <grpc/support/sync.h>`
Fix includes 9 years ago			`#include "src/core/lib/iomgr/iomgr.h"`
Add working tests for httpcli 10 years ago			`#include "test/core/util/port.h"`
Initial import. 10 years ago			`#include "test/core/util/test_config.h"`

Initial refactoring of a few tests 10 years ago			`static int g_done = 0;`
Rephrase integration for httpcli 10 years ago			`static grpc_httpcli_context g_context;`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`static gpr_mu *g_mu;`
s/grpc_pops/grpc_polling_entity 9 years ago			`static grpc_polling_entity g_pops;`
Initial import. 10 years ago
Compiling again 7 years ago			`static grpc_millis n_seconds_time(int seconds) {`
Explicitly call out round up vs round down 7 years ago			`return grpc_timespec_to_millis_round_up(`
			`grpc_timeout_seconds_to_deadline(seconds));`
Initial import. 10 years ago			`}`

Convert tests to new error scheme 9 years ago			`static void on_finish(grpc_exec_ctx exec_ctx, void arg, grpc_error *error) {`
clang-format all core files 9 years ago			`const char *expect =`
			`"<html><head><title>Hello world!</title></head>"`
			`"<body><p>This is a test</p></body></html>";`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`grpc_http_response response = static_cast<grpc_http_response >(arg);`
clang-format all core files 9 years ago			`GPR_ASSERT(response);`
			`GPR_ASSERT(response->status == 200);`
			`GPR_ASSERT(response->body_length == strlen(expect));`
			`GPR_ASSERT(0 == memcmp(expect, response->body, response->body_length));`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_lock(g_mu);`
Initial refactoring of a few tests 10 years ago			`g_done = 1;`
Merge github.com:grpc/grpc into error 9 years ago			`GPR_ASSERT(GRPC_LOG_IF_ERROR(`
			`"pollset_kick",`
Add pollset_kick stats 7 years ago			`grpc_pollset_kick(exec_ctx, grpc_polling_entity_pollset(&g_pops), NULL)));`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_unlock(g_mu);`
Initial import. 10 years ago			`}`

Fixes, review feedback 9 years ago			`static void test_get(int port) {`
Initial import. 10 years ago			`grpc_httpcli_request req;`
clang-format affected files 10 years ago			`char *host;`
Rename init 9 years ago			`grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;`
Initial import. 10 years ago
Initial refactoring of a few tests 10 years ago			`g_done = 0;`
Fixes, review feedback 9 years ago			`gpr_log(GPR_INFO, "test_get");`
Initial import. 10 years ago
clang-format all core files 9 years ago			`gpr_asprintf(&host, "localhost:%d", port);`
			`gpr_log(GPR_INFO, "requesting from %s", host);`
Add working tests for httpcli 10 years ago
clang-format all core files 9 years ago			`memset(&req, 0, sizeof(req));`
Add working tests for httpcli 10 years ago			`req.host = host;`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`req.http.path = const_cast<char *>("/get");`
Fixes, review feedback 9 years ago			`req.handshaker = &grpc_httpcli_plaintext;`
Initial import. 10 years ago
Convert tests to new error scheme 9 years ago			`grpc_http_response response;`
			`memset(&response, 0, sizeof(response));`
BufferPool --> ResourceQuota 8 years ago			`grpc_resource_quota *resource_quota = grpc_resource_quota_create("test_get");`
Changes to exec_ctx/closure/combiner/workqueue interfaces - make closures know where they should be executed (eg, on a workqueue, or a combiner, or on an exec_ctx) - this allows removal of a large number of trampoline functions that were appearing whenever we used combiners, and should allow for a much easier interface to combiner locks 8 years ago			`grpc_httpcli_get(`
			`&exec_ctx, &g_context, &g_pops, resource_quota, &req, n_seconds_time(15),`
Add rich closure debug mode 8 years ago			`GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx),`
Changes to exec_ctx/closure/combiner/workqueue interfaces - make closures know where they should be executed (eg, on a workqueue, or a combiner, or on an exec_ctx) - this allows removal of a large number of trampoline functions that were appearing whenever we used combiners, and should allow for a much easier interface to combiner locks 8 years ago			`&response);`
Progress towards making grpc_slice_unref_internal take an exec_ctx 8 years ago			`grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_lock(g_mu);`
clang-format all core files 9 years ago			`while (!g_done) {`
Move worker into pollset 9 years ago			`grpc_pollset_worker *worker = NULL;`
Progress converting to new error system 9 years ago			`GPR_ASSERT(GRPC_LOG_IF_ERROR(`
			`"pollset_work",`
Merge github.com:grpc/grpc into error 9 years ago			`grpc_pollset_work(&exec_ctx, grpc_polling_entity_pollset(&g_pops),`
Compiling again 7 years ago			`&worker, n_seconds_time(1))));`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_unlock(g_mu);`
clang-format all core files 9 years ago			`grpc_exec_ctx_finish(&exec_ctx);`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_lock(g_mu);`
clang-format all core files 9 years ago			`}`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_unlock(g_mu);`
clang-format all core files 9 years ago			`gpr_free(host);`
Progress converting to new error system 9 years ago			`grpc_http_response_destroy(&response);`
Initial import. 10 years ago			`}`

Fixes, review feedback 9 years ago			`static void test_post(int port) {`
Initial import. 10 years ago			`grpc_httpcli_request req;`
clang-format affected files 10 years ago			`char *host;`
Rename init 9 years ago			`grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;`
Initial import. 10 years ago
Merge github.com:grpc/grpc into we-dont-need-no-backup Conflicts: test/core/bad_client/bad_client.c test/core/httpcli/httpcli_test.c 10 years ago			`g_done = 0;`
Fixes, review feedback 9 years ago			`gpr_log(GPR_INFO, "test_post");`
Initial import. 10 years ago
clang-format all core files 9 years ago			`gpr_asprintf(&host, "localhost:%d", port);`
			`gpr_log(GPR_INFO, "posting to %s", host);`
Add working tests for httpcli 10 years ago
clang-format all core files 9 years ago			`memset(&req, 0, sizeof(req));`
Add working tests for httpcli 10 years ago			`req.host = host;`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`req.http.path = const_cast<char *>("/post");`
Fixes, review feedback 9 years ago			`req.handshaker = &grpc_httpcli_plaintext;`
Initial import. 10 years ago
Convert tests to new error scheme 9 years ago			`grpc_http_response response;`
			`memset(&response, 0, sizeof(response));`
BufferPool --> ResourceQuota 8 years ago			`grpc_resource_quota *resource_quota = grpc_resource_quota_create("test_post");`
Changes to exec_ctx/closure/combiner/workqueue interfaces - make closures know where they should be executed (eg, on a workqueue, or a combiner, or on an exec_ctx) - this allows removal of a large number of trampoline functions that were appearing whenever we used combiners, and should allow for a much easier interface to combiner locks 8 years ago			`grpc_httpcli_post(`
			`&exec_ctx, &g_context, &g_pops, resource_quota, &req, "hello", 5,`
			`n_seconds_time(15),`
Add rich closure debug mode 8 years ago			`GRPC_CLOSURE_CREATE(on_finish, &response, grpc_schedule_on_exec_ctx),`
Changes to exec_ctx/closure/combiner/workqueue interfaces - make closures know where they should be executed (eg, on a workqueue, or a combiner, or on an exec_ctx) - this allows removal of a large number of trampoline functions that were appearing whenever we used combiners, and should allow for a much easier interface to combiner locks 8 years ago			`&response);`
Progress towards making grpc_slice_unref_internal take an exec_ctx 8 years ago			`grpc_resource_quota_unref_internal(&exec_ctx, resource_quota);`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_lock(g_mu);`
clang-format all core files 9 years ago			`while (!g_done) {`
Move worker into pollset 9 years ago			`grpc_pollset_worker *worker = NULL;`
Progress converting to new error system 9 years ago			`GPR_ASSERT(GRPC_LOG_IF_ERROR(`
			`"pollset_work",`
Merge github.com:grpc/grpc into error 9 years ago			`grpc_pollset_work(&exec_ctx, grpc_polling_entity_pollset(&g_pops),`
Compiling again 7 years ago			`&worker, n_seconds_time(1))));`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_unlock(g_mu);`
clang-format all core files 9 years ago			`grpc_exec_ctx_finish(&exec_ctx);`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_lock(g_mu);`
clang-format all core files 9 years ago			`}`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago			`gpr_mu_unlock(g_mu);`
clang-format all core files 9 years ago			`gpr_free(host);`
Progress converting to new error system 9 years ago			`grpc_http_response_destroy(&response);`
Merge github.com:grpc/grpc into we-dont-need-no-backup Conflicts: test/core/bad_client/bad_client.c test/core/httpcli/httpcli_test.c 10 years ago			`}`

Merge github.com:grpc/grpc into error 9 years ago			`static void destroy_pops(grpc_exec_ctx exec_ctx, void p, grpc_error *error) {`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`grpc_pollset_destroy(exec_ctx, grpc_polling_entity_pollset(`
			`static_cast<grpc_polling_entity *>(p)));`
Call list progress 9 years ago			`}`
Initial import. 10 years ago
clang-format all core files 9 years ago			`int main(int argc, char **argv) {`
Call list progress 9 years ago			`grpc_closure destroyed;`
Rename init 9 years ago			`grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;`
clang-format affected files 10 years ago			`gpr_subprocess *server;`
Add working tests for httpcli 10 years ago			`char *me = argv[0];`
clang-format all core files 9 years ago			`char *lslash = strrchr(me, '/');`
clang-format affected files 10 years ago			`char *args[4];`
clang-format all core files 9 years ago			`int port = grpc_pick_unused_port_or_die();`
Added python_wrapper.sh to take care of finding an appropriate version of python from the system. 9 years ago			`int arg_shift = 0;`
			`/* figure out where we are */`
			`char *root;`
			`if (lslash) {`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`root = static_cast<char *>(gpr_malloc((size_t)(lslash - me + 1)));`
Added python_wrapper.sh to take care of finding an appropriate version of python from the system. 9 years ago			`memcpy(root, me, (size_t)(lslash - me));`
			`root[lslash - me] = 0;`
			`} else {`
			`root = gpr_strdup(".");`
			`}`
Add working tests for httpcli 10 years ago
Allows http(s)cli_test's server.py override. 9 years ago			`GPR_ASSERT(argc <= 2);`
			`if (argc == 2) {`
			`args[0] = gpr_strdup(argv[1]);`
clang-format all core files 9 years ago			`} else {`
Added python_wrapper.sh to take care of finding an appropriate version of python from the system. 9 years ago			`arg_shift = 1;`
			`gpr_asprintf(&args[0], "%s/../../tools/distrib/python_wrapper.sh", root);`
Add HTTP request parsing. This extends the existing http parser to support requests as well as responses. httpcli continues to exist and work as it has previously, though in the new directory src/core/http (to reflect the fact the directory now contains code relevant to parsing requests, which httpcli would not generally involve itself in). 9 years ago			`gpr_asprintf(&args[1], "%s/../../test/core/http/test_server.py", root);`
clang-format all core files 9 years ago			`}`
Add working tests for httpcli 10 years ago
			`/* start the server */`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`args[1 + arg_shift] = const_cast<char *>("--port");`
Added python_wrapper.sh to take care of finding an appropriate version of python from the system. 9 years ago			`gpr_asprintf(&args[2 + arg_shift], "%d", port);`
			`server = gpr_subprocess_create(3 + arg_shift, (const char **)args);`
clang-format all core files 9 years ago			`GPR_ASSERT(server);`
			`gpr_free(args[0]);`
Added python_wrapper.sh to take care of finding an appropriate version of python from the system. 9 years ago			`if (arg_shift) gpr_free(args[1]);`
			`gpr_free(args[2 + arg_shift]);`
			`gpr_free(root);`
clang-format all core files 9 years ago
			`gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME),`
			`gpr_time_from_seconds(5, GPR_TIMESPAN)));`

			`grpc_test_init(argc, argv);`
			`grpc_init();`
			`grpc_httpcli_context_init(&g_context);`
rename all test core files to cc and a lot of C++ style conversions 7 years ago			`grpc_pollset *pollset =`
			`static_cast<grpc_pollset *>(gpr_zalloc(grpc_pollset_size()));`
Introduced grpc_pops (pollset or pollset_set) 9 years ago			`grpc_pollset_init(pollset, &g_mu);`
moar renamings 9 years ago			`g_pops = grpc_polling_entity_create_from_pollset(pollset);`
clang-format all core files 9 years ago
Fixes, review feedback 9 years ago			`test_get(port);`
			`test_post(port);`
clang-format all core files 9 years ago
Fix broken shutdown, and cascading exec_ctx usage bugs 8 years ago			`grpc_httpcli_context_destroy(&exec_ctx, &g_context);`
Add rich closure debug mode 8 years ago			`GRPC_CLOSURE_INIT(&destroyed, destroy_pops, &g_pops,`
Changes to exec_ctx/closure/combiner/workqueue interfaces - make closures know where they should be executed (eg, on a workqueue, or a combiner, or on an exec_ctx) - this allows removal of a large number of trampoline functions that were appearing whenever we used combiners, and should allow for a much easier interface to combiner locks 8 years ago			`grpc_schedule_on_exec_ctx);`
clang-format 9 years ago			`grpc_pollset_shutdown(&exec_ctx, grpc_polling_entity_pollset(&g_pops),`
			`&destroyed);`
clang-format all core files 9 years ago			`grpc_exec_ctx_finish(&exec_ctx);`
			`grpc_shutdown();`

moar renamings 9 years ago			`gpr_free(grpc_polling_entity_pollset(&g_pops));`
Revert "Revert "Add an implementation firewall against pollset_set"" 9 years ago
clang-format all core files 9 years ago			`gpr_subprocess_destroy(server);`
Initial import. 10 years ago
			`return 0;`
Add missing new-lines at end of file 10 years ago			`}`