| /external/webrtc/webrtc/libjingle/xmpp/ |
| receivetask.cc | 16 bool ReceiveTask::HandleStanza(const XmlElement* stanza) {
17 if (WantsStanza(stanza)) {
18 QueueStanza(stanza);
26 const XmlElement* stanza = NextStanza(); local
27 if (stanza == NULL)
30 ReceiveStanza(stanza);
|
| presencereceivetask.h | 41 virtual bool HandleStanza(const XmlElement * stanza);
46 void HandlePresence(const Jid& from, const XmlElement * stanza);
48 // Extracts presence information for the presence stanza sent form the
50 static void DecodeStatus(const Jid& from, const XmlElement * stanza,
|
| receivetask.h | 19 // indicate that a stanza should be received and ReceiveStanza to
31 virtual bool HandleStanza(const XmlElement* stanza);
33 // Return true if the stanza should be received.
34 virtual bool WantsStanza(const XmlElement* stanza) = 0;
35 // Process the received stanza.
36 virtual void ReceiveStanza(const XmlElement* stanza) = 0;
|
| iqtask.cc | 37 bool IqTask::HandleStanza(const buzz::XmlElement* stanza) {
38 if (!MatchResponseIq(stanza, to_, task_id()))
41 if (stanza->Attr(buzz::QN_TYPE) != buzz::STR_RESULT &&
42 stanza->Attr(buzz::QN_TYPE) != buzz::STR_ERROR) {
46 QueueStanza(stanza);
51 const buzz::XmlElement* stanza = NextStanza(); local
52 if (stanza == NULL)
55 bool success = (stanza->Attr(buzz::QN_TYPE) == buzz::STR_RESULT);
57 HandleResult(stanza);
59 SignalError(this, stanza->FirstNamed(QN_ERROR))
[all...] |
| pingtask.cc | 32 bool PingTask::HandleStanza(const buzz::XmlElement* stanza) {
33 if (!MatchResponseIq(stanza, Jid(STR_EMPTY), task_id())) {
37 if (stanza->Attr(buzz::QN_TYPE) != buzz::STR_RESULT &&
38 stanza->Attr(buzz::QN_TYPE) != buzz::STR_ERROR) {
42 QueueStanza(stanza);
53 const buzz::XmlElement* stanza = NextStanza(); local
54 if (stanza != NULL) {
69 rtc::scoped_ptr<buzz::XmlElement> stanza(
71 stanza->AddElement(new buzz::XmlElement(QN_PING));
72 SendStanza(stanza.get())
[all...] |
| presencereceivetask.cc | 32 const XmlElement * stanza = NextStanza(); local
33 if (stanza == NULL) {
37 Jid from(stanza->Attr(QN_FROM));
38 HandlePresence(from, stanza);
43 bool PresenceReceiveTask::HandleStanza(const XmlElement * stanza) {
45 if (stanza->Name() != QN_PRESENCE) {
50 QueueStanza(stanza);
56 const XmlElement* stanza) {
57 if (stanza->Attr(QN_TYPE) == STR_ERROR) {
62 DecodeStatus(from, stanza, &status)
[all...] |
| mucroomuniquehangoutidtask.cc | 22 // Construct a stanza to request a unique room id. eg:
37 void MucRoomUniqueHangoutIdTask::HandleResult(const XmlElement* stanza) {
39 const XmlElement* unique_elem = stanza->FirstNamed(QN_MUC_UNIQUE_QUERY);
42 SignalError(this, stanza);
|
| jingleinfotask.cc | 42 virtual bool HandleStanza(const XmlElement * stanza) {
43 if (!MatchResponseIq(stanza, Jid(), task_id()))
46 if (stanza->Attr(QN_TYPE) != STR_RESULT)
49 // Queue the stanza with the parent so these don't get handled out of order
51 parent->QueueStanza(stanza);
69 JingleInfoTask::HandleStanza(const XmlElement * stanza) {
70 if (!MatchRequestIq(stanza, "set", QN_JINGLE_INFO_QUERY))
74 Jid from(stanza->Attr(QN_FROM));
80 QueueStanza(stanza);
89 const XmlElement * stanza = NextStanza() local
[all...] |
| iqtask.h | 28 const XmlElement* stanza() const { return stanza_.get(); } function in class:buzz::IqTask
38 virtual bool HandleStanza(const XmlElement* stanza);
|
| fakexmppclient.h | 55 virtual XmppReturnStatus SendStanza(const XmlElement* stanza) {
56 sent_stanzas_.push_back(stanza);
86 // Takes ownership of stanza.
87 void HandleStanza(XmlElement* stanza) {
90 if ((*task)->HandleStanza(stanza)) {
91 delete stanza;
95 delete stanza;
|
| xmpptask.cc | 49 XmppReturnStatus XmppTask::SendStanza(const XmlElement* stanza) {
52 return GetClient()->SendStanza(stanza);
72 void XmppTask::QueueStanza(const XmlElement* stanza) {
78 stanza_queue_.push_back(new XmlElement(*stanza));
115 bool XmppTask::MatchResponseIq(const XmlElement* stanza,
118 if (stanza->Name() != QN_IQ)
121 if (stanza->Attr(QN_ID) != id)
124 return MatchStanzaFrom(stanza, to);
127 bool XmppTask::MatchStanzaFrom(const XmlElement* stanza,
129 Jid from(stanza->Attr(QN_FROM))
[all...] |
| pubsub_task.cc | 32 bool PubsubTask::HandleStanza(const buzz::XmlElement* stanza) {
33 const buzz::QName& stanza_name(stanza->Name());
35 if (MatchStanzaFrom(stanza, pubsub_node_jid_)) {
37 stanza->FirstNamed(QN_PUBSUB_EVENT);
44 if (MatchResponseIq(stanza, pubsub_node_jid_, task_id())) {
45 const buzz::XmlElement* pubsub_item = stanza->FirstNamed(QN_PUBSUB);
56 const buzz::XmlElement* stanza = NextStanza(); local
57 if (stanza == NULL) {
61 if (stanza->Attr(buzz::QN_TYPE) == buzz::STR_ERROR) {
62 OnPubsubError(stanza->FirstNamed(buzz::QN_ERROR))
[all...] |
| pubsubtasks.h | 25 // The entire <item>, owned by the stanza handler. To keep a
42 virtual void HandleResult(const XmlElement* stanza);
62 virtual bool WantsStanza(const XmlElement* stanza);
63 virtual void ReceiveStanza(const XmlElement* stanza);
87 virtual void HandleResult(const XmlElement* stanza);
107 virtual void HandleResult(const XmlElement* stanza);
|
| moduleimpl.h | 36 //! Process the given stanza.
37 //! The module must return true if it has handled the stanza.
38 //! A false return value causes the stanza to be passed on to
53 bool HandleStanza(const XmlElement* stanza) {
54 return module_->HandleStanza(stanza);
|
| mucroomuniquehangoutidtask.h | 29 virtual void HandleResult(const buzz::XmlElement* stanza);
|
| pubsubtasks.cc | 26 bool IsPubSubEventItemsElem(const XmlElement* stanza,
28 if (stanza->Name() != QN_MESSAGE) {
32 const XmlElement* event_elem = stanza->FirstNamed(QN_PUBSUB_EVENT);
107 void ParseEventItemsElem(const XmlElement* stanza,
109 const XmlElement* event_elem = stanza->FirstNamed(QN_PUBSUB_EVENT);
130 void ParsePubSubItemsElem(const XmlElement* stanza,
132 const XmlElement* pubsub_elem = stanza->FirstNamed(QN_PUBSUB);
153 void PubSubRequestTask::HandleResult(const XmlElement* stanza) {
155 ParsePubSubItemsElem(stanza, &items);
166 bool PubSubReceiveTask::WantsStanza(const XmlElement* stanza) {
[all...] |
| xmpptask.h | 38 // right away, they should decide if they own the sent stanza,
39 // and if so, queue it and Wake() the task, or if a stanza does not belong
43 // for example, disconnect a client while processing a stanza -
62 virtual XmppReturnStatus SendStanza(const XmlElement* stanza) = 0;
126 virtual bool HandleStanza(const XmlElement* stanza) { return false; }
129 XmppReturnStatus SendStanza(const XmlElement* stanza);
138 virtual void QueueStanza(const XmlElement* stanza);
141 bool MatchStanzaFrom(const XmlElement* stanza, const Jid& match_jid);
143 bool MatchResponseIq(const XmlElement* stanza, const Jid& to,
146 static bool MatchRequestIq(const XmlElement* stanza, const std::string& type
[all...] |
| pubsubclient.cc | 74 const XmlElement* stanza) {
75 SignalRequestError(this, stanza);
83 const XmlElement* GetItemFromStanza(const XmlElement* stanza) {
84 if (stanza != NULL) {
85 const XmlElement* pubsub = stanza->FirstNamed(QN_PUBSUB);
97 const XmlElement* item = GetItemFromStanza(task->stanza());
105 const XmlElement* item = GetItemFromStanza(publish_task->stanza());
114 const XmlElement* stanza) {
117 SignalRetractError(this, retract_task->task_id(), stanza);
|
| jingleinfotask.h | 40 virtual bool HandleStanza(const XmlElement * stanza);
|
| mucroomconfigtask.h | 37 virtual void HandleResult(const XmlElement* stanza);
|
| mucroomdiscoverytask.h | 36 virtual void HandleResult(const XmlElement* stanza);
|
| pingtask_unittest.cc | 30 buzz::XmppReturnStatus SendStanza(const buzz::XmlElement* stanza);
66 const buzz::XmlElement* stanza) {
67 buzz::XmppReturnStatus result = FakeXmppClient::SendStanza(stanza);
68 if (test->respond_to_pings && (stanza->FirstNamed(buzz::QN_PING) != NULL)) {
|
| xmppengineimpl.h | 113 //! The stream:error stanza, when the error is XmppEngine::ERROR_STREAM.
114 //! Notice the stanza returned is owned by the XmppEngine and
127 //! Stanza delivery is chained to session handlers; the first to
128 //! return 'true' is the last to get each stanza.
135 //! Sends a stanza to the server.
136 virtual XmppReturnStatus SendStanza(const XmlElement* stanza);
143 virtual XmppReturnStatus SendIq(const XmlElement* stanza,
152 //! Forms and sends an error in response to the given stanza.
173 void IncomingStanza(const XmlElement *stanza);
174 void IncomingStart(const XmlElement *stanza);
[all...] |
| hangoutpubsubclient.cc | 190 PubSubClient* client, const XmlElement* stanza) {
191 SignalRequestError(client->node(), stanza);
195 PubSubClient* client, const XmlElement* stanza) {
196 SignalRequestError(client->node(), stanza);
250 const XmlElement* stanza) {
251 SignalPublishPresenterError(task_id, stanza);
312 const XmlElement* stanza) {
315 SignalRemoteMuteError(task_id, mutee_nick, stanza);
317 SignalPublishAudioMuteError(task_id, stanza);
334 const XmlElement* stanza) {
[all...] |
| /external/libweave/src/notification/ |
| xmpp_channel.cc | 145 void XmppChannel::OnStanza(std::unique_ptr<XmlNode> stanza) {
146 // Handle stanza asynchronously, since XmppChannel::OnStanza() is a callback
147 // from expat XML parser and some stanza could cause the XMPP stream to be
153 base::Passed(std::move(stanza))),
157 void XmppChannel::HandleStanza(std::unique_ptr<XmlNode> stanza) {
158 VLOG(2) << "XMPP stanza received: " << stanza->ToString();
162 if (stanza->name() == "stream:features") {
163 auto children = stanza->FindChildren("mechanisms/mechanism", false);
174 if (stanza->name() == "success")
[all...] |
