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 "jingle/glue/chrome_async_socket.h" | 5 #include "jingle/glue/chrome_async_socket.h" |
6 | 6 |
7 #include <deque> | 7 #include <deque> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
(...skipping 25 matching lines...) Expand all Loading... |
36 public: | 36 public: |
37 AsyncSocketDataProvider() : has_pending_read_(false) {} | 37 AsyncSocketDataProvider() : has_pending_read_(false) {} |
38 | 38 |
39 virtual ~AsyncSocketDataProvider() { | 39 virtual ~AsyncSocketDataProvider() { |
40 EXPECT_TRUE(writes_.empty()); | 40 EXPECT_TRUE(writes_.empty()); |
41 EXPECT_TRUE(reads_.empty()); | 41 EXPECT_TRUE(reads_.empty()); |
42 } | 42 } |
43 | 43 |
44 // If there's no read, sets the "has pending read" flag. Otherwise, | 44 // If there's no read, sets the "has pending read" flag. Otherwise, |
45 // pops the next read. | 45 // pops the next read. |
46 virtual net::MockRead GetNextRead() OVERRIDE { | 46 virtual net::MockRead GetNextRead() override { |
47 if (reads_.empty()) { | 47 if (reads_.empty()) { |
48 DCHECK(!has_pending_read_); | 48 DCHECK(!has_pending_read_); |
49 has_pending_read_ = true; | 49 has_pending_read_ = true; |
50 const net::MockRead pending_read(net::SYNCHRONOUS, net::ERR_IO_PENDING); | 50 const net::MockRead pending_read(net::SYNCHRONOUS, net::ERR_IO_PENDING); |
51 return pending_read; | 51 return pending_read; |
52 } | 52 } |
53 net::MockRead mock_read = reads_.front(); | 53 net::MockRead mock_read = reads_.front(); |
54 reads_.pop_front(); | 54 reads_.pop_front(); |
55 return mock_read; | 55 return mock_read; |
56 } | 56 } |
57 | 57 |
58 // Simply pops the next write and, if applicable, compares it to | 58 // Simply pops the next write and, if applicable, compares it to |
59 // |data|. | 59 // |data|. |
60 virtual net::MockWriteResult OnWrite(const std::string& data) OVERRIDE { | 60 virtual net::MockWriteResult OnWrite(const std::string& data) override { |
61 DCHECK(!writes_.empty()); | 61 DCHECK(!writes_.empty()); |
62 net::MockWrite mock_write = writes_.front(); | 62 net::MockWrite mock_write = writes_.front(); |
63 writes_.pop_front(); | 63 writes_.pop_front(); |
64 if (mock_write.result != net::OK) { | 64 if (mock_write.result != net::OK) { |
65 return net::MockWriteResult(mock_write.mode, mock_write.result); | 65 return net::MockWriteResult(mock_write.mode, mock_write.result); |
66 } | 66 } |
67 std::string expected_data(mock_write.data, mock_write.data_len); | 67 std::string expected_data(mock_write.data, mock_write.data_len); |
68 EXPECT_EQ(expected_data, data); | 68 EXPECT_EQ(expected_data, data); |
69 if (expected_data != data) { | 69 if (expected_data != data) { |
70 return net::MockWriteResult(net::SYNCHRONOUS, net::ERR_UNEXPECTED); | 70 return net::MockWriteResult(net::SYNCHRONOUS, net::ERR_UNEXPECTED); |
71 } | 71 } |
72 return net::MockWriteResult(mock_write.mode, data.size()); | 72 return net::MockWriteResult(mock_write.mode, data.size()); |
73 } | 73 } |
74 | 74 |
75 // We ignore resets so we can pre-load the socket data provider with | 75 // We ignore resets so we can pre-load the socket data provider with |
76 // read/write events. | 76 // read/write events. |
77 virtual void Reset() OVERRIDE {} | 77 virtual void Reset() override {} |
78 | 78 |
79 // If there is a pending read, completes it with the given read. | 79 // If there is a pending read, completes it with the given read. |
80 // Otherwise, queues up the given read. | 80 // Otherwise, queues up the given read. |
81 void AddRead(const net::MockRead& mock_read) { | 81 void AddRead(const net::MockRead& mock_read) { |
82 DCHECK_NE(mock_read.result, net::ERR_IO_PENDING); | 82 DCHECK_NE(mock_read.result, net::ERR_IO_PENDING); |
83 if (has_pending_read_) { | 83 if (has_pending_read_) { |
84 socket()->OnReadComplete(mock_read); | 84 socket()->OnReadComplete(mock_read); |
85 has_pending_read_ = false; | 85 has_pending_read_ = false; |
86 return; | 86 return; |
87 } | 87 } |
(...skipping 20 matching lines...) Expand all Loading... |
108 net::ClientSocketFactory* mock_client_socket_factory, | 108 net::ClientSocketFactory* mock_client_socket_factory, |
109 const net::AddressList& address_list) | 109 const net::AddressList& address_list) |
110 : mock_client_socket_factory_(mock_client_socket_factory), | 110 : mock_client_socket_factory_(mock_client_socket_factory), |
111 address_list_(address_list), | 111 address_list_(address_list), |
112 cert_verifier_(new net::MockCertVerifier), | 112 cert_verifier_(new net::MockCertVerifier), |
113 transport_security_state_(new net::TransportSecurityState) { | 113 transport_security_state_(new net::TransportSecurityState) { |
114 } | 114 } |
115 | 115 |
116 // ResolvingClientSocketFactory implementation. | 116 // ResolvingClientSocketFactory implementation. |
117 virtual scoped_ptr<net::StreamSocket> CreateTransportClientSocket( | 117 virtual scoped_ptr<net::StreamSocket> CreateTransportClientSocket( |
118 const net::HostPortPair& host_and_port) OVERRIDE { | 118 const net::HostPortPair& host_and_port) override { |
119 return mock_client_socket_factory_->CreateTransportClientSocket( | 119 return mock_client_socket_factory_->CreateTransportClientSocket( |
120 address_list_, NULL, net::NetLog::Source()); | 120 address_list_, NULL, net::NetLog::Source()); |
121 } | 121 } |
122 | 122 |
123 virtual scoped_ptr<net::SSLClientSocket> CreateSSLClientSocket( | 123 virtual scoped_ptr<net::SSLClientSocket> CreateSSLClientSocket( |
124 scoped_ptr<net::ClientSocketHandle> transport_socket, | 124 scoped_ptr<net::ClientSocketHandle> transport_socket, |
125 const net::HostPortPair& host_and_port) OVERRIDE { | 125 const net::HostPortPair& host_and_port) override { |
126 net::SSLClientSocketContext context; | 126 net::SSLClientSocketContext context; |
127 context.cert_verifier = cert_verifier_.get(); | 127 context.cert_verifier = cert_verifier_.get(); |
128 context.transport_security_state = transport_security_state_.get(); | 128 context.transport_security_state = transport_security_state_.get(); |
129 return mock_client_socket_factory_->CreateSSLClientSocket( | 129 return mock_client_socket_factory_->CreateSSLClientSocket( |
130 transport_socket.Pass(), host_and_port, ssl_config_, context); | 130 transport_socket.Pass(), host_and_port, ssl_config_, context); |
131 } | 131 } |
132 | 132 |
133 private: | 133 private: |
134 scoped_ptr<net::ClientSocketFactory> mock_client_socket_factory_; | 134 scoped_ptr<net::ClientSocketFactory> mock_client_socket_factory_; |
135 net::AddressList address_list_; | 135 net::AddressList address_list_; |
(...skipping 947 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1083 message_loop_->RunUntilIdle(); | 1083 message_loop_->RunUntilIdle(); |
1084 | 1084 |
1085 ExpectNoSignal(); | 1085 ExpectNoSignal(); |
1086 | 1086 |
1087 DoSSLCloseOpenedNoError(); | 1087 DoSSLCloseOpenedNoError(); |
1088 } | 1088 } |
1089 | 1089 |
1090 } // namespace | 1090 } // namespace |
1091 | 1091 |
1092 } // namespace jingle_glue | 1092 } // namespace jingle_glue |
OLD | NEW |