Refine condition

pull/5560/head
Craig Tiller 9 years ago
parent 389297dedf
commit 1bd9ea407f
  1. 5
      src/core/transport/chttp2_transport.c
  2. 3
      src/core/transport/transport.h

@ -1006,8 +1006,9 @@ static void perform_transport_op(grpc_exec_ctx *exec_ctx, grpc_transport *gt,
lock(t); lock(t);
/* Let's be overly cautious: don't change any state while we're parsing */ /* If there's a set_accept_stream ensure that we're not parsing
if (t->parsing_active) { to avoid changing things out from underneath */
if (t->parsing_active && t->set_accept_stream) {
GPR_ASSERT(t->post_parsing_op == NULL); GPR_ASSERT(t->post_parsing_op == NULL);
t->post_parsing_op = gpr_malloc(sizeof(*op)); t->post_parsing_op = gpr_malloc(sizeof(*op));
memcpy(t->post_parsing_op, op, sizeof(*op)); memcpy(t->post_parsing_op, op, sizeof(*op));

@ -123,8 +123,7 @@ typedef struct grpc_transport_stream_op {
/** Transport op: a set of operations to perform on a transport as a whole */ /** Transport op: a set of operations to perform on a transport as a whole */
typedef struct grpc_transport_op { typedef struct grpc_transport_op {
/** Called when processing of this op is done. /** Called when processing of this op is done. */
Only one transport_op is allowed to be outstanding at any time. */
grpc_closure *on_consumed; grpc_closure *on_consumed;
/** connectivity monitoring - set connectivity_state to NULL to unsubscribe */ /** connectivity monitoring - set connectivity_state to NULL to unsubscribe */
grpc_closure *on_connectivity_state_change; grpc_closure *on_connectivity_state_change;

Loading…
Cancel
Save