Searched refs:incoming_frame_size (Results 1 – 4 of 4) sorted by relevance
205 int64_t incoming_frame_size) { in ValidateRecvData() argument206 if (incoming_frame_size > announced_window_) { in ValidateRecvData()210 incoming_frame_size, announced_window_); in ValidateRecvData()222 grpc_error* StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument226 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()238 if (incoming_frame_size > acked_stream_window) { in RecvData()239 if (incoming_frame_size <= sent_stream_window) { in RecvData()249 incoming_frame_size, acked_stream_window, sent_stream_window); in RecvData()254 incoming_frame_size, acked_stream_window); in RecvData()261 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()[all …]
173 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); } in RecvData() argument217 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument253 grpc_error* ValidateRecvData(int64_t incoming_frame_size);254 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument255 announced_window_ -= incoming_frame_size; in CommitRecvData()258 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument260 grpc_error* error = ValidateRecvData(incoming_frame_size); in RecvData()262 CommitRecvData(incoming_frame_size); in RecvData()363 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); } in RecvData() argument408 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument[all …]
111 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()119 t->incoming_frame_size |= (static_cast<uint32_t>(*cur)) << 8; in grpc_chttp2_perform_read()127 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()181 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()193 t->incoming_frame_size > in grpc_chttp2_perform_read()198 t->incoming_frame_size, in grpc_chttp2_perform_read()211 if (static_cast<uint32_t>(end - cur) == t->incoming_frame_size) { in grpc_chttp2_perform_read()223 } else if (static_cast<uint32_t>(end - cur) > t->incoming_frame_size) { in grpc_chttp2_perform_read()228 cur_offset + t->incoming_frame_size), in grpc_chttp2_perform_read()233 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()[all …]
416 uint32_t incoming_frame_size; member