// 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. #include "chrome/browser/renderer_host/save_file_resource_handler.h" #include "base/logging.h" #include "base/message_loop.h" #include "base/string_number_conversions.h" #include "chrome/browser/download/save_file_manager.h" #include "content/browser/browser_thread.h" #include "net/base/io_buffer.h" #include "net/url_request/url_request_status.h" SaveFileResourceHandler::SaveFileResourceHandler(int render_process_host_id, int render_view_id, const GURL& url, SaveFileManager* manager) : save_id_(-1), render_process_id_(render_process_host_id), render_view_id_(render_view_id), url_(url), content_length_(0), save_manager_(manager) { } bool SaveFileResourceHandler::OnUploadProgress(int request_id, uint64 position, uint64 size) { return true; } bool SaveFileResourceHandler::OnRequestRedirected(int request_id, const GURL& url, ResourceResponse* response, bool* defer) { final_url_ = url; return true; } bool SaveFileResourceHandler::OnResponseStarted(int request_id, ResourceResponse* response) { save_id_ = save_manager_->GetNextId(); // |save_manager_| consumes (deletes): SaveFileCreateInfo* info = new SaveFileCreateInfo; info->url = url_; info->final_url = final_url_; info->total_bytes = content_length_; info->save_id = save_id_; info->render_process_id = render_process_id_; info->render_view_id = render_view_id_; info->request_id = request_id; info->content_disposition = content_disposition_; info->save_source = SaveFileCreateInfo::SAVE_FILE_FROM_NET; BrowserThread::PostTask( BrowserThread::FILE, FROM_HERE, NewRunnableMethod(save_manager_, &SaveFileManager::StartSave, info)); return true; } bool SaveFileResourceHandler::OnWillStart(int request_id, const GURL& url, bool* defer) { return true; } bool SaveFileResourceHandler::OnWillRead(int request_id, net::IOBuffer** buf, int* buf_size, int min_size) { DCHECK(buf && buf_size); if (!read_buffer_) { *buf_size = min_size < 0 ? kReadBufSize : min_size; read_buffer_ = new net::IOBuffer(*buf_size); } *buf = read_buffer_.get(); return true; } bool SaveFileResourceHandler::OnReadCompleted(int request_id, int* bytes_read) { DCHECK(read_buffer_); // We are passing ownership of this buffer to the save file manager. scoped_refptr<net::IOBuffer> buffer; read_buffer_.swap(buffer); BrowserThread::PostTask( BrowserThread::FILE, FROM_HERE, NewRunnableMethod(save_manager_, &SaveFileManager::UpdateSaveProgress, save_id_, buffer, *bytes_read)); return true; } bool SaveFileResourceHandler::OnResponseCompleted( int request_id, const net::URLRequestStatus& status, const std::string& security_info) { BrowserThread::PostTask( BrowserThread::FILE, FROM_HERE, NewRunnableMethod(save_manager_, &SaveFileManager::SaveFinished, save_id_, url_, render_process_id_, status.is_success() && !status.is_io_pending())); read_buffer_ = NULL; return true; } void SaveFileResourceHandler::OnRequestClosed() { } void SaveFileResourceHandler::set_content_length( const std::string& content_length) { base::StringToInt64(content_length, &content_length_); } SaveFileResourceHandler::~SaveFileResourceHandler() {}