| OLD | NEW | 
 | (Empty) | 
|   1 /* |  | 
|   2  * libjingle |  | 
|   3  * Copyright 2005 Google Inc. |  | 
|   4  * |  | 
|   5  * Redistribution and use in source and binary forms, with or without |  | 
|   6  * modification, are permitted provided that the following conditions are met: |  | 
|   7  * |  | 
|   8  *  1. Redistributions of source code must retain the above copyright notice, |  | 
|   9  *     this list of conditions and the following disclaimer. |  | 
|  10  *  2. Redistributions in binary form must reproduce the above copyright notice, |  | 
|  11  *     this list of conditions and the following disclaimer in the documentation |  | 
|  12  *     and/or other materials provided with the distribution. |  | 
|  13  *  3. The name of the author may not be used to endorse or promote products |  | 
|  14  *     derived from this software without specific prior written permission. |  | 
|  15  * |  | 
|  16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED |  | 
|  17  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |  | 
|  18  * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO |  | 
|  19  * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |  | 
|  20  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, |  | 
|  21  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; |  | 
|  22  * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |  | 
|  23  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR |  | 
|  24  * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF |  | 
|  25  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |  | 
|  26  */ |  | 
|  27  |  | 
|  28 // Class to collect statistics from a media channel |  | 
|  29  |  | 
|  30 #ifndef TALK_SESSION_MEDIA_MEDIAMONITOR_H_ |  | 
|  31 #define TALK_SESSION_MEDIA_MEDIAMONITOR_H_ |  | 
|  32  |  | 
|  33 #include "webrtc/base/criticalsection.h" |  | 
|  34 #include "webrtc/base/sigslot.h" |  | 
|  35 #include "webrtc/base/thread.h" |  | 
|  36 #include "webrtc/base/thread_annotations.h" |  | 
|  37 #include "webrtc/media/base/mediachannel.h" |  | 
|  38  |  | 
|  39 namespace cricket { |  | 
|  40  |  | 
|  41 // The base MediaMonitor class, independent of voice and video. |  | 
|  42 class MediaMonitor : public rtc::MessageHandler, |  | 
|  43     public sigslot::has_slots<> { |  | 
|  44  public: |  | 
|  45   MediaMonitor(rtc::Thread* worker_thread, |  | 
|  46                rtc::Thread* monitor_thread); |  | 
|  47   ~MediaMonitor(); |  | 
|  48  |  | 
|  49   void Start(uint32_t milliseconds); |  | 
|  50   void Stop(); |  | 
|  51  |  | 
|  52  protected: |  | 
|  53   void OnMessage(rtc::Message *message); |  | 
|  54   void PollMediaChannel(); |  | 
|  55   virtual void GetStats() = 0; |  | 
|  56   virtual void Update() = 0; |  | 
|  57  |  | 
|  58   rtc::CriticalSection crit_; |  | 
|  59   rtc::Thread* worker_thread_; |  | 
|  60   rtc::Thread* monitor_thread_; |  | 
|  61   bool monitoring_; |  | 
|  62   uint32_t rate_; |  | 
|  63 }; |  | 
|  64  |  | 
|  65 // Templatized MediaMonitor that can deal with different kinds of media. |  | 
|  66 template<class MC, class MI> |  | 
|  67 class MediaMonitorT : public MediaMonitor { |  | 
|  68  public: |  | 
|  69   MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread, |  | 
|  70                 rtc::Thread* monitor_thread) |  | 
|  71       : MediaMonitor(worker_thread, monitor_thread), |  | 
|  72         media_channel_(media_channel) {} |  | 
|  73   sigslot::signal2<MC*, const MI&> SignalUpdate; |  | 
|  74  |  | 
|  75  protected: |  | 
|  76   // These routines assume the crit_ lock is held by the calling thread. |  | 
|  77   virtual void GetStats() { |  | 
|  78     media_info_.Clear(); |  | 
|  79     media_channel_->GetStats(&media_info_); |  | 
|  80   } |  | 
|  81   virtual void Update() EXCLUSIVE_LOCKS_REQUIRED(crit_) { |  | 
|  82     MI stats(media_info_); |  | 
|  83     crit_.Leave(); |  | 
|  84     SignalUpdate(media_channel_, stats); |  | 
|  85     crit_.Enter(); |  | 
|  86   } |  | 
|  87  |  | 
|  88  private: |  | 
|  89   MC* media_channel_; |  | 
|  90   MI media_info_; |  | 
|  91 }; |  | 
|  92  |  | 
|  93 typedef MediaMonitorT<VoiceMediaChannel, VoiceMediaInfo> VoiceMediaMonitor; |  | 
|  94 typedef MediaMonitorT<VideoMediaChannel, VideoMediaInfo> VideoMediaMonitor; |  | 
|  95 typedef MediaMonitorT<DataMediaChannel, DataMediaInfo> DataMediaMonitor; |  | 
|  96  |  | 
|  97 }  // namespace cricket |  | 
|  98  |  | 
|  99 #endif  // TALK_SESSION_MEDIA_MEDIAMONITOR_H_ |  | 
| OLD | NEW |