[chromedriver] Implement reconnection to DevTools.

chrome/test/chromedriver/net/sync_websocket_impl.h

 // 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.
 
 #ifndef CHROME_TEST_CHROMEDRIVER_NET_SYNC_WEBSOCKET_IMPL_H_
 #define CHROME_TEST_CHROMEDRIVER_NET_SYNC_WEBSOCKET_IMPL_H_
 
 #include <list>
 #include <string>
 
@@ skipping 17 matching lines @@
 }
 
 class GURL;
 
 class SyncWebSocketImpl : public SyncWebSocket {
  public:
   explicit SyncWebSocketImpl(net::URLRequestContextGetter* context_getter);
   virtual ~SyncWebSocketImpl();
 
   // Overridden from SyncWebSocket:
+  virtual bool IsConnected() OVERRIDE;
   virtual bool Connect(const GURL& url) OVERRIDE;
   virtual bool Send(const std::string& message) OVERRIDE;
   virtual bool ReceiveNextMessage(std::string* message) OVERRIDE;
   virtual bool HasNextMessage() OVERRIDE;
 
  private:
   struct CoreTraits;
   class Core : public WebSocketListener,
                public base::RefCountedThreadSafe<Core, CoreTraits> {
    public:
     explicit Core(net::URLRequestContextGetter* context_getter);
 
+    bool IsConnected();
+
     bool Connect(const GURL& url);
 
     bool Send(const std::string& message);
 
     bool ReceiveNextMessage(std::string* message);
 
     bool HasNextMessage();
 
     // Overriden from WebSocketListener:
     virtual void OnMessageReceived(const std::string& message) OVERRIDE;
@@ skipping 20 matching lines @@
     void OnDestruct() const;
 
     scoped_refptr<net::URLRequestContextGetter> context_getter_;
 
     // Only accessed on IO thread.
     scoped_ptr<WebSocket> socket_;
 
     base::Lock lock_;
 
     // Protected by |lock_|.
-    bool closed_;
+    bool is_connected_;
 
     // Protected by |lock_|.
     std::list<std::string> received_queue_;
 
     // Protected by |lock_|.
     // Signaled when the socket closes or a message is received.
     base::ConditionVariable on_update_event_;
   };
 
   scoped_refptr<Core> core_;
 };
 
 struct SyncWebSocketImpl::CoreTraits {
   static void Destruct(const SyncWebSocketImpl::Core* core) {
     core->OnDestruct();
   }
 };
 
 #endif  // CHROME_TEST_CHROMEDRIVER_NET_SYNC_WEBSOCKET_IMPL_H_