blob: eb11516002892a7ba2efdf4937cd4433f5b6c16c [file] [log] [blame]
henrike@webrtc.org269fb4b2014-10-28 22:20:111/*
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved.
3 *
4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11#ifndef WEBRTC_P2P_CLIENT_SOCKETMONITOR_H_
12#define WEBRTC_P2P_CLIENT_SOCKETMONITOR_H_
13
14#include <vector>
15
henrike@webrtc.org269fb4b2014-10-28 22:20:1116#include "webrtc/base/criticalsection.h"
17#include "webrtc/base/sigslot.h"
18#include "webrtc/base/thread.h"
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2119#include "webrtc/p2p/base/transport.h" // for ConnectionInfos
20
21// TODO(pthatcher): Move these to connectionmonitor.h and
22// connectionmonitor.cc, or just move them into channel.cc
henrike@webrtc.org269fb4b2014-10-28 22:20:1123
24namespace cricket {
25
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2126class ConnectionStatsGetter {
henrike@webrtc.org269fb4b2014-10-28 22:20:1127 public:
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2128 virtual ~ConnectionStatsGetter() {}
29 virtual bool GetConnectionStats(ConnectionInfos* infos) = 0;
30};
31
32class ConnectionMonitor : public rtc::MessageHandler,
33 public sigslot::has_slots<> {
34public:
35 ConnectionMonitor(ConnectionStatsGetter* stats_getter,
36 rtc::Thread* worker_thread,
37 rtc::Thread* monitoring_thread);
38 ~ConnectionMonitor();
henrike@webrtc.org269fb4b2014-10-28 22:20:1139
40 void Start(int cms);
41 void Stop();
42
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2143 sigslot::signal2<ConnectionMonitor*,
henrike@webrtc.org269fb4b2014-10-28 22:20:1144 const std::vector<ConnectionInfo>&> SignalUpdate;
45
46 protected:
47 void OnMessage(rtc::Message* message);
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2148 private:
49 void PollConnectionStats_w();
henrike@webrtc.org269fb4b2014-10-28 22:20:1150
51 std::vector<ConnectionInfo> connection_infos_;
pthatcher@webrtc.orgb4aac132015-03-13 18:25:2152 ConnectionStatsGetter* stats_getter_;
53 rtc::Thread* worker_thread_;
henrike@webrtc.org269fb4b2014-10-28 22:20:1154 rtc::Thread* monitoring_thread_;
55 rtc::CriticalSection crit_;
Peter Boström0c4e06b2015-10-07 10:23:2156 uint32_t rate_;
henrike@webrtc.org269fb4b2014-10-28 22:20:1157 bool monitoring_;
58};
59
60} // namespace cricket
61
62#endif // WEBRTC_P2P_CLIENT_SOCKETMONITOR_H_