Index: remoting/protocol/session_manager_pair.cc |
diff --git a/remoting/protocol/session_manager_pair.cc b/remoting/protocol/session_manager_pair.cc |
deleted file mode 100644 |
index ab776cd5b2141d652311983d544f29a7713e97d2..0000000000000000000000000000000000000000 |
--- a/remoting/protocol/session_manager_pair.cc |
+++ /dev/null |
@@ -1,97 +0,0 @@ |
-// Copyright (c) 2010 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "remoting/protocol/session_manager_pair.h" |
- |
-#include "base/logging.h" |
-#include "remoting/jingle_glue/jingle_thread.h" |
-#include "third_party/libjingle/source/talk/base/network.h" |
-#include "third_party/libjingle/source/talk/base/basicpacketsocketfactory.h" |
-#include "third_party/libjingle/source/talk/p2p/base/sessionmanager.h" |
-#include "third_party/libjingle/source/talk/p2p/client/basicportallocator.h" |
-#include "third_party/libjingle/source/talk/xmllite/xmlelement.h" |
- |
-namespace remoting { |
- |
-const char SessionManagerPair::kHostJid[] = "host1@gmail.com/123"; |
-const char SessionManagerPair::kClientJid[] = "host2@gmail.com/321"; |
- |
-SessionManagerPair::SessionManagerPair(JingleThread* thread) |
- : message_loop_(thread->message_loop()) { |
-} |
- |
-SessionManagerPair::~SessionManagerPair() {} |
- |
-void SessionManagerPair::Init() { |
- DCHECK_EQ(message_loop_, MessageLoop::current()); |
- |
- network_manager_.reset(new talk_base::NetworkManager()); |
- socket_factory_.reset(new talk_base::BasicPacketSocketFactory( |
- talk_base::Thread::Current())); |
- |
- cricket::BasicPortAllocator* port_allocator = |
- new cricket::BasicPortAllocator(network_manager_.get(), |
- socket_factory_.get()); |
- port_allocator_.reset(port_allocator); |
- |
- host_session_manager_.reset(new cricket::SessionManager(port_allocator)); |
- host_session_manager_->SignalOutgoingMessage.connect( |
- this, &SessionManagerPair::ProcessMessage); |
- host_session_manager_->SignalRequestSignaling.connect( |
- host_session_manager_.get(), &cricket::SessionManager::OnSignalingReady); |
- |
- client_session_manager_.reset(new cricket::SessionManager(port_allocator)); |
- client_session_manager_->SignalOutgoingMessage.connect( |
- this, &SessionManagerPair::ProcessMessage); |
- client_session_manager_->SignalRequestSignaling.connect( |
- client_session_manager_.get(), |
- &cricket::SessionManager::OnSignalingReady); |
-} |
- |
-cricket::SessionManager* SessionManagerPair::host_session_manager() { |
- return host_session_manager_.get(); |
-} |
- |
-cricket::SessionManager* SessionManagerPair::client_session_manager() { |
- return client_session_manager_.get(); |
-} |
- |
-void SessionManagerPair::ProcessMessage(cricket::SessionManager* manager, |
- const buzz::XmlElement* stanza) { |
- message_loop_->PostTask( |
- FROM_HERE, NewRunnableMethod(this, &SessionManagerPair::DoProcessMessage, |
- manager, new buzz::XmlElement(*stanza))); |
-} |
- |
-void SessionManagerPair::DoProcessMessage(cricket::SessionManager* manager, |
- buzz::XmlElement* stanza) { |
- DCHECK_EQ(message_loop_, MessageLoop::current()); |
- DCHECK(manager == host_session_manager_.get() || |
- manager == client_session_manager_.get()); |
- buzz::QName from_attr("", "from"); |
- buzz::QName to_attr("", "to"); |
- std::string to = stanza->Attr(to_attr); |
- if (to == kHostJid) { |
- DCHECK(manager == client_session_manager_.get()); |
- stanza->SetAttr(from_attr, kClientJid); |
- DeliverMessage(host_session_manager_.get(), stanza); |
- } else if (to == kClientJid) { |
- DCHECK(manager == host_session_manager_.get()); |
- stanza->SetAttr(from_attr, kHostJid); |
- DeliverMessage(client_session_manager_.get(), stanza); |
- } else { |
- LOG(ERROR) << "Dropping stanza sent to unknown jid " << to; |
- } |
- delete stanza; |
-} |
- |
-void SessionManagerPair::DeliverMessage(cricket::SessionManager* to, |
- buzz::XmlElement* stanza) { |
- if (to->IsSessionMessage(stanza)) { |
- to->OnIncomingMessage(stanza); |
- } |
-} |
- |
- |
-} // namespace remoting |