content/renderer/pepper/ppb_tcp_socket_private_impl.cc - Issue 22923014: TCPSockets are switched to the new Pepper proxy.

Side by Side Diff: content/renderer/pepper/ppb_tcp_socket_private_impl.cc

Issue 22923014: TCPSockets are switched to the new Pepper proxy. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src

Patch Set: Sync. Created 7 years, 4 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch | Annotate | Revision Log

« content/browser/renderer_host/pepper/ssl_context_helper.h ('K') | « content/renderer/pepper/ppb_tcp_socket_private_impl.h ('k') | content/renderer/pepper/resource_creation_impl.cc » ('j') | ppapi/proxy/pp_utils.h » ('J')
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Hide Comments ('s')

OLD	NEW
	(Empty)
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 #include "content/renderer/pepper/ppb_tcp_socket_private_impl.h"

6

7 #include "content/common/pepper_messages.h"

8 #include "content/renderer/pepper/host_globals.h"

9 #include "content/renderer/pepper/pepper_plugin_instance_impl.h"

10 #include "content/renderer/render_thread_impl.h"

11 #include "ppapi/proxy/ppapi_messages.h"

12 #include "ppapi/shared_impl/socket_option_data.h"

13

14 namespace content {

15

16 PPB_TCPSocket_Private_Impl::PPB_TCPSocket_Private_Impl(

17 PP_Instance instance,

18 uint32 socket_id,

19 int routing_id)

20 : ppapi::TCPSocketPrivateImpl(instance, socket_id),

21 routing_id_(routing_id) {

22 ChildThread::current()->AddRoute(routing_id, this);

23 }

24

25 PPB_TCPSocket_Private_Impl::~PPB_TCPSocket_Private_Impl() {

26 ChildThread::current()->RemoveRoute(routing_id_);

27 Disconnect();

28 }

29

30 PP_Resource PPB_TCPSocket_Private_Impl::CreateResource(PP_Instance instance) {

31 int routing_id = RenderThreadImpl::current()->GenerateRoutingID();

32 uint32 socket_id = 0;

33 RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_CreatePrivate(

34 routing_id, 0, &socket_id));

35 if (!socket_id)

36 return 0;

37

38 return (new PPB_TCPSocket_Private_Impl(

39 instance, socket_id, routing_id))->GetReference();

40 }

41

42 void PPB_TCPSocket_Private_Impl::SendConnect(const std::string& host,

43 uint16_t port) {

44 RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_Connect(

45 routing_id_, socket_id_, host, port));

46 }

47

48 void PPB_TCPSocket_Private_Impl::SendConnectWithNetAddress(

49 const PP_NetAddress_Private& addr) {

50 RenderThreadImpl::current()->Send(

51 new PpapiHostMsg_PPBTCPSocket_ConnectWithNetAddress(

52 routing_id_, socket_id_, addr));

53 }

54

55 void PPB_TCPSocket_Private_Impl::SendSSLHandshake(

56 const std::string& server_name,

57 uint16_t server_port,

58 const std::vector<std::vector<char> >& trusted_certs,

59 const std::vector<std::vector<char> >& untrusted_certs) {

60 RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_SSLHandshake(

61 socket_id_, server_name, server_port, trusted_certs, untrusted_certs));

62 }

63

64 void PPB_TCPSocket_Private_Impl::SendRead(int32_t bytes_to_read) {

65 RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_Read(

66 socket_id_, bytes_to_read));

67 }

68

69

70 void PPB_TCPSocket_Private_Impl::SendWrite(const std::string& buffer) {

71 RenderThreadImpl::current()->Send(

72 new PpapiHostMsg_PPBTCPSocket_Write(socket_id_, buffer));

73 }

74

75 void PPB_TCPSocket_Private_Impl::SendDisconnect() {

76 RenderThreadImpl::current()->Send(

77 new PpapiHostMsg_PPBTCPSocket_Disconnect(socket_id_));

78 }

79

80 void PPB_TCPSocket_Private_Impl::SendSetOption(

81 PP_TCPSocket_Option name,

82 const ppapi::SocketOptionData& value) {

83 RenderThreadImpl::current()->Send(

84 new PpapiHostMsg_PPBTCPSocket_SetOption(socket_id_, name, value));

85 }

86

87 bool PPB_TCPSocket_Private_Impl::OnMessageReceived(

88 const IPC::Message& message) {

89 bool handled = true;

90 IPC_BEGIN_MESSAGE_MAP(PPB_TCPSocket_Private_Impl, message)

91 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ConnectACK, OnTCPSocketConnectACK)

92 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SSLHandshakeACK,

93 OnTCPSocketSSLHandshakeACK)

94 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ReadACK, OnTCPSocketReadACK)

95 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_WriteACK, OnTCPSocketWriteACK)

96 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SetOptionACK,

97 OnTCPSocketSetOptionACK)

98 IPC_MESSAGE_UNHANDLED(handled = false)

99 IPC_END_MESSAGE_MAP()

100 return handled;

101 }

102

103 void PPB_TCPSocket_Private_Impl::OnTCPSocketConnectACK(

104 uint32 plugin_dispatcher_id,

105 uint32 socket_id,

106 int32_t result,

107 const PP_NetAddress_Private& local_addr,

108 const PP_NetAddress_Private& remote_addr) {

109 OnConnectCompleted(result, local_addr, remote_addr);

110 }

111

112 void PPB_TCPSocket_Private_Impl::OnTCPSocketSSLHandshakeACK(

113 uint32 plugin_dispatcher_id,

114 uint32 socket_id,

115 bool succeeded,

116 const ppapi::PPB_X509Certificate_Fields& certificate_fields) {

117 OnSSLHandshakeCompleted(succeeded, certificate_fields);

118 }

119

120 void PPB_TCPSocket_Private_Impl::OnTCPSocketReadACK(uint32 plugin_dispatcher_id,

121 uint32 socket_id,

122 int32_t result,

123 const std::string& data) {

124 OnReadCompleted(result, data);

125 }

126

127 void PPB_TCPSocket_Private_Impl::OnTCPSocketWriteACK(

128 uint32 plugin_dispatcher_id,

129 uint32 socket_id,

130 int32_t result) {

131 OnWriteCompleted(result);

132 }

133

134 void PPB_TCPSocket_Private_Impl::OnTCPSocketSetOptionACK(

135 uint32 plugin_dispatcher_id,

136 uint32 socket_id,

137 int32_t result) {

138 OnSetOptionCompleted(result);

139 }

140

141 } // namespace content

OLD	NEW