aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext/transport
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2017-10-12 22:02:28 -0700
committerGravatar Craig Tiller <ctiller@google.com>2017-10-12 22:02:28 -0700
commit3273648a87a34a166f7ef83955a9700f2c9dd45e (patch)
tree80b8cd40e296f5f0856050cc74eef91b66b85541 /src/core/ext/transport
parentb278bc701810a790d9a00486cb997abb099a47dc (diff)
flow control fixes
Diffstat (limited to 'src/core/ext/transport')
-rw-r--r--src/core/ext/transport/chttp2/transport/flow_control.h11
1 files changed, 11 insertions, 0 deletions
diff --git a/src/core/ext/transport/chttp2/transport/flow_control.h b/src/core/ext/transport/chttp2/transport/flow_control.h
index 13a3341122..33542a31e4 100644
--- a/src/core/ext/transport/chttp2/transport/flow_control.h
+++ b/src/core/ext/transport/chttp2/transport/flow_control.h
@@ -201,6 +201,11 @@ class TransportFlowControl {
FlowControlAction PeriodicUpdate(grpc_exec_ctx* exec_ctx);
+ void TestOnlyForceHugeWindow() {
+ announced_window_ = 1024 * 1024 * 1024;
+ remote_window_ = 1024 * 1024 * 1024;
+ }
+
private:
double SmoothLogBdp(grpc_exec_ctx* exec_ctx, double value);
FlowControlAction::Urgency DeltaUrgency(int32_t value,
@@ -289,6 +294,12 @@ class StreamFlowControl {
const grpc_chttp2_stream* stream() const { return s_; }
+ void TestOnlyForceHugeWindow() {
+ announced_window_delta_ = 1024 * 1024 * 1024;
+ local_window_delta_ = 1024 * 1024 * 1024;
+ remote_window_delta_ = 1024 * 1024 * 1024;
+ }
+
private:
TransportFlowControl* const tfc_;
const grpc_chttp2_stream* const s_;