Add WorkerPool::PostTaskAndReply and use in DHCP code.

net/proxy/dhcp_proxy_script_adapter_fetcher_win.h

 // Copyright (c) 2011 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.
 
 #ifndef NET_PROXY_DHCP_SCRIPT_ADAPTER_FETCHER_WIN_H_
 #define NET_PROXY_DHCP_SCRIPT_ADAPTER_FETCHER_WIN_H_
 #pragma once
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 89 matching lines @@
   enum State {
     STATE_START,
     STATE_WAIT_DHCP,
     STATE_WAIT_URL,
     STATE_FINISH,
     STATE_CANCEL,
   };
 
   State state() const;
 
-  // This inner class is used to encapsulate the worker thread, which has
-  // only a weak reference back to the main object, so that the main object
-  // can be destroyed before the thread ends.  This also keeps the main
-  // object completely thread safe and allows it to be non-refcounted.
-  //
-  // TODO(joi): Replace with PostTaskAndReply once http://crbug.com/86301
-  // has been implemented.
-  class NET_EXPORT_PRIVATE WorkerThread
-      : public base::RefCountedThreadSafe<WorkerThread> {
+  // This inner class encapsulates work done on a worker pool thread.
+  // By using a separate object, we can keep the main object completely
+  // thread safe and let it be non-refcounted.
+  class NET_EXPORT_PRIVATE DhcpQuery
+      : public base::RefCountedThreadSafe<DhcpQuery> {
    public:
-    // Creates and initializes (but does not start) the worker thread.
-    explicit WorkerThread(
-        const base::WeakPtr<DhcpProxyScriptAdapterFetcher>& owner);
-    virtual ~WorkerThread();
+    DhcpQuery();
+    virtual ~DhcpQuery();
 
-    // Starts the worker thread, fetching information for |adapter_name| using
-    // |get_pac_from_url_func|.
-    void Start(const std::string& adapter_name);
+    // This method should run on a worker pool thread, via PostTaskAndReply.
+    // After it has run, the |url()| method on this object will return the
+    // URL retrieved.
+    void GetPacURLForAdapter(const std::string& adapter_name);
+
+    // Returns the URL retrieved for the given adapter, once the task has run.
+    std::string url() const;
 
    protected:
     // Virtual method introduced to allow unit testing.
     virtual std::string ImplGetPacURLFromDhcp(const std::string& adapter_name);
 
    private:
-    // This is the method that runs on the worker thread.
-    void ThreadFunc(const std::string& adapter_name);
+    // The URL retrieved for the given adapter.
+    std::string url_;
 
-    // Callback for the above; this executes back on the main thread,
-    // not the worker thread.
-    void OnThreadDone(const std::string& url);
-
-    // All work except ThreadFunc and (sometimes) destruction should occur
-    // on the thread that constructs the object.
-    base::ThreadChecker thread_checker_;
-
-    // May only be accessed on the thread that constructs the object.
-    base::WeakPtr<DhcpProxyScriptAdapterFetcher> owner_;
-
-    // Used by worker thread to post a message back to the original
-    // thread.  Fine to use a proxy since in the case where the original
-    // thread has gone away, that would mean the |owner_| object is gone
-    // anyway, so there is nobody to receive the result.
-    scoped_refptr<base::MessageLoopProxy> origin_loop_;
-
-    DISALLOW_COPY_AND_ASSIGN(WorkerThread);
+    DISALLOW_COPY_AND_ASSIGN(DhcpQuery);
   };
 
   // Virtual methods introduced to allow unit testing.
   virtual ProxyScriptFetcher* ImplCreateScriptFetcher();
-  virtual WorkerThread* ImplCreateWorkerThread(
-      const base::WeakPtr<DhcpProxyScriptAdapterFetcher>& owner);
+  virtual DhcpQuery* ImplCreateDhcpQuery();
   virtual base::TimeDelta ImplGetTimeout() const;
 
  private:
   // Event/state transition handlers
-  void OnQueryDhcpDone(const std::string& url);
+  void OnDhcpQueryDone(scoped_refptr<DhcpQuery> dhcp_query);
   void OnTimeout();
   void OnFetcherDone(int result);
   void TransitionToFinish();
 
   // Current state of this state machine.
   State state_;
 
   // A network error indicating result of operation.
   int result_;
 
   // Empty string or the PAC script downloaded.
   string16 pac_script_;
 
   // Empty URL or the PAC URL configured in DHCP.
   GURL pac_url_;
 
   // Callback to let our client know we're done. Invalid in states
   // START, FINISH and CANCEL.
   OldCompletionCallback* callback_;
 
-  // Container for our worker thread. NULL if not currently running.
-  scoped_refptr<WorkerThread> worker_thread_;
-
   // Fetcher to retrieve PAC files once URL is known.
   scoped_ptr<ProxyScriptFetcher> script_fetcher_;
 
   // Callback from the script fetcher.
   OldCompletionCallbackImpl<DhcpProxyScriptAdapterFetcher>
       script_fetcher_callback_;
 
   // Implements a timeout on the call to the Win32 DHCP API.
   base::OneShotTimer<DhcpProxyScriptAdapterFetcher> wait_timer_;
 
   scoped_refptr<URLRequestContext> url_request_context_;
 
   DISALLOW_IMPLICIT_CONSTRUCTORS(DhcpProxyScriptAdapterFetcher);
 };
 
 }  // namespace net
 
 #endif  // NET_PROXY_DHCP_SCRIPT_ADAPTER_FETCHER_WIN_H_