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/tools/quic/test_tools/quic_test_client.h" | 5 #include "net/tools/quic/test_tools/quic_test_client.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
(...skipping 564 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
575 return; | 575 return; |
576 } | 576 } |
577 if (buffer_body()) { | 577 if (buffer_body()) { |
578 // TODO(fnk): The stream still buffers the whole thing. Fix that. | 578 // TODO(fnk): The stream still buffers the whole thing. Fix that. |
579 response_ = stream_->data(); | 579 response_ = stream_->data(); |
580 } | 580 } |
581 response_complete_ = true; | 581 response_complete_ = true; |
582 response_headers_complete_ = stream_->headers_decompressed(); | 582 response_headers_complete_ = stream_->headers_decompressed(); |
583 SpdyBalsaUtils::SpdyHeadersToResponseHeaders(stream_->response_headers(), | 583 SpdyBalsaUtils::SpdyHeadersToResponseHeaders(stream_->response_headers(), |
584 &response_headers_); | 584 &response_headers_); |
585 response_trailers_ = stream_->received_trailers(); | 585 response_trailers_ = stream_->received_trailers().Clone(); |
586 stream_error_ = stream_->stream_error(); | 586 stream_error_ = stream_->stream_error(); |
587 bytes_read_ = stream_->stream_bytes_read() + stream_->header_bytes_read(); | 587 bytes_read_ = stream_->stream_bytes_read() + stream_->header_bytes_read(); |
588 bytes_written_ = | 588 bytes_written_ = |
589 stream_->stream_bytes_written() + stream_->header_bytes_written(); | 589 stream_->stream_bytes_written() + stream_->header_bytes_written(); |
590 response_header_size_ = response_headers_.GetSizeForWriteBuffer(); | 590 response_header_size_ = response_headers_.GetSizeForWriteBuffer(); |
591 response_body_size_ = stream_->data().size(); | 591 response_body_size_ = stream_->data().size(); |
592 stream_ = nullptr; | 592 stream_ = nullptr; |
593 } | 593 } |
594 | 594 |
595 bool QuicTestClient::CheckVary(const SpdyHeaderBlock& client_request, | 595 bool QuicTestClient::CheckVary(const SpdyHeaderBlock& client_request, |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
675 CHECK(message); | 675 CHECK(message); |
676 message->headers()->SetRequestVersion( | 676 message->headers()->SetRequestVersion( |
677 HTTPMessage::VersionToString(HttpConstants::HTTP_1_1)); | 677 HTTPMessage::VersionToString(HttpConstants::HTTP_1_1)); |
678 message->headers()->SetRequestMethod( | 678 message->headers()->SetRequestMethod( |
679 HTTPMessage::MethodToString(HttpConstants::GET)); | 679 HTTPMessage::MethodToString(HttpConstants::GET)); |
680 message->headers()->SetRequestUri(uri); | 680 message->headers()->SetRequestUri(uri); |
681 } | 681 } |
682 | 682 |
683 } // namespace test | 683 } // namespace test |
684 } // namespace net | 684 } // namespace net |
OLD | NEW |