Add an observer interface for DriveScheduler.

chrome/browser/chromeos/drive/drive_scheduler.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/chromeos/drive/drive_scheduler.h"
 
 #include <math.h>
 
 #include "base/message_loop.h"
 #include "base/prefs/pref_service.h"
@@ skipping 12 matching lines @@
 
 namespace {
 const int kMaxThrottleCount = 5;
 }
 
 const int DriveScheduler::kMaxJobCount[] = {
   5,  // METADATA_QUEUE
   1,  // FILE_QUEUE
 };
 
-DriveScheduler::JobInfo::JobInfo(JobType in_job_type)
-    : job_type(in_job_type),
-      job_id(-1),
-      completed_bytes(0),
-      total_bytes(0),
-      state(STATE_NONE) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-}
-
 DriveScheduler::QueueEntry::QueueEntry()
     : job_id(-1),
       context(DriveClientContext(USER_INITIATED)) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 }
 
 DriveScheduler::QueueEntry::~QueueEntry() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 }
 
 bool DriveScheduler::QueueEntry::Compare(
     const DriveScheduler::QueueEntry* left,
     const DriveScheduler::QueueEntry* right) {
   return (left->context.type < right->context.type);
 }
 
 DriveScheduler::DriveScheduler(
     Profile* profile,
     google_apis::DriveServiceInterface* drive_service)
-    : next_job_id_(0),
-      throttle_count_(0),
+    : throttle_count_(0),
       disable_throttling_(false),
       drive_service_(drive_service),
       uploader_(new google_apis::DriveUploader(drive_service)),
       profile_(profile),
       initialized_(false),
       weak_ptr_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   for (int i = 0; i < NUM_QUEUES; ++i) {
     jobs_running_[i] = 0;
   }
@@ skipping 22 matching lines @@
 
   // Initialize() may be called more than once for the lifetime when the
   // file system is remounted.
   if (initialized_)
     return;
 
   net::NetworkChangeNotifier::AddConnectionTypeObserver(this);
   initialized_ = true;
 }
 
+std::vector<JobInfo> DriveScheduler::GetJobInfoList() {
+  std::vector<JobInfo> job_info_list;
+  for (JobIDMap::iterator iter(&job_map_); !iter.IsAtEnd(); iter.Advance())
+    job_info_list.push_back(*iter.GetCurrentValue());
+  return job_info_list;
+}
+
+void DriveScheduler::AddObserver(JobListObserver* observer) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  observer_list_.AddObserver(observer);
+}
+
+void DriveScheduler::RemoveObserver(JobListObserver* observer) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  observer_list_.RemoveObserver(observer);
+}
+
 void DriveScheduler::GetAccountMetadata(
     const google_apis::GetAccountMetadataCallback& callback) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   DCHECK(!callback.is_null());
 
   scoped_ptr<QueueEntry> new_job(new QueueEntry);
   new_job->get_account_metadata_callback = callback;
 
   StartNewJob(new_job.Pass(), TYPE_GET_ACCOUNT_METADATA);
 }
@@ skipping 775 matching lines @@
 
     case TYPE_DOWNLOAD_FILE:
     case TYPE_UPLOAD_NEW_FILE:
     case TYPE_UPLOAD_EXISTING_FILE:
       return FILE_QUEUE;
   }
   NOTREACHED();
   return FILE_QUEUE;
 }
 
+void DriveScheduler::NotifyJobAdded(const JobInfo& job_info) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  FOR_EACH_OBSERVER(JobListObserver, observer_list_, OnJobAdded(job_info));
+}
+
+void DriveScheduler::NotifyJobDone(const JobInfo& job_info) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  FOR_EACH_OBSERVER(JobListObserver, observer_list_, OnJobDone(job_info));
+}
+
+void DriveScheduler::NotifyJobUpdated(const JobInfo& job_info) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  FOR_EACH_OBSERVER(JobListObserver, observer_list_, OnJobUpdated(job_info));
+}
+
 }  // namespace drive