Index: remoting/protocol/fake_session.cc |
diff --git a/remoting/protocol/fake_session.cc b/remoting/protocol/fake_session.cc |
index f1a890a22bec774dfc058747cb0599db0354b00a..c43b86368b8626cf4ff3fedcbf60efb7d22bab56 100644 |
--- a/remoting/protocol/fake_session.cc |
+++ b/remoting/protocol/fake_session.cc |
@@ -36,32 +36,12 @@ void FakeSocket::AppendInputData(const char* data, int data_size) { |
memcpy(read_buffer_->data(), |
&(*input_data_.begin()) + input_pos_, result); |
input_pos_ += result; |
- if (old_read_callback_) |
- old_read_callback_->Run(result); |
- else |
- read_callback_.Run(result); |
+ read_callback_.Run(result); |
read_buffer_ = NULL; |
} |
} |
int FakeSocket::Read(net::IOBuffer* buf, int buf_len, |
- net::OldCompletionCallback* callback) { |
- EXPECT_EQ(message_loop_, MessageLoop::current()); |
- if (input_pos_ < static_cast<int>(input_data_.size())) { |
- int result = std::min(buf_len, |
- static_cast<int>(input_data_.size()) - input_pos_); |
- memcpy(buf->data(), &(*input_data_.begin()) + input_pos_, result); |
- input_pos_ += result; |
- return result; |
- } else { |
- read_pending_ = true; |
- read_buffer_ = buf; |
- read_buffer_size_ = buf_len; |
- old_read_callback_ = callback; |
- return net::ERR_IO_PENDING; |
- } |
-} |
-int FakeSocket::Read(net::IOBuffer* buf, int buf_len, |
const net::CompletionCallback& callback) { |
EXPECT_EQ(message_loop_, MessageLoop::current()); |
if (input_pos_ < static_cast<int>(input_data_.size())) { |
@@ -80,7 +60,7 @@ int FakeSocket::Read(net::IOBuffer* buf, int buf_len, |
} |
int FakeSocket::Write(net::IOBuffer* buf, int buf_len, |
- net::OldCompletionCallback* callback) { |
+ const net::CompletionCallback& callback) { |
EXPECT_EQ(message_loop_, MessageLoop::current()); |
written_data_.insert(written_data_.end(), |
buf->data(), buf->data() + buf_len); |
@@ -96,10 +76,6 @@ bool FakeSocket::SetSendBufferSize(int32 size) { |
return false; |
} |
-int FakeSocket::Connect(net::OldCompletionCallback* callback) { |
- EXPECT_EQ(message_loop_, MessageLoop::current()); |
- return net::OK; |
-} |
int FakeSocket::Connect(const net::CompletionCallback& callback) { |
EXPECT_EQ(message_loop_, MessageLoop::current()); |
return net::OK; |
@@ -166,7 +142,6 @@ base::TimeDelta FakeSocket::GetConnectTimeMicros() const { |
FakeUdpSocket::FakeUdpSocket() |
: read_pending_(false), |
- old_read_callback_(NULL), |
input_pos_(0), |
message_loop_(MessageLoop::current()) { |
} |
@@ -186,32 +161,12 @@ void FakeUdpSocket::AppendInputPacket(const char* data, int data_size) { |
int result = std::min(data_size, read_buffer_size_); |
memcpy(read_buffer_->data(), data, result); |
input_pos_ = input_packets_.size(); |
- if (old_read_callback_) |
- old_read_callback_->Run(result); |
- else |
- old_read_callback_->Run(result); |
+ read_callback_.Run(result); |
read_buffer_ = NULL; |
} |
} |
int FakeUdpSocket::Read(net::IOBuffer* buf, int buf_len, |
- net::OldCompletionCallback* callback) { |
- EXPECT_EQ(message_loop_, MessageLoop::current()); |
- if (input_pos_ < static_cast<int>(input_packets_.size())) { |
- int result = std::min( |
- buf_len, static_cast<int>(input_packets_[input_pos_].size())); |
- memcpy(buf->data(), &(*input_packets_[input_pos_].begin()), result); |
- ++input_pos_; |
- return result; |
- } else { |
- read_pending_ = true; |
- read_buffer_ = buf; |
- read_buffer_size_ = buf_len; |
- old_read_callback_ = callback; |
- return net::ERR_IO_PENDING; |
- } |
-} |
-int FakeUdpSocket::Read(net::IOBuffer* buf, int buf_len, |
const net::CompletionCallback& callback) { |
EXPECT_EQ(message_loop_, MessageLoop::current()); |
if (input_pos_ < static_cast<int>(input_packets_.size())) { |
@@ -230,7 +185,7 @@ int FakeUdpSocket::Read(net::IOBuffer* buf, int buf_len, |
} |
int FakeUdpSocket::Write(net::IOBuffer* buf, int buf_len, |
- net::OldCompletionCallback* callback) { |
+ const net::CompletionCallback& callback) { |
EXPECT_EQ(message_loop_, MessageLoop::current()); |
written_packets_.push_back(std::string()); |
written_packets_.back().assign(buf->data(), buf->data() + buf_len); |