ppapi/thunk/ppb_websocket_thunk.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 // From ppb_websocket.idl modified Tue Aug 20 08:13:36 2013.
   6
   7 #include "ppapi/c/pp_completion_callback.h"
   8 #include "ppapi/c/pp_errors.h"
   9 #include "ppapi/c/ppb_websocket.h"
  10 #include "ppapi/shared_impl/tracked_callback.h"
  11 #include "ppapi/thunk/enter.h"
  12 #include "ppapi/thunk/ppapi_thunk_export.h"
  13 #include "ppapi/thunk/ppb_websocket_api.h"
  14
  15 namespace ppapi {
  16 namespace thunk {
  17
  18 namespace {
  19
  20 PP_Resource Create(PP_Instance instance) {
  21   VLOG(4) << "PPB_WebSocket::Create()";
  22   EnterResourceCreation enter(instance);
  23   if (enter.failed())
  24     return 0;
  25   return enter.functions()->CreateWebSocket(instance);
  26 }
  27
  28 PP_Bool IsWebSocket(PP_Resource resource) {
  29   VLOG(4) << "PPB_WebSocket::IsWebSocket()";
  30   EnterResource<PPB_WebSocket_API> enter(resource, false);
  31   return PP_FromBool(enter.succeeded());
  32 }
  33
  34 int32_t Connect(PP_Resource web_socket,
  35                 struct PP_Var url,
  36                 const struct PP_Var protocols[],
  37                 uint32_t protocol_count,
  38                 struct PP_CompletionCallback callback) {
  39   VLOG(4) << "PPB_WebSocket::Connect()";
  40   EnterResource<PPB_WebSocket_API> enter(web_socket, callback, false);
  41   if (enter.failed())
  42     return enter.retval();
  43   return enter.SetResult(enter.object()->Connect(url,
  44                                                  protocols,
  45                                                  protocol_count,
  46                                                  enter.callback()));
  47 }
  48
  49 int32_t Close(PP_Resource web_socket,
  50               uint16_t code,
  51               struct PP_Var reason,
  52               struct PP_CompletionCallback callback) {
  53   VLOG(4) << "PPB_WebSocket::Close()";
  54   EnterResource<PPB_WebSocket_API> enter(web_socket, callback, false);
  55   if (enter.failed())
  56     return enter.retval();
  57   return enter.SetResult(enter.object()->Close(code, reason, enter.callback()));
  58 }
  59
  60 int32_t ReceiveMessage(PP_Resource web_socket,
  61                        struct PP_Var* message,
  62                        struct PP_CompletionCallback callback) {
  63   VLOG(4) << "PPB_WebSocket::ReceiveMessage()";
  64   EnterResource<PPB_WebSocket_API> enter(web_socket, callback, false);
  65   if (enter.failed())
  66     return enter.retval();
  67   return enter.SetResult(enter.object()->ReceiveMessage(message,
  68                                                         enter.callback()));
  69 }
  70
  71 int32_t SendMessage(PP_Resource web_socket, struct PP_Var message) {
  72   VLOG(4) << "PPB_WebSocket::SendMessage()";
  73   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
  74   if (enter.failed())
  75     return enter.retval();
  76   return enter.object()->SendMessage(message);
  77 }
  78
  79 uint64_t GetBufferedAmount(PP_Resource web_socket) {
  80   VLOG(4) << "PPB_WebSocket::GetBufferedAmount()";
  81   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
  82   if (enter.failed())
  83     return 0;
  84   return enter.object()->GetBufferedAmount();
  85 }
  86
  87 uint16_t GetCloseCode(PP_Resource web_socket) {
  88   VLOG(4) << "PPB_WebSocket::GetCloseCode()";
  89   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
  90   if (enter.failed())
  91     return 0;
  92   return enter.object()->GetCloseCode();
  93 }
  94
  95 struct PP_Var GetCloseReason(PP_Resource web_socket) {
  96   VLOG(4) << "PPB_WebSocket::GetCloseReason()";
  97   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
  98   if (enter.failed())
  99     return PP_MakeUndefined();
 100   return enter.object()->GetCloseReason();
 101 }
 102
 103 PP_Bool GetCloseWasClean(PP_Resource web_socket) {
 104   VLOG(4) << "PPB_WebSocket::GetCloseWasClean()";
 105   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
 106   if (enter.failed())
 107     return PP_FALSE;
 108   return enter.object()->GetCloseWasClean();
 109 }
 110
 111 struct PP_Var GetExtensions(PP_Resource web_socket) {
 112   VLOG(4) << "PPB_WebSocket::GetExtensions()";
 113   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
 114   if (enter.failed())
 115     return PP_MakeUndefined();
 116   return enter.object()->GetExtensions();
 117 }
 118
 119 struct PP_Var GetProtocol(PP_Resource web_socket) {
 120   VLOG(4) << "PPB_WebSocket::GetProtocol()";
 121   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
 122   if (enter.failed())
 123     return PP_MakeUndefined();
 124   return enter.object()->GetProtocol();
 125 }
 126
 127 PP_WebSocketReadyState GetReadyState(PP_Resource web_socket) {
 128   VLOG(4) << "PPB_WebSocket::GetReadyState()";
 129   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
 130   if (enter.failed())
 131     return PP_WEBSOCKETREADYSTATE_INVALID;
 132   return enter.object()->GetReadyState();
 133 }
 134
 135 struct PP_Var GetURL(PP_Resource web_socket) {
 136   VLOG(4) << "PPB_WebSocket::GetURL()";
 137   EnterResource<PPB_WebSocket_API> enter(web_socket, false);
 138   if (enter.failed())
 139     return PP_MakeUndefined();
 140   return enter.object()->GetURL();
 141 }
 142
 143 const PPB_WebSocket_1_0 g_ppb_websocket_thunk_1_0 = {
 144   &Create,
 145   &IsWebSocket,
 146   &Connect,
 147   &Close,
 148   &ReceiveMessage,
 149   &SendMessage,
 150   &GetBufferedAmount,
 151   &GetCloseCode,
 152   &GetCloseReason,
 153   &GetCloseWasClean,
 154   &GetExtensions,
 155   &GetProtocol,
 156   &GetReadyState,
 157   &GetURL
 158 };
 159
 160 }  // namespace
 161
 162 PPAPI_THUNK_EXPORT const PPB_WebSocket_1_0* GetPPB_WebSocket_1_0_Thunk() {
 163   return &g_ppb_websocket_thunk_1_0;
 164 }
 165
 166 }  // namespace thunk
 167 }  // namespace ppapi