| Index: webrtc/libjingle/xmpp/pingtask.cc
|
| diff --git a/webrtc/libjingle/xmpp/pingtask.cc b/webrtc/libjingle/xmpp/pingtask.cc
|
| deleted file mode 100644
|
| index f7bef11043b688260239e8303e7abf1a705941a5..0000000000000000000000000000000000000000
|
| --- a/webrtc/libjingle/xmpp/pingtask.cc
|
| +++ /dev/null
|
| @@ -1,93 +0,0 @@
|
| -/*
|
| - * Copyright 2011 The WebRTC Project Authors. All rights reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -#include "webrtc/libjingle/xmpp/pingtask.h"
|
| -
|
| -#include <memory>
|
| -
|
| -#include "webrtc/libjingle/xmpp/constants.h"
|
| -#include "webrtc/base/logging.h"
|
| -
|
| -namespace buzz {
|
| -
|
| -PingTask::PingTask(buzz::XmppTaskParentInterface* parent,
|
| - rtc::MessageQueue* message_queue,
|
| - uint32_t ping_period_millis,
|
| - uint32_t ping_timeout_millis)
|
| - : buzz::XmppTask(parent, buzz::XmppEngine::HL_SINGLE),
|
| - message_queue_(message_queue),
|
| - ping_period_millis_(ping_period_millis),
|
| - ping_timeout_millis_(ping_timeout_millis),
|
| - next_ping_time_(0),
|
| - ping_response_deadline_(0) {
|
| - ASSERT(ping_period_millis >= ping_timeout_millis);
|
| -}
|
| -
|
| -bool PingTask::HandleStanza(const buzz::XmlElement* stanza) {
|
| - if (!MatchResponseIq(stanza, Jid(STR_EMPTY), task_id())) {
|
| - return false;
|
| - }
|
| -
|
| - if (stanza->Attr(buzz::QN_TYPE) != buzz::STR_RESULT &&
|
| - stanza->Attr(buzz::QN_TYPE) != buzz::STR_ERROR) {
|
| - return false;
|
| - }
|
| -
|
| - QueueStanza(stanza);
|
| - return true;
|
| -}
|
| -
|
| -// This task runs indefinitely and remains in either the start or blocked
|
| -// states.
|
| -int PingTask::ProcessStart() {
|
| - if (ping_period_millis_ < ping_timeout_millis_) {
|
| - LOG(LS_ERROR) << "ping_period_millis should be >= ping_timeout_millis";
|
| - return STATE_ERROR;
|
| - }
|
| - const buzz::XmlElement* stanza = NextStanza();
|
| - if (stanza != NULL) {
|
| - // Received a ping response of some sort (don't care what it is).
|
| - ping_response_deadline_ = 0;
|
| - }
|
| -
|
| - int64_t now = rtc::TimeMillis();
|
| -
|
| - // If the ping timed out, signal.
|
| - if (ping_response_deadline_ != 0 && now >= ping_response_deadline_) {
|
| - SignalTimeout();
|
| - return STATE_ERROR;
|
| - }
|
| -
|
| - // Send a ping if it's time.
|
| - if (now >= next_ping_time_) {
|
| - std::unique_ptr<buzz::XmlElement> stanza(
|
| - MakeIq(buzz::STR_GET, Jid(STR_EMPTY), task_id()));
|
| - stanza->AddElement(new buzz::XmlElement(QN_PING));
|
| - SendStanza(stanza.get());
|
| -
|
| - ping_response_deadline_ = now + ping_timeout_millis_;
|
| - next_ping_time_ = now + ping_period_millis_;
|
| -
|
| - // Wake ourselves up when it's time to send another ping or when the ping
|
| - // times out (so we can fire a signal).
|
| - message_queue_->PostDelayed(RTC_FROM_HERE, ping_timeout_millis_, this);
|
| - message_queue_->PostDelayed(RTC_FROM_HERE, ping_period_millis_, this);
|
| - }
|
| -
|
| - return STATE_BLOCKED;
|
| -}
|
| -
|
| -void PingTask::OnMessage(rtc::Message* msg) {
|
| - // Get the task manager to run this task so we can send a ping or signal or
|
| - // process a ping response.
|
| - Wake();
|
| -}
|
| -
|
| -} // namespace buzz
|
|
|