src/media/cast/cast_environment.h

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef MEDIA_CAST_CAST_ENVIRONMENT_H_
   6 #define MEDIA_CAST_CAST_ENVIRONMENT_H_
   7
   8 #include "base/basictypes.h"
   9 #include "base/memory/ref_counted.h"
  10 #include "base/memory/scoped_ptr.h"
  11 #include "base/single_thread_task_runner.h"
  12 #include "base/time/tick_clock.h"
  13 #include "base/time/time.h"
  14 #include "media/cast/logging/logging_defines.h"
  15 #include "media/cast/logging/logging_impl.h"
  16
  17 namespace media {
  18 namespace cast {
  19
  20 class CastEnvironment : public base::RefCountedThreadSafe<CastEnvironment> {
  21  public:
  22   // An enumeration of the cast threads.
  23   enum ThreadId {
  24     // The main thread is where the cast system is configured and where timers
  25     // and network IO is performed.
  26     MAIN,
  27     // The audio encoder thread is where all send side audio processing is done,
  28     // primarily encoding but also re-sampling.
  29     AUDIO_ENCODER,
  30     // The audio decoder thread is where all receive side audio processing is
  31     // done, primarily decoding but also error concealment and re-sampling.
  32     AUDIO_DECODER,
  33     // The video encoder thread is where the video encode processing is done.
  34     VIDEO_ENCODER,
  35     // The video decoder thread is where the video decode processing is done.
  36     VIDEO_DECODER,
  37     // The transport thread is where the transport processing is done.
  38     TRANSPORT,
  39   };
  40
  41   CastEnvironment(
  42       scoped_ptr<base::TickClock> clock,
  43       scoped_refptr<base::SingleThreadTaskRunner> main_thread_proxy,
  44       scoped_refptr<base::SingleThreadTaskRunner> audio_encode_thread_proxy,
  45       scoped_refptr<base::SingleThreadTaskRunner> audio_decode_thread_proxy,
  46       scoped_refptr<base::SingleThreadTaskRunner> video_encode_thread_proxy,
  47       scoped_refptr<base::SingleThreadTaskRunner> video_decode_thread_proxy,
  48       scoped_refptr<base::SingleThreadTaskRunner> transport_thread_proxy,
  49       const CastLoggingConfig& config);
  50
  51   // These are the same methods in message_loop.h, but are guaranteed to either
  52   // get posted to the MessageLoop if it's still alive, or be deleted otherwise.
  53   // They return true iff the thread existed and the task was posted.  Note that
  54   // even if the task is posted, there's no guarantee that it will run, since
  55   // the target thread may already have a Quit message in its queue.
  56   bool PostTask(ThreadId identifier,
  57                 const tracked_objects::Location& from_here,
  58                 const base::Closure& task);
  59
  60   bool PostDelayedTask(ThreadId identifier,
  61                        const tracked_objects::Location& from_here,
  62                        const base::Closure& task,
  63                        base::TimeDelta delay);
  64
  65   bool CurrentlyOn(ThreadId identifier);
  66
  67   base::TickClock* Clock() const;
  68
  69   // Logging is not thread safe. Should always be called from the main thread.
  70   LoggingImpl* Logging();
  71
  72   scoped_refptr<base::SingleThreadTaskRunner>
  73       GetMessageSingleThreadTaskRunnerForThread(ThreadId identifier);
  74
  75   bool HasAudioEncoderThread() {
  76     return audio_encode_thread_proxy_ ? true : false;
  77   }
  78
  79   bool HasVideoEncoderThread() {
  80     return video_encode_thread_proxy_ ? true : false;
  81   }
  82
  83  protected:
  84   virtual ~CastEnvironment();
  85
  86  private:
  87   friend class base::RefCountedThreadSafe<CastEnvironment>;
  88
  89   scoped_ptr<base::TickClock> clock_;
  90   scoped_refptr<base::SingleThreadTaskRunner> main_thread_proxy_;
  91   scoped_refptr<base::SingleThreadTaskRunner> audio_encode_thread_proxy_;
  92   scoped_refptr<base::SingleThreadTaskRunner> audio_decode_thread_proxy_;
  93   scoped_refptr<base::SingleThreadTaskRunner> video_encode_thread_proxy_;
  94   scoped_refptr<base::SingleThreadTaskRunner> video_decode_thread_proxy_;
  95   scoped_refptr<base::SingleThreadTaskRunner> transport_thread_proxy_;
  96
  97   scoped_ptr<LoggingImpl> logging_;
  98
  99   DISALLOW_COPY_AND_ASSIGN(CastEnvironment);
 100 };
 101
 102 }  // namespace cast
 103 }  // namespace media
 104
 105 #endif  // MEDIA_CAST_CAST_ENVIRONMENT_H_