| Index: ppapi/thunk/ppb_tcp_socket_private_thunk.cc
|
| diff --git a/ppapi/thunk/ppb_tcp_socket_private_thunk.cc b/ppapi/thunk/ppb_tcp_socket_private_thunk.cc
|
| index 9085e9bf55c89a924edf709fe1d622f1fdab42fc..3997d080d1053c0d81607f31279618303f062a40 100644
|
| --- a/ppapi/thunk/ppb_tcp_socket_private_thunk.cc
|
| +++ b/ppapi/thunk/ppb_tcp_socket_private_thunk.cc
|
| @@ -5,7 +5,6 @@
|
| #include "ppapi/c/pp_completion_callback.h"
|
| #include "ppapi/c/pp_errors.h"
|
| #include "ppapi/c/private/ppb_tcp_socket_private.h"
|
| -#include "ppapi/thunk/common.h"
|
| #include "ppapi/thunk/enter.h"
|
| #include "ppapi/thunk/thunk.h"
|
| #include "ppapi/thunk/ppb_tcp_socket_private_api.h"
|
| @@ -16,6 +15,8 @@ namespace thunk {
|
|
|
| namespace {
|
|
|
| +typedef EnterResource<PPB_TCPSocket_Private_API> EnterTCP;
|
| +
|
| PP_Resource Create(PP_Instance instance) {
|
| EnterFunction<ResourceCreationAPI> enter(instance, true);
|
| if (enter.failed())
|
| @@ -24,7 +25,7 @@ PP_Resource Create(PP_Instance instance) {
|
| }
|
|
|
| PP_Bool IsTCPSocket(PP_Resource resource) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(resource, false);
|
| + EnterTCP enter(resource, false);
|
| return PP_FromBool(enter.succeeded());
|
| }
|
|
|
| @@ -32,26 +33,24 @@ int32_t Connect(PP_Resource tcp_socket,
|
| const char* host,
|
| uint16_t port,
|
| PP_CompletionCallback callback) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, callback, true);
|
| if (enter.failed())
|
| - return MayForceCallback(callback, PP_ERROR_BADRESOURCE);
|
| - int32_t result = enter.object()->Connect(host, port, callback);
|
| - return MayForceCallback(callback, result);
|
| + return enter.retval();
|
| + return enter.SetResult(enter.object()->Connect(host, port, callback));
|
| }
|
|
|
| int32_t ConnectWithNetAddress(PP_Resource tcp_socket,
|
| const PP_NetAddress_Private* addr,
|
| PP_CompletionCallback callback) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, callback, true);
|
| if (enter.failed())
|
| - return MayForceCallback(callback, PP_ERROR_BADRESOURCE);
|
| - int32_t result = enter.object()->ConnectWithNetAddress(addr, callback);
|
| - return MayForceCallback(callback, result);
|
| + return enter.retval();
|
| + return enter.SetResult(enter.object()->ConnectWithNetAddress(addr, callback));
|
| }
|
|
|
| PP_Bool GetLocalAddress(PP_Resource tcp_socket,
|
| PP_NetAddress_Private* local_addr) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, true);
|
| if (enter.failed())
|
| return PP_FALSE;
|
| return enter.object()->GetLocalAddress(local_addr);
|
| @@ -59,7 +58,7 @@ PP_Bool GetLocalAddress(PP_Resource tcp_socket,
|
|
|
| PP_Bool GetRemoteAddress(PP_Resource tcp_socket,
|
| PP_NetAddress_Private* remote_addr) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, true);
|
| if (enter.failed())
|
| return PP_FALSE;
|
| return enter.object()->GetRemoteAddress(remote_addr);
|
| @@ -69,38 +68,36 @@ int32_t SSLHandshake(PP_Resource tcp_socket,
|
| const char* server_name,
|
| uint16_t server_port,
|
| PP_CompletionCallback callback) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, callback, true);
|
| if (enter.failed())
|
| - return MayForceCallback(callback, PP_ERROR_BADRESOURCE);
|
| - int32_t result = enter.object()->SSLHandshake(server_name, server_port,
|
| - callback);
|
| - return MayForceCallback(callback, result);
|
| + return enter.retval();
|
| + return enter.SetResult(enter.object()->SSLHandshake(server_name, server_port,
|
| + callback));
|
| }
|
|
|
| int32_t Read(PP_Resource tcp_socket,
|
| char* buffer,
|
| int32_t bytes_to_read,
|
| PP_CompletionCallback callback) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, callback, true);
|
| if (enter.failed())
|
| - return MayForceCallback(callback, PP_ERROR_BADRESOURCE);
|
| - int32_t result = enter.object()->Read(buffer, bytes_to_read, callback);
|
| - return MayForceCallback(callback, result);
|
| + return enter.retval();
|
| + return enter.SetResult(enter.object()->Read(buffer, bytes_to_read, callback));
|
| }
|
|
|
| int32_t Write(PP_Resource tcp_socket,
|
| const char* buffer,
|
| int32_t bytes_to_write,
|
| PP_CompletionCallback callback) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, callback, true);
|
| if (enter.failed())
|
| - return MayForceCallback(callback, PP_ERROR_BADRESOURCE);
|
| - int32_t result = enter.object()->Write(buffer, bytes_to_write, callback);
|
| - return MayForceCallback(callback, result);
|
| + return enter.retval();
|
| + return enter.SetResult(enter.object()->Write(buffer, bytes_to_write,
|
| + callback));
|
| }
|
|
|
| void Disconnect(PP_Resource tcp_socket) {
|
| - EnterResource<PPB_TCPSocket_Private_API> enter(tcp_socket, true);
|
| + EnterTCP enter(tcp_socket, true);
|
| if (enter.succeeded())
|
| enter.object()->Disconnect();
|
| }
|
|
|