OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/core/reliable_quic_stream.h" | 5 #include "net/quic/core/reliable_quic_stream.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "net/quic/core/iovector.h" | 8 #include "net/quic/core/iovector.h" |
9 #include "net/quic/core/quic_bug_tracker.h" | 9 #include "net/quic/core/quic_bug_tracker.h" |
10 #include "net/quic/core/quic_flags.h" | 10 #include "net/quic/core/quic_flags.h" |
(...skipping 28 matching lines...) Expand all Loading... |
39 } | 39 } |
40 | 40 |
41 return kMinimumFlowControlSendWindow; | 41 return kMinimumFlowControlSendWindow; |
42 } | 42 } |
43 | 43 |
44 } // namespace | 44 } // namespace |
45 | 45 |
46 ReliableQuicStream::PendingData::PendingData( | 46 ReliableQuicStream::PendingData::PendingData( |
47 string data_in, | 47 string data_in, |
48 QuicAckListenerInterface* ack_listener_in) | 48 QuicAckListenerInterface* ack_listener_in) |
49 : data(data_in), offset(0), ack_listener(ack_listener_in) {} | 49 : data(std::move(data_in)), offset(0), ack_listener(ack_listener_in) {} |
50 | 50 |
51 ReliableQuicStream::PendingData::~PendingData() {} | 51 ReliableQuicStream::PendingData::~PendingData() {} |
52 | 52 |
53 ReliableQuicStream::ReliableQuicStream(QuicStreamId id, QuicSession* session) | 53 ReliableQuicStream::ReliableQuicStream(QuicStreamId id, QuicSession* session) |
54 : queued_data_bytes_(0), | 54 : queued_data_bytes_(0), |
55 sequencer_(this, session->connection()->clock()), | 55 sequencer_(this, session->connection()->clock()), |
56 id_(id), | 56 id_(id), |
57 session_(session), | 57 session_(session), |
58 stream_bytes_read_(0), | 58 stream_bytes_read_(0), |
59 stream_bytes_written_(0), | 59 stream_bytes_written_(0), |
(...skipping 404 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
464 } | 464 } |
465 } | 465 } |
466 | 466 |
467 void ReliableQuicStream::UpdateSendWindowOffset(QuicStreamOffset new_window) { | 467 void ReliableQuicStream::UpdateSendWindowOffset(QuicStreamOffset new_window) { |
468 if (flow_controller_.UpdateSendWindowOffset(new_window)) { | 468 if (flow_controller_.UpdateSendWindowOffset(new_window)) { |
469 OnCanWrite(); | 469 OnCanWrite(); |
470 } | 470 } |
471 } | 471 } |
472 | 472 |
473 } // namespace net | 473 } // namespace net |
OLD | NEW |