HomeSort by relevance Sort by last modified time
    Searched refs:incoming_frame_size (Results 1 - 4 of 4) sorted by null

  /external/grpc-grpc/src/core/ext/transport/chttp2/transport/
flow_control.h 173 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); }
217 grpc_error* RecvData(int64_t incoming_frame_size) override {
253 grpc_error* ValidateRecvData(int64_t incoming_frame_size);
254 void CommitRecvData(int64_t incoming_frame_size) {
255 announced_window_ -= incoming_frame_size;
258 grpc_error* RecvData(int64_t incoming_frame_size) override {
260 grpc_error* error = ValidateRecvData(incoming_frame_size);
262 CommitRecvData(incoming_frame_size);
363 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); }
408 grpc_error* RecvData(int64_t incoming_frame_size) override
    [all...]
flow_control.cc 205 int64_t incoming_frame_size) {
206 if (incoming_frame_size > announced_window_) {
210 incoming_frame_size, announced_window_);
222 grpc_error* StreamFlowControl::RecvData(int64_t incoming_frame_size) {
226 error = tfc_->ValidateRecvData(incoming_frame_size);
238 if (incoming_frame_size > acked_stream_window) {
239 if (incoming_frame_size <= sent_stream_window) {
249 incoming_frame_size, acked_stream_window, sent_stream_window);
254 incoming_frame_size, acked_stream_window);
261 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size);
    [all...]
parsing.cc 111 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16;
119 t->incoming_frame_size |= (static_cast<uint32_t>(*cur)) << 8;
127 t->incoming_frame_size |= *cur;
181 if (t->incoming_frame_size == 0) {
193 t->incoming_frame_size >
198 t->incoming_frame_size,
211 if (static_cast<uint32_t>(end - cur) == t->incoming_frame_size) {
223 } else if (static_cast<uint32_t>(end - cur) > t->incoming_frame_size) {
228 cur_offset + t->incoming_frame_size),
233 cur += t->incoming_frame_size;
    [all...]
internal.h 416 uint32_t incoming_frame_size; member in struct:grpc_chttp2_transport

Completed in 85 milliseconds