diff options
author | brettw@chromium.org <brettw@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2011-08-24 15:19:37 +0000 |
---|---|---|
committer | brettw@chromium.org <brettw@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2011-08-24 15:19:37 +0000 |
commit | bbf076f18dbb27fba74de06f4994aa1480690ea3 (patch) | |
tree | 6dcabc6d408c997b18f8762fee0fac8470770fb4 /webkit/plugins/ppapi/ppb_transport_impl.cc | |
parent | 081c03452bb7d97b138bed3ccc7cbe0903eae05c (diff) | |
download | chromium_src-bbf076f18dbb27fba74de06f4994aa1480690ea3.zip chromium_src-bbf076f18dbb27fba74de06f4994aa1480690ea3.tar.gz chromium_src-bbf076f18dbb27fba74de06f4994aa1480690ea3.tar.bz2 |
Remove webkit::ppapi::Resource.
This makes all resource _impl's derive directly from ppapi::Resource so we
can share code better. This means removing PluginInstances and converting
them to PP_Instances.
This adds a new ResourceHelper static class to help in the conversion of
resources to PluginInstances for the _impl classes.
Overall the new code is in general slightly worse than the old because using
the ResourceHelper is more annoying than just calling instance() on the old
webkit::ppapi::Resource object. However, I'm hoping that, because this will
allow us to move more code into shared_impl and reduce duplicate logic, it
will eventually have a net positive effect.
This also adds a ScopedPPResource class that works just like a scoped_refptr. We need this in a few places. Most of the places that used the old ScopedResourceId class could be removed now since resources have PP_Resource IDs generated even when there's no plugin reference (this didn't use to be the case) so we can pass resources as input params to the plugin even when there's no plugin ref, as long as there's a scoped_refptr to the Resource.
Review URL: http://codereview.chromium.org/7669055
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@98047 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'webkit/plugins/ppapi/ppb_transport_impl.cc')
-rw-r--r-- | webkit/plugins/ppapi/ppb_transport_impl.cc | 42 |
1 files changed, 33 insertions, 9 deletions
diff --git a/webkit/plugins/ppapi/ppb_transport_impl.cc b/webkit/plugins/ppapi/ppb_transport_impl.cc index 3048c60..d4ba8df 100644 --- a/webkit/plugins/ppapi/ppb_transport_impl.cc +++ b/webkit/plugins/ppapi/ppb_transport_impl.cc @@ -16,6 +16,7 @@ #include "webkit/plugins/ppapi/common.h" #include "webkit/plugins/ppapi/plugin_module.h" #include "webkit/plugins/ppapi/ppapi_plugin_instance.h" +#include "webkit/plugins/ppapi/resource_helper.h" using ppapi::StringVar; using ppapi::thunk::PPB_Transport_API; @@ -47,7 +48,7 @@ int MapNetError(int result) { } // namespace -PPB_Transport_Impl::PPB_Transport_Impl(PluginInstance* instance) +PPB_Transport_Impl::PPB_Transport_Impl(PP_Instance instance) : Resource(instance), started_(false), writable_(false), @@ -61,7 +62,7 @@ PPB_Transport_Impl::~PPB_Transport_Impl() { } // static -PP_Resource PPB_Transport_Impl::Create(PluginInstance* instance, +PP_Resource PPB_Transport_Impl::Create(PP_Instance instance, const char* name, const char* proto) { scoped_refptr<PPB_Transport_Impl> t(new PPB_Transport_Impl(instance)); @@ -86,7 +87,10 @@ bool PPB_Transport_Impl::Init(const char* name, const char* proto) { return false; } - p2p_transport_.reset(instance()->delegate()->CreateP2PTransport()); + PluginDelegate* plugin_delegate = ResourceHelper::GetPluginDelegate(this); + if (!plugin_delegate) + return false; + p2p_transport_.reset(plugin_delegate->CreateP2PTransport()); return p2p_transport_.get() != NULL; } @@ -113,8 +117,12 @@ int32_t PPB_Transport_Impl::Connect(PP_CompletionCallback callback) { started_ = true; + PluginModule* plugin_module = ResourceHelper::GetPluginModule(this); + if (!plugin_module) + return PP_ERROR_FAILED; + connect_callback_ = new TrackedCompletionCallback( - instance()->module()->GetCallbackTracker(), pp_resource(), callback); + plugin_module->GetCallbackTracker(), pp_resource(), callback); return PP_OK_COMPLETIONPENDING; } @@ -126,15 +134,19 @@ int32_t PPB_Transport_Impl::GetNextAddress(PP_Var* address, if (next_address_callback_.get() && !next_address_callback_->completed()) return PP_ERROR_INPROGRESS; + PluginModule* plugin_module = ResourceHelper::GetPluginModule(this); + if (!plugin_module) + return PP_ERROR_FAILED; + if (!local_candidates_.empty()) { - *address = StringVar::StringToPPVar(instance()->module()->pp_module(), + *address = StringVar::StringToPPVar(plugin_module->pp_module(), local_candidates_.front()); local_candidates_.pop_front(); return PP_OK; } next_address_callback_ = new TrackedCompletionCallback( - instance()->module()->GetCallbackTracker(), pp_resource(), callback); + plugin_module->GetCallbackTracker(), pp_resource(), callback); return PP_OK_COMPLETIONPENDING; } @@ -162,12 +174,16 @@ int32_t PPB_Transport_Impl::Recv(void* data, uint32_t len, if (!channel) return PP_ERROR_FAILED; + PluginModule* plugin_module = ResourceHelper::GetPluginModule(this); + if (!plugin_module) + return PP_ERROR_FAILED; + scoped_refptr<net::IOBuffer> buffer = new net::WrappedIOBuffer(static_cast<const char*>(data)); int result = MapNetError(channel->Read(buffer, len, &channel_read_callback_)); if (result == PP_OK_COMPLETIONPENDING) { recv_callback_ = new TrackedCompletionCallback( - instance()->module()->GetCallbackTracker(), pp_resource(), callback); + plugin_module->GetCallbackTracker(), pp_resource(), callback); } return result; @@ -185,13 +201,17 @@ int32_t PPB_Transport_Impl::Send(const void* data, uint32_t len, if (!channel) return PP_ERROR_FAILED; + PluginModule* plugin_module = ResourceHelper::GetPluginModule(this); + if (!plugin_module) + return PP_ERROR_FAILED; + scoped_refptr<net::IOBuffer> buffer = new net::WrappedIOBuffer(static_cast<const char*>(data)); int result = MapNetError(channel->Write(buffer, len, &channel_write_callback_)); if (result == PP_OK_COMPLETIONPENDING) { send_callback_ = new TrackedCompletionCallback( - instance()->module()->GetCallbackTracker(), pp_resource(), callback); + plugin_module->GetCallbackTracker(), pp_resource(), callback); } return result; @@ -202,7 +222,11 @@ int32_t PPB_Transport_Impl::Close() { return PP_ERROR_FAILED; p2p_transport_.reset(); - instance()->module()->GetCallbackTracker()->AbortAll(); + + + PluginModule* plugin_module = ResourceHelper::GetPluginModule(this); + if (plugin_module) + plugin_module->GetCallbackTracker()->AbortAll(); return PP_OK; } |