Home
last modified time | relevance | path

Searched refs:socket_id (Results 1 – 25 of 44) sorted by relevance

12

/external/chromium_org/content/browser/renderer_host/
Dsocket_stream_dispatcher_host.cc62 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); in OnConnected() local
63 DVLOG(2) << "SocketStreamDispatcherHost::OnConnected socket_id=" << socket_id in OnConnected()
65 if (socket_id == kNoSocketId) { in OnConnected()
70 socket_id, max_pending_send_allowed))) { in OnConnected()
72 DeleteSocketStreamHost(socket_id); in OnConnected()
78 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); in OnSentData() local
79 DVLOG(2) << "SocketStreamDispatcherHost::OnSentData socket_id=" << socket_id in OnSentData()
81 if (socket_id == kNoSocketId) { in OnSentData()
85 if (!Send(new SocketStreamMsg_SentData(socket_id, amount_sent))) { in OnSentData()
87 DeleteSocketStreamHost(socket_id); in OnSentData()
[all …]
Dsocket_stream_host.cc20 explicit SocketStreamId(int socket_id) : socket_id_(socket_id) {} in SocketStreamId() argument
22 int socket_id() const { return socket_id_; } in socket_id() function in content::__anond2d0f7470111::SocketStreamId
34 int socket_id) in SocketStreamHost() argument
38 socket_id_(socket_id) { in SocketStreamHost()
50 return socket_stream_id->socket_id(); in SocketIdFromSocketStream()
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);
Dsocket_stream_host.h34 int socket_id);
41 int socket_id() const { return socket_id_; } in socket_id() function
/external/chromium_org/content/child/
Dsocket_stream_dispatcher.cc197 void SocketStreamDispatcher::OnConnected(int socket_id, in OnConnected() argument
200 << max_pending_send_allowed << ") to socket_id=" << socket_id; in OnConnected()
203 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id); in OnConnected()
207 DLOG(ERROR) << "No bridge for socket_id=" << socket_id; in OnConnected()
210 void SocketStreamDispatcher::OnSentData(int socket_id, int amount_sent) { in OnSentData() argument
212 << " bytes) to socket_id=" << socket_id; in OnSentData()
215 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id); in OnSentData()
219 DLOG(ERROR) << "No bridge for socket_id=" << socket_id; in OnSentData()
223 int socket_id, const std::vector<char>& data) { in OnReceivedData() argument
225 << " bytes) to socket_id=" << socket_id; in OnReceivedData()
[all …]
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);
/external/chromium_org/extensions/browser/api/bluetooth_socket/
Dbluetooth_socket_event_dispatcher.cc102 int socket_id) { in OnSocketConnect() argument
110 params.socket_id = socket_id; in OnSocketConnect()
117 int socket_id) { in OnSocketListen() argument
125 params.socket_id = socket_id; in OnSocketListen()
132 int socket_id) { in OnSocketResume() argument
140 params.socket_id = socket_id; in OnSocketResume()
143 params.sockets->Get(params.extension_id, params.socket_id); in OnSocketResume()
161 params.sockets->Get(params.extension_id, params.socket_id); in StartReceive()
193 receive_info.socket_id = params.socket_id; in ReceiveCallback()
226 receive_error_info.socket_id = params.socket_id; in ReceiveErrorCallback()
[all …]
Dbluetooth_socket_api.cc38 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, in CreateSocketInfo() argument
44 socket_info->socket_id = socket_id; in CreateSocketInfo()
205 create_info.socket_id = AddSocket(socket); in Work()
221 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in Work()
245 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in Work()
255 params_->socket_id); in Work()
283 BluetoothApiSocket* socket = GetSocket(socket_id()); in OnGetAdapter()
324 BluetoothApiSocket* api_socket = GetSocket(socket_id()); in OnCreateService()
333 socket_event_dispatcher_->OnSocketListen(extension_id(), socket_id()); in OnCreateService()
352 int BluetoothSocketListenUsingRfcommFunction::socket_id() const { in socket_id() function in extensions::core_api::BluetoothSocketListenUsingRfcommFunction
[all …]
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
/external/chromium_org/extensions/browser/api/sockets_tcp_server/
Dsockets_tcp_server_api.cc26 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, in CreateSocketInfo() argument
31 socket_info->socket_id = socket_id; in CreateSocketInfo()
73 int socket_id) { in GetTcpSocket() argument
74 return static_cast<ResumableTCPServerSocket*>(GetSocket(socket_id)); in GetTcpSocket()
98 create_info.socket_id = AddSocket(socket); in Work()
113 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); in Work()
143 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); in Work()
153 params_->socket_id); in Work()
180 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); in Work()
204 params_->socket_id); in Work()
[all …]
Dtcp_server_socket_event_dispatcher.cc67 int socket_id) { in OnServerSocketListen() argument
70 StartSocketAccept(extension_id, socket_id); in OnServerSocketListen()
75 int socket_id) { in OnServerSocketResume() argument
78 StartSocketAccept(extension_id, socket_id); in OnServerSocketResume()
83 int socket_id) { in StartSocketAccept() argument
92 params.socket_id = socket_id; in StartSocketAccept()
102 params.server_sockets->Get(params.extension_id, params.socket_id); in StartAccept()
133 accept_info.socket_id = params.socket_id; in AcceptCallback()
151 accept_error_info.socket_id = params.socket_id; in AcceptCallback()
162 params.server_sockets->Get(params.extension_id, params.socket_id); in AcceptCallback()
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
72 void StartSocketAccept(const std::string& extension_id, int socket_id);
/external/chromium_org/extensions/browser/api/sockets_udp/
Dsockets_udp_api.cc31 ResumableUDPSocket* UDPSocketAsyncApiFunction::GetUdpSocket(int socket_id) { in GetUdpSocket() argument
32 return static_cast<ResumableUDPSocket*>(GetSocket(socket_id)); in GetUdpSocket()
45 int socket_id) { in GetUdpSocket() argument
46 return static_cast<ResumableUDPSocket*>(GetSocket(socket_id)); in GetUdpSocket()
50 int socket_id, in CreateSocketInfo() argument
56 socket_info->socket_id = socket_id; in CreateSocketInfo()
109 create_info.socket_id = AddSocket(socket); in Work()
124 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); in Work()
153 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); in Work()
163 params_->socket_id); in Work()
[all …]
Dudp_socket_event_dispatcher.cc56 int socket_id) { in OnSocketBind() argument
57 OnSocketResume(extension_id, socket_id); in OnSocketBind()
61 int socket_id) { in OnSocketResume() argument
69 params.socket_id = socket_id; in OnSocketResume()
79 params.sockets->Get(params.extension_id, params.socket_id); in StartReceive()
113 receive_info.socket_id = params.socket_id; in ReceiveCallback()
136 receive_error_info.socket_id = params.socket_id; in ReceiveCallback()
147 params.sockets->Get(params.extension_id, params.socket_id); in ReceiveCallback()
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
/external/chromium_org/extensions/browser/api/sockets_tcp/
Dtcp_socket_event_dispatcher.cc61 int socket_id) { in OnSocketConnect() argument
64 StartSocketRead(extension_id, socket_id); in OnSocketConnect()
68 int socket_id) { in OnSocketResume() argument
71 StartSocketRead(extension_id, socket_id); in OnSocketResume()
75 int socket_id) { in StartSocketRead() argument
83 params.socket_id = socket_id; in StartSocketRead()
93 params.sockets->Get(params.extension_id, params.socket_id); in StartRead()
130 receive_info.socket_id = params.socket_id; in ReadCallback()
151 receive_error_info.socket_id = params.socket_id; in ReadCallback()
162 params.sockets->Get(params.extension_id, params.socket_id); in ReadCallback()
Dsockets_tcp_api.cc29 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, in CreateSocketInfo() argument
34 socket_info->socket_id = socket_id; in CreateSocketInfo()
97 ResumableTCPSocket* TCPSocketAsyncApiFunction::GetTcpSocket(int socket_id) { in GetTcpSocket() argument
98 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id)); in GetTcpSocket()
111 int socket_id) { in GetTcpSocket() argument
112 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id)); in GetTcpSocket()
134 create_info.socket_id = AddSocket(socket); in Work()
149 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); in Work()
178 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); in Work()
188 params_->socket_id); in Work()
[all …]
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
67 void StartSocketRead(const std::string& extension_id, int socket_id);
/external/chromium_org/content/renderer/p2p/
Dsocket_dispatcher.cc142 int socket_id, in OnSocketCreated() argument
145 P2PSocketClientImpl* client = GetClient(socket_id); in OnSocketCreated()
152 int socket_id, const net::IPEndPoint& address) { in OnIncomingTcpConnection() argument
153 P2PSocketClientImpl* client = GetClient(socket_id); in OnIncomingTcpConnection()
159 void P2PSocketDispatcher::OnSendComplete(int socket_id) { in OnSendComplete() argument
160 P2PSocketClientImpl* client = GetClient(socket_id); in OnSendComplete()
166 void P2PSocketDispatcher::OnError(int socket_id) { in OnError() argument
167 P2PSocketClientImpl* client = GetClient(socket_id); in OnError()
174 int socket_id, const net::IPEndPoint& address, in OnDataReceived() argument
177 P2PSocketClientImpl* client = GetClient(socket_id); in OnDataReceived()
[all …]
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/content/browser/renderer_host/p2p/
Dsocket_dispatcher_host.cc191 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket(int socket_id) { in LookupSocket() argument
192 SocketsMap::iterator it = sockets_.find(socket_id); in LookupSocket()
225 P2PSocketType type, int socket_id, in OnCreateSocket() argument
228 if (LookupSocket(socket_id)) { in OnCreateSocket()
235 this, socket_id, type, url_context_.get(), &throttler_)); in OnCreateSocket()
238 Send(new P2PMsg_OnError(socket_id)); in OnCreateSocket()
243 sockets_[socket_id] = socket.release(); in OnCreateSocket()
246 sockets_[socket_id]->StartRtpDump(dump_incoming_rtp_packet_, in OnCreateSocket()
269 void P2PSocketDispatcherHost::OnSend(int socket_id, in OnSend() argument
274 P2PSocketHost* socket = LookupSocket(socket_id); in OnSend()
[all …]
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);
Dsocket_host.cc459 int socket_id, in P2PSocketHost() argument
462 id_(socket_id), in P2PSocketHost()
547 int socket_id, in Create() argument
553 return new P2PSocketHostUdp(message_sender, socket_id, throttler); in Create()
556 message_sender, socket_id, P2P_SOCKET_TCP_CLIENT); in Create()
560 message_sender, socket_id, P2P_SOCKET_STUN_TCP_CLIENT); in Create()
565 return new P2PSocketHostTcp(message_sender, socket_id, type, url_context); in Create()
571 message_sender, socket_id, type, url_context); in Create()
/external/chromium_org/extensions/browser/api/socket/
Dsocket_apitest.cc31 int socket_id = -1; in IN_PROC_BROWSER_TEST_F() local
32 EXPECT_TRUE(value->GetInteger("socketId", &socket_id)); in IN_PROC_BROWSER_TEST_F()
33 EXPECT_GT(socket_id, 0); in IN_PROC_BROWSER_TEST_F()
48 int socket_id = -1; in IN_PROC_BROWSER_TEST_F() local
49 EXPECT_TRUE(value->GetInteger("socketId", &socket_id)); in IN_PROC_BROWSER_TEST_F()
50 ASSERT_GT(socket_id, 0); in IN_PROC_BROWSER_TEST_F()
Dsocket_api.cc318 Socket* socket = GetSocket(params_->socket_id); in Work()
352 Socket* socket = GetSocket(params_->socket_id); in AsyncWorkStart()
385 Socket* socket = GetSocket(params_->socket_id); in AsyncWorkStart()
460 Socket* socket = GetSocket(params_->socket_id); in AsyncWorkStart()
573 Socket* socket = GetSocket(params_->socket_id); in Work()
597 Socket* socket = GetSocket(params_->socket_id); in Work()
616 Socket* socket = GetSocket(params_->socket_id); in Work()
720 Socket* socket = GetSocket(params_->socket_id); in Work()
764 Socket* socket = GetSocket(params_->socket_id); in Work()
806 Socket* socket = GetSocket(params_->socket_id); in Work()
[all …]

12