Make automation proxy objects to ref_counted. That allows to process async no...

chrome/test/automation/tab_proxy.cc

 // Copyright (c) 2006-2008 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/test/automation/tab_proxy.h"
 
 #include <algorithm>
 
 #include "base/logging.h"
 #include "chrome/common/json_value_serializer.h"
@@ skipping 319 matching lines @@
 
   if (!count) {
     NOTREACHED();
     return false;
   }
 
   return sender_->Send(new AutomationMsg_ConstrainedWindowCount(
       0, handle_, count));
 }
 
-ConstrainedWindowProxy* TabProxy::GetConstrainedWindow(
+scoped_refptr<ConstrainedWindowProxy> TabProxy::GetConstrainedWindow(
     int window_index) const {
   if (!is_valid())
     return NULL;
 
   int handle = 0;
-  if (sender_->Send(new AutomationMsg_ConstrainedWindow(0, handle_,
+  if (!sender_->Send(new AutomationMsg_ConstrainedWindow(0, handle_,
                                                         window_index,
-                                                        &handle))) {
-    return new ConstrainedWindowProxy(sender_, tracker_, handle);
+                                                        &handle)))
+    return NULL;
+  
+  if (handle == 0)
+    return NULL;
+
+  ConstrainedWindowProxy* w = static_cast<ConstrainedWindowProxy*>(
+      tracker_->GetResource(handle));
+  if (!w) {
+    w = new ConstrainedWindowProxy(sender_, tracker_, handle);
+    w->AddRef();
   }
 
-  return NULL;
+  // Since there is no scoped_refptr::attach.
+  scoped_refptr<ConstrainedWindowProxy> result;
+  result.swap(&w);
+  return result;
 }
 
 bool TabProxy::WaitForChildWindowCountToChange(int count, int* new_count,
                                                int wait_timeout) {
   int intervals = std::min(wait_timeout/automation::kSleepTime, 1);
   for (int i = 0; i < intervals; ++i) {
     PlatformThread::Sleep(automation::kSleepTime);
     bool succeeded = GetConstrainedWindowCount(new_count);
     if (!succeeded) return false;
     if (count != *new_count) return true;
@@ skipping 267 matching lines @@
   params.top = top;
   params.width = width;
   params.height = height;
   params.flags = flags;
   params.set_parent = (::IsWindow(parent_window) ? true : false);
   params.parent_window = parent_window;
   sender_->Send(new AutomationMsg_TabReposition(0, handle_, params));
 }
 
 #endif  // defined(OS_WIN)
+
+void TabProxy::AddObserver(TabProxyDelegate* observer) {
+  AutoLock lock(list_lock_);
+  observers_list_.AddObserver(observer);
+}
+
+void TabProxy::RemoveObserver(TabProxyDelegate* observer) {
+  AutoLock lock(list_lock_);
+  observers_list_.RemoveObserver(observer);
+}
+
+// Called on Channel background thread, if TabMessages filter is installed.
+void TabProxy::OnMessageReceived(const IPC::Message& message) {
+  AutoLock lock(list_lock_);
+  FOR_EACH_OBSERVER(TabProxyDelegate, observers_list_,
+                    OnMessageReceived(this, message));
+}