| OLD | NEW | 
|---|
| 1 /* | 1 /* | 
| 2  *  Copyright (c) 2011 The WebRTC project authors. All Rights Reserved. | 2  *  Copyright (c) 2011 The WebRTC project authors. All Rights Reserved. | 
| 3  * | 3  * | 
| 4  *  Use of this source code is governed by a BSD-style license | 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 | 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 | 6  *  tree. An additional intellectual property rights grant can be found | 
| 7  *  in the file PATENTS.  All contributing project authors may | 7  *  in the file PATENTS.  All contributing project authors may | 
| 8  *  be found in the AUTHORS file in the root of the source tree. | 8  *  be found in the AUTHORS file in the root of the source tree. | 
| 9  */ | 9  */ | 
| 10 | 10 | 
| (...skipping 15 matching lines...) Expand all  Loading... | 
| 26 | 26 | 
| 27 class ProcessThreadImpl : public ProcessThread { | 27 class ProcessThreadImpl : public ProcessThread { | 
| 28  public: | 28  public: | 
| 29   explicit ProcessThreadImpl(const char* thread_name); | 29   explicit ProcessThreadImpl(const char* thread_name); | 
| 30   ~ProcessThreadImpl() override; | 30   ~ProcessThreadImpl() override; | 
| 31 | 31 | 
| 32   void Start() override; | 32   void Start() override; | 
| 33   void Stop() override; | 33   void Stop() override; | 
| 34 | 34 | 
| 35   void WakeUp(Module* module) override; | 35   void WakeUp(Module* module) override; | 
| 36   void PostTask(std::unique_ptr<ProcessTask> task) override; | 36   void PostTask(rtc::scoped_ptr<ProcessTask> task) override; | 
| 37 | 37 | 
| 38   void RegisterModule(Module* module) override; | 38   void RegisterModule(Module* module) override; | 
| 39   void DeRegisterModule(Module* module) override; | 39   void DeRegisterModule(Module* module) override; | 
| 40 | 40 | 
| 41  protected: | 41  protected: | 
| 42   static bool Run(void* obj); | 42   static bool Run(void* obj); | 
| 43   bool Process(); | 43   bool Process(); | 
| 44 | 44 | 
| 45  private: | 45  private: | 
| 46   struct ModuleCallback { | 46   struct ModuleCallback { | 
| (...skipping 30 matching lines...) Expand all  Loading... | 
| 77   ModuleList modules_; | 77   ModuleList modules_; | 
| 78   // TODO(tommi): Support delayed tasks. | 78   // TODO(tommi): Support delayed tasks. | 
| 79   std::queue<ProcessTask*> queue_; | 79   std::queue<ProcessTask*> queue_; | 
| 80   bool stop_; | 80   bool stop_; | 
| 81   const char* thread_name_; | 81   const char* thread_name_; | 
| 82 }; | 82 }; | 
| 83 | 83 | 
| 84 }  // namespace webrtc | 84 }  // namespace webrtc | 
| 85 | 85 | 
| 86 #endif // WEBRTC_MODULES_UTILITY_SOURCE_PROCESS_THREAD_IMPL_H_ | 86 #endif // WEBRTC_MODULES_UTILITY_SOURCE_PROCESS_THREAD_IMPL_H_ | 
| OLD | NEW | 
|---|