| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 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 | 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 BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 5 #ifndef BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| 6 #define BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 6 #define BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| 7 | 7 |
| 8 #include <queue> | 8 #include <queue> |
| 9 #include <string> | 9 #include <string> |
| 10 | 10 |
| (...skipping 278 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 289 Type type() const { return type_; } | 289 Type type() const { return type_; } |
| 290 | 290 |
| 291 // Optional call to connect the thread name with this loop. | 291 // Optional call to connect the thread name with this loop. |
| 292 void set_thread_name(const std::string& thread_name) { | 292 void set_thread_name(const std::string& thread_name) { |
| 293 DCHECK(thread_name_.empty()) << "Should not rename this thread!"; | 293 DCHECK(thread_name_.empty()) << "Should not rename this thread!"; |
| 294 thread_name_ = thread_name; | 294 thread_name_ = thread_name; |
| 295 } | 295 } |
| 296 const std::string& thread_name() const { return thread_name_; } | 296 const std::string& thread_name() const { return thread_name_; } |
| 297 | 297 |
| 298 // Gets the TaskRunner associated with this message loop. | 298 // Gets the TaskRunner associated with this message loop. |
| 299 const scoped_refptr<SingleThreadTaskRunner>& task_runner() { | 299 // TODO(skyostil): Change this to return a const reference to a refptr |
| 300 return task_runner_; | 300 // once the internal type matches what is being returned (crbug.com/465354). |
| 301 } | 301 scoped_refptr<SingleThreadTaskRunner> task_runner() { return task_runner_; } |
| 302 | |
| 303 // Sets a new TaskRunner for this message loop. The message loop must already | |
| 304 // have been bound to a thread prior to this call, and the task runner must | |
| 305 // belong to that thread. Note that changing the task runner will also affect | |
| 306 // the ThreadTaskRunnerHandle for the target thread. Must be called on the | |
| 307 // thread to which the message loop is bound. | |
| 308 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner); | |
| 309 | 302 |
| 310 // Enables or disables the recursive task processing. This happens in the case | 303 // Enables or disables the recursive task processing. This happens in the case |
| 311 // of recursive message loops. Some unwanted message loop may occurs when | 304 // of recursive message loops. Some unwanted message loop may occurs when |
| 312 // using common controls or printer functions. By default, recursive task | 305 // using common controls or printer functions. By default, recursive task |
| 313 // processing is disabled. | 306 // processing is disabled. |
| 314 // | 307 // |
| 315 // Please utilize |ScopedNestableTaskAllower| instead of calling these methods | 308 // Please utilize |ScopedNestableTaskAllower| instead of calling these methods |
| 316 // directly. In general nestable message loops are to be avoided. They are | 309 // directly. In general nestable message loops are to be avoided. They are |
| 317 // dangerous and difficult to get right, so please use with extreme caution. | 310 // dangerous and difficult to get right, so please use with extreme caution. |
| 318 // | 311 // |
| (...skipping 202 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 521 HistogramBase* message_histogram_; | 514 HistogramBase* message_histogram_; |
| 522 | 515 |
| 523 RunLoop* run_loop_; | 516 RunLoop* run_loop_; |
| 524 | 517 |
| 525 ObserverList<TaskObserver> task_observers_; | 518 ObserverList<TaskObserver> task_observers_; |
| 526 | 519 |
| 527 debug::TaskAnnotator task_annotator_; | 520 debug::TaskAnnotator task_annotator_; |
| 528 | 521 |
| 529 scoped_refptr<internal::IncomingTaskQueue> incoming_task_queue_; | 522 scoped_refptr<internal::IncomingTaskQueue> incoming_task_queue_; |
| 530 | 523 |
| 531 // A task runner which we haven't bound to a thread yet. | |
| 532 scoped_refptr<internal::MessageLoopTaskRunner> unbound_task_runner_; | |
| 533 | |
| 534 // The task runner associated with this message loop. | 524 // The task runner associated with this message loop. |
| 535 scoped_refptr<SingleThreadTaskRunner> task_runner_; | 525 scoped_refptr<internal::MessageLoopTaskRunner> task_runner_; |
| 536 scoped_ptr<ThreadTaskRunnerHandle> thread_task_runner_handle_; | 526 scoped_ptr<ThreadTaskRunnerHandle> thread_task_runner_handle_; |
| 537 | 527 |
| 538 template <class T, class R> friend class base::subtle::DeleteHelperInternal; | 528 template <class T, class R> friend class base::subtle::DeleteHelperInternal; |
| 539 template <class T, class R> friend class base::subtle::ReleaseHelperInternal; | 529 template <class T, class R> friend class base::subtle::ReleaseHelperInternal; |
| 540 | 530 |
| 541 void DeleteSoonInternal(const tracked_objects::Location& from_here, | 531 void DeleteSoonInternal(const tracked_objects::Location& from_here, |
| 542 void(*deleter)(const void*), | 532 void(*deleter)(const void*), |
| 543 const void* object); | 533 const void* object); |
| 544 void ReleaseSoonInternal(const tracked_objects::Location& from_here, | 534 void ReleaseSoonInternal(const tracked_objects::Location& from_here, |
| 545 void(*releaser)(const void*), | 535 void(*releaser)(const void*), |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 683 | 673 |
| 684 // Do not add any member variables to MessageLoopForIO! This is important b/c | 674 // Do not add any member variables to MessageLoopForIO! This is important b/c |
| 685 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra | 675 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra |
| 686 // data that you need should be stored on the MessageLoop's pump_ instance. | 676 // data that you need should be stored on the MessageLoop's pump_ instance. |
| 687 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO), | 677 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO), |
| 688 MessageLoopForIO_should_not_have_extra_member_variables); | 678 MessageLoopForIO_should_not_have_extra_member_variables); |
| 689 | 679 |
| 690 } // namespace base | 680 } // namespace base |
| 691 | 681 |
| 692 #endif // BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 682 #endif // BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| OLD | NEW |