Searched refs:flow_controller_ (Results 1 – 5 of 5) sorted by relevance
33 flow_controller_.reset(new QuicFlowController( in Initialize()43 scoped_ptr<QuicFlowController> flow_controller_; member in net::test::QuicFlowControllerTest50 EXPECT_TRUE(flow_controller_->IsEnabled()); in TEST_F()51 EXPECT_FALSE(flow_controller_->IsBlocked()); in TEST_F()52 EXPECT_FALSE(flow_controller_->FlowControlViolation()); in TEST_F()53 EXPECT_EQ(send_window_, flow_controller_->SendWindowSize()); in TEST_F()56 flow_controller_->AddBytesSent(send_window_ / 2); in TEST_F()57 EXPECT_FALSE(flow_controller_->IsBlocked()); in TEST_F()58 EXPECT_EQ(send_window_ / 2, flow_controller_->SendWindowSize()); in TEST_F()61 flow_controller_->AddBytesSent(send_window_ / 2); in TEST_F()[all …]
157 flow_controller_( in ReliableQuicStream()193 if (flow_controller_.FlowControlViolation() || in OnStreamFrame()336 flow_controller_.MaybeSendBlocked(); in MaybeSendBlocked()345 !flow_controller_.IsBlocked()) { in MaybeSendBlocked()366 if (flow_controller_.IsEnabled()) { in WritevData()368 uint64 send_window = flow_controller_.SendWindowSize(); in WritevData()471 uint64 bytes_to_consume = flow_controller_.highest_received_byte_offset() - in OnClose()472 flow_controller_.bytes_consumed(); in OnClose()478 if (!flow_controller_.IsEnabled()) { in OnWindowUpdateFrame()482 if (flow_controller_.UpdateSendWindowOffset(frame.byte_offset)) { in OnWindowUpdateFrame()[all …]
114 flow_controller_.reset(new QuicFlowController( in QuicSession()119 flow_controller_.reset(new QuicFlowController( in QuicSession()263 if (flow_controller_->UpdateSendWindowOffset(frames[i].byte_offset)) { in OnWindowUpdateFrames()305 if (flow_controller_->IsBlocked()) { in OnCanWrite()353 (!flow_controller_->IsBlocked() && in WillingAndAbleToWrite()448 if (flow_controller_->UpdateHighestReceivedOffset( in UpdateFlowControlOnFinalReceivedByteOffset()449 flow_controller_->highest_received_byte_offset() + offset_diff)) { in UpdateFlowControlOnFinalReceivedByteOffset()451 if (flow_controller_->FlowControlViolation()) { in UpdateFlowControlOnFinalReceivedByteOffset()458 flow_controller_->AddBytesConsumed(offset_diff); in UpdateFlowControlOnFinalReceivedByteOffset()547 flow_controller_->UpdateSendWindowOffset(new_window); in OnNewSessionFlowControlWindow()[all …]
102 QuicFlowController* flow_controller() { return &flow_controller_; } in flow_controller()171 flow_controller_.Disable(); in DisableFlowControl()242 QuicFlowController flow_controller_; variable
207 QuicFlowController* flow_controller() { return flow_controller_.get(); } in flow_controller()324 scoped_ptr<QuicFlowController> flow_controller_; variable