| 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);
|
|
|