1 // Copyright 2013 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 #ifndef PPAPI_PROXY_UDP_SOCKET_RESOURCE_BASE_H_ 6 #define PPAPI_PROXY_UDP_SOCKET_RESOURCE_BASE_H_ 7 8 #include <string> 9 10 #include "base/basictypes.h" 11 #include "base/compiler_specific.h" 12 #include "base/memory/ref_counted.h" 13 #include "ppapi/c/ppb_udp_socket.h" 14 #include "ppapi/c/private/ppb_net_address_private.h" 15 #include "ppapi/proxy/plugin_resource.h" 16 #include "ppapi/proxy/ppapi_proxy_export.h" 17 #include "ppapi/shared_impl/tracked_callback.h" 18 19 namespace ppapi { 20 namespace proxy { 21 22 class ResourceMessageReplyParams; 23 24 class PPAPI_PROXY_EXPORT UDPSocketResourceBase: public PluginResource { 25 public: 26 // The maximum number of bytes that each PpapiHostMsg_PPBUDPSocket_RecvFrom 27 // message is allowed to request. 28 static const int32_t kMaxReadSize; 29 // The maximum number of bytes that each PpapiHostMsg_PPBUDPSocket_SendTo 30 // message is allowed to carry. 31 static const int32_t kMaxWriteSize; 32 33 // The maximum number that we allow for setting 34 // PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE. This number is only for input 35 // argument sanity check, it doesn't mean the browser guarantees to support 36 // such a buffer size. 37 static const int32_t kMaxSendBufferSize; 38 // The maximum number that we allow for setting 39 // PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE. This number is only for input 40 // argument sanity check, it doesn't mean the browser guarantees to support 41 // such a buffer size. 42 static const int32_t kMaxReceiveBufferSize; 43 44 protected: 45 UDPSocketResourceBase(Connection connection, 46 PP_Instance instance, 47 bool private_api); 48 virtual ~UDPSocketResourceBase(); 49 50 int32_t SetOptionImpl(PP_UDPSocket_Option name, 51 const PP_Var& value, 52 scoped_refptr<TrackedCallback> callback); 53 int32_t BindImpl(const PP_NetAddress_Private* addr, 54 scoped_refptr<TrackedCallback> callback); 55 PP_Bool GetBoundAddressImpl(PP_NetAddress_Private* addr); 56 // |addr| could be NULL to indicate that an output value is not needed. 57 int32_t RecvFromImpl(char* buffer, 58 int32_t num_bytes, 59 PP_Resource* addr, 60 scoped_refptr<TrackedCallback> callback); 61 PP_Bool GetRecvFromAddressImpl(PP_NetAddress_Private* addr); 62 int32_t SendToImpl(const char* buffer, 63 int32_t num_bytes, 64 const PP_NetAddress_Private* addr, 65 scoped_refptr<TrackedCallback> callback); 66 void CloseImpl(); 67 68 private: 69 void PostAbortIfNecessary(scoped_refptr<TrackedCallback>* callback); 70 71 // IPC message handlers. 72 void OnPluginMsgSetOptionReply(scoped_refptr<TrackedCallback> callback, 73 const ResourceMessageReplyParams& params); 74 void OnPluginMsgBindReply(const ResourceMessageReplyParams& params, 75 const PP_NetAddress_Private& bound_addr); 76 void OnPluginMsgRecvFromReply(PP_Resource* output_addr, 77 const ResourceMessageReplyParams& params, 78 const std::string& data, 79 const PP_NetAddress_Private& addr); 80 void OnPluginMsgSendToReply(const ResourceMessageReplyParams& params, 81 int32_t bytes_written); 82 83 void RunCallback(scoped_refptr<TrackedCallback> callback, int32_t pp_result); 84 85 bool private_api_; 86 bool bound_; 87 bool closed_; 88 89 scoped_refptr<TrackedCallback> bind_callback_; 90 scoped_refptr<TrackedCallback> recvfrom_callback_; 91 scoped_refptr<TrackedCallback> sendto_callback_; 92 93 char* read_buffer_; 94 int32_t bytes_to_read_; 95 96 PP_NetAddress_Private recvfrom_addr_; 97 PP_NetAddress_Private bound_addr_; 98 99 DISALLOW_COPY_AND_ASSIGN(UDPSocketResourceBase); 100 }; 101 102 } // namespace proxy 103 } // namespace ppapi 104 105 #endif // PPAPI_PROXY_UDP_SOCKET_RESOURCE_BASE_H_ 106