Index: remoting/protocol/fake_session.cc |
diff --git a/remoting/protocol/fake_session.cc b/remoting/protocol/fake_session.cc |
index b23dbb1dc299b82bb6f31e937e80d99ae5d27b8e..a2496a7a674efd4c58e0a09207348cc2604561c7 100644 |
--- a/remoting/protocol/fake_session.cc |
+++ b/remoting/protocol/fake_session.cc |
@@ -70,6 +70,67 @@ bool FakeSocket::SetSendBufferSize(int32 size) { |
return false; |
} |
+int FakeSocket::Connect(net::CompletionCallback* callback) { |
+ return net::OK; |
+} |
+ |
+void FakeSocket::Disconnect() { |
+ NOTIMPLEMENTED(); |
+} |
+ |
+bool FakeSocket::IsConnected() const { |
+ return true; |
+} |
+ |
+bool FakeSocket::IsConnectedAndIdle() const { |
+ NOTIMPLEMENTED(); |
+ return false; |
+} |
+ |
+int FakeSocket::GetPeerAddress( |
+ net::AddressList* address) const { |
+ NOTIMPLEMENTED(); |
+ return net::ERR_FAILED; |
+} |
+ |
+int FakeSocket::GetLocalAddress( |
+ net::IPEndPoint* address) const { |
+ NOTIMPLEMENTED(); |
+ return net::ERR_FAILED; |
+} |
+ |
+const net::BoundNetLog& FakeSocket::NetLog() const { |
+ return net_log_; |
+} |
+ |
+void FakeSocket::SetSubresourceSpeculation() { |
+ NOTIMPLEMENTED(); |
+} |
+ |
+void FakeSocket::SetOmniboxSpeculation() { |
+ NOTIMPLEMENTED(); |
+} |
+ |
+bool FakeSocket::WasEverUsed() const { |
+ NOTIMPLEMENTED(); |
+ return true; |
+} |
+ |
+bool FakeSocket::UsingTCPFastOpen() const { |
+ NOTIMPLEMENTED(); |
+ return true; |
+} |
+ |
+int64 FakeSocket::NumBytesRead() const { |
+ NOTIMPLEMENTED(); |
+ return 0; |
+} |
+ |
+base::TimeDelta FakeSocket::GetConnectTimeMicros() const { |
+ NOTIMPLEMENTED(); |
+ return base::TimeDelta(); |
+} |
+ |
FakeUdpSocket::FakeUdpSocket() |
: read_pending_(false), |
input_pos_(0) { |
@@ -135,21 +196,31 @@ FakeSession::FakeSession() |
FakeSession::~FakeSession() { } |
-void FakeSession::SetStateChangeCallback( |
- StateChangeCallback* callback) { |
+FakeSocket* FakeSession::GetStreamChannel(const std::string& name) { |
+ return stream_channels_[name]; |
+} |
+ |
+FakeUdpSocket* FakeSession::GetDatagramChannel(const std::string& name) { |
+ return datagram_channels_[name]; |
+} |
+ |
+void FakeSession::SetStateChangeCallback(StateChangeCallback* callback) { |
callback_.reset(callback); |
} |
void FakeSession::CreateStreamChannel( |
const std::string& name, const StreamChannelCallback& callback) { |
- NOTIMPLEMENTED(); |
- callback.Run(name, NULL); |
+ LOG(ERROR) << " creating channel " << name; |
+ FakeSocket* channel = new FakeSocket(); |
+ stream_channels_[name] = channel; |
+ callback.Run(name, channel); |
} |
void FakeSession::CreateDatagramChannel( |
const std::string& name, const DatagramChannelCallback& callback) { |
- NOTIMPLEMENTED(); |
- callback.Run(name, NULL); |
+ FakeUdpSocket* channel = new FakeUdpSocket(); |
+ datagram_channels_[name] = channel; |
+ callback.Run(name, channel); |
} |
FakeSocket* FakeSession::control_channel() { |
@@ -160,18 +231,6 @@ FakeSocket* FakeSession::event_channel() { |
return &event_channel_; |
} |
-FakeSocket* FakeSession::video_channel() { |
- return &video_channel_; |
-} |
- |
-FakeUdpSocket* FakeSession::video_rtp_channel() { |
- return &video_rtp_channel_; |
-} |
- |
-FakeUdpSocket* FakeSession::video_rtcp_channel() { |
- return &video_rtcp_channel_; |
-} |
- |
const std::string& FakeSession::jid() { |
return jid_; |
} |