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 |