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
3 // found in the LICENSE file.
5 #include "remoting/jingle_glue/fake_signal_strategy.h"
8 #include "base/location.h"
9 #include "base/logging.h"
10 #include "base/single_thread_task_runner.h"
11 #include "base/stl_util.h"
12 #include "base/strings/string_number_conversions.h"
13 #include "base/thread_task_runner_handle.h"
14 #include "third_party/libjingle/source/talk/xmllite/xmlelement.h"
15 #include "third_party/libjingle/source/talk/xmpp/constants.h"
20 void FakeSignalStrategy::Connect(FakeSignalStrategy* peer1,
21 FakeSignalStrategy* peer2) {
26 FakeSignalStrategy::FakeSignalStrategy(const std::string& jid)
34 FakeSignalStrategy::~FakeSignalStrategy() {
35 while (!received_messages_.empty()) {
36 delete received_messages_.front();
37 received_messages_.pop_front();
41 void FakeSignalStrategy::Connect() {
42 DCHECK(CalledOnValidThread());
43 FOR_EACH_OBSERVER(Listener, listeners_,
44 OnSignalStrategyStateChange(CONNECTED));
47 void FakeSignalStrategy::Disconnect() {
48 DCHECK(CalledOnValidThread());
49 FOR_EACH_OBSERVER(Listener, listeners_,
50 OnSignalStrategyStateChange(DISCONNECTED));
53 SignalStrategy::State FakeSignalStrategy::GetState() const {
57 SignalStrategy::Error FakeSignalStrategy::GetError() const {
61 std::string FakeSignalStrategy::GetLocalJid() const {
62 DCHECK(CalledOnValidThread());
66 void FakeSignalStrategy::AddListener(Listener* listener) {
67 DCHECK(CalledOnValidThread());
68 listeners_.AddObserver(listener);
71 void FakeSignalStrategy::RemoveListener(Listener* listener) {
72 DCHECK(CalledOnValidThread());
73 listeners_.RemoveObserver(listener);
76 bool FakeSignalStrategy::SendStanza(scoped_ptr<buzz::XmlElement> stanza) {
77 DCHECK(CalledOnValidThread());
79 stanza->SetAttr(buzz::QN_FROM, jid_);
82 peer_->OnIncomingMessage(stanza.Pass());
89 std::string FakeSignalStrategy::GetNextId() {
91 return base::IntToString(last_id_);
94 void FakeSignalStrategy::OnIncomingMessage(
95 scoped_ptr<buzz::XmlElement> stanza) {
96 pending_messages_.push(stanza.get());
97 received_messages_.push_back(stanza.release());
98 base::ThreadTaskRunnerHandle::Get()->PostTask(
99 FROM_HERE, base::Bind(&FakeSignalStrategy::DeliverIncomingMessages,
100 weak_factory_.GetWeakPtr()));
103 void FakeSignalStrategy::DeliverIncomingMessages() {
104 while (!pending_messages_.empty()) {
105 buzz::XmlElement* stanza = pending_messages_.front();
106 const std::string& to_field = stanza->Attr(buzz::QN_TO);
107 if (to_field != jid_) {
108 LOG(WARNING) << "Dropping stanza that is addressed to " << to_field
109 << ". Local jid: " << jid_
110 << ". Message content: " << stanza->Str();
114 ObserverListBase<Listener>::Iterator it(listeners_);
116 while ((listener = it.GetNext()) != NULL) {
117 if (listener->OnSignalStrategyIncomingStanza(stanza))
121 pending_messages_.pop();
125 } // namespace remoting