Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(486)

Side by Side Diff: base/message_loop.h

Issue 3884001: Switch to using TimeTicks rather than Time in message loops (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: '' Created 10 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « no previous file | base/message_loop.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2006-2008 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_H_ 5 #ifndef BASE_MESSAGE_LOOP_H_
6 #define BASE_MESSAGE_LOOP_H_ 6 #define BASE_MESSAGE_LOOP_H_
7 #pragma once 7 #pragma once
8 8
9 #include <queue> 9 #include <queue>
10 #include <string> 10 #include <string>
(...skipping 323 matching lines...) Expand 10 before | Expand all | Expand 10 after
334 public: 334 public:
335 explicit AutoRunState(MessageLoop* loop); 335 explicit AutoRunState(MessageLoop* loop);
336 ~AutoRunState(); 336 ~AutoRunState();
337 private: 337 private:
338 MessageLoop* loop_; 338 MessageLoop* loop_;
339 RunState* previous_state_; 339 RunState* previous_state_;
340 }; 340 };
341 341
342 // This structure is copied around by value. 342 // This structure is copied around by value.
343 struct PendingTask { 343 struct PendingTask {
344 Task* task; // The task to run. 344 Task* task; // The task to run.
345 base::Time delayed_run_time; // The time when the task should be run. 345 base::TimeTicks delayed_run_time; // The time when the task should be run.
346 int sequence_num; // Used to facilitate sorting by run time. 346 int sequence_num; // Secondary sort key for run time.
347 bool nestable; // True if OK to dispatch from a nested loop. 347 bool nestable; // OK to dispatch from a nested loop.
348 348
349 PendingTask(Task* task, bool nestable) 349 PendingTask(Task* task, bool nestable)
350 : task(task), sequence_num(0), nestable(nestable) { 350 : task(task), sequence_num(0), nestable(nestable) {
351 } 351 }
352 352
353 // Used to support sorting. 353 // Used to support sorting.
354 bool operator<(const PendingTask& other) const; 354 bool operator<(const PendingTask& other) const;
355 }; 355 };
356 356
357 class TaskQueue : public std::queue<PendingTask> { 357 class TaskQueue : public std::queue<PendingTask> {
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after
422 // destructor to make sure all the task's destructors get called. Returns 422 // destructor to make sure all the task's destructors get called. Returns
423 // true if some work was done. 423 // true if some work was done.
424 bool DeletePendingTasks(); 424 bool DeletePendingTasks();
425 425
426 // Post a task to our incomming queue. 426 // Post a task to our incomming queue.
427 void PostTask_Helper(const tracked_objects::Location& from_here, Task* task, 427 void PostTask_Helper(const tracked_objects::Location& from_here, Task* task,
428 int64 delay_ms, bool nestable); 428 int64 delay_ms, bool nestable);
429 429
430 // base::MessagePump::Delegate methods: 430 // base::MessagePump::Delegate methods:
431 virtual bool DoWork(); 431 virtual bool DoWork();
432 virtual bool DoDelayedWork(base::Time* next_delayed_work_time); 432 virtual bool DoDelayedWork(base::TimeTicks* next_delayed_work_time);
433 virtual bool DoIdleWork(); 433 virtual bool DoIdleWork();
434 434
435 // Start recording histogram info about events and action IF it was enabled 435 // Start recording histogram info about events and action IF it was enabled
436 // and IF the statistics recorder can accept a registration of our histogram. 436 // and IF the statistics recorder can accept a registration of our histogram.
437 void StartHistogrammer(); 437 void StartHistogrammer();
438 438
439 // Add occurence of event to our histogram, so that we can see what is being 439 // Add occurence of event to our histogram, so that we can see what is being
440 // done in a specific MessageLoop instance (i.e., specific thread). 440 // done in a specific MessageLoop instance (i.e., specific thread).
441 // If message_histogram_ is NULL, this is a no-op. 441 // If message_histogram_ is NULL, this is a no-op.
442 void HistogramEvent(int event); 442 void HistogramEvent(int event);
443 443
444 Type type_; 444 Type type_;
445 445
446 // A list of tasks that need to be processed by this instance. Note that 446 // A list of tasks that need to be processed by this instance. Note that
447 // this queue is only accessed (push/pop) by our current thread. 447 // this queue is only accessed (push/pop) by our current thread.
448 TaskQueue work_queue_; 448 TaskQueue work_queue_;
449 449
450 // Contains delayed tasks, sorted by their 'delayed_run_time' property. 450 // Contains delayed tasks, sorted by their 'delayed_run_time' property.
451 DelayedTaskQueue delayed_work_queue_; 451 DelayedTaskQueue delayed_work_queue_;
452 452
453 // A recent snapshot of Time::Now(), used to check delayed_work_queue_. 453 // A recent snapshot of Time::Now(), used to check delayed_work_queue_.
454 base::Time recent_time_; 454 base::TimeTicks recent_time_;
455 455
456 // A queue of non-nestable tasks that we had to defer because when it came 456 // A queue of non-nestable tasks that we had to defer because when it came
457 // time to execute them we were in a nested message loop. They will execute 457 // time to execute them we were in a nested message loop. They will execute
458 // once we're out of nested message loops. 458 // once we're out of nested message loops.
459 TaskQueue deferred_non_nestable_work_queue_; 459 TaskQueue deferred_non_nestable_work_queue_;
460 460
461 scoped_refptr<base::MessagePump> pump_; 461 scoped_refptr<base::MessagePump> pump_;
462 462
463 ObserverList<DestructionObserver> destruction_observers_; 463 ObserverList<DestructionObserver> destruction_observers_;
464 464
(...skipping 144 matching lines...) Expand 10 before | Expand all | Expand 10 after
609 #endif // defined(OS_POSIX) 609 #endif // defined(OS_POSIX)
610 }; 610 };
611 611
612 // Do not add any member variables to MessageLoopForIO! This is important b/c 612 // Do not add any member variables to MessageLoopForIO! This is important b/c
613 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra 613 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra
614 // data that you need should be stored on the MessageLoop's pump_ instance. 614 // data that you need should be stored on the MessageLoop's pump_ instance.
615 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO), 615 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO),
616 MessageLoopForIO_should_not_have_extra_member_variables); 616 MessageLoopForIO_should_not_have_extra_member_variables);
617 617
618 #endif // BASE_MESSAGE_LOOP_H_ 618 #endif // BASE_MESSAGE_LOOP_H_
OLDNEW
« no previous file with comments | « no previous file | base/message_loop.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698