1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "quiche/quic/test_tools/quic_stream_peer.h"
6
7 #include <list>
8
9 #include "quiche/quic/core/quic_stream.h"
10 #include "quiche/quic/core/quic_types.h"
11 #include "quiche/quic/test_tools/quic_flow_controller_peer.h"
12 #include "quiche/quic/test_tools/quic_stream_send_buffer_peer.h"
13
14 namespace quic {
15 namespace test {
16
17 // static
SetWriteSideClosed(bool value,QuicStream * stream)18 void QuicStreamPeer::SetWriteSideClosed(bool value, QuicStream* stream) {
19 stream->write_side_closed_ = value;
20 }
21
22 // static
SetStreamBytesWritten(QuicStreamOffset stream_bytes_written,QuicStream * stream)23 void QuicStreamPeer::SetStreamBytesWritten(
24 QuicStreamOffset stream_bytes_written, QuicStream* stream) {
25 stream->send_buffer_.stream_bytes_written_ = stream_bytes_written;
26 stream->send_buffer_.stream_bytes_outstanding_ = stream_bytes_written;
27 QuicStreamSendBufferPeer::SetStreamOffset(&stream->send_buffer_,
28 stream_bytes_written);
29 }
30
31 // static
SetSendWindowOffset(QuicStream * stream,QuicStreamOffset offset)32 void QuicStreamPeer::SetSendWindowOffset(QuicStream* stream,
33 QuicStreamOffset offset) {
34 QuicFlowControllerPeer::SetSendWindowOffset(&*stream->flow_controller_,
35 offset);
36 }
37
38 // static
bytes_consumed(QuicStream * stream)39 QuicByteCount QuicStreamPeer::bytes_consumed(QuicStream* stream) {
40 return stream->flow_controller_->bytes_consumed();
41 }
42
43 // static
SetReceiveWindowOffset(QuicStream * stream,QuicStreamOffset offset)44 void QuicStreamPeer::SetReceiveWindowOffset(QuicStream* stream,
45 QuicStreamOffset offset) {
46 QuicFlowControllerPeer::SetReceiveWindowOffset(&*stream->flow_controller_,
47 offset);
48 }
49
50 // static
SetMaxReceiveWindow(QuicStream * stream,QuicStreamOffset size)51 void QuicStreamPeer::SetMaxReceiveWindow(QuicStream* stream,
52 QuicStreamOffset size) {
53 QuicFlowControllerPeer::SetMaxReceiveWindow(&*stream->flow_controller_, size);
54 }
55
56 // static
SendWindowSize(QuicStream * stream)57 QuicByteCount QuicStreamPeer::SendWindowSize(QuicStream* stream) {
58 return stream->flow_controller_->SendWindowSize();
59 }
60
61 // static
ReceiveWindowOffset(QuicStream * stream)62 QuicStreamOffset QuicStreamPeer::ReceiveWindowOffset(QuicStream* stream) {
63 return QuicFlowControllerPeer::ReceiveWindowOffset(
64 &*stream->flow_controller_);
65 }
66
67 // static
ReceiveWindowSize(QuicStream * stream)68 QuicByteCount QuicStreamPeer::ReceiveWindowSize(QuicStream* stream) {
69 return QuicFlowControllerPeer::ReceiveWindowSize(&*stream->flow_controller_);
70 }
71
72 // static
SendWindowOffset(QuicStream * stream)73 QuicStreamOffset QuicStreamPeer::SendWindowOffset(QuicStream* stream) {
74 return stream->flow_controller_->send_window_offset();
75 }
76
77 // static
read_side_closed(QuicStream * stream)78 bool QuicStreamPeer::read_side_closed(QuicStream* stream) {
79 return stream->read_side_closed_;
80 }
81
82 // static
CloseReadSide(QuicStream * stream)83 void QuicStreamPeer::CloseReadSide(QuicStream* stream) {
84 stream->CloseReadSide();
85 }
86
87 // static
StreamContributesToConnectionFlowControl(QuicStream * stream)88 bool QuicStreamPeer::StreamContributesToConnectionFlowControl(
89 QuicStream* stream) {
90 return stream->stream_contributes_to_connection_flow_control_;
91 }
92
93 // static
sequencer(QuicStream * stream)94 QuicStreamSequencer* QuicStreamPeer::sequencer(QuicStream* stream) {
95 return &(stream->sequencer_);
96 }
97
98 // static
session(QuicStream * stream)99 QuicSession* QuicStreamPeer::session(QuicStream* stream) {
100 return stream->session();
101 }
102
103 // static
SendBuffer(QuicStream * stream)104 QuicStreamSendBuffer& QuicStreamPeer::SendBuffer(QuicStream* stream) {
105 return stream->send_buffer_;
106 }
107
108 // static
SetFinReceived(QuicStream * stream)109 void QuicStreamPeer::SetFinReceived(QuicStream* stream) {
110 stream->fin_received_ = true;
111 }
112
113 // static
SetFinSent(QuicStream * stream)114 void QuicStreamPeer::SetFinSent(QuicStream* stream) {
115 stream->fin_sent_ = true;
116 }
117
118 } // namespace test
119 } // namespace quic
120