| 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/quic_session.h" | 5 #include "net/quic/quic_session.h" |
| 6 | 6 |
| 7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
| 8 #include "net/quic/crypto/proof_verifier.h" | 8 #include "net/quic/crypto/proof_verifier.h" |
| 9 #include "net/quic/quic_connection.h" | 9 #include "net/quic/quic_connection.h" |
| 10 #include "net/quic/quic_headers_stream.h" | 10 #include "net/quic/quic_headers_stream.h" |
| (...skipping 334 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 345 bool QuicSession::HasPendingWrites() const { | 345 bool QuicSession::HasPendingWrites() const { |
| 346 return write_blocked_streams_.HasWriteBlockedStreams(); | 346 return write_blocked_streams_.HasWriteBlockedStreams(); |
| 347 } | 347 } |
| 348 | 348 |
| 349 bool QuicSession::HasPendingHandshake() const { | 349 bool QuicSession::HasPendingHandshake() const { |
| 350 return has_pending_handshake_; | 350 return has_pending_handshake_; |
| 351 } | 351 } |
| 352 | 352 |
| 353 QuicConsumedData QuicSession::WritevData( | 353 QuicConsumedData QuicSession::WritevData( |
| 354 QuicStreamId id, | 354 QuicStreamId id, |
| 355 const struct iovec* iov, | 355 const IOVector& data, |
| 356 int iov_count, | |
| 357 QuicStreamOffset offset, | 356 QuicStreamOffset offset, |
| 358 bool fin, | 357 bool fin, |
| 359 QuicAckNotifier::DelegateInterface* ack_notifier_delegate) { | 358 QuicAckNotifier::DelegateInterface* ack_notifier_delegate) { |
| 360 IOVector data; | |
| 361 data.AppendIovec(iov, iov_count); | |
| 362 return connection_->SendStreamData(id, data, offset, fin, | 359 return connection_->SendStreamData(id, data, offset, fin, |
| 363 ack_notifier_delegate); | 360 ack_notifier_delegate); |
| 364 } | 361 } |
| 365 | 362 |
| 366 size_t QuicSession::WriteHeaders(QuicStreamId id, | 363 size_t QuicSession::WriteHeaders(QuicStreamId id, |
| 367 const SpdyHeaderBlock& headers, | 364 const SpdyHeaderBlock& headers, |
| 368 bool fin) { | 365 bool fin) { |
| 369 DCHECK_LT(QUIC_VERSION_12, connection()->version()); | 366 DCHECK_LT(QUIC_VERSION_12, connection()->version()); |
| 370 if (connection()->version() <= QUIC_VERSION_12) { | 367 if (connection()->version() <= QUIC_VERSION_12) { |
| 371 return 0; | 368 return 0; |
| (...skipping 312 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 684 NOTIMPLEMENTED(); | 681 NOTIMPLEMENTED(); |
| 685 return false; | 682 return false; |
| 686 } | 683 } |
| 687 | 684 |
| 688 void QuicSession::PostProcessAfterData() { | 685 void QuicSession::PostProcessAfterData() { |
| 689 STLDeleteElements(&closed_streams_); | 686 STLDeleteElements(&closed_streams_); |
| 690 closed_streams_.clear(); | 687 closed_streams_.clear(); |
| 691 } | 688 } |
| 692 | 689 |
| 693 } // namespace net | 690 } // namespace net |
| OLD | NEW |