diff options
| -rw-r--r-- | src/core/lib/transport/transport.h | 2 | ||||
| -rw-r--r-- | test/core/end2end/fuzzers/server_fuzzer.c | 5 |
2 files changed, 5 insertions, 2 deletions
diff --git a/src/core/lib/transport/transport.h b/src/core/lib/transport/transport.h index 22f53e5179..a78d71322c 100644 --- a/src/core/lib/transport/transport.h +++ b/src/core/lib/transport/transport.h @@ -50,7 +50,7 @@ typedef struct grpc_transport grpc_transport; for a stream. */ typedef struct grpc_stream grpc_stream; -#define GRPC_STREAM_REFCOUNT_DEBUG +//#define GRPC_STREAM_REFCOUNT_DEBUG typedef struct grpc_stream_refcount { gpr_refcount refs; diff --git a/test/core/end2end/fuzzers/server_fuzzer.c b/test/core/end2end/fuzzers/server_fuzzer.c index 370d7425e0..e943429315 100644 --- a/test/core/end2end/fuzzers/server_fuzzer.c +++ b/test/core/end2end/fuzzers/server_fuzzer.c @@ -91,13 +91,16 @@ int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) { switch (detag(ev.tag)) { case 1: requested_calls--; - abort(); + // TODO(ctiller): keep reading that call! + break; } } } done: if (call1 != NULL) grpc_call_destroy(call1); + grpc_call_details_destroy(&call_details1); + grpc_metadata_array_destroy(&request_metadata1); grpc_server_shutdown_and_notify(server, cq, tag(0xdead)); for (int i=0; i<=requested_calls; i++) GPR_ASSERT(grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), NULL).type == GRPC_OP_COMPLETE); |