Chiebot-Mirror
/
grpc
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Make all tests build again

Browse Source
reviewable/pr8239/r2
Craig Tiller 9 years ago
parent 69a1f66005
commit 08d297e375
16 changed files with 75 additions and 62 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      src/core/lib/iomgr/buffer_pool.c
  2. 2
      test/core/bad_client/bad_client.c
  3. 2
      test/core/end2end/fixtures/h2_sockpair+trace.c
  4. 2
      test/core/end2end/fixtures/h2_sockpair.c
  5. 2
      test/core/end2end/fixtures/h2_sockpair_1byte.c
  6. 2
      test/core/end2end/fuzzers/api_fuzzer.c
  7. 2
      test/core/end2end/fuzzers/client_fuzzer.c
  8. 2
      test/core/end2end/fuzzers/server_fuzzer.c
  9. 4
      test/core/http/httpcli_test.c
  10. 4
      test/core/http/httpscli_test.c
  11. 92
      test/core/iomgr/buffer_pool_test.c
  12. 2
      test/core/iomgr/endpoint_pair_test.c
  13. 3
      test/core/iomgr/fd_conservation_posix_test.c
  14. 11
      test/core/iomgr/tcp_posix_test.c
  15. 3
      test/core/security/secure_endpoint_test.c
  16. 2
      test/core/util/port_server_client.c

2
src/core/lib/iomgr/buffer_pool.c
Unescape View File

@ -42,6 +42,8 @@
#include "src/core/lib/iomgr/combiner.h"
int grpc_buffer_pool_trace = 0;
typedef bool (*bpstate_func)(grpc_exec_ctx *exec_ctx,
grpc_buffer_pool *buffer_pool);

2
test/core/bad_client/bad_client.c
Unescape View File

@ -114,7 +114,7 @@ void grpc_run_bad_client_test(
grpc_init();
/* Create endpoints */
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("bad_client_test");
sfd = grpc_iomgr_create_endpoint_pair("fixture", buffer_pool, 65536);
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);

2
test/core/end2end/fixtures/h2_sockpair+trace.c
Unescape View File

@ -91,7 +91,7 @@ static grpc_end2end_test_fixture chttp2_create_fixture_socketpair(
f.fixture_data = sfd;
f.cq = grpc_completion_queue_create(NULL);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("fixture");
*sfd = grpc_iomgr_create_endpoint_pair("fixture", buffer_pool, 65536);
grpc_buffer_pool_unref(buffer_pool);

2
test/core/end2end/fixtures/h2_sockpair.c
Unescape View File

@ -90,7 +90,7 @@ static grpc_end2end_test_fixture chttp2_create_fixture_socketpair(
f.fixture_data = sfd;
f.cq = grpc_completion_queue_create(NULL);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("fixture");
*sfd = grpc_iomgr_create_endpoint_pair("fixture", buffer_pool, 65536);
grpc_buffer_pool_unref(buffer_pool);

2
test/core/end2end/fixtures/h2_sockpair_1byte.c
Unescape View File

@ -90,7 +90,7 @@ static grpc_end2end_test_fixture chttp2_create_fixture_socketpair(
f.fixture_data = sfd;
f.cq = grpc_completion_queue_create(NULL);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("fixture");
*sfd = grpc_iomgr_create_endpoint_pair("fixture", buffer_pool, 1);
grpc_buffer_pool_unref(buffer_pool);

2
test/core/end2end/fuzzers/api_fuzzer.c
Unescape View File

@ -522,7 +522,7 @@ int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
int pending_pings = 0;
g_active_call = new_call(NULL, ROOT);
g_buffer_pool = grpc_buffer_pool_create();
g_buffer_pool = grpc_buffer_pool_create("api_fuzzer");
grpc_completion_queue *cq = grpc_completion_queue_create(NULL);

2
test/core/end2end/fuzzers/client_fuzzer.c
Unescape View File

@ -58,7 +58,7 @@ int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
grpc_init();
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("client_fuzzer");
grpc_endpoint *mock_endpoint =
grpc_mock_endpoint_create(discard_write, buffer_pool);
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);

2
test/core/end2end/fuzzers/server_fuzzer.c
Unescape View File

@ -56,7 +56,7 @@ int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
grpc_init();
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("server_fuzzer");
grpc_endpoint *mock_endpoint =
grpc_mock_endpoint_create(discard_write, buffer_pool);
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);

4
test/core/http/httpcli_test.c
Unescape View File

@ -89,7 +89,7 @@ static void test_get(int port) {
grpc_http_response response;
memset(&response, 0, sizeof(response));
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("test_get");
grpc_httpcli_get(&exec_ctx, &g_context, &g_pops, buffer_pool, &req,
n_seconds_time(15),
grpc_closure_create(on_finish, &response), &response);
@ -129,7 +129,7 @@ static void test_post(int port) {
grpc_http_response response;
memset(&response, 0, sizeof(response));
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("test_post");
grpc_httpcli_post(&exec_ctx, &g_context, &g_pops, buffer_pool, &req, "hello",
5, n_seconds_time(15),
grpc_closure_create(on_finish, &response), &response);

4
test/core/http/httpscli_test.c
Unescape View File

@ -90,7 +90,7 @@ static void test_get(int port) {
grpc_http_response response;
memset(&response, 0, sizeof(response));
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("test_get");
grpc_httpcli_get(&exec_ctx, &g_context, &g_pops, buffer_pool, &req,
n_seconds_time(15),
grpc_closure_create(on_finish, &response), &response);
@ -131,7 +131,7 @@ static void test_post(int port) {
grpc_http_response response;
memset(&response, 0, sizeof(response));
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("test_post");
grpc_httpcli_post(&exec_ctx, &g_context, &g_pops, buffer_pool, &req, "hello",
5, n_seconds_time(15),
grpc_closure_create(on_finish, &response), &response);

92
test/core/iomgr/buffer_pool_test.c
Unescape View File

@ -91,31 +91,31 @@ static void destroy_user(grpc_buffer_user *usr) {
static void test_no_op(void) {
gpr_log(GPR_INFO, "** test_no_op **");
grpc_buffer_pool_unref(grpc_buffer_pool_create());
grpc_buffer_pool_unref(grpc_buffer_pool_create("test_no_op"));
}
static void test_resize_then_destroy(void) {
gpr_log(GPR_INFO, "** test_resize_then_destroy **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_resize_then_destroy");
grpc_buffer_pool_resize(p, 1024 * 1024);
grpc_buffer_pool_unref(p);
}
static void test_buffer_user_no_op(void) {
gpr_log(GPR_INFO, "** test_buffer_user_no_op **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_buffer_user_no_op");
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
grpc_buffer_pool_unref(p);
destroy_user(&usr);
}
static void test_instant_alloc_then_free(void) {
gpr_log(GPR_INFO, "** test_instant_alloc_then_free **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_instant_alloc_then_free");
grpc_buffer_pool_resize(p, 1024 * 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_buffer_user_alloc(&exec_ctx, &usr, 1024, NULL);
@ -132,10 +132,10 @@ static void test_instant_alloc_then_free(void) {
static void test_instant_alloc_free_pair(void) {
gpr_log(GPR_INFO, "** test_instant_alloc_free_pair **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_instant_alloc_free_pair");
grpc_buffer_pool_resize(p, 1024 * 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_buffer_user_alloc(&exec_ctx, &usr, 1024, NULL);
@ -148,10 +148,10 @@ static void test_instant_alloc_free_pair(void) {
static void test_simple_async_alloc(void) {
gpr_log(GPR_INFO, "** test_simple_async_alloc **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_simple_async_alloc");
grpc_buffer_pool_resize(p, 1024 * 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
bool done = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -170,10 +170,11 @@ static void test_simple_async_alloc(void) {
static void test_async_alloc_blocked_by_size(void) {
gpr_log(GPR_INFO, "** test_async_alloc_blocked_by_size **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_async_alloc_blocked_by_size");
grpc_buffer_pool_resize(p, 1);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool done = false;
{
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -194,12 +195,12 @@ static void test_async_alloc_blocked_by_size(void) {
static void test_scavenge(void) {
gpr_log(GPR_INFO, "** test_scavenge **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_scavenge");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr1;
grpc_buffer_user usr2;
grpc_buffer_user_init(&usr1, p);
grpc_buffer_user_init(&usr2, p);
grpc_buffer_user_init(&usr1, p, "usr1");
grpc_buffer_user_init(&usr2, p, "usr2");
{
bool done = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -231,12 +232,12 @@ static void test_scavenge(void) {
static void test_scavenge_blocked(void) {
gpr_log(GPR_INFO, "** test_scavenge_blocked **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_scavenge_blocked");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr1;
grpc_buffer_user usr2;
grpc_buffer_user_init(&usr1, p);
grpc_buffer_user_init(&usr2, p);
grpc_buffer_user_init(&usr1, p, "usr1");
grpc_buffer_user_init(&usr2, p, "usr2");
bool done;
{
done = false;
@ -270,10 +271,11 @@ static void test_scavenge_blocked(void) {
static void test_blocked_until_scheduled_reclaim(void) {
gpr_log(GPR_INFO, "** test_blocked_until_scheduled_reclaim **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_blocked_until_scheduled_reclaim");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
bool done = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -308,12 +310,13 @@ static void test_blocked_until_scheduled_reclaim(void) {
static void test_blocked_until_scheduled_reclaim_and_scavenge(void) {
gpr_log(GPR_INFO, "** test_blocked_until_scheduled_reclaim_and_scavenge **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create(
"test_blocked_until_scheduled_reclaim_and_scavenge");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr1;
grpc_buffer_user usr2;
grpc_buffer_user_init(&usr1, p);
grpc_buffer_user_init(&usr2, p);
grpc_buffer_user_init(&usr1, p, "usr1");
grpc_buffer_user_init(&usr2, p, "usr2");
{
bool done = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -349,10 +352,11 @@ static void test_blocked_until_scheduled_reclaim_and_scavenge(void) {
static void test_blocked_until_scheduled_destructive_reclaim(void) {
gpr_log(GPR_INFO, "** test_blocked_until_scheduled_destructive_reclaim **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create(
"test_blocked_until_scheduled_destructive_reclaim");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
bool done = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -387,10 +391,11 @@ static void test_blocked_until_scheduled_destructive_reclaim(void) {
static void test_unused_reclaim_is_cancelled(void) {
gpr_log(GPR_INFO, "** test_unused_reclaim_is_cancelled **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_unused_reclaim_is_cancelled");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool benign_done = false;
bool destructive_done = false;
{
@ -412,10 +417,11 @@ static void test_unused_reclaim_is_cancelled(void) {
static void test_benign_reclaim_is_preferred(void) {
gpr_log(GPR_INFO, "** test_benign_reclaim_is_preferred **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_benign_reclaim_is_preferred");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool benign_done = false;
bool destructive_done = false;
{
@ -459,10 +465,11 @@ static void test_benign_reclaim_is_preferred(void) {
static void test_multiple_reclaims_can_be_triggered(void) {
gpr_log(GPR_INFO, "** test_multiple_reclaims_can_be_triggered **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_multiple_reclaims_can_be_triggered");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool benign_done = false;
bool destructive_done = false;
{
@ -507,10 +514,11 @@ static void test_multiple_reclaims_can_be_triggered(void) {
static void test_buffer_user_stays_allocated_until_memory_released(void) {
gpr_log(GPR_INFO,
"** test_buffer_user_stays_allocated_until_memory_released **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create(
"test_buffer_user_stays_allocated_until_memory_released");
grpc_buffer_pool_resize(p, 1024 * 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool done = false;
{
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -539,11 +547,12 @@ static void test_buffer_user_stays_allocated_until_memory_released(void) {
static void test_pools_merged_on_buffer_user_deletion(void) {
gpr_log(GPR_INFO, "** test_pools_merged_on_buffer_user_deletion **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_pools_merged_on_buffer_user_deletion");
grpc_buffer_pool_resize(p, 1024);
for (int i = 0; i < 10; i++) {
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
bool done = false;
bool reclaimer_cancelled = false;
{
@ -587,10 +596,11 @@ static void test_pools_merged_on_buffer_user_deletion(void) {
static void test_reclaimers_can_be_posted_repeatedly(void) {
gpr_log(GPR_INFO, "** test_reclaimers_can_be_posted_repeatedly **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p =
grpc_buffer_pool_create("test_reclaimers_can_be_posted_repeatedly");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
{
bool allocated = false;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
@ -629,11 +639,11 @@ static void test_reclaimers_can_be_posted_repeatedly(void) {
static void test_one_slice(void) {
gpr_log(GPR_INFO, "** test_one_slice **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_one_slice");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
grpc_buffer_user_slice_allocator alloc;
int num_allocs = 0;
@ -658,11 +668,11 @@ static void test_one_slice(void) {
static void test_one_slice_deleted_late(void) {
gpr_log(GPR_INFO, "** test_one_slice_deleted_late **");
grpc_buffer_pool *p = grpc_buffer_pool_create();
grpc_buffer_pool *p = grpc_buffer_pool_create("test_one_slice_deleted_late");
grpc_buffer_pool_resize(p, 1024);
grpc_buffer_user usr;
grpc_buffer_user_init(&usr, p);
grpc_buffer_user_init(&usr, p, "usr");
grpc_buffer_user_slice_allocator alloc;
int num_allocs = 0;

2
test/core/iomgr/endpoint_pair_test.c
Unescape View File

@ -49,7 +49,7 @@ static grpc_endpoint_test_fixture create_fixture_endpoint_pair(
size_t slice_size) {
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_endpoint_test_fixture f;
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("endpoint_pair_test");
grpc_endpoint_pair p =
grpc_iomgr_create_endpoint_pair("test", buffer_pool, slice_size);
grpc_buffer_pool_unref(buffer_pool);

3
test/core/iomgr/fd_conservation_posix_test.c
Unescape View File

@ -52,7 +52,8 @@ int main(int argc, char **argv) {
of descriptors */
rlim.rlim_cur = rlim.rlim_max = 10;
GPR_ASSERT(0 == setrlimit(RLIMIT_NOFILE, &rlim));
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool =
grpc_buffer_pool_create("fd_conservation_posix_test");
for (i = 0; i < 100; i++) {
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;

11
test/core/iomgr/tcp_posix_test.c
Unescape View File

@ -176,7 +176,7 @@ static void read_test(size_t num_bytes, size_t slice_size) {
create_sockets(sv);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("read_test");
ep = grpc_tcp_create(grpc_fd_create(sv[1], "read_test"), buffer_pool,
slice_size, "test");
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);
@ -226,7 +226,7 @@ static void large_read_test(size_t slice_size) {
create_sockets(sv);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("large_read_test");
ep = grpc_tcp_create(grpc_fd_create(sv[1], "large_read_test"), buffer_pool,
slice_size, "test");
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);
@ -364,7 +364,7 @@ static void write_test(size_t num_bytes, size_t slice_size) {
create_sockets(sv);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("write_test");
ep = grpc_tcp_create(grpc_fd_create(sv[1], "write_test"), buffer_pool,
GRPC_TCP_DEFAULT_READ_SLICE_SIZE, "test");
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);
@ -430,7 +430,7 @@ static void release_fd_test(size_t num_bytes, size_t slice_size) {
create_sockets(sv);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create("release_fd_test");
ep = grpc_tcp_create(grpc_fd_create(sv[1], "read_test"), buffer_pool,
slice_size, "test");
GPR_ASSERT(grpc_tcp_fd(ep) == sv[1] && sv[1] >= 0);
@ -520,7 +520,8 @@ static grpc_endpoint_test_fixture create_fixture_tcp_socketpair(
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
create_sockets(sv);
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool =
grpc_buffer_pool_create("tcp_posix_test_socketpair");
f.client_ep = grpc_tcp_create(grpc_fd_create(sv[0], "fixture:client"),
buffer_pool, slice_size, "test");
f.server_ep = grpc_tcp_create(grpc_fd_create(sv[1], "fixture:server"),

3
test/core/security/secure_endpoint_test.c
Unescape View File

@ -56,7 +56,8 @@ static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair(
grpc_endpoint_test_fixture f;
grpc_endpoint_pair tcp;
grpc_buffer_pool *buffer_pool = grpc_buffer_pool_create();
grpc_buffer_pool *buffer_pool =
grpc_buffer_pool_create("secure_endpoint_test");
tcp = grpc_iomgr_create_endpoint_pair("fixture", buffer_pool, slice_size);
grpc_buffer_pool_internal_unref(&exec_ctx, buffer_pool);
grpc_endpoint_add_to_pollset(&exec_ctx, tcp.client, g_pollset);

2
test/core/util/port_server_client.c
Unescape View File

@ -49,8 +49,6 @@
#include "src/core/lib/http/httpcli.h"
int grpc_buffer_pool_trace = 0;
typedef struct freereq {
gpr_mu *mu;
grpc_polling_entity pops;

Write Preview
Loading…
Cancel
Save