Searched refs:socket_id (Results 1 - 25 of 45) sorted by relevance

12

/external/chromium_org/content/browser/renderer_host/
H A Dsocket_stream_dispatcher_host.cc62 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
63 DVLOG(2) << "SocketStreamDispatcherHost::OnConnected socket_id=" << socket_id
65 if (socket_id == kNoSocketId) {
70 socket_id, max_pending_send_allowed))) {
72 DeleteSocketStreamHost(socket_id);
78 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
79 DVLOG(2) << "SocketStreamDispatcherHost::OnSentData socket_id=" << socket_id
81 if (socket_id
93 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
108 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
119 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
136 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
154 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local
173 int socket_id = SocketStreamHost::SocketIdFromSocketStream(request); local
193 int socket_id = id.request_id; local
207 int socket_id = id.request_id; local
222 OnConnect(int render_frame_id, const GURL& url, int socket_id) argument
228 << " socket_id=" << socket_id; local
257 OnSendData( int socket_id, const std::vector<char>& data) argument
271 OnCloseReq(int socket_id) argument
279 DeleteSocketStreamHost(int socket_id) argument
299 int socket_id = iter.GetCurrentKey(); local
[all...]
H A Dsocket_stream_host.cc20 explicit SocketStreamId(int socket_id) : socket_id_(socket_id) {} argument
22 int socket_id() const { return socket_id_; } function in class:content::__anon7380::SocketStreamId
34 int socket_id)
38 socket_id_(socket_id) {
41 << " socket_id=" << socket_id_;
50 return socket_stream_id->socket_id();
56 VLOG(1) << "SocketStreamHost destructed socket_id=" << socket_id_;
30 SocketStreamHost( net::SocketStream::Delegate* delegate, int child_id, int render_frame_id, int socket_id) argument
H A Dsocket_stream_host.h24 // socket_id assigned by SocketStreamHost constructor. If socket id is
34 int socket_id);
37 // Gets socket_id associated with |socket|.
41 int socket_id() const { return socket_id_; } function in class:content::SocketStreamHost
H A Dsocket_stream_dispatcher_host.h78 void OnConnect(int render_frame_id, const GURL& url, int socket_id);
79 void OnSendData(int socket_id, const std::vector<char>& data);
80 void OnCloseReq(int socket_id);
82 void DeleteSocketStreamHost(int socket_id);
/external/chromium_org/content/child/
H A Dsocket_stream_dispatcher.h40 void OnConnected(int socket_id, int max_amount_send_allowed);
41 void OnSentData(int socket_id, int amount_sent);
42 void OnReceivedData(int socket_id, const std::vector<char>& data);
43 void OnClosed(int socket_id);
44 void OnFailed(int socket_id, int error_code);
H A Dsocket_stream_dispatcher.cc197 void SocketStreamDispatcher::OnConnected(int socket_id, argument
200 << max_pending_send_allowed << ") to socket_id=" << socket_id; local
203 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id);
207 DLOG(ERROR) << "No bridge for socket_id=" << socket_id;
210 void SocketStreamDispatcher::OnSentData(int socket_id, int amount_sent) { argument
212 << " bytes) to socket_id=" << socket_id; local
215 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id);
222 OnReceivedData( int socket_id, const std::vector<char>& data) argument
235 OnClosed(int socket_id) argument
246 OnFailed(int socket_id, int error_code) argument
[all...]
/external/chromium_org/extensions/browser/api/sockets_tcp/
H A Dtcp_socket_event_dispatcher.cc61 int socket_id) {
64 StartSocketRead(extension_id, socket_id);
68 int socket_id) {
71 StartSocketRead(extension_id, socket_id);
75 int socket_id) {
83 params.socket_id = socket_id;
93 params.sockets->Get(params.extension_id, params.socket_id);
130 receive_info.socket_id = params.socket_id;
60 OnSocketConnect(const std::string& extension_id, int socket_id) argument
67 OnSocketResume(const std::string& extension_id, int socket_id) argument
74 StartSocketRead(const std::string& extension_id, int socket_id) argument
[all...]
H A Dtcp_socket_event_dispatcher.h33 void OnSocketConnect(const std::string& extension_id, int socket_id);
36 void OnSocketResume(const std::string& extension_id, int socket_id);
63 int socket_id; member in struct:extensions::core_api::TCPSocketEventDispatcher::ReadParams
67 void StartSocketRead(const std::string& extension_id, int socket_id);
H A Dsockets_tcp_api.cc29 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, argument
34 socket_info->socket_id = socket_id;
97 ResumableTCPSocket* TCPSocketAsyncApiFunction::GetTcpSocket(int socket_id) { argument
98 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id));
111 int socket_id) {
112 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id));
134 create_info.socket_id = AddSocket(socket);
149 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id);
178 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id);
110 GetTcpSocket( int socket_id) argument
443 int socket_id = *it; local
[all...]
/external/chromium_org/extensions/browser/api/sockets_tcp_server/
H A Dtcp_server_socket_event_dispatcher.cc67 int socket_id) {
70 StartSocketAccept(extension_id, socket_id);
75 int socket_id) {
78 StartSocketAccept(extension_id, socket_id);
83 int socket_id) {
92 params.socket_id = socket_id;
102 params.server_sockets->Get(params.extension_id, params.socket_id);
133 accept_info.socket_id = params.socket_id;
65 OnServerSocketListen( const std::string& extension_id, int socket_id) argument
73 OnServerSocketResume( const std::string& extension_id, int socket_id) argument
81 StartSocketAccept( const std::string& extension_id, int socket_id) argument
[all...]
H A Dsockets_tcp_server_api.cc26 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, argument
31 socket_info->socket_id = socket_id;
73 int socket_id) {
74 return static_cast<ResumableTCPServerSocket*>(GetSocket(socket_id));
98 create_info.socket_id = AddSocket(socket);
113 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
143 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
153 params_->socket_id);
180 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
72 GetTcpSocket( int socket_id) argument
287 int socket_id = *it; local
[all...]
H A Dtcp_server_socket_event_dispatcher.h34 void OnServerSocketListen(const std::string& extension_id, int socket_id);
37 void OnServerSocketResume(const std::string& extension_id, int socket_id);
68 int socket_id; member in struct:extensions::core_api::TCPServerSocketEventDispatcher::AcceptParams
72 void StartSocketAccept(const std::string& extension_id, int socket_id);
/external/chromium_org/content/renderer/p2p/
H A Dsocket_dispatcher.cc142 int socket_id,
145 P2PSocketClientImpl* client = GetClient(socket_id);
152 int socket_id, const net::IPEndPoint& address) {
153 P2PSocketClientImpl* client = GetClient(socket_id);
159 void P2PSocketDispatcher::OnSendComplete(int socket_id) { argument
160 P2PSocketClientImpl* client = GetClient(socket_id);
166 void P2PSocketDispatcher::OnError(int socket_id) { argument
167 P2PSocketClientImpl* client = GetClient(socket_id);
174 int socket_id, const net::IPEndPoint& address,
177 P2PSocketClientImpl* client = GetClient(socket_id);
141 OnSocketCreated( int socket_id, const net::IPEndPoint& local_address, const net::IPEndPoint& remote_address) argument
151 OnIncomingTcpConnection( int socket_id, const net::IPEndPoint& address) argument
173 OnDataReceived( int socket_id, const net::IPEndPoint& address, const std::vector<char>& data, const base::TimeTicks& timestamp) argument
183 GetClient(int socket_id) argument
[all...]
H A Dsocket_dispatcher.h95 void OnSocketCreated(int socket_id,
98 void OnIncomingTcpConnection(int socket_id, const net::IPEndPoint& address);
99 void OnSendComplete(int socket_id);
100 void OnError(int socket_id);
101 void OnDataReceived(int socket_id, const net::IPEndPoint& address,
105 P2PSocketClientImpl* GetClient(int socket_id);
/external/chromium_org/extensions/browser/api/socket/
H A Dsocket_apitest.cc31 int socket_id = -1; local
32 EXPECT_TRUE(value->GetInteger("socketId", &socket_id));
33 EXPECT_GT(socket_id, 0);
48 int socket_id = -1; local
49 EXPECT_TRUE(value->GetInteger("socketId", &socket_id));
50 ASSERT_GT(socket_id, 0);
/external/chromium_org/extensions/browser/api/bluetooth_socket/
H A Dbluetooth_socket_event_dispatcher.cc102 int socket_id) {
110 params.socket_id = socket_id;
117 int socket_id) {
125 params.socket_id = socket_id;
132 int socket_id) {
140 params.socket_id = socket_id;
143 params.sockets->Get(params.extension_id, params.socket_id);
100 OnSocketConnect( const std::string& extension_id, int socket_id) argument
115 OnSocketListen( const std::string& extension_id, int socket_id) argument
130 OnSocketResume( const std::string& extension_id, int socket_id) argument
[all...]
H A Dbluetooth_socket_event_dispatcher.h39 void OnSocketConnect(const std::string& extension_id, int socket_id);
42 void OnSocketListen(const std::string& extension_id, int socket_id);
45 void OnSocketResume(const std::string& extension_id, int socket_id);
73 int socket_id; member in struct:extensions::core_api::BluetoothSocketEventDispatcher::SocketParams
H A Dbluetooth_socket_api.cc38 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, argument
44 socket_info->socket_id = socket_id;
205 create_info.socket_id = AddSocket(socket);
221 BluetoothApiSocket* socket = GetSocket(params_->socket_id);
245 BluetoothApiSocket* socket = GetSocket(params_->socket_id);
255 params_->socket_id);
283 BluetoothApiSocket* socket = GetSocket(socket_id());
324 BluetoothApiSocket* api_socket = GetSocket(socket_id());
333 socket_event_dispatcher_->OnSocketListen(extension_id(), socket_id());
352 int BluetoothSocketListenUsingRfcommFunction::socket_id() const { function in class:extensions::core_api::BluetoothSocketListenUsingRfcommFunction
395 int BluetoothSocketListenUsingL2capFunction::socket_id() const { function in class:extensions::core_api::BluetoothSocketListenUsingL2capFunction
667 int socket_id = *it; local
[all...]
/external/chromium_org/extensions/browser/api/sockets_udp/
H A Dudp_socket_event_dispatcher.cc56 int socket_id) {
57 OnSocketResume(extension_id, socket_id);
61 int socket_id) {
69 params.socket_id = socket_id;
79 params.sockets->Get(params.extension_id, params.socket_id);
113 receive_info.socket_id = params.socket_id;
136 receive_error_info.socket_id = params.socket_id;
55 OnSocketBind(const std::string& extension_id, int socket_id) argument
60 OnSocketResume(const std::string& extension_id, int socket_id) argument
[all...]
H A Dsockets_udp_api.cc31 ResumableUDPSocket* UDPSocketAsyncApiFunction::GetUdpSocket(int socket_id) { argument
32 return static_cast<ResumableUDPSocket*>(GetSocket(socket_id));
45 int socket_id) {
46 return static_cast<ResumableUDPSocket*>(GetSocket(socket_id));
50 int socket_id,
56 socket_info->socket_id = socket_id;
109 create_info.socket_id = AddSocket(socket);
124 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
153 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id);
44 GetUdpSocket( int socket_id) argument
49 CreateSocketInfo( int socket_id, ResumableUDPSocket* socket) argument
348 int socket_id = *it; local
[all...]
H A Dudp_socket_event_dispatcher.h33 void OnSocketBind(const std::string& extension_id, int socket_id);
36 void OnSocketResume(const std::string& extension_id, int socket_id);
63 int socket_id; member in struct:extensions::core_api::UDPSocketEventDispatcher::ReceiveParams
/external/chromium_org/content/browser/renderer_host/p2p/
H A Dsocket_dispatcher_host.h69 P2PSocketHost* LookupSocket(int socket_id);
78 int socket_id,
84 void OnSend(int socket_id,
89 void OnSetOption(int socket_id, P2PSocketOption option, int value);
90 void OnDestroySocket(int socket_id);
H A Dsocket_dispatcher_host.cc191 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket(int socket_id) { argument
192 SocketsMap::iterator it = sockets_.find(socket_id);
225 P2PSocketType type, int socket_id,
228 if (LookupSocket(socket_id)) {
235 this, socket_id, type, url_context_.get(), &throttler_));
238 Send(new P2PMsg_OnError(socket_id));
243 sockets_[socket_id] = socket.release();
246 sockets_[socket_id]->StartRtpDump(dump_incoming_rtp_packet_,
259 "for invalid socket_id.";
269 void P2PSocketDispatcherHost::OnSend(int socket_id, argument
224 OnCreateSocket( P2PSocketType type, int socket_id, const net::IPEndPoint& local_address, const P2PHostAndIPEndPoint& remote_address) argument
292 OnSetOption(int socket_id, P2PSocketOption option, int value) argument
304 OnDestroySocket(int socket_id) argument
[all...]
H A Dsocket_host_tcp.h32 int socket_id,
104 int socket_id,
125 int socket_id,
H A Dsocket_host.cc459 int socket_id,
462 id_(socket_id),
547 int socket_id,
553 return new P2PSocketHostUdp(message_sender, socket_id, throttler);
556 message_sender, socket_id, P2P_SOCKET_TCP_CLIENT);
560 message_sender, socket_id, P2P_SOCKET_STUN_TCP_CLIENT);
565 return new P2PSocketHostTcp(message_sender, socket_id, type, url_context);
571 message_sender, socket_id, type, url_context);
458 P2PSocketHost(IPC::Sender* message_sender, int socket_id, ProtocolType protocol_type) argument
546 Create(IPC::Sender* message_sender, int socket_id, P2PSocketType type, net::URLRequestContextGetter* url_context, P2PMessageThrottler* throttler) argument

Completed in 227 milliseconds

12