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 168
