| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | mucroomconfigtask.cc | 19 namespace buzz { namespace
34 buzz::XmlElement* owner_query = new in MakeRequest()
35 buzz::XmlElement(buzz::QN_MUC_OWNER_QUERY, true); in MakeRequest()
37 buzz::XmlElement* x_form = new buzz::XmlElement(buzz::QN_XDATA_X, true); in MakeRequest()
38 x_form->SetAttr(buzz::QN_TYPE, buzz::STR_FORM); in MakeRequest()
40 buzz::XmlElement* roomname_field = in MakeRequest()
41 new buzz::XmlElement(buzz::QN_XDATA_FIELD, false); in MakeRequest()
42 roomname_field->SetAttr(buzz::QN_VAR, buzz::STR_MUC_ROOMCONFIG_ROOMNAME); in MakeRequest()
43 roomname_field->SetAttr(buzz::QN_TYPE, buzz::STR_TEXT_SINGLE); in MakeRequest()
45 buzz::XmlElement* roomname_value = in MakeRequest()
[all …]
|
| D | pubsub_task.cc | 20 namespace buzz { namespace
23 const buzz::Jid& pubsub_node_jid) in PubsubTask()
24 : buzz::XmppTask(parent, buzz::XmppEngine::HL_SENDER), in PubsubTask()
32 bool PubsubTask::HandleStanza(const buzz::XmlElement* stanza) { in HandleStanza()
33 const buzz::QName& stanza_name(stanza->Name()); in HandleStanza()
34 if (stanza_name == buzz::QN_MESSAGE) { in HandleStanza()
36 const buzz::XmlElement* pubsub_event_item = in HandleStanza()
43 } else if (stanza_name == buzz::QN_IQ) { in HandleStanza()
45 const buzz::XmlElement* pubsub_item = stanza->FirstNamed(QN_PUBSUB); in HandleStanza()
56 const buzz::XmlElement* stanza = NextStanza(); in ProcessResponse()
[all …]
|
| D | pubsubtasks_unittest.cc | 33 void OnReceiveUpdate(buzz::PubSubReceiveTask* task, in OnReceiveUpdate()
34 const std::vector<buzz::PubSubItem>& items) { in OnReceiveUpdate()
38 void OnRequestResult(buzz::PubSubRequestTask* task, in OnRequestResult()
39 const std::vector<buzz::PubSubItem>& items) { in OnRequestResult()
43 void OnItems(const std::vector<buzz::PubSubItem>& items) { in OnItems()
44 for (std::vector<buzz::PubSubItem>::const_iterator item = items.begin(); in OnItems()
55 void OnPublishResult(buzz::PubSubPublishTask* task) { in OnPublishResult()
59 void OnRetractResult(buzz::PubSubRetractTask* task) { in OnRetractResult()
63 void OnError(buzz::IqTask* task, const buzz::XmlElement* stanza) { in OnError()
79 client = new buzz::FakeXmppClient(runner.get()); in PubSubTasksTest()
[all …]
|
| D | xmppauth.cc | 25 void XmppAuth::StartPreXmppAuth(const buzz::Jid& jid, in StartPreXmppAuth()
48 if (GetAuthMechanism() == buzz::AUTH_MECHANISM_OAUTH2 && in ChooseBestSaslMechanism()
49 contains(mechanisms, buzz::AUTH_MECHANISM_OAUTH2)) { in ChooseBestSaslMechanism()
50 return buzz::AUTH_MECHANISM_OAUTH2; in ChooseBestSaslMechanism()
54 if (GetAuthMechanism() == buzz::AUTH_MECHANISM_GOOGLE_TOKEN && in ChooseBestSaslMechanism()
55 contains(mechanisms, buzz::AUTH_MECHANISM_GOOGLE_TOKEN)) { in ChooseBestSaslMechanism()
56 return buzz::AUTH_MECHANISM_GOOGLE_TOKEN; in ChooseBestSaslMechanism()
60 if (GetAuthMechanism() == buzz::AUTH_MECHANISM_GOOGLE_COOKIE && in ChooseBestSaslMechanism()
61 contains(mechanisms, buzz::AUTH_MECHANISM_GOOGLE_COOKIE)) { in ChooseBestSaslMechanism()
62 return buzz::AUTH_MECHANISM_GOOGLE_COOKIE; in ChooseBestSaslMechanism()
[all …]
|
| D | pubsubclient_unittest.cc | 32 void OnItems(buzz::PubSubClient*, in OnItems()
33 const std::vector<buzz::PubSubItem>& items) { in OnItems()
34 for (std::vector<buzz::PubSubItem>::const_iterator item = items.begin(); in OnItems()
45 void OnRequestError(buzz::PubSubClient* client, in OnRequestError()
46 const buzz::XmlElement* stanza) { in OnRequestError()
50 void OnPublishResult(buzz::PubSubClient* client, in OnPublishResult()
52 const buzz::XmlElement* item) { in OnPublishResult()
56 void OnPublishError(buzz::PubSubClient* client, in OnPublishError()
58 const buzz::XmlElement* item, in OnPublishError()
59 const buzz::XmlElement* stanza) { in OnPublishError()
[all …]
|
| D | iqtask.cc | 16 namespace buzz { namespace
22 const buzz::Jid& to, in IqTask()
23 buzz::XmlElement* el) in IqTask()
24 : buzz::XmppTask(parent, buzz::XmppEngine::HL_SINGLE), in IqTask()
32 buzz::XmppReturnStatus ret = SendStanza(stanza_.get()); in ProcessStart()
34 return (ret == buzz::XMPP_RETURN_OK) ? STATE_RESPONSE : STATE_ERROR; in ProcessStart()
37 bool IqTask::HandleStanza(const buzz::XmlElement* stanza) { in HandleStanza()
41 if (stanza->Attr(buzz::QN_TYPE) != buzz::STR_RESULT && in HandleStanza()
42 stanza->Attr(buzz::QN_TYPE) != buzz::STR_ERROR) { in HandleStanza()
51 const buzz::XmlElement* stanza = NextStanza(); in ProcessResponse()
[all …]
|
| D | xmpppump.h | 22 namespace buzz {
29 virtual void OnStateChange(buzz::XmppEngine::State state) = 0;
34 XmppPump(buzz::XmppPumpNotify * notify = NULL);
36 buzz::XmppClient *client() { return client_; } in client()
38 void DoLogin(const buzz::XmppClientSettings & xcs,
39 buzz::AsyncSocket* socket,
40 buzz::PreXmppAuth* auth);
43 void OnStateChange(buzz::XmppEngine::State state);
51 buzz::XmppReturnStatus SendStanza(const buzz::XmlElement *stanza);
54 buzz::XmppClient *client_;
[all …]
|
| D | mucroomlookuptask_unittest.cc | 26 void OnResult(buzz::MucRoomLookupTask* task, in OnResult()
27 const buzz::MucRoomInfo& room) { in OnResult()
31 void OnError(buzz::IqTask* task, in OnError()
32 const buzz::XmlElement* error) { in OnError()
36 buzz::MucRoomInfo last_room;
53 xmpp_client = new buzz::FakeXmppClient(runner); in SetUp()
64 buzz::FakeXmppClient* xmpp_client;
66 buzz::Jid lookup_server_jid;
67 buzz::Jid room_jid;
77 buzz::MucRoomLookupTask* task = in TEST_F()
[all …]
|
| D | pingtask.cc | 17 namespace buzz { namespace
19 PingTask::PingTask(buzz::XmppTaskParentInterface* parent, in PingTask()
23 : buzz::XmppTask(parent, buzz::XmppEngine::HL_SINGLE), in PingTask()
32 bool PingTask::HandleStanza(const buzz::XmlElement* stanza) { in HandleStanza()
37 if (stanza->Attr(buzz::QN_TYPE) != buzz::STR_RESULT && in HandleStanza()
38 stanza->Attr(buzz::QN_TYPE) != buzz::STR_ERROR) { in HandleStanza()
53 const buzz::XmlElement* stanza = NextStanza(); in ProcessStart()
69 rtc::scoped_ptr<buzz::XmlElement> stanza( in ProcessStart()
70 MakeIq(buzz::STR_GET, Jid(STR_EMPTY), task_id())); in ProcessStart()
71 stanza->AddElement(new buzz::XmlElement(QN_PING)); in ProcessStart()
|
| D | xmpppump.cc | 15 namespace buzz { namespace
18 state_ = buzz::XmppEngine::STATE_NONE; in XmppPump()
20 client_ = new buzz::XmppClient(this); // NOTE: deleted by TaskRunner in XmppPump()
23 void XmppPump::DoLogin(const buzz::XmppClientSettings & xcs, in DoLogin()
24 buzz::AsyncSocket* socket, in DoLogin()
25 buzz::PreXmppAuth* auth) { in DoLogin()
26 OnStateChange(buzz::XmppEngine::STATE_START); in DoLogin()
37 OnStateChange(buzz::XmppEngine::STATE_CLOSED); in DoDisconnect()
40 void XmppPump::OnStateChange(buzz::XmppEngine::State state) { in OnStateChange()
60 buzz::XmppReturnStatus XmppPump::SendStanza(const buzz::XmlElement *stanza) { in SendStanza()
[all …]
|
| D | pingtask_unittest.cc | 24 class PingXmppClient : public buzz::FakeXmppClient {
30 buzz::XmppReturnStatus SendStanza(const buzz::XmlElement* stanza);
51 void ConnectTimeoutSignal(buzz::PingTask* task) { in ConnectTimeoutSignal()
65 buzz::XmppReturnStatus PingXmppClient::SendStanza( in SendStanza()
66 const buzz::XmlElement* stanza) { in SendStanza()
67 buzz::XmppReturnStatus result = FakeXmppClient::SendStanza(stanza); in SendStanza()
68 if (test->respond_to_pings && (stanza->FirstNamed(buzz::QN_PING) != NULL)) { in SendStanza()
71 HandleStanza(buzz::XmlElement::ForStr(ping_response)); in SendStanza()
78 buzz::PingTask* task = new buzz::PingTask(xmpp_client, in TEST_F()
93 buzz::PingTask* task = new buzz::PingTask(xmpp_client, in TEST_F()
|
| D | xmppsocket.cc | 31 namespace buzz { namespace
33 XmppSocket::XmppSocket(buzz::TlsOptions tls) : cricket_socket_(NULL), in XmppSocket()
35 state_ = buzz::AsyncSocket::STATE_CLOSED; in XmppSocket()
47 if (tls_ != buzz::TLS_DISABLED) { in CreateCricketSocket()
61 if (tls_ != buzz::TLS_DISABLED) in CreateCricketSocket()
98 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnConnectEvent()
99 state_ = buzz::AsyncSocket::STATE_TLS_OPEN; in OnConnectEvent()
105 state_ = buzz::AsyncSocket::STATE_OPEN; in OnConnectEvent()
119 if (state_ == buzz::AsyncSocket::STATE_TLS_CONNECTING) { in OnEvent()
120 state_ = buzz::AsyncSocket::STATE_TLS_OPEN; in OnEvent()
[all …]
|
| D | pubsub_task.h | 20 namespace buzz {
27 class PubsubTask : public buzz::XmppTask {
32 typedef void (PubsubTask::*NodeHandler)(const buzz::XmlElement* node);
34 PubsubTask(XmppTaskParentInterface* parent, const buzz::Jid& pubsub_node_jid);
36 virtual bool HandleStanza(const buzz::XmlElement* stanza);
43 virtual void OnPubsubError(const buzz::XmlElement* error_stanza);
48 void HandlePubsubIqGetResponse(const buzz::XmlElement* pubsub_iq_response);
49 void HandlePubsubEventMessage(const buzz::XmlElement* pubsub_event_message);
50 void HandlePubsubItems(const buzz::XmlElement* items);
52 buzz::Jid pubsub_node_jid_;
|
| D | mucroomconfigtask_unittest.cc | 26 void OnResult(buzz::MucRoomConfigTask*) { in OnResult()
30 void OnError(buzz::IqTask* task, in OnError()
31 const buzz::XmlElement* error) { in OnError()
48 xmpp_client = new buzz::FakeXmppClient(runner); in SetUp()
59 buzz::FakeXmppClient* xmpp_client;
61 buzz::Jid room_jid;
71 buzz::MucRoomConfigTask* task = new buzz::MucRoomConfigTask( in TEST_F()
105 xmpp_client->HandleStanza(buzz::XmlElement::ForStr(response_iq)); in TEST_F()
113 buzz::MucRoomConfigTask* task = new buzz::MucRoomConfigTask( in TEST_F()
123 xmpp_client->HandleStanza(buzz::XmlElement::ForStr(error_iq)); in TEST_F()
|
| D | mucroomdiscoverytask_unittest.cc | 26 void OnResult(buzz::MucRoomDiscoveryTask* task, in OnResult()
39 void OnError(buzz::IqTask* task, in OnError()
40 const buzz::XmlElement* error) { in OnError()
62 xmpp_client = new buzz::FakeXmppClient(runner); in SetUp()
73 buzz::FakeXmppClient* xmpp_client;
75 buzz::Jid room_jid;
83 buzz::MucRoomDiscoveryTask* task = new buzz::MucRoomDiscoveryTask( in TEST_F()
117 xmpp_client->HandleStanza(buzz::XmlElement::ForStr(response_iq)); in TEST_F()
130 buzz::MucRoomDiscoveryTask* task = new buzz::MucRoomDiscoveryTask( in TEST_F()
143 xmpp_client->HandleStanza(buzz::XmlElement::ForStr(error_iq)); in TEST_F()
|
| D | mucroomuniquehangoutidtask_unittest.cc | 26 void OnResult(buzz::MucRoomUniqueHangoutIdTask* task, in OnResult()
31 void OnError(buzz::IqTask* task, in OnError()
32 const buzz::XmlElement* error) { in OnError()
49 xmpp_client = new buzz::FakeXmppClient(runner); in SetUp()
60 buzz::FakeXmppClient* xmpp_client;
62 buzz::Jid lookup_server_jid;
69 buzz::MucRoomUniqueHangoutIdTask* task = new buzz::MucRoomUniqueHangoutIdTask( in TEST_F()
94 xmpp_client->HandleStanza(buzz::XmlElement::ForStr(response_iq)); in TEST_F()
|
| D | hangoutpubsubclient_unittest.cc | 86 void OnRequestError(const std::string& node, const buzz::XmlElement* stanza) { in OnRequestError()
92 const buzz::XmlElement* stanza) { in OnPublishAudioMuteError()
98 const buzz::XmlElement* stanza) { in OnPublishVideoMuteError()
104 const buzz::XmlElement* stanza) { in OnPublishVideoPauseError()
110 const buzz::XmlElement* stanza) { in OnPublishPresenterError()
116 const buzz::XmlElement* stanza) { in OnPublishRecordingError()
129 const buzz::XmlElement* stanza) { in OnRemoteMuteError()
143 const buzz::XmlElement* stanza) { in OnMediaBlockError()
192 xmpp_client = new buzz::FakeXmppClient(runner.get()); in HangoutPubSubClientTest()
193 client.reset(new buzz::HangoutPubSubClient(xmpp_client, pubsubjid, nick)); in HangoutPubSubClientTest()
[all …]
|
| D | xmppthread.cc | 16 namespace buzz { namespace
23 LoginData(const buzz::XmppClientSettings& s) : xcs(s) {} in LoginData()
26 buzz::XmppClientSettings xcs;
32 pump_ = new buzz::XmppPump(this); in XmppThread()
44 void XmppThread::Login(const buzz::XmppClientSettings& xcs) { in Login()
52 void XmppThread::OnStateChange(buzz::XmppEngine::State state) { in OnStateChange()
59 pump_->DoLogin(data->xcs, new XmppSocket(buzz::TLS_DISABLED), in OnMessage()
|
| D | xmppthread.h | 20 namespace buzz {
23 public rtc::Thread, buzz::XmppPumpNotify, rtc::MessageHandler {
28 buzz::XmppClient* client() { return pump_->client(); } in client()
32 void Login(const buzz::XmppClientSettings & xcs);
36 buzz::XmppPump* pump_;
38 void OnStateChange(buzz::XmppEngine::State state);
|
| D | xmppsocket.h | 30 namespace buzz {
32 class XmppSocket : public buzz::AsyncSocket, public sigslot::has_slots<> {
34 XmppSocket(buzz::TlsOptions tls);
37 virtual buzz::AsyncSocket::State state();
38 virtual buzz::AsyncSocket::Error error();
64 buzz::AsyncSocket::State state_;
66 buzz::TlsOptions tls_;
|
| D | xmppengine_unittest.cc | 23 using buzz::Jid;
24 using buzz::QName;
25 using buzz::XmlElement;
26 using buzz::XmppEngine;
27 using buzz::XmppIqCookie;
28 using buzz::XmppIqHandler;
29 using buzz::XmppTestHandler;
30 using buzz::QN_ID;
31 using buzz::QN_IQ;
32 using buzz::QN_TYPE;
[all …]
|
| D | xmppauth.h | 22 class XmppAuth: public buzz::PreXmppAuth {
29 virtual void StartPreXmppAuth(const buzz::Jid& jid,
39 virtual buzz::CaptchaChallenge GetCaptchaChallenge() const { in GetCaptchaChallenge()
40 return buzz::CaptchaChallenge(); in GetCaptchaChallenge()
49 virtual buzz::SaslMechanism * CreateSaslMechanism(
53 buzz::Jid jid_;
|
| D | mucroomuniquehangoutidtask.h | 16 namespace buzz {
21 class MucRoomUniqueHangoutIdTask : public buzz::IqTask {
23 MucRoomUniqueHangoutIdTask(buzz::XmppTaskParentInterface* parent,
29 virtual void HandleResult(const buzz::XmlElement* stanza);
32 static buzz::XmlElement* MakeUniqueRequestXml();
|
| D | pingtask.h | 18 namespace buzz {
28 class PingTask : public buzz::XmppTask, private rtc::MessageHandler {
30 PingTask(buzz::XmppTaskParentInterface* parent,
35 virtual bool HandleStanza(const buzz::XmlElement* stanza);
|
| /external/webrtc/webrtc/libjingle/xmllite/ |
| D | xmlprinter_unittest.cc | 22 using buzz::QName;
23 using buzz::XmlElement;
24 using buzz::XmlnsStack;
25 using buzz::XmlPrinter;
|