Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(94)

Side by Side Diff: remoting/jingle_glue/log_to_server.cc

Issue 390983003: Remove remoting/jingle_glue (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « remoting/jingle_glue/log_to_server.h ('k') | remoting/jingle_glue/log_to_server_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright 2014 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.
4
5 #include "remoting/jingle_glue/log_to_server.h"
6
7 #include "remoting/base/constants.h"
8 #include "remoting/jingle_glue/iq_sender.h"
9 #include "remoting/jingle_glue/signal_strategy.h"
10 #include "third_party/libjingle/source/talk/xmllite/xmlelement.h"
11 #include "third_party/libjingle/source/talk/xmpp/constants.h"
12
13 using buzz::QName;
14 using buzz::XmlElement;
15
16 namespace remoting {
17
18 LogToServer::LogToServer(ServerLogEntry::Mode mode,
19 SignalStrategy* signal_strategy,
20 const std::string& directory_bot_jid)
21 : mode_(mode),
22 signal_strategy_(signal_strategy),
23 directory_bot_jid_(directory_bot_jid) {
24 signal_strategy_->AddListener(this);
25 }
26
27 LogToServer::~LogToServer() {
28 signal_strategy_->RemoveListener(this);
29 }
30
31 void LogToServer::OnSignalStrategyStateChange(SignalStrategy::State state) {
32 DCHECK(CalledOnValidThread());
33
34 if (state == SignalStrategy::CONNECTED) {
35 iq_sender_.reset(new IqSender(signal_strategy_));
36 SendPendingEntries();
37 } else if (state == SignalStrategy::DISCONNECTED) {
38 iq_sender_.reset();
39 }
40 }
41
42 bool LogToServer::OnSignalStrategyIncomingStanza(
43 const buzz::XmlElement* stanza) {
44 return false;
45 }
46
47 void LogToServer::Log(const ServerLogEntry& entry) {
48 pending_entries_.push_back(entry);
49 SendPendingEntries();
50 }
51
52 void LogToServer::SendPendingEntries() {
53 if (iq_sender_ == NULL) {
54 return;
55 }
56 if (pending_entries_.empty()) {
57 return;
58 }
59 // Make one stanza containing all the pending entries.
60 scoped_ptr<XmlElement> stanza(ServerLogEntry::MakeStanza());
61 while (!pending_entries_.empty()) {
62 ServerLogEntry& entry = pending_entries_.front();
63 stanza->AddElement(entry.ToStanza().release());
64 pending_entries_.pop_front();
65 }
66 // Send the stanza to the server.
67 scoped_ptr<IqRequest> req = iq_sender_->SendIq(
68 buzz::STR_SET, directory_bot_jid_, stanza.Pass(),
69 IqSender::ReplyCallback());
70 // We ignore any response, so let the IqRequest be destroyed.
71 return;
72 }
73
74 } // namespace remoting
OLDNEW
« no previous file with comments | « remoting/jingle_glue/log_to_server.h ('k') | remoting/jingle_glue/log_to_server_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698