OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 #include "media/base/message_loop_factory_impl.h" | 5 #include "media/base/message_loop_factory_impl.h" |
6 | 6 |
7 namespace media { | 7 namespace media { |
8 | 8 |
9 MessageLoopFactoryImpl::MessageLoopFactoryImpl() {} | 9 MessageLoopFactoryImpl::MessageLoopFactoryImpl() {} |
10 | 10 |
(...skipping 30 matching lines...) Expand all Loading... |
41 if (thread->Start()) { | 41 if (thread->Start()) { |
42 MessageLoop* message_loop = thread->message_loop(); | 42 MessageLoop* message_loop = thread->message_loop(); |
43 thread_map_[name] = thread.release(); | 43 thread_map_[name] = thread.release(); |
44 return message_loop; | 44 return message_loop; |
45 } | 45 } |
46 | 46 |
47 LOG(ERROR) << "Failed to start '" << name << "' thread!"; | 47 LOG(ERROR) << "Failed to start '" << name << "' thread!"; |
48 return NULL; | 48 return NULL; |
49 } | 49 } |
50 | 50 |
| 51 scoped_refptr<base::MessageLoopProxy> |
| 52 MessageLoopFactoryImpl::GetMessageLoopProxy(const std::string& name) { |
| 53 if (name.empty()) { |
| 54 return NULL; |
| 55 } |
| 56 |
| 57 base::AutoLock auto_lock(lock_); |
| 58 |
| 59 ThreadMap::iterator it = thread_map_.find(name); |
| 60 if (it != thread_map_.end()) |
| 61 return (*it).second->message_loop_proxy(); |
| 62 |
| 63 scoped_ptr<base::Thread> thread(new base::Thread(name.c_str())); |
| 64 |
| 65 if (thread->Start()) { |
| 66 scoped_refptr<base::MessageLoopProxy> message_loop_proxy = |
| 67 thread->message_loop_proxy(); |
| 68 thread_map_[name] = thread.release(); |
| 69 return message_loop_proxy; |
| 70 } |
| 71 |
| 72 LOG(ERROR) << "Failed to start '" << name << "' thread!"; |
| 73 return NULL; |
| 74 } |
| 75 |
51 } // namespace media | 76 } // namespace media |
OLD | NEW |