/external/chromium_org/content/browser/renderer_host/ |
H A D | socket_stream_dispatcher_host.cc | 62 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 D | socket_stream_host.cc | 20 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 D | socket_stream_host.h | 24 // 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 D | socket_stream_dispatcher_host.h | 78 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 D | socket_stream_dispatcher.h | 40 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 D | socket_stream_dispatcher.cc | 197 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 D | tcp_socket_event_dispatcher.cc | 61 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 D | tcp_socket_event_dispatcher.h | 33 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 D | sockets_tcp_api.cc | 29 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 D | tcp_server_socket_event_dispatcher.cc | 67 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 D | sockets_tcp_server_api.cc | 26 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 D | tcp_server_socket_event_dispatcher.h | 34 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 D | socket_dispatcher.cc | 142 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 D | socket_dispatcher.h | 95 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 D | socket_apitest.cc | 31 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 D | bluetooth_socket_event_dispatcher.cc | 102 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 D | bluetooth_socket_event_dispatcher.h | 39 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 D | bluetooth_socket_api.cc | 38 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 D | udp_socket_event_dispatcher.cc | 56 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 D | sockets_udp_api.cc | 31 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 D | udp_socket_event_dispatcher.h | 33 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 D | socket_dispatcher_host.h | 69 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 D | socket_dispatcher_host.cc | 191 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 D | socket_host_tcp.h | 32 int socket_id, 104 int socket_id, 125 int socket_id,
|
H A D | socket_host.cc | 459 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
|