Chromium Code Reviews| Index: headless/app/headless_shell.cc |
| diff --git a/headless/app/headless_shell.cc b/headless/app/headless_shell.cc |
| index 942fb9bbad7084131d5f94af51c8bdb28cc6e313..e03c6e9ca00d6fbb5b813ec97866585d034c57f3 100644 |
| --- a/headless/app/headless_shell.cc |
| +++ b/headless/app/headless_shell.cc |
| @@ -11,6 +11,7 @@ |
| #include "base/callback.h" |
| #include "base/command_line.h" |
| #include "base/files/file_path.h" |
| +#include "base/files/file_proxy.h" |
| #include "base/json/json_writer.h" |
| #include "base/location.h" |
| #include "base/memory/ptr_util.h" |
| @@ -26,6 +27,7 @@ |
| #include "headless/public/headless_browser.h" |
| #include "headless/public/headless_devtools_client.h" |
| #include "headless/public/headless_devtools_target.h" |
| +#include "headless/public/headless_shell.h" |
| #include "headless/public/headless_web_contents.h" |
| #include "headless/public/util/deterministic_dispatcher.h" |
| #include "headless/public/util/deterministic_http_protocol_handler.h" |
| @@ -102,7 +104,11 @@ class HeadlessShell : public HeadlessWebContents::Observer, |
| // TODO(alexclarke): Should we navigate to about:blank first if using |
| // virtual time? |
| if (args.empty()) |
| +#if defined(OS_WIN) |
| + args.push_back(L"about:blank"); |
| +#else |
| args.push_back("about:blank"); |
| +#endif |
| for (auto it = args.rbegin(); it != args.rend(); ++it) { |
| GURL url(*it); |
| HeadlessWebContents* web_contents = builder.SetInitialURL(url).Build(); |
| @@ -319,28 +325,26 @@ class HeadlessShell : public HeadlessWebContents::Observer, |
| file_name = base::FilePath().AppendASCII(kDefaultScreenshotFileName); |
| } |
| - screenshot_file_stream_.reset( |
| - new net::FileStream(browser_->BrowserFileThread())); |
| - const int open_result = screenshot_file_stream_->Open( |
| - file_name, base::File::FLAG_CREATE_ALWAYS | base::File::FLAG_WRITE | |
| - base::File::FLAG_ASYNC, |
| - base::Bind(&HeadlessShell::OnScreenshotFileOpened, |
| - weak_factory_.GetWeakPtr(), base::Passed(std::move(result)), |
| - file_name)); |
| - if (open_result != net::ERR_IO_PENDING) { |
| + screenshot_file_proxy_.reset( |
| + new base::FileProxy(browser_->BrowserFileThread().get())); |
| + if (!screenshot_file_proxy_->CreateOrOpen( |
| + file_name, base::File::FLAG_CREATE_ALWAYS | base::File::FLAG_WRITE, |
| + base::Bind(&HeadlessShell::OnScreenshotFileOpened, |
| + weak_factory_.GetWeakPtr(), base::Passed(&result), |
|
Sami
2017/02/09 17:51:40
nit: Could you keep this base::Passed(std::move(re
dvallet
2017/02/10 05:29:49
Done
|
| + file_name))) { |
| // Operation could not be started. |
| - OnScreenshotFileOpened(nullptr, file_name, open_result); |
| + OnScreenshotFileOpened(nullptr, file_name, base::File::FILE_ERROR_FAILED); |
| } |
| } |
| void OnScreenshotFileOpened( |
| std::unique_ptr<page::CaptureScreenshotResult> result, |
| const base::FilePath file_name, |
| - const int open_result) { |
| - if (open_result != net::OK) { |
| + base::File::Error error_code) { |
| + if (!screenshot_file_proxy_->IsValid()) { |
| LOG(ERROR) << "Writing screenshot to file " << file_name.value() |
| << " was unsuccessful, could not open file: " |
| - << net::ErrorToString(open_result); |
| + << base::File::ErrorToString(error_code); |
| return; |
| } |
| @@ -349,19 +353,21 @@ class HeadlessShell : public HeadlessWebContents::Observer, |
| scoped_refptr<net::IOBufferWithSize> buf = |
| new net::IOBufferWithSize(decoded_png.size()); |
| memcpy(buf->data(), decoded_png.data(), decoded_png.size()); |
| - const int write_result = screenshot_file_stream_->Write( |
| - buf.get(), buf->size(), |
| - base::Bind(&HeadlessShell::OnScreenshotFileWritten, |
| - weak_factory_.GetWeakPtr(), file_name, buf->size())); |
| - if (write_result != net::ERR_IO_PENDING) { |
| + |
| + if (!screenshot_file_proxy_->Write( |
| + 0, buf->data(), buf->size(), |
| + base::Bind(&HeadlessShell::OnScreenshotFileWritten, |
| + weak_factory_.GetWeakPtr(), file_name, buf->size()))) { |
| // Operation may have completed successfully or failed. |
| - OnScreenshotFileWritten(file_name, buf->size(), write_result); |
| + OnScreenshotFileWritten(file_name, buf->size(), |
| + base::File::FILE_ERROR_FAILED, 0); |
| } |
| } |
| void OnScreenshotFileWritten(const base::FilePath file_name, |
| const int length, |
| - const int write_result) { |
| + base::File::Error error_code, |
| + int write_result) { |
| if (write_result < length) { |
| // TODO(eseckler): Support recovering from partial writes. |
| LOG(ERROR) << "Writing screenshot to file " << file_name.value() |
| @@ -370,15 +376,15 @@ class HeadlessShell : public HeadlessWebContents::Observer, |
| LOG(INFO) << "Screenshot written to file " << file_name.value() << "." |
| << std::endl; |
| } |
| - int close_result = screenshot_file_stream_->Close(base::Bind( |
| - &HeadlessShell::OnScreenshotFileClosed, weak_factory_.GetWeakPtr())); |
| - if (close_result != net::ERR_IO_PENDING) { |
| + if (!screenshot_file_proxy_->Close( |
| + base::Bind(&HeadlessShell::OnScreenshotFileClosed, |
| + weak_factory_.GetWeakPtr()))) { |
| // Operation could not be started. |
| - OnScreenshotFileClosed(close_result); |
| + OnScreenshotFileClosed(base::File::FILE_ERROR_FAILED); |
| } |
| } |
| - void OnScreenshotFileClosed(const int close_result) { Shutdown(); } |
| + void OnScreenshotFileClosed(base::File::Error error_code) { Shutdown(); } |
| bool RemoteDebuggingEnabled() const { |
| const base::CommandLine& command_line = |
| @@ -392,7 +398,7 @@ class HeadlessShell : public HeadlessWebContents::Observer, |
| std::unique_ptr<HeadlessDevToolsClient> devtools_client_; |
| HeadlessWebContents* web_contents_; |
| bool processed_page_ready_; |
| - std::unique_ptr<net::FileStream> screenshot_file_stream_; |
| + std::unique_ptr<base::FileProxy> screenshot_file_proxy_; |
| HeadlessBrowserContext* browser_context_; |
| std::unique_ptr<DeterministicDispatcher> deterministic_dispatcher_; |
| base::WeakPtrFactory<HeadlessShell> weak_factory_; |