瀏覽代碼

Remove duplicated code

Muxi Yan 8 年之前
父節點
當前提交
ef033aa6a8

+ 0 - 11
src/core/ext/transport/chttp2/transport/chttp2_transport.c

@@ -2680,17 +2680,6 @@ void grpc_chttp2_incoming_byte_stream_push(grpc_exec_ctx *exec_ctx,
   }
 }
 
-void grpc_chttp2_incoming_byte_stream_notify(
-    grpc_exec_ctx *exec_ctx, grpc_chttp2_incoming_byte_stream *bs,
-    grpc_error *error) {
-  gpr_mu_lock(&bs->slice_mu);
-  if (bs->on_next) {
-    grpc_closure_sched(exec_ctx, bs->next_action.on_complete, error);
-    bs->on_next = NULL;
-  }
-  gpr_mu_unlock(&bs->slice_mu);
-}
-
 void grpc_chttp2_incoming_byte_stream_finished(
     grpc_exec_ctx *exec_ctx, grpc_chttp2_incoming_byte_stream *bs,
     grpc_error *error) {

+ 0 - 2
src/core/ext/transport/chttp2/transport/frame_data.c

@@ -291,8 +291,6 @@ grpc_error *parse_inner_buffer(grpc_exec_ctx *exec_ctx,
       grpc_chttp2_unprocessed_frames_buffer_push(
           exec_ctx, p, s,
           grpc_slice_sub(slice, (size_t)(cur - beg), (size_t)(end - beg)));
-      grpc_chttp2_incoming_byte_stream_notify(exec_ctx, p->parsing_frame,
-                                              GRPC_ERROR_NONE);
       gpr_mu_unlock(&s->buffer_mu);
       return GRPC_ERROR_NONE;
   }