Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(531)

Unified Diff: chrome/browser/chrome_plugin_host.cc

Issue 6576020: Remove Gears from Chrome (Closed) Base URL: http://git.chromium.org/git/chromium.git@trunk
Patch Set: windows fixes Created 9 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « chrome/browser/chrome_plugin_host.h ('k') | chrome/browser/chrome_plugin_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chrome/browser/chrome_plugin_host.cc
diff --git a/chrome/browser/chrome_plugin_host.cc b/chrome/browser/chrome_plugin_host.cc
deleted file mode 100644
index 4c069ab774d8cfad84e6493d31dbe713ff683c69..0000000000000000000000000000000000000000
--- a/chrome/browser/chrome_plugin_host.cc
+++ /dev/null
@@ -1,842 +0,0 @@
-// 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/chrome_plugin_host.h"
-
-#include <set>
-#include <string>
-#include <vector>
-
-#include "base/basictypes.h"
-#include "base/command_line.h"
-#include "base/file_path.h"
-#include "base/file_util.h"
-#include "base/message_loop.h"
-#include "base/metrics/histogram.h"
-#include "base/path_service.h"
-#include "base/perftimer.h"
-#include "base/singleton.h"
-#include "base/string_util.h"
-#include "base/utf_string_conversions.h"
-#include "chrome/browser/browser_list.h"
-#include "chrome/browser/chrome_plugin_browsing_context.h"
-#include "chrome/browser/gears_integration.h"
-#include "chrome/browser/profiles/profile.h"
-#include "chrome/browser/ui/webui/html_dialog_ui.h"
-#include "chrome/common/chrome_constants.h"
-#include "chrome/common/chrome_counters.h"
-#include "chrome/common/chrome_paths.h"
-#include "chrome/common/chrome_plugin_lib.h"
-#include "chrome/common/chrome_plugin_util.h"
-#include "chrome/common/gears_api.h"
-#include "chrome/common/net/url_request_context_getter.h"
-#include "chrome/common/net/url_request_intercept_job.h"
-#include "chrome/common/plugin_messages.h"
-#include "chrome/common/render_messages.h"
-#include "content/browser/browser_thread.h"
-#include "content/browser/plugin_process_host.h"
-#include "content/browser/plugin_service.h"
-#include "content/browser/renderer_host/render_process_host.h"
-#include "content/common/notification_service.h"
-#include "net/base/cookie_monster.h"
-#include "net/base/io_buffer.h"
-#include "net/base/net_errors.h"
-#include "net/http/http_request_headers.h"
-#include "net/url_request/url_request.h"
-#include "net/url_request/url_request_context.h"
-#include "net/url_request/url_request_error_job.h"
-#include "third_party/skia/include/core/SkBitmap.h"
-
-
-using base::TimeDelta;
-
-// This class manages the interception of network requests. It queries the
-// plugin on every request, and creates an intercept job if the plugin can
-// intercept the request.
-// NOTE: All methods must be called on the IO thread.
-class PluginRequestInterceptor
- : public PluginHelper, public net::URLRequest::Interceptor {
- public:
- static net::URLRequestJob* UninterceptedProtocolHandler(
- net::URLRequest* request, const std::string& scheme) {
- // This will get called if a plugin failed to intercept a request for a
- // protocol it has registered. In that case, we return NULL and the request
- // will result in an error.
- return new net::URLRequestErrorJob(request, net::ERR_FILE_NOT_FOUND);
- }
-
- explicit PluginRequestInterceptor(ChromePluginLib* plugin)
- : PluginHelper(plugin) {
- net::URLRequest::RegisterRequestInterceptor(this);
- }
-
- virtual ~PluginRequestInterceptor() {
- net::URLRequest::UnregisterRequestInterceptor(this);
-
- // Unregister our protocols.
- for (HandledProtocolList::iterator it = registered_protocols_.begin();
- it != registered_protocols_.end(); ++it) {
- net::URLRequest::ProtocolFactory* factory =
- net::URLRequest::RegisterProtocolFactory(*it, NULL);
- DCHECK(factory == UninterceptedProtocolHandler);
- }
- }
-
- void RegisterProtocol(const std::string& scheme) {
- DCHECK(CalledOnValidThread());
-
- std::string lower_scheme = StringToLowerASCII(scheme);
- handled_protocols_.insert(lower_scheme);
-
- // Only add a protocol factory if the net::URLRequest doesn't already handle
- // it. If we fail to intercept, the request will be treated as an error.
- if (!net::URLRequest::IsHandledProtocol(lower_scheme)) {
- registered_protocols_.insert(lower_scheme);
- net::URLRequest::RegisterProtocolFactory(lower_scheme,
- &UninterceptedProtocolHandler);
- }
- }
-
- // net::URLRequest::Interceptor
- virtual net::URLRequestJob* MaybeIntercept(net::URLRequest* request) {
- // TODO(darin): This DCHECK fails in the unit tests because our interceptor
- // is being persisted across unit tests. As a result, each time we get
- // poked on a different thread, but never from more than one thread at a
- // time. We need a way to have the URLRequestJobManager get reset between
- // unit tests.
- // DCHECK(CalledOnValidThread());
-
- if (!IsHandledProtocol(request->url().scheme()))
- return NULL;
-
- CPBrowsingContext context =
- CPBrowsingContextManager::GetInstance()->Lookup(request->context());
- scoped_ptr<ScopableCPRequest> cprequest(
- new ScopableCPRequest(request->url().spec().c_str(),
- request->method().c_str(),
- context));
-
- PerfTimer timer;
- if (!plugin_->functions().should_intercept_request(cprequest.get())) {
- LogInterceptMissTime(timer.Elapsed());
- return NULL;
- }
- LogInterceptHitTime(timer.Elapsed());
- return new URLRequestInterceptJob(request, plugin_, cprequest.release());
- }
-
- private:
- bool IsHandledProtocol(const std::string& scheme) {
- return handled_protocols_.find(scheme) != handled_protocols_.end();
- }
-
- void LogInterceptHitTime(const TimeDelta& time) {
- UMA_HISTOGRAM_TIMES("Gears.InterceptHit", time);
- }
-
- void LogInterceptMissTime(const TimeDelta& time) {
- UMA_HISTOGRAM_TIMES("Gears.InterceptMiss", time);
- }
-
- typedef std::set<std::string> HandledProtocolList;
- HandledProtocolList handled_protocols_;
- HandledProtocolList registered_protocols_;
-};
-
-// This class manages a network request made by the plugin, also acting as
-// the net::URLRequest delegate.
-// NOTE: All methods must be called on the IO thread.
-class PluginRequestHandler : public PluginHelper,
- public net::URLRequest::Delegate {
- public:
- static PluginRequestHandler* FromCPRequest(CPRequest* request) {
- return ScopableCPRequest::GetData<PluginRequestHandler*>(request);
- }
-
- PluginRequestHandler(ChromePluginLib* plugin, ScopableCPRequest* cprequest)
- : PluginHelper(plugin), cprequest_(cprequest), user_buffer_(NULL) {
- cprequest_->data = this; // see FromCPRequest().
-
- net::URLRequestContext* context = CPBrowsingContextManager::GetInstance()->
- ToURLRequestContext(cprequest_->context);
- // TODO(mpcomplete): remove fallback case when Gears support is prevalent.
- if (!context)
- context = Profile::GetDefaultRequestContext()->GetURLRequestContext();
-
- GURL gurl(cprequest_->url);
- request_.reset(new net::URLRequest(gurl, this));
- request_->set_context(context);
- request_->set_method(cprequest_->method);
- request_->set_load_flags(PluginResponseUtils::CPLoadFlagsToNetFlags(0));
- }
-
- net::URLRequest* request() { return request_.get(); }
-
- // Wraper of net::URLRequest::Read()
- bool Read(char* dest, int dest_size, int *bytes_read) {
- CHECK(!my_buffer_.get());
- // We'll use our own buffer until the read actually completes.
- user_buffer_ = dest;
- my_buffer_ = new net::IOBuffer(dest_size);
-
- if (request_->Read(my_buffer_, dest_size, bytes_read)) {
- memcpy(dest, my_buffer_->data(), *bytes_read);
- my_buffer_ = NULL;
- return true;
- }
-
- if (!request_->status().is_io_pending())
- my_buffer_ = NULL;
-
- return false;
- }
-
- // net::URLRequest::Delegate
- virtual void OnReceivedRedirect(net::URLRequest* request, const GURL& new_url,
- bool* defer_redirect) {
- plugin_->functions().response_funcs->received_redirect(
- cprequest_.get(), new_url.spec().c_str());
- }
-
- virtual void OnResponseStarted(net::URLRequest* request) {
- // TODO(mpcomplete): better error codes
- CPError result =
- request_->status().is_success() ? CPERR_SUCCESS : CPERR_FAILURE;
- plugin_->functions().response_funcs->start_completed(
- cprequest_.get(), result);
- }
-
- virtual void OnReadCompleted(net::URLRequest* request, int bytes_read) {
- CHECK(my_buffer_.get());
- CHECK(user_buffer_);
- if (bytes_read > 0) {
- memcpy(user_buffer_, my_buffer_->data(), bytes_read);
- } else if (bytes_read < 0) {
- // TODO(mpcomplete): better error codes
- bytes_read = CPERR_FAILURE;
- }
- my_buffer_ = NULL;
- plugin_->functions().response_funcs->read_completed(
- cprequest_.get(), bytes_read);
- }
-
- private:
- scoped_ptr<ScopableCPRequest> cprequest_;
- scoped_ptr<net::URLRequest> request_;
- scoped_refptr<net::IOBuffer> my_buffer_;
- char* user_buffer_;
-};
-
-// This class manages plugins that want to handle UI commands. Right now, we
-// only allow 1 plugin to do this, so there's only ever 1 instance of this
-// class at once.
-// NOTE: All methods must be called on the IO thread.
-class PluginCommandHandler : public PluginHelper {
- public:
- static void HandleCommand(int command,
- CPCommandInterface* data,
- int32 context_as_int32) {
- CPBrowsingContext context =
- static_cast<CPBrowsingContext>(context_as_int32);
- // Ensure plugins are loaded before we try to talk to it. This will be a
- // noop if plugins are loaded already.
- ChromePluginLib::LoadChromePlugins(GetCPBrowserFuncsForBrowser());
-
- DCHECK(ChromePluginLib::IsPluginThread());
- CPError rv = CPERR_INVALID_VERSION;
- if (instance_ && instance_->plugin_->functions().handle_command) {
- rv = instance_->plugin_->functions().handle_command(
- context, command, data ? data->GetData() : NULL);
- }
- if (data)
- data->OnCommandInvoked(rv);
- }
-
- static void RegisterPlugin(ChromePluginLib* plugin) {
- DCHECK(ChromePluginLib::IsPluginThread());
- // TODO(mpcomplete): We only expect to have Gears register a command handler
- // at the moment. We should either add support for other plugins to do
- // this, or verify that the plugin is Gears.
- DCHECK(!instance_) <<
- "We only support a single plugin handling UI commands.";
- if (instance_)
- return;
- // Deleted in response to a notification in PluginHelper.
- new PluginCommandHandler(plugin);
- }
-
- private:
- explicit PluginCommandHandler(ChromePluginLib* plugin)
- : PluginHelper(plugin) {
- DCHECK(instance_ == NULL);
- instance_ = this;
- }
-
- virtual ~PluginCommandHandler() {
- instance_ = NULL;
- }
-
- static PluginCommandHandler* instance_;
-};
-
-PluginCommandHandler* PluginCommandHandler::instance_ = NULL;
-
-// This class acts as a helper to display the HTML dialog. It is created
-// on demand on the plugin thread, and proxies calls to and from the UI thread
-// to display the UI.
-class ModelessHtmlDialogDelegate : public HtmlDialogUIDelegate {
- public:
- ModelessHtmlDialogDelegate(const GURL& url,
- int width, int height,
- const std::string& json_arguments,
- void* plugin_context,
- ChromePluginLib* plugin,
- MessageLoop* main_message_loop,
- gfx::NativeWindow parent_wnd)
- : main_message_loop_(main_message_loop),
- io_message_loop_(MessageLoop::current()),
- plugin_(plugin),
- plugin_context_(plugin_context),
- parent_wnd_(parent_wnd) {
- DCHECK(ChromePluginLib::IsPluginThread());
- params_.url = url;
- params_.height = height;
- params_.width = width;
- params_.json_input = json_arguments;
-
- main_message_loop_->PostTask(FROM_HERE, NewRunnableMethod(
- this, &ModelessHtmlDialogDelegate::Show));
- }
- virtual ~ModelessHtmlDialogDelegate() {
- DCHECK(ChromePluginLib::IsPluginThread());
- }
-
- // The following public methods are called from the UI thread.
-
- // HtmlDialogUIDelegate implementation:
- virtual bool IsDialogModal() const { return false; }
- virtual std::wstring GetDialogTitle() const { return L"Gears"; }
- virtual GURL GetDialogContentURL() const { return params_.url; }
- virtual void GetWebUIMessageHandlers(
- std::vector<WebUIMessageHandler*>* handlers) const {}
- virtual void GetDialogSize(gfx::Size* size) const {
- size->set_width(params_.width);
- size->set_height(params_.height);
- }
- virtual std::string GetDialogArgs() const { return params_.json_input; }
- virtual void OnDialogClosed(const std::string& json_retval) {
- io_message_loop_->PostTask(FROM_HERE, NewRunnableMethod(
- this, &ModelessHtmlDialogDelegate::ReportResults, json_retval));
- }
- virtual void OnCloseContents(TabContents* source, bool* out_close_dialog) { }
- virtual bool ShouldShowDialogTitle() const { return true; }
-
- private:
- // Actually shows the dialog on the UI thread.
- void Show() {
- DCHECK(MessageLoop::current() == main_message_loop_);
- Browser* browser = BrowserList::GetLastActive();
- browser->BrowserShowHtmlDialog(this, parent_wnd_);
- }
-
- // Gives the JSON result string back to the plugin.
- void ReportResults(const std::string& json_retval) {
- DCHECK(MessageLoop::current() == io_message_loop_);
- // The plugin may have unloaded before it was time to report the results.
- if (plugin_->is_loaded())
- plugin_->functions().html_dialog_closed(plugin_context_,
- json_retval.c_str());
- delete this;
- }
-
- // The parameters needed to display a modal HTML dialog.
- HtmlDialogUI::HtmlDialogParams params_;
-
- // Message loops for sending messages between UI and IO threads.
- MessageLoop* main_message_loop_;
- MessageLoop* io_message_loop_;
-
- // The plugin object that requested the dialog. This can only be accessed on
- // the IO thread.
- scoped_refptr<ChromePluginLib> plugin_;
-
- // The plugin's context argument to CPB_ShowHtmlDialog.
- void* plugin_context_;
-
- // The window this dialog box should be parented to, or NULL for the last
- // active browser window.
- gfx::NativeWindow parent_wnd_;
-
- DISALLOW_COPY_AND_ASSIGN(ModelessHtmlDialogDelegate);
-};
-
-// Allows InvokeLater without adding refcounting. The object is only deleted
-// when its last InvokeLater is run anyway.
-DISABLE_RUNNABLE_METHOD_REFCOUNT(ModelessHtmlDialogDelegate);
-
-namespace {
-
-//
-// Generic functions
-//
-
-void STDCALL CPB_SetKeepProcessAlive(CPID id, CPBool keep_alive) {
- // This is a no-op in the main browser process
-}
-
-CPError STDCALL CPB_GetCookies(CPID id, CPBrowsingContext bcontext,
- const char* url, char** cookies) {
- CHECK(ChromePluginLib::IsPluginThread());
- net::URLRequestContext* context = CPBrowsingContextManager::GetInstance()->
- ToURLRequestContext(bcontext);
- // TODO(mpcomplete): remove fallback case when Gears support is prevalent.
- if (!context) {
- context = Profile::GetDefaultRequestContext()->GetURLRequestContext();
- if (!context)
- return CPERR_FAILURE;
- }
- std::string cookies_str = context->cookie_store()->GetCookies(GURL(url));
- *cookies = CPB_StringDup(CPB_Alloc, cookies_str);
- return CPERR_SUCCESS;
-}
-
-CPError STDCALL CPB_ShowHtmlDialogModal(
- CPID id, CPBrowsingContext context, const char* url, int width, int height,
- const char* json_arguments, char** json_retval) {
- // Should not be called in browser process.
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_ShowHtmlDialog(
- CPID id, CPBrowsingContext context, const char* url, int width, int height,
- const char* json_arguments, void* plugin_context) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
-#if defined(OS_WIN)
- HWND parent_hwnd = reinterpret_cast<HWND>(static_cast<uintptr_t>(context));
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return CPERR_FAILURE;
- MessageLoop* main_message_loop = service->main_message_loop();
- ModelessHtmlDialogDelegate* delegate =
- new ModelessHtmlDialogDelegate(GURL(url), width, height, json_arguments,
- plugin_context, plugin, main_message_loop,
- parent_hwnd);
-#else
- // TODO(port): port ModelessHtmlDialogDelegate
- NOTIMPLEMENTED();
-#endif
-
- return CPERR_SUCCESS;
-}
-
-CPError STDCALL CPB_GetCommandLineArguments(
- CPID id, CPBrowsingContext context, const char* url, char** arguments) {
- CHECK(ChromePluginLib::IsPluginThread());
- std::string arguments_str;
- CPError rv = CPB_GetCommandLineArgumentsCommon(url, &arguments_str);
- if (rv == CPERR_SUCCESS)
- *arguments = CPB_StringDup(CPB_Alloc, arguments_str);
- return rv;
-}
-
-CPBrowsingContext STDCALL CPB_GetBrowsingContextFromNPP(struct _NPP* npp) {
- CHECK(ChromePluginLib::IsPluginThread());
- NOTREACHED() << "NPP does not exist in the browser process.";
- return 0;
-}
-
-int STDCALL CPB_GetBrowsingContextInfo(
- CPID id, CPBrowsingContext context, CPBrowsingContextInfoType type,
- void* buf, uint32 buf_size) {
- CHECK(ChromePluginLib::IsPluginThread());
- switch (type) {
- case CPBROWSINGCONTEXT_DATA_DIR_PTR: {
- if (buf_size < sizeof(char*))
- return sizeof(char*);
-
- // TODO(mpcomplete): http://b/1143021 - When we support multiple profiles,
- // fetch the data dir from the context.
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return CPERR_FAILURE;
- FilePath path = service->GetChromePluginDataDir();
- // This is wrong -- we can't in general stuff a path through a std::string.
- // But this code is Gears-specific, so Windows-only anyway for now.
- std::string retval;
-#if defined(OS_WIN)
- retval = WideToUTF8(path.Append(chrome::kChromePluginDataDirname).value());
-#else
- NOTREACHED();
-#endif
- *static_cast<char**>(buf) = CPB_StringDup(CPB_Alloc, retval);
- return CPERR_SUCCESS;
- }
- case CPBROWSINGCONTEXT_UI_LOCALE_PTR: {
- if (buf_size < sizeof(char*))
- return sizeof(char*);
-
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return CPERR_FAILURE;
- const std::string& retval = service->GetUILocale();
- *static_cast<char**>(buf) = CPB_StringDup(CPB_Alloc, retval);
- return CPERR_SUCCESS;
- }
- }
-
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_AddUICommand(CPID id, int command) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
- PluginCommandHandler::RegisterPlugin(plugin);
- return CPERR_SUCCESS;
-}
-
-static void NotifyGearsShortcutsChanged() {
- DCHECK(MessageLoop::current() ==
- PluginService::GetInstance()->main_message_loop());
-
- // TODO(michaeln): source should be the original profile, fix this
- // when gears provides the correct browser context, and when we
- // can relate that to an actual profile.
- NotificationService::current()->Notify(
- NotificationType::WEB_APP_INSTALL_CHANGED,
- Source<Profile>(NULL),
- NotificationService::NoDetails());
-}
-
-CPError STDCALL CPB_HandleCommand(
- CPID id, CPBrowsingContext context, int command, void *data) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
- if (command == GEARSBROWSERCOMMAND_CREATE_SHORTCUT_DONE) {
- GearsCreateShortcutResult* result =
- static_cast<GearsCreateShortcutResult*>(data);
- CHECK(result);
-
- GearsCreateShortcutData* shortcut_data =
- static_cast<GearsCreateShortcutData*>(result->shortcut);
- shortcut_data->command_interface->OnCommandResponse(result->result);
- } else if (command == GEARSBROWSERCOMMAND_NOTIFY_SHORTCUTS_CHANGED) {
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return CPERR_FAILURE;
- service->main_message_loop()->PostTask(FROM_HERE,
- NewRunnableFunction(NotifyGearsShortcutsChanged));
- return CPERR_SUCCESS;
- }
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_GetDragData(
- CPID id, CPBrowsingContext context, struct NPObject* event, bool add_data,
- int32* identity, int32* event_id, char** drag_type, char** drag_data) {
- *identity = *event_id = 0;
- NOTREACHED() << "Should not be called in the browser process.";
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_SetDropEffect(
- CPID id, CPBrowsingContext context, struct NPObject* event, int effect) {
- NOTREACHED() << "Should not be called in the browser process.";
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_AllowFileDrop(
- CPID id, CPBrowsingContext context, const char* file_drag_data) {
- NOTREACHED() << "Should not be called in the browser process.";
- return CPERR_FAILURE;
-}
-
-//
-// Functions related to network interception
-//
-
-void STDCALL CPB_EnableRequestIntercept(CPID id, const char** schemes,
- uint32 num_schemes) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
- if (schemes && num_schemes > 0) {
- PluginRequestInterceptor* interceptor =
- new PluginRequestInterceptor(plugin);
- for (uint32 i = 0; i < num_schemes; ++i)
- interceptor->RegisterProtocol(schemes[i]);
- } else {
- PluginRequestInterceptor::DestroyAllHelpersForPlugin(plugin);
- }
-}
-
-void STDCALL CPRR_ReceivedRedirect(CPRequest* request, const char* new_url) {
-}
-
-void STDCALL CPRR_StartCompleted(CPRequest* request, CPError result) {
- CHECK(ChromePluginLib::IsPluginThread());
- URLRequestInterceptJob* job = URLRequestInterceptJob::FromCPRequest(request);
- CHECK(job);
- job->OnStartCompleted(result);
-}
-
-void STDCALL CPRR_ReadCompleted(CPRequest* request, int bytes_read) {
- CHECK(ChromePluginLib::IsPluginThread());
- URLRequestInterceptJob* job = URLRequestInterceptJob::FromCPRequest(request);
- CHECK(job);
- job->OnReadCompleted(bytes_read);
-}
-
-void STDCALL CPRR_UploadProgress(CPRequest* request, uint64 pos, uint64 size) {
- // Does not apply, plugins do not yet intercept uploads
-}
-
-//
-// Functions related to serving network requests to the plugin
-//
-
-CPError STDCALL CPB_CreateRequest(CPID id, CPBrowsingContext context,
- const char* method, const char* url,
- CPRequest** request) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
- ScopableCPRequest* cprequest = new ScopableCPRequest(url, method, context);
- PluginRequestHandler* handler = new PluginRequestHandler(plugin, cprequest);
- CHECK(handler);
-
- *request = cprequest;
- return CPERR_SUCCESS;
-}
-
-CPError STDCALL CPR_StartRequest(CPRequest* request) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
- handler->request()->Start();
- return CPERR_IO_PENDING;
-}
-
-void STDCALL CPR_EndRequest(CPRequest* request, CPError reason) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- delete handler;
-}
-
-void STDCALL CPR_SetExtraRequestHeaders(CPRequest* request,
- const char* headers) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
- net::HttpRequestHeaders http_headers;
- http_headers.AddHeadersFromString(headers);
- handler->request()->SetExtraRequestHeaders(http_headers);
-}
-
-void STDCALL CPR_SetRequestLoadFlags(CPRequest* request, uint32 flags) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
- uint32 net_flags = PluginResponseUtils::CPLoadFlagsToNetFlags(flags);
- handler->request()->set_load_flags(net_flags);
-}
-
-void STDCALL CPR_AppendDataToUpload(CPRequest* request, const char* bytes,
- int bytes_len) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
- handler->request()->AppendBytesToUpload(bytes, bytes_len);
-}
-
-CPError STDCALL CPR_AppendFileToUpload(CPRequest* request, const char* filepath,
- uint64 offset, uint64 length) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
-
- if (!length) length = kuint64max;
- FilePath path(FilePath::FromWStringHack(UTF8ToWide(filepath)));
- handler->request()->AppendFileRangeToUpload(path, offset, length,
- base::Time());
- return CPERR_SUCCESS;
-}
-
-int STDCALL CPR_GetResponseInfo(CPRequest* request, CPResponseInfoType type,
- void* buf, uint32 buf_size) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
- return PluginResponseUtils::GetResponseInfo(
- handler->request()->response_headers(), type, buf, buf_size);
-}
-
-int STDCALL CPR_Read(CPRequest* request, void* buf, uint32 buf_size) {
- CHECK(ChromePluginLib::IsPluginThread());
- PluginRequestHandler* handler = PluginRequestHandler::FromCPRequest(request);
- CHECK(handler);
-
- int bytes_read;
- if (handler->Read(static_cast<char*>(buf), buf_size, &bytes_read))
- return bytes_read; // 0 == CPERR_SUCESS
-
- if (handler->request()->status().is_io_pending())
- return CPERR_IO_PENDING;
-
- return CPERR_FAILURE;
-}
-
-CPBool STDCALL CPB_IsPluginProcessRunning(CPID id) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return false;
- PluginProcessHost *host = service->FindNpapiPluginProcess(plugin->filename());
- return host ? true : false;
-}
-
-CPProcessType STDCALL CPB_GetProcessType(CPID id) {
- CHECK(ChromePluginLib::IsPluginThread());
- return CP_PROCESS_BROWSER;
-}
-
-CPError STDCALL CPB_SendMessage(CPID id, const void *data, uint32 data_len) {
- CHECK(ChromePluginLib::IsPluginThread());
- ChromePluginLib* plugin = ChromePluginLib::FromCPID(id);
- CHECK(plugin);
-
- PluginService* service = PluginService::GetInstance();
- if (!service)
- return CPERR_FAILURE;
- PluginProcessHost *host =
- service->FindOrStartNpapiPluginProcess(plugin->filename());
- if (!host)
- return CPERR_FAILURE;
-
- const unsigned char* data_ptr = static_cast<const unsigned char*>(data);
- std::vector<uint8> v(data_ptr, data_ptr + data_len);
-#if defined(OS_WIN)
- if (!host->Send(new PluginProcessMsg_PluginMessage(v)))
- return CPERR_FAILURE;
-#else
- // TODO(port): Implement PluginProcessMsg.
- NOTIMPLEMENTED();
-#endif
-
- return CPERR_SUCCESS;
-}
-
-CPError STDCALL CPB_SendSyncMessage(CPID id, const void *data, uint32 data_len,
- void **retval, uint32 *retval_len) {
- NOTREACHED() << "Sync messages should not be sent from the browser process.";
-
- return CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_PluginThreadAsyncCall(CPID id,
- void (*func)(void *),
- void *user_data) {
- bool posted = BrowserThread::PostTask(
- BrowserThread::IO, FROM_HERE,
- NewRunnableFunction(func, user_data));
- return posted ? CPERR_SUCCESS : CPERR_FAILURE;
-}
-
-CPError STDCALL CPB_OpenFileDialog(CPID id,
- CPBrowsingContext context,
- bool multiple_files,
- const char *title,
- const char *filter,
- void *user_data) {
- NOTREACHED() <<
- "Open file dialog should only be called from the renderer process.";
-
- return CPERR_FAILURE;
-}
-
-} // namespace
-
-CPBrowserFuncs* GetCPBrowserFuncsForBrowser() {
- static CPBrowserFuncs browser_funcs;
- static CPRequestFuncs request_funcs;
- static CPResponseFuncs response_funcs;
- static bool initialized = false;
- if (!initialized) {
- initialized = true;
-
- browser_funcs.size = sizeof(browser_funcs);
- browser_funcs.version = CP_VERSION;
- browser_funcs.enable_request_intercept = CPB_EnableRequestIntercept;
- browser_funcs.create_request = CPB_CreateRequest;
- browser_funcs.get_cookies = CPB_GetCookies;
- browser_funcs.alloc = CPB_Alloc;
- browser_funcs.free = CPB_Free;
- browser_funcs.set_keep_process_alive = CPB_SetKeepProcessAlive;
- browser_funcs.show_html_dialog_modal = CPB_ShowHtmlDialogModal;
- browser_funcs.show_html_dialog = CPB_ShowHtmlDialog;
- browser_funcs.is_plugin_process_running = CPB_IsPluginProcessRunning;
- browser_funcs.get_process_type = CPB_GetProcessType;
- browser_funcs.send_message = CPB_SendMessage;
- browser_funcs.get_browsing_context_from_npp = CPB_GetBrowsingContextFromNPP;
- browser_funcs.get_browsing_context_info = CPB_GetBrowsingContextInfo;
- browser_funcs.get_command_line_arguments = CPB_GetCommandLineArguments;
- browser_funcs.add_ui_command = CPB_AddUICommand;
- browser_funcs.handle_command = CPB_HandleCommand;
-
- browser_funcs.request_funcs = &request_funcs;
- browser_funcs.response_funcs = &response_funcs;
- browser_funcs.send_sync_message = CPB_SendSyncMessage;
- browser_funcs.plugin_thread_async_call = CPB_PluginThreadAsyncCall;
- browser_funcs.open_file_dialog = CPB_OpenFileDialog;
- browser_funcs.get_drag_data = CPB_GetDragData;
- browser_funcs.set_drop_effect = CPB_SetDropEffect;
- browser_funcs.allow_file_drop = CPB_AllowFileDrop;
-
- request_funcs.size = sizeof(request_funcs);
- request_funcs.start_request = CPR_StartRequest;
- request_funcs.end_request = CPR_EndRequest;
- request_funcs.set_extra_request_headers = CPR_SetExtraRequestHeaders;
- request_funcs.set_request_load_flags = CPR_SetRequestLoadFlags;
- request_funcs.append_data_to_upload = CPR_AppendDataToUpload;
- request_funcs.get_response_info = CPR_GetResponseInfo;
- request_funcs.read = CPR_Read;
- request_funcs.append_file_to_upload = CPR_AppendFileToUpload;
-
- response_funcs.size = sizeof(response_funcs);
- response_funcs.received_redirect = CPRR_ReceivedRedirect;
- response_funcs.start_completed = CPRR_StartCompleted;
- response_funcs.read_completed = CPRR_ReadCompleted;
- response_funcs.upload_progress = CPRR_UploadProgress;
- }
-
- return &browser_funcs;
-}
-
-void CPCommandInterface::OnCommandInvoked(CPError retval) {
- delete this;
-}
-
-void CPCommandInterface::OnCommandResponse(CPError retval) {}
-
-void CPHandleCommand(int command, CPCommandInterface* data,
- CPBrowsingContext context) {
- // Sadly if we try and pass context through, we seem to break cl's little
- // brain trying to compile the Tuple3 ctor. This cast works.
- int32 context_as_int32 = static_cast<int32>(context);
- // Plugins can only be accessed on the IO thread.
- BrowserThread::PostTask(
- BrowserThread::IO, FROM_HERE,
- NewRunnableFunction(PluginCommandHandler::HandleCommand,
- command, data, context_as_int32));
-}
« no previous file with comments | « chrome/browser/chrome_plugin_host.h ('k') | chrome/browser/chrome_plugin_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698