PPAPI: Force async callback invocation option.

ppapi/proxy/ppb_flash_net_connector_proxy.cc

 // 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 "ppapi/proxy/ppb_flash_net_connector_proxy.h"
 
 #include <algorithm>
 
 #include "ppapi/c/pp_errors.h"
 #include "ppapi/c/private/ppb_flash_net_connector.h"
 #include "ppapi/proxy/plugin_dispatcher.h"
 #include "ppapi/proxy/plugin_resource.h"
 #include "ppapi/proxy/ppapi_messages.h"
 #include "ppapi/proxy/serialized_var.h"
+#include "ppapi/thunk/common.h"
 
 namespace pp {
 namespace proxy {
 
 std::string NetAddressToString(const PP_Flash_NetAddress& addr) {
   return std::string(addr.data, std::min(static_cast<size_t>(addr.size),
                                          sizeof(addr.data)));
 }
 
 void StringToNetAddress(const std::string& str, PP_Flash_NetAddress* addr) {
@@ skipping 136 matching lines @@
 int32_t ConnectTcp(PP_Resource connector_id,
                    const char* host,
                    uint16_t port,
                    PP_FileHandle* socket_out,
                    struct PP_Flash_NetAddress* local_addr_out,
                    struct PP_Flash_NetAddress* remote_addr_out,
                    struct PP_CompletionCallback callback) {
   FlashNetConnector* object =
       PluginResource::GetAs<FlashNetConnector>(connector_id);
   if (!object)
-    return PP_ERROR_BADARGUMENT;
-  return ConnectWithMessage(
+    return ppapi::thunk::MayForceCallback(callback, PP_ERROR_BADARGUMENT);
+  int32_t result = ConnectWithMessage(
       object,
       new PpapiHostMsg_PPBFlashNetConnector_ConnectTcp(
           INTERFACE_ID_PPB_FLASH_NETCONNECTOR,
           object->host_resource(), host, port),
       socket_out, local_addr_out, remote_addr_out, callback);
+  return ppapi::thunk::MayForceCallback(callback, result);
 }
 
 int32_t ConnectTcpAddress(PP_Resource connector_id,
                           const struct PP_Flash_NetAddress* addr,
                           PP_FileHandle* socket_out,
                           struct PP_Flash_NetAddress* local_addr_out,
                           struct PP_Flash_NetAddress* remote_addr_out,
                           struct PP_CompletionCallback callback) {
   FlashNetConnector* object =
       PluginResource::GetAs<FlashNetConnector>(connector_id);
   if (!object)
-    return PP_ERROR_BADARGUMENT;
-  return ConnectWithMessage(
+    return ppapi::thunk::MayForceCallback(callback, PP_ERROR_BADARGUMENT);
+  int32_t result = ConnectWithMessage(
       object,
       new PpapiHostMsg_PPBFlashNetConnector_ConnectTcpAddress(
           INTERFACE_ID_PPB_FLASH_NETCONNECTOR,
           object->host_resource(), NetAddressToString(*addr)),
       socket_out, local_addr_out, remote_addr_out, callback);
+  return ppapi::thunk::MayForceCallback(callback, result);
 }
 
 const PPB_Flash_NetConnector flash_netconnector_interface = {
   &Create,
   &IsFlashNetConnector,
   &ConnectTcp,
   &ConnectTcpAddress
 };
 
 InterfaceProxy* CreateFlashNetConnectorProxy(Dispatcher* dispatcher,
@@ skipping 125 matching lines @@
   } else {
     dispatcher()->Send(new PpapiMsg_PPBFlashNetConnector_ConnectACK(
         INTERFACE_ID_PPB_FLASH_NETCONNECTOR,
         info->resource, result,
         IPC::InvalidPlatformFileForTransit(), std::string(), std::string()));
   }
 }
 
 }  // namespace proxy
 }  // namespace pp