OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef JINGLE_GLUE_THREAD_WRAPPER_H_ | 5 #ifndef JINGLE_GLUE_THREAD_WRAPPER_H_ |
6 #define JINGLE_GLUE_THREAD_WRAPPER_H_ | 6 #define JINGLE_GLUE_THREAD_WRAPPER_H_ |
7 | 7 |
8 #include <list> | 8 #include <list> |
9 #include <map> | 9 #include <map> |
10 | 10 |
(...skipping 17 matching lines...) Expand all Loading... |
28 // must pass a valid task runner for the current thread and also delete the | 28 // must pass a valid task runner for the current thread and also delete the |
29 // wrapper later. | 29 // wrapper later. |
30 class JingleThreadWrapper : public base::MessageLoop::DestructionObserver, | 30 class JingleThreadWrapper : public base::MessageLoop::DestructionObserver, |
31 public rtc::Thread { | 31 public rtc::Thread { |
32 public: | 32 public: |
33 // Create JingleThreadWrapper for the current thread if it hasn't been created | 33 // Create JingleThreadWrapper for the current thread if it hasn't been created |
34 // yet. The thread wrapper is destroyed automatically when the current | 34 // yet. The thread wrapper is destroyed automatically when the current |
35 // MessageLoop is destroyed. | 35 // MessageLoop is destroyed. |
36 static void EnsureForCurrentMessageLoop(); | 36 static void EnsureForCurrentMessageLoop(); |
37 | 37 |
38 // Returns thread wrapper for the current thread. NULL is returned | 38 // Creates JingleThreadWrapper for |task_runner| that runs tasks on the |
39 // if EnsureForCurrentMessageLoop() has never been called for this | 39 // current thread. |
40 // thread. | 40 static scoped_ptr<JingleThreadWrapper> WrapTaskRunner( |
| 41 scoped_refptr<base::SingleThreadTaskRunner> task_runner); |
| 42 |
| 43 // Returns thread wrapper for the current thread or nullptr if it doesn't |
| 44 // exist. |
41 static JingleThreadWrapper* current(); | 45 static JingleThreadWrapper* current(); |
42 | 46 |
43 explicit JingleThreadWrapper( | |
44 scoped_refptr<base::SingleThreadTaskRunner> task_runner); | |
45 ~JingleThreadWrapper() override; | 47 ~JingleThreadWrapper() override; |
46 | 48 |
47 // Sets whether the thread can be used to send messages | 49 // Sets whether the thread can be used to send messages |
48 // synchronously to another thread using Send() method. Set to false | 50 // synchronously to another thread using Send() method. Set to false |
49 // by default to avoid potential jankiness when Send() used on | 51 // by default to avoid potential jankiness when Send() used on |
50 // renderer thread. It should be set explicitly for threads that | 52 // renderer thread. It should be set explicitly for threads that |
51 // need to call Send() for other threads. | 53 // need to call Send() for other threads. |
52 void set_send_allowed(bool allowed) { send_allowed_ = allowed; } | 54 void set_send_allowed(bool allowed) { send_allowed_ = allowed; } |
53 | 55 |
54 // MessageLoop::DestructionObserver implementation. | 56 // MessageLoop::DestructionObserver implementation. |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
88 int GetDelay() override; | 90 int GetDelay() override; |
89 | 91 |
90 // rtc::Thread overrides. | 92 // rtc::Thread overrides. |
91 void Stop() override; | 93 void Stop() override; |
92 void Run() override; | 94 void Run() override; |
93 | 95 |
94 private: | 96 private: |
95 typedef std::map<int, rtc::Message> MessagesQueue; | 97 typedef std::map<int, rtc::Message> MessagesQueue; |
96 struct PendingSend; | 98 struct PendingSend; |
97 | 99 |
| 100 explicit JingleThreadWrapper( |
| 101 scoped_refptr<base::SingleThreadTaskRunner> task_runner); |
| 102 |
98 void PostTaskInternal( | 103 void PostTaskInternal( |
99 int delay_ms, rtc::MessageHandler* handler, | 104 int delay_ms, rtc::MessageHandler* handler, |
100 uint32 message_id, rtc::MessageData* data); | 105 uint32 message_id, rtc::MessageData* data); |
101 void RunTask(int task_id); | 106 void RunTask(int task_id); |
102 void ProcessPendingSends(); | 107 void ProcessPendingSends(); |
103 | 108 |
104 // Task runner used to execute messages posted on this thread. | 109 // Task runner used to execute messages posted on this thread. |
105 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; | 110 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; |
106 | 111 |
107 bool send_allowed_; | 112 bool send_allowed_; |
108 | 113 |
109 // |lock_| must be locked when accessing |messages_|. | 114 // |lock_| must be locked when accessing |messages_|. |
110 base::Lock lock_; | 115 base::Lock lock_; |
111 int last_task_id_; | 116 int last_task_id_; |
112 MessagesQueue messages_; | 117 MessagesQueue messages_; |
113 std::list<PendingSend*> pending_send_messages_; | 118 std::list<PendingSend*> pending_send_messages_; |
114 base::WaitableEvent pending_send_event_; | 119 base::WaitableEvent pending_send_event_; |
115 | 120 |
116 base::WeakPtr<JingleThreadWrapper> weak_ptr_; | 121 base::WeakPtr<JingleThreadWrapper> weak_ptr_; |
117 base::WeakPtrFactory<JingleThreadWrapper> weak_ptr_factory_; | 122 base::WeakPtrFactory<JingleThreadWrapper> weak_ptr_factory_; |
118 | 123 |
119 DISALLOW_COPY_AND_ASSIGN(JingleThreadWrapper); | 124 DISALLOW_COPY_AND_ASSIGN(JingleThreadWrapper); |
120 }; | 125 }; |
121 | 126 |
122 } // namespace jingle_glue | 127 } // namespace jingle_glue |
123 | 128 |
124 #endif // JINGLE_GLUE_THREAD_WRAPPER_H_ | 129 #endif // JINGLE_GLUE_THREAD_WRAPPER_H_ |
OLD | NEW |