| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <signal.h> | 5 #include <signal.h> |
| 6 #include <stdlib.h> | 6 #include <stdlib.h> |
| 7 | 7 |
| 8 #if defined(OS_WIN) | 8 #if defined(OS_WIN) |
| 9 #include <windows.h> | 9 #include <windows.h> |
| 10 #endif | 10 #endif |
| 11 | 11 |
| 12 #include <iostream> | 12 #include <iostream> |
| 13 #include <fstream> | 13 #include <fstream> |
| 14 | 14 |
| 15 #include "base/at_exit.h" | 15 #include "base/at_exit.h" |
| 16 #include "base/command_line.h" | 16 #include "base/command_line.h" |
| 17 #include "base/file_path.h" | 17 #include "base/file_path.h" |
| 18 #include "base/file_util.h" | 18 #include "base/file_util.h" |
| 19 #include "base/logging.h" | 19 #include "base/logging.h" |
| 20 #include "base/memory/scoped_ptr.h" | 20 #include "base/memory/scoped_ptr.h" |
| 21 #include "base/string_number_conversions.h" | 21 #include "base/string_number_conversions.h" |
| 22 #include "base/string_split.h" | 22 #include "base/string_split.h" |
| 23 #include "base/string_util.h" | 23 #include "base/string_util.h" |
| 24 #include "base/synchronization/waitable_event.h" | 24 #include "base/synchronization/waitable_event.h" |
| 25 #include "base/test/test_timeouts.h" | 25 #include "base/test/test_timeouts.h" |
| 26 #include "base/threading/platform_thread.h" | 26 #include "base/threading/platform_thread.h" |
| 27 #include "base/utf_string_conversions.h" | 27 #include "base/utf_string_conversions.h" |
| 28 #include "chrome/common/chrome_paths.h" | 28 #include "chrome/common/chrome_paths.h" |
| 29 #include "chrome/common/chrome_switches.h" | 29 #include "chrome/common/chrome_switches.h" |
| 30 #include "chrome/test/webdriver/dispatch.h" | |
| 31 #include "chrome/test/webdriver/session_manager.h" | |
| 32 #include "chrome/test/webdriver/utility_functions.h" | |
| 33 #include "chrome/test/webdriver/commands/alert_commands.h" | 30 #include "chrome/test/webdriver/commands/alert_commands.h" |
| 34 #include "chrome/test/webdriver/commands/cookie_commands.h" | 31 #include "chrome/test/webdriver/commands/cookie_commands.h" |
| 35 #include "chrome/test/webdriver/commands/create_session.h" | 32 #include "chrome/test/webdriver/commands/create_session.h" |
| 36 #include "chrome/test/webdriver/commands/execute_async_script_command.h" | 33 #include "chrome/test/webdriver/commands/execute_async_script_command.h" |
| 37 #include "chrome/test/webdriver/commands/execute_command.h" | 34 #include "chrome/test/webdriver/commands/execute_command.h" |
| 38 #include "chrome/test/webdriver/commands/find_element_commands.h" | 35 #include "chrome/test/webdriver/commands/find_element_commands.h" |
| 39 #include "chrome/test/webdriver/commands/navigate_commands.h" | 36 #include "chrome/test/webdriver/commands/navigate_commands.h" |
| 40 #include "chrome/test/webdriver/commands/mouse_commands.h" | 37 #include "chrome/test/webdriver/commands/mouse_commands.h" |
| 41 #include "chrome/test/webdriver/commands/screenshot_command.h" | 38 #include "chrome/test/webdriver/commands/screenshot_command.h" |
| 42 #include "chrome/test/webdriver/commands/session_with_id.h" | 39 #include "chrome/test/webdriver/commands/session_with_id.h" |
| 43 #include "chrome/test/webdriver/commands/set_timeout_commands.h" | 40 #include "chrome/test/webdriver/commands/set_timeout_commands.h" |
| 44 #include "chrome/test/webdriver/commands/source_command.h" | 41 #include "chrome/test/webdriver/commands/source_command.h" |
| 45 #include "chrome/test/webdriver/commands/target_locator_commands.h" | 42 #include "chrome/test/webdriver/commands/target_locator_commands.h" |
| 46 #include "chrome/test/webdriver/commands/title_command.h" | 43 #include "chrome/test/webdriver/commands/title_command.h" |
| 47 #include "chrome/test/webdriver/commands/url_command.h" | 44 #include "chrome/test/webdriver/commands/url_command.h" |
| 48 #include "chrome/test/webdriver/commands/webelement_commands.h" | 45 #include "chrome/test/webdriver/commands/webelement_commands.h" |
| 46 #include "chrome/test/webdriver/dispatch.h" |
| 47 #include "chrome/test/webdriver/session_manager.h" |
| 48 #include "chrome/test/webdriver/utility_functions.h" |
| 49 #include "chrome/test/webdriver/webdriver_logging.h" |
| 49 #include "third_party/mongoose/mongoose.h" | 50 #include "third_party/mongoose/mongoose.h" |
| 50 | 51 |
| 51 #if defined(OS_WIN) | 52 #if defined(OS_WIN) |
| 52 #include <time.h> | 53 #include <time.h> |
| 53 #elif defined(OS_POSIX) | 54 #elif defined(OS_POSIX) |
| 54 #include <errno.h> | 55 #include <errno.h> |
| 55 #include <sys/time.h> | 56 #include <sys/time.h> |
| 56 #include <sys/types.h> | 57 #include <sys/types.h> |
| 57 #include <sys/wait.h> | 58 #include <sys/wait.h> |
| 58 #endif | 59 #endif |
| 59 | 60 |
| 60 namespace webdriver { | 61 namespace webdriver { |
| 61 | 62 |
| 62 void InitCallbacks(struct mg_context* ctx, Dispatcher* dispatcher, | 63 void InitCallbacks(struct mg_context* ctx, Dispatcher* dispatcher, |
| 63 base::WaitableEvent* shutdown_event, | 64 base::WaitableEvent* shutdown_event, |
| 64 bool forbid_other_requests) { | 65 bool forbid_other_requests) { |
| 65 dispatcher->AddShutdown("/shutdown", shutdown_event); | 66 dispatcher->AddShutdown("/shutdown", shutdown_event); |
| 66 dispatcher->AddStatus("/healthz"); | 67 dispatcher->AddHealthz("/healthz"); |
| 68 dispatcher->AddLog("/log"); |
| 67 | 69 |
| 68 dispatcher->Add<CreateSession>("/session"); | 70 dispatcher->Add<CreateSession>("/session"); |
| 69 | 71 |
| 70 // WebElement commands | 72 // WebElement commands |
| 71 dispatcher->Add<FindOneElementCommand>( "/session/*/element"); | 73 dispatcher->Add<FindOneElementCommand>( "/session/*/element"); |
| 72 dispatcher->Add<FindManyElementsCommand>("/session/*/elements"); | 74 dispatcher->Add<FindManyElementsCommand>("/session/*/elements"); |
| 73 dispatcher->Add<ActiveElementCommand>( "/session/*/element/active"); | 75 dispatcher->Add<ActiveElementCommand>( "/session/*/element/active"); |
| 74 dispatcher->Add<FindOneElementCommand>( "/session/*/element/*/element"); | 76 dispatcher->Add<FindOneElementCommand>( "/session/*/element/*/element"); |
| 75 dispatcher->Add<FindManyElementsCommand>("/session/*/elements/*/elements"); | 77 dispatcher->Add<FindManyElementsCommand>("/session/*/elements/*/elements"); |
| 76 dispatcher->Add<ElementAttributeCommand>("/session/*/element/*/attribute/*"); | 78 dispatcher->Add<ElementAttributeCommand>("/session/*/element/*/attribute/*"); |
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 136 // Since the /session/* is a wild card that would match the above URIs, this | 138 // Since the /session/* is a wild card that would match the above URIs, this |
| 137 // line MUST be after all other webdriver command callbacks. | 139 // line MUST be after all other webdriver command callbacks. |
| 138 dispatcher->Add<SessionWithID>("/session/*"); | 140 dispatcher->Add<SessionWithID>("/session/*"); |
| 139 | 141 |
| 140 if (forbid_other_requests) | 142 if (forbid_other_requests) |
| 141 dispatcher->ForbidAllOtherRequests(); | 143 dispatcher->ForbidAllOtherRequests(); |
| 142 } | 144 } |
| 143 | 145 |
| 144 } // namespace webdriver | 146 } // namespace webdriver |
| 145 | 147 |
| 146 // Initializes logging for ChromeDriver. | |
| 147 void InitChromeDriverLogging(const CommandLine& command_line) { | |
| 148 bool success = InitLogging( | |
| 149 FILE_PATH_LITERAL("chromedriver.log"), | |
| 150 logging::LOG_TO_BOTH_FILE_AND_SYSTEM_DEBUG_LOG, | |
| 151 logging::LOCK_LOG_FILE, | |
| 152 logging::DELETE_OLD_LOG_FILE, | |
| 153 logging::DISABLE_DCHECK_FOR_NON_OFFICIAL_RELEASE_BUILDS); | |
| 154 if (!success) { | |
| 155 PLOG(ERROR) << "Unable to initialize logging"; | |
| 156 } | |
| 157 logging::SetLogItems(false, // enable_process_id | |
| 158 false, // enable_thread_id | |
| 159 true, // enable_timestamp | |
| 160 false); // enable_tickcount | |
| 161 if (command_line.HasSwitch(switches::kLoggingLevel)) { | |
| 162 std::string log_level = command_line.GetSwitchValueASCII( | |
| 163 switches::kLoggingLevel); | |
| 164 int level = 0; | |
| 165 if (base::StringToInt(log_level, &level)) { | |
| 166 logging::SetMinLogLevel(level); | |
| 167 } else { | |
| 168 LOG(WARNING) << "Bad log level: " << log_level; | |
| 169 } | |
| 170 } | |
| 171 } | |
| 172 | |
| 173 // Configures mongoose according to the given command line flags. | 148 // Configures mongoose according to the given command line flags. |
| 174 // Returns true on success. | 149 // Returns true on success. |
| 175 bool SetMongooseOptions(struct mg_context* ctx, | 150 bool SetMongooseOptions(struct mg_context* ctx, |
| 176 const std::string& port, | 151 const std::string& port, |
| 177 const std::string& root) { | 152 const std::string& root) { |
| 178 if (!mg_set_option(ctx, "ports", port.c_str())) { | 153 if (!mg_set_option(ctx, "ports", port.c_str())) { |
| 179 std::cout << "ChromeDriver cannot bind to port (" | 154 std::cout << "ChromeDriver cannot bind to port (" |
| 180 << port.c_str() << ")" << std::endl; | 155 << port.c_str() << ")" << std::endl; |
| 181 return false; | 156 return false; |
| 182 } | 157 } |
| (...skipping 19 matching lines...) Expand all Loading... |
| 202 | 177 |
| 203 #if defined(OS_POSIX) | 178 #if defined(OS_POSIX) |
| 204 signal(SIGPIPE, SIG_IGN); | 179 signal(SIGPIPE, SIG_IGN); |
| 205 #endif | 180 #endif |
| 206 srand((unsigned int)time(NULL)); | 181 srand((unsigned int)time(NULL)); |
| 207 | 182 |
| 208 // Register Chrome's path provider so that the AutomationProxy will find our | 183 // Register Chrome's path provider so that the AutomationProxy will find our |
| 209 // built Chrome. | 184 // built Chrome. |
| 210 chrome::RegisterPathProvider(); | 185 chrome::RegisterPathProvider(); |
| 211 TestTimeouts::Initialize(); | 186 TestTimeouts::Initialize(); |
| 212 InitChromeDriverLogging(*cmd_line); | |
| 213 | 187 |
| 214 // Parse command line flags. | 188 // Parse command line flags. |
| 215 std::string port = "9515"; | 189 std::string port = "9515"; |
| 216 std::string root; | 190 std::string root; |
| 217 std::string url_base; | 191 std::string url_base; |
| 192 bool verbose = false; |
| 218 if (cmd_line->HasSwitch("port")) | 193 if (cmd_line->HasSwitch("port")) |
| 219 port = cmd_line->GetSwitchValueASCII("port"); | 194 port = cmd_line->GetSwitchValueASCII("port"); |
| 220 // The 'root' flag allows the user to specify a location to serve files from. | 195 // The 'root' flag allows the user to specify a location to serve files from. |
| 221 // If it is not given, a callback will be registered to forbid all file | 196 // If it is not given, a callback will be registered to forbid all file |
| 222 // requests. | 197 // requests. |
| 223 if (cmd_line->HasSwitch("root")) | 198 if (cmd_line->HasSwitch("root")) |
| 224 root = cmd_line->GetSwitchValueASCII("root"); | 199 root = cmd_line->GetSwitchValueASCII("root"); |
| 225 if (cmd_line->HasSwitch("url-base")) | 200 if (cmd_line->HasSwitch("url-base")) |
| 226 url_base = cmd_line->GetSwitchValueASCII("url-base"); | 201 url_base = cmd_line->GetSwitchValueASCII("url-base"); |
| 202 // Whether or not to do verbose logging. |
| 203 if (cmd_line->HasSwitch("verbose")) |
| 204 verbose = true; |
| 205 |
| 206 webdriver::InitWebDriverLogging( |
| 207 verbose ? logging::LOG_INFO : logging::LOG_WARNING); |
| 227 | 208 |
| 228 webdriver::SessionManager* manager = webdriver::SessionManager::GetInstance(); | 209 webdriver::SessionManager* manager = webdriver::SessionManager::GetInstance(); |
| 229 manager->set_port(port); | 210 manager->set_port(port); |
| 230 manager->set_url_base(url_base); | 211 manager->set_url_base(url_base); |
| 231 | 212 |
| 232 // Initialize SHTTPD context. | 213 // Initialize SHTTPD context. |
| 233 // Listen on port 9515 or port specified on command line. | 214 // Listen on port 9515 or port specified on command line. |
| 234 // TODO(jmikhail) Maybe add port 9516 as a secure connection. | 215 // TODO(jmikhail) Maybe add port 9516 as a secure connection. |
| 235 ctx = mg_start(); | 216 ctx = mg_start(); |
| 236 if (!SetMongooseOptions(ctx, port, root)) { | 217 if (!SetMongooseOptions(ctx, port, root)) { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 256 | 237 |
| 257 // Run until we receive command to shutdown. | 238 // Run until we receive command to shutdown. |
| 258 shutdown_event.Wait(); | 239 shutdown_event.Wait(); |
| 259 | 240 |
| 260 // We should not reach here since the service should never quit. | 241 // We should not reach here since the service should never quit. |
| 261 // TODO(jmikhail): register a listener for SIGTERM and break the | 242 // TODO(jmikhail): register a listener for SIGTERM and break the |
| 262 // message loop gracefully. | 243 // message loop gracefully. |
| 263 mg_stop(ctx); | 244 mg_stop(ctx); |
| 264 return (EXIT_SUCCESS); | 245 return (EXIT_SUCCESS); |
| 265 } | 246 } |
| OLD | NEW |