OLD | NEW |
| (Empty) |
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_SHARED_IMPL_TCP_SOCKET_SHARED_H_ | |
6 #define PPAPI_SHARED_IMPL_TCP_SOCKET_SHARED_H_ | |
7 | |
8 #include <queue> | |
9 #include <string> | |
10 #include <vector> | |
11 | |
12 #include "base/compiler_specific.h" | |
13 #include "ppapi/c/ppb_tcp_socket.h" | |
14 #include "ppapi/c/private/ppb_net_address_private.h" | |
15 #include "ppapi/shared_impl/resource.h" | |
16 #include "ppapi/shared_impl/tracked_callback.h" | |
17 | |
18 namespace ppapi { | |
19 | |
20 class PPB_X509Certificate_Fields; | |
21 class PPB_X509Certificate_Private_Shared; | |
22 class SocketOptionData; | |
23 | |
24 // This class provides the shared implementation for both PPB_TCPSocket and | |
25 // PPB_TCPSocket_Private. | |
26 class PPAPI_SHARED_EXPORT TCPSocketShared { | |
27 public: | |
28 // The maximum number of bytes that each PpapiHostMsg_PPBTCPSocket_Read | |
29 // message is allowed to request. | |
30 static const int32_t kMaxReadSize; | |
31 // The maximum number of bytes that each PpapiHostMsg_PPBTCPSocket_Write | |
32 // message is allowed to carry. | |
33 static const int32_t kMaxWriteSize; | |
34 | |
35 // The maximum number that we allow for setting | |
36 // PP_TCPSOCKET_OPTION_SEND_BUFFER_SIZE. This number is only for input | |
37 // argument sanity check, it doesn't mean the browser guarantees to support | |
38 // such a buffer size. | |
39 static const int32_t kMaxSendBufferSize; | |
40 // The maximum number that we allow for setting | |
41 // PP_TCPSOCKET_OPTION_RECV_BUFFER_SIZE. This number is only for input | |
42 // argument sanity check, it doesn't mean the browser guarantees to support | |
43 // such a buffer size. | |
44 static const int32_t kMaxReceiveBufferSize; | |
45 | |
46 // Notifications on operations completion. | |
47 void OnConnectCompleted(int32_t result, | |
48 const PP_NetAddress_Private& local_addr, | |
49 const PP_NetAddress_Private& remote_addr); | |
50 void OnSSLHandshakeCompleted( | |
51 bool succeeded, | |
52 const PPB_X509Certificate_Fields& certificate_fields); | |
53 void OnReadCompleted(int32_t result, const std::string& data); | |
54 void OnWriteCompleted(int32_t result); | |
55 void OnSetOptionCompleted(int32_t result); | |
56 | |
57 // Send functions that need to be implemented differently for the | |
58 // proxied and non-proxied derived classes. | |
59 virtual void SendConnect(const std::string& host, uint16_t port) = 0; | |
60 virtual void SendConnectWithNetAddress(const PP_NetAddress_Private& addr) = 0; | |
61 virtual void SendSSLHandshake( | |
62 const std::string& server_name, | |
63 uint16_t server_port, | |
64 const std::vector<std::vector<char> >& trusted_certs, | |
65 const std::vector<std::vector<char> >& untrusted_certs) = 0; | |
66 virtual void SendRead(int32_t bytes_to_read) = 0; | |
67 virtual void SendWrite(const std::string& buffer) = 0; | |
68 virtual void SendDisconnect() = 0; | |
69 virtual void SendSetOption(PP_TCPSocket_Option name, | |
70 const SocketOptionData& value) = 0; | |
71 | |
72 virtual Resource* GetOwnerResource() = 0; | |
73 | |
74 // Used to override PP_Error codes received from the browser side. | |
75 virtual int32_t OverridePPError(int32_t pp_error); | |
76 | |
77 protected: | |
78 enum ConnectionState { | |
79 // Before a connection is successfully established (including a connect | |
80 // request is pending or a previous connect request failed). | |
81 BEFORE_CONNECT, | |
82 // A connection has been successfully established (including a request of | |
83 // initiating SSL is pending). | |
84 CONNECTED, | |
85 // An SSL connection has been successfully established. | |
86 SSL_CONNECTED, | |
87 // The connection has been ended. | |
88 DISCONNECTED | |
89 }; | |
90 | |
91 TCPSocketShared(ResourceObjectType resource_type, uint32 socket_id); | |
92 virtual ~TCPSocketShared(); | |
93 | |
94 int32_t ConnectImpl(const char* host, | |
95 uint16_t port, | |
96 scoped_refptr<TrackedCallback> callback); | |
97 int32_t ConnectWithNetAddressImpl(const PP_NetAddress_Private* addr, | |
98 scoped_refptr<TrackedCallback> callback); | |
99 PP_Bool GetLocalAddressImpl(PP_NetAddress_Private* local_addr); | |
100 PP_Bool GetRemoteAddressImpl(PP_NetAddress_Private* remote_addr); | |
101 int32_t SSLHandshakeImpl(const char* server_name, | |
102 uint16_t server_port, | |
103 scoped_refptr<TrackedCallback> callback); | |
104 PP_Resource GetServerCertificateImpl(); | |
105 PP_Bool AddChainBuildingCertificateImpl(PP_Resource certificate, | |
106 PP_Bool trusted); | |
107 int32_t ReadImpl(char* buffer, | |
108 int32_t bytes_to_read, | |
109 scoped_refptr<TrackedCallback> callback); | |
110 int32_t WriteImpl(const char* buffer, | |
111 int32_t bytes_to_write, | |
112 scoped_refptr<TrackedCallback> callback); | |
113 void DisconnectImpl(); | |
114 int32_t SetOptionImpl(PP_TCPSocket_Option name, | |
115 const PP_Var& value, | |
116 scoped_refptr<TrackedCallback> callback); | |
117 | |
118 void Init(uint32 socket_id); | |
119 bool IsConnected() const; | |
120 void PostAbortIfNecessary(scoped_refptr<TrackedCallback>* callback); | |
121 | |
122 ResourceObjectType resource_type_; | |
123 | |
124 uint32 socket_id_; | |
125 ConnectionState connection_state_; | |
126 | |
127 scoped_refptr<TrackedCallback> connect_callback_; | |
128 scoped_refptr<TrackedCallback> ssl_handshake_callback_; | |
129 scoped_refptr<TrackedCallback> read_callback_; | |
130 scoped_refptr<TrackedCallback> write_callback_; | |
131 std::queue<scoped_refptr<TrackedCallback> > set_option_callbacks_; | |
132 | |
133 char* read_buffer_; | |
134 int32_t bytes_to_read_; | |
135 | |
136 PP_NetAddress_Private local_addr_; | |
137 PP_NetAddress_Private remote_addr_; | |
138 | |
139 scoped_refptr<PPB_X509Certificate_Private_Shared> server_certificate_; | |
140 | |
141 std::vector<std::vector<char> > trusted_certificates_; | |
142 std::vector<std::vector<char> > untrusted_certificates_; | |
143 | |
144 private: | |
145 DISALLOW_COPY_AND_ASSIGN(TCPSocketShared); | |
146 }; | |
147 | |
148 } // namespace ppapi | |
149 | |
150 #endif // PPAPI_SHARED_IMPL_TCP_SOCKET_SHARED_H_ | |
OLD | NEW |