Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(106)

Side by Side Diff: trunk/src/remoting/protocol/fake_session.cc

Issue 227083002: Revert 261966 "make SetReceiveBufferSize and SetSendBufferSize r..." (Closed) Base URL: svn://svn.chromium.org/chrome/
Patch Set: Created 6 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 "remoting/protocol/fake_session.h" 5 #include "remoting/protocol/fake_session.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/message_loop/message_loop.h" 8 #include "base/message_loop/message_loop.h"
9 #include "net/base/address_list.h" 9 #include "net/base/address_list.h"
10 #include "net/base/io_buffer.h" 10 #include "net/base/io_buffer.h"
(...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after
129 129
130 if (peer_socket_.get()) { 130 if (peer_socket_.get()) {
131 message_loop_->PostTask( 131 message_loop_->PostTask(
132 FROM_HERE, 132 FROM_HERE,
133 base::Bind(&FakeSocket::AppendInputData, 133 base::Bind(&FakeSocket::AppendInputData,
134 peer_socket_, 134 peer_socket_,
135 std::vector<char>(buf->data(), buf->data() + buf_len))); 135 std::vector<char>(buf->data(), buf->data() + buf_len)));
136 } 136 }
137 } 137 }
138 138
139 int FakeSocket::SetReceiveBufferSize(int32 size) { 139 bool FakeSocket::SetReceiveBufferSize(int32 size) {
140 NOTIMPLEMENTED(); 140 NOTIMPLEMENTED();
141 return net::ERR_NOT_IMPLEMENTED; 141 return false;
142 } 142 }
143 143 bool FakeSocket::SetSendBufferSize(int32 size) {
144 int FakeSocket::SetSendBufferSize(int32 size) {
145 NOTIMPLEMENTED(); 144 NOTIMPLEMENTED();
146 return net::ERR_NOT_IMPLEMENTED; 145 return false;
147 } 146 }
148 147
149 int FakeSocket::Connect(const net::CompletionCallback& callback) { 148 int FakeSocket::Connect(const net::CompletionCallback& callback) {
150 EXPECT_EQ(message_loop_, base::MessageLoop::current()); 149 EXPECT_EQ(message_loop_, base::MessageLoop::current());
151 return net::OK; 150 return net::OK;
152 } 151 }
153 152
154 void FakeSocket::Disconnect() { 153 void FakeSocket::Disconnect() {
155 peer_socket_.reset(); 154 peer_socket_.reset();
156 } 155 }
157 156
158 bool FakeSocket::IsConnected() const { 157 bool FakeSocket::IsConnected() const {
159 EXPECT_EQ(message_loop_, base::MessageLoop::current()); 158 EXPECT_EQ(message_loop_, base::MessageLoop::current());
160 return true; 159 return true;
161 } 160 }
162 161
163 bool FakeSocket::IsConnectedAndIdle() const { 162 bool FakeSocket::IsConnectedAndIdle() const {
164 NOTIMPLEMENTED(); 163 NOTIMPLEMENTED();
165 return false; 164 return false;
166 } 165 }
167 166
168 int FakeSocket::GetPeerAddress(net::IPEndPoint* address) const { 167 int FakeSocket::GetPeerAddress(net::IPEndPoint* address) const {
169 net::IPAddressNumber ip(net::kIPv4AddressSize); 168 net::IPAddressNumber ip(net::kIPv4AddressSize);
170 *address = net::IPEndPoint(ip, 0); 169 *address = net::IPEndPoint(ip, 0);
171 return net::OK; 170 return net::OK;
172 } 171 }
173 172
174 int FakeSocket::GetLocalAddress(net::IPEndPoint* address) const { 173 int FakeSocket::GetLocalAddress(net::IPEndPoint* address) const {
175 NOTIMPLEMENTED(); 174 NOTIMPLEMENTED();
176 return net::ERR_NOT_IMPLEMENTED; 175 return net::ERR_FAILED;
177 } 176 }
178 177
179 const net::BoundNetLog& FakeSocket::NetLog() const { 178 const net::BoundNetLog& FakeSocket::NetLog() const {
180 EXPECT_EQ(message_loop_, base::MessageLoop::current()); 179 EXPECT_EQ(message_loop_, base::MessageLoop::current());
181 return net_log_; 180 return net_log_;
182 } 181 }
183 182
184 void FakeSocket::SetSubresourceSpeculation() { 183 void FakeSocket::SetSubresourceSpeculation() {
185 NOTIMPLEMENTED(); 184 NOTIMPLEMENTED();
186 } 185 }
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
257 } 256 }
258 257
259 int FakeUdpSocket::Write(net::IOBuffer* buf, int buf_len, 258 int FakeUdpSocket::Write(net::IOBuffer* buf, int buf_len,
260 const net::CompletionCallback& callback) { 259 const net::CompletionCallback& callback) {
261 EXPECT_EQ(message_loop_, base::MessageLoop::current()); 260 EXPECT_EQ(message_loop_, base::MessageLoop::current());
262 written_packets_.push_back(std::string()); 261 written_packets_.push_back(std::string());
263 written_packets_.back().assign(buf->data(), buf->data() + buf_len); 262 written_packets_.back().assign(buf->data(), buf->data() + buf_len);
264 return buf_len; 263 return buf_len;
265 } 264 }
266 265
267 int FakeUdpSocket::SetReceiveBufferSize(int32 size) { 266 bool FakeUdpSocket::SetReceiveBufferSize(int32 size) {
268 NOTIMPLEMENTED(); 267 NOTIMPLEMENTED();
269 return net::ERR_NOT_IMPLEMENTED; 268 return false;
270 } 269 }
271 270 bool FakeUdpSocket::SetSendBufferSize(int32 size) {
272 int FakeUdpSocket::SetSendBufferSize(int32 size) {
273 NOTIMPLEMENTED(); 271 NOTIMPLEMENTED();
274 return net::ERR_NOT_IMPLEMENTED; 272 return false;
275 } 273 }
276 274
277 FakeSession::FakeSession() 275 FakeSession::FakeSession()
278 : event_handler_(NULL), 276 : event_handler_(NULL),
279 candidate_config_(CandidateSessionConfig::CreateDefault()), 277 candidate_config_(CandidateSessionConfig::CreateDefault()),
280 config_(SessionConfig::ForTest()), 278 config_(SessionConfig::ForTest()),
281 message_loop_(base::MessageLoop::current()), 279 message_loop_(base::MessageLoop::current()),
282 async_creation_(false), 280 async_creation_(false),
283 jid_(kTestJid), 281 jid_(kTestJid),
284 error_(OK), 282 error_(OK),
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after
384 callback.Run(scoped_ptr<net::Socket>(datagram_channels_[name])); 382 callback.Run(scoped_ptr<net::Socket>(datagram_channels_[name]));
385 } 383 }
386 384
387 void FakeSession::CancelChannelCreation(const std::string& name) { 385 void FakeSession::CancelChannelCreation(const std::string& name) {
388 stream_channels_.erase(name); 386 stream_channels_.erase(name);
389 datagram_channels_.erase(name); 387 datagram_channels_.erase(name);
390 } 388 }
391 389
392 } // namespace protocol 390 } // namespace protocol
393 } // namespace remoting 391 } // namespace remoting
OLDNEW
« no previous file with comments | « trunk/src/remoting/protocol/fake_session.h ('k') | trunk/src/tools/metrics/histograms/histograms.xml » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698