[chromedriver] Apply page load timeout to slow cross-process navigations

chrome/test/chromedriver/chrome/devtools_client_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_CHROME_DEVTOOLS_CLIENT_IMPL_H_
 #define CHROME_TEST_CHROMEDRIVER_CHROME_DEVTOOLS_CLIENT_IMPL_H_
 
 #include <list>
 #include <map>
 #include <string>
@@ skipping 69 matching lines @@
 
   void SetParserFuncForTesting(const ParserFunc& parser_func);
 
   // Overridden from DevToolsClient:
   const std::string& GetId() override;
   bool WasCrashed() override;
   Status ConnectIfNecessary() override;
   Status SendCommand(
       const std::string& method,
       const base::DictionaryValue& params) override;
+  Status SendCommandWithTimeout(
+      const std::string& method,
+      const base::DictionaryValue& params,
+      const Timeout* timeout) override;
   Status SendAsyncCommand(
       const std::string& method,
       const base::DictionaryValue& params) override;
   Status SendCommandAndGetResult(
       const std::string& method,
       const base::DictionaryValue& params,
       scoped_ptr<base::DictionaryValue>* result) override;
+  Status SendCommandAndGetResultWithTimeout(
+      const std::string& method,
+      const base::DictionaryValue& params,
+      const Timeout* timeout,
+      scoped_ptr<base::DictionaryValue>* result) override;
   void AddListener(DevToolsEventListener* listener) override;
   Status HandleEventsUntil(const ConditionalFunc& conditional_func,
-                           const base::TimeDelta& timeout) override;
+                           const Timeout& timeout) override;
   Status HandleReceivedEvents() override;
 
  private:
   enum ResponseState {
     // The client is waiting for the response.
     kWaiting,
     // The command response will not be received because it is blocked by an
     // alert that the command triggered.
     kBlocked,
     // The client no longer cares about the response.
     kIgnored,
     // The response has been received.
     kReceived
   };
   struct ResponseInfo {
     explicit ResponseInfo(const std::string& method);
     ~ResponseInfo();
 
     ResponseState state;
     std::string method;
     internal::InspectorCommandResponse response;
   };
   typedef std::map<int, linked_ptr<ResponseInfo> > ResponseInfoMap;
 
   Status SendCommandInternal(
       const std::string& method,
       const base::DictionaryValue& params,
       scoped_ptr<base::DictionaryValue>* result,
-      bool wait_for_response);
-  Status ProcessNextMessage(int expected_id, const base::TimeDelta& timeout);
+      bool wait_for_response,
+      const Timeout* timeout);
+  Status ProcessNextMessage(int expected_id, const Timeout& timeout);
   Status ProcessEvent(const internal::InspectorEvent& event);
   Status ProcessCommandResponse(
       const internal::InspectorCommandResponse& response);
   Status EnsureListenersNotifiedOfConnect();
   Status EnsureListenersNotifiedOfEvent();
   Status EnsureListenersNotifiedOfCommandResponse();
 
   scoped_ptr<SyncWebSocket> socket_;
   GURL url_;
   bool crashed_;
@@ skipping 18 matching lines @@
 bool ParseInspectorMessage(
     const std::string& message,
     int expected_id,
     InspectorMessageType* type,
     InspectorEvent* event,
     InspectorCommandResponse* command_response);
 
 }  // namespace internal
 
 #endif  // CHROME_TEST_CHROMEDRIVER_CHROME_DEVTOOLS_CLIENT_IMPL_H_