| 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/http/http_network_transaction.h" | 5 #include "net/http/http_network_transaction.h" |
| 6 | 6 |
| 7 #include <math.h> // ceil | 7 #include <math.h> // ceil |
| 8 #include <stdarg.h> | 8 #include <stdarg.h> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 5756 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5767 | 5767 |
| 5768 MockWrite data_writes[] = { | 5768 MockWrite data_writes[] = { |
| 5769 MockWrite(ASYNC, reinterpret_cast<char*>(write_buffer), | 5769 MockWrite(ASYNC, reinterpret_cast<char*>(write_buffer), |
| 5770 arraysize(write_buffer)), | 5770 arraysize(write_buffer)), |
| 5771 MockWrite("GET / HTTP/1.1\r\n" | 5771 MockWrite("GET / HTTP/1.1\r\n" |
| 5772 "Host: www.google.com\r\n" | 5772 "Host: www.google.com\r\n" |
| 5773 "Connection: keep-alive\r\n\r\n") | 5773 "Connection: keep-alive\r\n\r\n") |
| 5774 }; | 5774 }; |
| 5775 | 5775 |
| 5776 MockRead data_reads[] = { | 5776 MockRead data_reads[] = { |
| 5777 MockWrite(ASYNC, reinterpret_cast<char*>(read_buffer), | 5777 MockRead(ASYNC, reinterpret_cast<char*>(read_buffer), |
| 5778 arraysize(read_buffer)), | 5778 arraysize(read_buffer)), |
| 5779 MockRead("HTTP/1.0 200 OK\r\n"), | 5779 MockRead("HTTP/1.0 200 OK\r\n"), |
| 5780 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), | 5780 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), |
| 5781 MockRead("Payload"), | 5781 MockRead("Payload"), |
| 5782 MockRead(SYNCHRONOUS, OK) | 5782 MockRead(SYNCHRONOUS, OK) |
| 5783 }; | 5783 }; |
| 5784 | 5784 |
| 5785 StaticSocketDataProvider data(data_reads, arraysize(data_reads), | 5785 StaticSocketDataProvider data(data_reads, arraysize(data_reads), |
| 5786 data_writes, arraysize(data_writes)); | 5786 data_writes, arraysize(data_writes)); |
| 5787 session_deps.socket_factory.AddSocketDataProvider(&data); | 5787 session_deps.socket_factory.AddSocketDataProvider(&data); |
| 5788 | 5788 |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5835 | 5835 |
| 5836 MockWrite data_writes[] = { | 5836 MockWrite data_writes[] = { |
| 5837 MockWrite(ASYNC, kSOCKS5GreetRequest, arraysize(kSOCKS5GreetRequest)), | 5837 MockWrite(ASYNC, kSOCKS5GreetRequest, arraysize(kSOCKS5GreetRequest)), |
| 5838 MockWrite(ASYNC, kSOCKS5OkRequest, arraysize(kSOCKS5OkRequest)), | 5838 MockWrite(ASYNC, kSOCKS5OkRequest, arraysize(kSOCKS5OkRequest)), |
| 5839 MockWrite("GET / HTTP/1.1\r\n" | 5839 MockWrite("GET / HTTP/1.1\r\n" |
| 5840 "Host: www.google.com\r\n" | 5840 "Host: www.google.com\r\n" |
| 5841 "Connection: keep-alive\r\n\r\n") | 5841 "Connection: keep-alive\r\n\r\n") |
| 5842 }; | 5842 }; |
| 5843 | 5843 |
| 5844 MockRead data_reads[] = { | 5844 MockRead data_reads[] = { |
| 5845 MockWrite(ASYNC, kSOCKS5GreetResponse, arraysize(kSOCKS5GreetResponse)), | 5845 MockRead(ASYNC, kSOCKS5GreetResponse, arraysize(kSOCKS5GreetResponse)), |
| 5846 MockWrite(ASYNC, kSOCKS5OkResponse, arraysize(kSOCKS5OkResponse)), | 5846 MockRead(ASYNC, kSOCKS5OkResponse, arraysize(kSOCKS5OkResponse)), |
| 5847 MockRead("HTTP/1.0 200 OK\r\n"), | 5847 MockRead("HTTP/1.0 200 OK\r\n"), |
| 5848 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), | 5848 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), |
| 5849 MockRead("Payload"), | 5849 MockRead("Payload"), |
| 5850 MockRead(SYNCHRONOUS, OK) | 5850 MockRead(SYNCHRONOUS, OK) |
| 5851 }; | 5851 }; |
| 5852 | 5852 |
| 5853 StaticSocketDataProvider data(data_reads, arraysize(data_reads), | 5853 StaticSocketDataProvider data(data_reads, arraysize(data_reads), |
| 5854 data_writes, arraysize(data_writes)); | 5854 data_writes, arraysize(data_writes)); |
| 5855 session_deps.socket_factory.AddSocketDataProvider(&data); | 5855 session_deps.socket_factory.AddSocketDataProvider(&data); |
| 5856 | 5856 |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5902 MockWrite data_writes[] = { | 5902 MockWrite data_writes[] = { |
| 5903 MockWrite(ASYNC, kSOCKS5GreetRequest, arraysize(kSOCKS5GreetRequest)), | 5903 MockWrite(ASYNC, kSOCKS5GreetRequest, arraysize(kSOCKS5GreetRequest)), |
| 5904 MockWrite(ASYNC, reinterpret_cast<const char*>(kSOCKS5OkRequest), | 5904 MockWrite(ASYNC, reinterpret_cast<const char*>(kSOCKS5OkRequest), |
| 5905 arraysize(kSOCKS5OkRequest)), | 5905 arraysize(kSOCKS5OkRequest)), |
| 5906 MockWrite("GET / HTTP/1.1\r\n" | 5906 MockWrite("GET / HTTP/1.1\r\n" |
| 5907 "Host: www.google.com\r\n" | 5907 "Host: www.google.com\r\n" |
| 5908 "Connection: keep-alive\r\n\r\n") | 5908 "Connection: keep-alive\r\n\r\n") |
| 5909 }; | 5909 }; |
| 5910 | 5910 |
| 5911 MockRead data_reads[] = { | 5911 MockRead data_reads[] = { |
| 5912 MockWrite(ASYNC, kSOCKS5GreetResponse, arraysize(kSOCKS5GreetResponse)), | 5912 MockRead(ASYNC, kSOCKS5GreetResponse, arraysize(kSOCKS5GreetResponse)), |
| 5913 MockWrite(ASYNC, kSOCKS5OkResponse, arraysize(kSOCKS5OkResponse)), | 5913 MockRead(ASYNC, kSOCKS5OkResponse, arraysize(kSOCKS5OkResponse)), |
| 5914 MockRead("HTTP/1.0 200 OK\r\n"), | 5914 MockRead("HTTP/1.0 200 OK\r\n"), |
| 5915 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), | 5915 MockRead("Content-Type: text/html; charset=iso-8859-1\r\n\r\n"), |
| 5916 MockRead("Payload"), | 5916 MockRead("Payload"), |
| 5917 MockRead(SYNCHRONOUS, OK) | 5917 MockRead(SYNCHRONOUS, OK) |
| 5918 }; | 5918 }; |
| 5919 | 5919 |
| 5920 StaticSocketDataProvider data(data_reads, arraysize(data_reads), | 5920 StaticSocketDataProvider data(data_reads, arraysize(data_reads), |
| 5921 data_writes, arraysize(data_writes)); | 5921 data_writes, arraysize(data_writes)); |
| 5922 session_deps.socket_factory.AddSocketDataProvider(&data); | 5922 session_deps.socket_factory.AddSocketDataProvider(&data); |
| 5923 | 5923 |
| (...skipping 1962 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 7886 TestRound(const MockWrite& write_arg, const MockRead& read_arg, | 7886 TestRound(const MockWrite& write_arg, const MockRead& read_arg, |
| 7887 int expected_rv_arg) | 7887 int expected_rv_arg) |
| 7888 : write(write_arg), | 7888 : write(write_arg), |
| 7889 read(read_arg), | 7889 read(read_arg), |
| 7890 expected_rv(expected_rv_arg), | 7890 expected_rv(expected_rv_arg), |
| 7891 extra_write(NULL), | 7891 extra_write(NULL), |
| 7892 extra_read(NULL) { | 7892 extra_read(NULL) { |
| 7893 } | 7893 } |
| 7894 TestRound(const MockWrite& write_arg, const MockRead& read_arg, | 7894 TestRound(const MockWrite& write_arg, const MockRead& read_arg, |
| 7895 int expected_rv_arg, const MockWrite* extra_write_arg, | 7895 int expected_rv_arg, const MockWrite* extra_write_arg, |
| 7896 const MockWrite* extra_read_arg) | 7896 const MockRead* extra_read_arg) |
| 7897 : write(write_arg), | 7897 : write(write_arg), |
| 7898 read(read_arg), | 7898 read(read_arg), |
| 7899 expected_rv(expected_rv_arg), | 7899 expected_rv(expected_rv_arg), |
| 7900 extra_write(extra_write_arg), | 7900 extra_write(extra_write_arg), |
| 7901 extra_read(extra_read_arg) { | 7901 extra_read(extra_read_arg) { |
| 7902 } | 7902 } |
| 7903 MockWrite write; | 7903 MockWrite write; |
| 7904 MockRead read; | 7904 MockRead read; |
| 7905 int expected_rv; | 7905 int expected_rv; |
| 7906 const MockWrite* extra_write; | 7906 const MockWrite* extra_write; |
| (...skipping 2280 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 10187 trans2.Start(&request2, callback2.callback(), BoundNetLog())); | 10187 trans2.Start(&request2, callback2.callback(), BoundNetLog())); |
| 10188 MessageLoop::current()->RunAllPending(); | 10188 MessageLoop::current()->RunAllPending(); |
| 10189 data2->RunFor(3); | 10189 data2->RunFor(3); |
| 10190 | 10190 |
| 10191 ASSERT_TRUE(callback2.have_result()); | 10191 ASSERT_TRUE(callback2.have_result()); |
| 10192 EXPECT_EQ(OK, callback2.WaitForResult()); | 10192 EXPECT_EQ(OK, callback2.WaitForResult()); |
| 10193 EXPECT_TRUE(trans2.GetResponseInfo()->was_fetched_via_spdy); | 10193 EXPECT_TRUE(trans2.GetResponseInfo()->was_fetched_via_spdy); |
| 10194 } | 10194 } |
| 10195 | 10195 |
| 10196 } // namespace net | 10196 } // namespace net |
| OLD | NEW |