|
|
|
@ -151,7 +151,7 @@ static void read_and_write_test_write_handler(grpc_exec_ctx *exec_ctx, |
|
|
|
|
gpr_slice *slices = NULL; |
|
|
|
|
size_t nslices; |
|
|
|
|
|
|
|
|
|
if (error != GRPC_ERROR_NONE) { |
|
|
|
|
if (error == GRPC_ERROR_NONE) { |
|
|
|
|
state->bytes_written += state->current_write_size; |
|
|
|
|
if (state->target_bytes - state->bytes_written < |
|
|
|
|
state->current_write_size) { |
|
|
|
@ -171,7 +171,7 @@ static void read_and_write_test_write_handler(grpc_exec_ctx *exec_ctx, |
|
|
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "Write handler done"); |
|
|
|
|
gpr_mu_lock(g_mu); |
|
|
|
|
state->write_done = 1 + (error != GRPC_ERROR_NONE); |
|
|
|
|
state->write_done = 1 + (error == GRPC_ERROR_NONE); |
|
|
|
|
GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, NULL)); |
|
|
|
|
gpr_mu_unlock(g_mu); |
|
|
|
|
} |
|
|
|
|