/external/chromium_org/content/browser/renderer_host/ |
H A D | socket_stream_dispatcher_host.cc | 61 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 62 DVLOG(2) << "SocketStreamDispatcherHost::OnConnected socket_id=" << socket_id 64 if (socket_id == kNoSocketId) { 69 socket_id, max_pending_send_allowed))) { 71 DeleteSocketStreamHost(socket_id); 77 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 78 DVLOG(2) << "SocketStreamDispatcherHost::OnSentData socket_id=" << socket_id 80 if (socket_id 92 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 107 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 118 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 135 int socket_id = SocketStreamHost::SocketIdFromSocketStream(socket); local 169 int socket_id = id.request_id; local 183 int socket_id = id.request_id; local 198 OnConnect(int render_view_id, const GURL& url, int socket_id) argument 204 << " socket_id=" << socket_id; local 232 OnSendData( int socket_id, const std::vector<char>& data) argument 246 OnCloseReq(int socket_id) argument 254 DeleteSocketStreamHost(int socket_id) argument 274 int socket_id = iter.GetCurrentKey(); local [all...] |
H A D | socket_stream_host.cc | 19 explicit SocketStreamId(int socket_id) : socket_id_(socket_id) {} argument 21 int socket_id() const { return socket_id_; } function in class:content::__anon8222::SocketStreamId 32 int socket_id) 35 socket_id_(socket_id) { 38 << " socket_id=" << socket_id_; 47 return socket_stream_id->socket_id(); 53 VLOG(1) << "SocketStreamHost destructed socket_id=" << socket_id_; 29 SocketStreamHost( net::SocketStream::Delegate* delegate, int render_view_id, int socket_id) argument
|
H A D | socket_stream_host.h | 24 // socket_id assigned by SocketStreamHost constructor. If socket id is 33 int socket_id); 36 // Gets socket_id associated with |socket|. 40 int socket_id() const { return socket_id_; } function in class:content::SocketStreamHost
|
H A D | socket_stream_dispatcher_host.h | 79 void OnConnect(int render_view_id, const GURL& url, int socket_id); 80 void OnSendData(int socket_id, const std::vector<char>& data); 81 void OnCloseReq(int socket_id); 83 void DeleteSocketStreamHost(int socket_id);
|
/external/chromium_org/content/child/ |
H A D | socket_stream_dispatcher.h | 42 void OnConnected(int socket_id, int max_amount_send_allowed); 43 void OnSentData(int socket_id, int amount_sent); 44 void OnReceivedData(int socket_id, const std::vector<char>& data); 45 void OnClosed(int socket_id); 46 void OnFailed(int socket_id, int error_code);
|
H A D | socket_stream_dispatcher.cc | 198 void SocketStreamDispatcher::OnConnected(int socket_id, argument 201 << max_pending_send_allowed << ") to socket_id=" << socket_id; local 204 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id); 208 DLOG(ERROR) << "No bridge for socket_id=" << socket_id; 211 void SocketStreamDispatcher::OnSentData(int socket_id, int amount_sent) { argument 213 << " bytes) to socket_id=" << socket_id; local 216 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id); 223 OnReceivedData( int socket_id, const std::vector<char>& data) argument 236 OnClosed(int socket_id) argument 247 OnFailed(int socket_id, int error_code) argument [all...] |
/external/chromium_org/ppapi/c/extensions/dev/ |
H A D | ppb_ext_socket_dev.h | 166 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 168 void (*Destroy)(PP_Instance instance, struct PP_Var socket_id); 176 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 188 struct PP_Var socket_id, 198 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 210 struct PP_Var socket_id, 220 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 222 void (*Disconnect)(PP_Instance instance, struct PP_Var socket_id); 227 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 237 struct PP_Var socket_id, [all...] |
/external/chromium_org/chrome/browser/extensions/api/sockets_tcp/ |
H A D | tcp_socket_event_dispatcher.cc | 60 int socket_id) { 63 StartSocketRead(extension_id, socket_id); 67 int socket_id) { 70 StartSocketRead(extension_id, socket_id); 74 int socket_id) { 82 params.socket_id = socket_id; 92 params.sockets->Get(params.extension_id, params.socket_id); 130 receive_info.socket_id = params.socket_id; 59 OnSocketConnect(const std::string& extension_id, int socket_id) argument 66 OnSocketResume(const std::string& extension_id, int socket_id) argument 73 StartSocketRead(const std::string& extension_id, int socket_id) argument [all...] |
H A D | tcp_socket_event_dispatcher.h | 29 void OnSocketConnect(const std::string& extension_id, int socket_id); 32 void OnSocketResume(const std::string& extension_id, int socket_id); 60 int socket_id; member in struct:extensions::api::TCPSocketEventDispatcher::ReadParams 64 void StartSocketRead(const std::string& extension_id, int socket_id);
|
H A D | sockets_tcp_api.cc | 22 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id, argument 27 socket_info->socket_id = socket_id; 90 ResumableTCPSocket* TCPSocketAsyncApiFunction::GetTcpSocket(int socket_id) { argument 91 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id)); 104 int socket_id) { 105 return static_cast<ResumableTCPSocket*>(GetSocket(socket_id)); 127 create_info.socket_id = AddSocket(socket); 142 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); 170 ResumableTCPSocket* socket = GetTcpSocket(params_->socket_id); 103 GetTcpSocket( int socket_id) argument 433 int socket_id = *it; local [all...] |
/external/chromium_org/ppapi/api/extensions/dev/ |
H A D | ppb_ext_socket_dev.idl | 142 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 146 [in] PP_Var socket_id); 155 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 168 [in] PP_Var socket_id, 179 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 192 [in] PP_Var socket_id, 203 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 207 [in] PP_Var socket_id); 213 * @param[in] socket_id An integer <code>PP_Var</code>. The socket ID. 224 [in] PP_Var socket_id, [all...] |
/external/chromium_org/ppapi/cpp/extensions/dev/ |
H A D | socket_dev.h | 66 DictField<int32_t> socket_id; member in class:pp::ext::socket::CreateInfo_Dev 82 OptionalDictField<int32_t> socket_id; member in class:pp::ext::socket::AcceptInfo_Dev 186 void Destroy(int32_t socket_id); 189 int32_t Connect(int32_t socket_id, 195 int32_t Bind(int32_t socket_id, 200 void Disconnect(int32_t socket_id); 203 int32_t Read(int32_t socket_id, 208 int32_t Write(int32_t socket_id, 213 int32_t RecvFrom(int32_t socket_id, 218 int32_t SendTo(int32_t socket_id, [all...] |
H A D | socket_dev.cc | 69 : socket_id(kSocketId) { 80 bool result = socket_id.Populate(dict); 88 bool result = socket_id.AddTo(&dict); 101 socket_id(kSocketId) { 113 result = socket_id.Populate(dict) && result; 122 result = socket_id.MayAddTo(&dict) && result; 334 void Socket_Dev::Destroy(int32_t socket_id) { argument 338 internal::ToVarConverter<int32_t> socket_id_var(socket_id); 345 int32_t Socket_Dev::Connect(int32_t socket_id, argument 352 internal::ToVarConverter<int32_t> socket_id_var(socket_id); 365 Bind(int32_t socket_id, const std::string& address, int32_t port, const BindCallback& callback) argument 385 Disconnect(int32_t socket_id) argument 396 Read(int32_t socket_id, const Optional<int32_t>& buffer_size, const ReadCallback& callback) argument 413 Write(int32_t socket_id, const VarArrayBuffer& data, const WriteCallback& callback) argument 430 RecvFrom(int32_t socket_id, const Optional<int32_t>& buffer_size, const RecvFromCallback& callback) argument 447 SendTo(int32_t socket_id, const VarArrayBuffer& data, const std::string& address, int32_t port, const SendToCallback& callback) argument 470 Listen(int32_t socket_id, const std::string& address, int32_t port, const Optional<int32_t>& backlog, const ListenCallback& callback) argument 493 Accept(int32_t socket_id, const AcceptCallback& callback) argument 507 SetKeepAlive(int32_t socket_id, bool enable, const Optional<int32_t>& delay, const SetKeepAliveCallback& callback) argument 527 SetNoDelay(int32_t socket_id, bool no_delay, const SetNoDelayCallback& callback) argument 544 GetInfo(int32_t socket_id, const GetInfoCallback& callback) argument 568 JoinGroup(int32_t socket_id, const std::string& address, const JoinGroupCallback& callback) argument 585 LeaveGroup(int32_t socket_id, const std::string& address, const LeaveGroupCallback& callback) argument 602 SetMulticastTimeToLive( int32_t socket_id, int32_t ttl, const SetMulticastTimeToLiveCallback& callback) argument 620 SetMulticastLoopbackMode( int32_t socket_id, bool enabled, const SetMulticastLoopbackModeCallback& callback) argument 638 GetJoinedGroups(int32_t socket_id, const GetJoinedGroupsCallback& callback) argument [all...] |
/external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/ |
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); 141 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); 151 params_->socket_id); 176 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 | 30 void OnServerSocketListen(const std::string& extension_id, int socket_id); 33 void OnServerSocketResume(const std::string& extension_id, int socket_id); 66 int socket_id; member in struct:extensions::api::TCPServerSocketEventDispatcher::AcceptParams 70 void StartSocketAccept(const std::string& extension_id, int socket_id);
|
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...] |
/external/chromium_org/content/renderer/p2p/ |
H A D | socket_dispatcher.cc | 141 int socket_id, const net::IPEndPoint& address) { 142 P2PSocketClientImpl* client = GetClient(socket_id); 149 int socket_id, const net::IPEndPoint& address) { 150 P2PSocketClientImpl* client = GetClient(socket_id); 156 void P2PSocketDispatcher::OnSendComplete(int socket_id) { argument 157 P2PSocketClientImpl* client = GetClient(socket_id); 163 void P2PSocketDispatcher::OnError(int socket_id) { argument 164 P2PSocketClientImpl* client = GetClient(socket_id); 171 int socket_id, const net::IPEndPoint& address, 174 P2PSocketClientImpl* client = GetClient(socket_id); 140 OnSocketCreated( int socket_id, const net::IPEndPoint& address) argument 148 OnIncomingTcpConnection( int socket_id, const net::IPEndPoint& address) argument 170 OnDataReceived( int socket_id, const net::IPEndPoint& address, const std::vector<char>& data, const base::TimeTicks& timestamp) argument 180 GetClient(int socket_id) argument [all...] |
H A D | socket_dispatcher.h | 98 void OnSocketCreated(int socket_id, const net::IPEndPoint& address); 99 void OnIncomingTcpConnection(int socket_id, const net::IPEndPoint& address); 100 void OnSendComplete(int socket_id); 101 void OnError(int socket_id); 102 void OnDataReceived(int socket_id, const net::IPEndPoint& address, 106 P2PSocketClientImpl* GetClient(int socket_id);
|
/external/chromium_org/chrome/browser/extensions/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; 135 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); 152 ResumableUDPSocket* socket = GetUdpSocket(params_->socket_id); 44 GetUdpSocket( int socket_id) argument 49 CreateSocketInfo( int socket_id, ResumableUDPSocket* socket) argument 350 int socket_id = *it; local [all...] |
H A D | udp_socket_event_dispatcher.h | 29 void OnSocketBind(const std::string& extension_id, int socket_id); 32 void OnSocketResume(const std::string& extension_id, int socket_id); 60 int socket_id; member in struct:extensions::api::UDPSocketEventDispatcher::ReceiveParams
|
/external/chromium_org/ppapi/tests/extensions/socket/ |
H A D | test_socket.cc | 100 int32_t socket_id = 0; local 109 socket_id = callback.output().socket_id(); 110 if (socket_id <= 0) 117 socket_id, address_, port_, Optional<int32_t>(), 134 client_socket_id = callback.output().socket_id(); 153 callback.WaitForResult(socket_.Accept(socket_id, callback.GetCallback())); 157 if (accept_info.result_code() != 0 || !accept_info.socket_id().IsSet()) 159 accepted_socket_id = *accept_info.socket_id(); 195 socket_.Destroy(socket_id); 200 int32_t socket_id = 0; local [all...] |
/external/chromium_org/ppapi/thunk/ |
H A D | ppb_ext_socket_thunk.cc | 36 void Destroy(PP_Instance instance, PP_Var socket_id) { argument 42 args.push_back(socket_id); 47 PP_Var socket_id, 58 input_args.push_back(socket_id); 67 PP_Var socket_id, 78 input_args.push_back(socket_id); 86 void Disconnect(PP_Instance instance, PP_Var socket_id) { argument 92 args.push_back(socket_id); 97 PP_Var socket_id, 107 input_args.push_back(socket_id); 46 Connect(PP_Instance instance, PP_Var socket_id, PP_Var hostname, PP_Var port, PP_Var* result, PP_CompletionCallback callback) argument 66 Bind(PP_Instance instance, PP_Var socket_id, PP_Var address, PP_Var port, PP_Var* result, PP_CompletionCallback callback) argument 96 Read(PP_Instance instance, PP_Var socket_id, PP_Var buffer_size, PP_Ext_Socket_ReadInfo_Dev* read_info, PP_CompletionCallback callback) argument 114 Write(PP_Instance instance, PP_Var socket_id, PP_Var data, PP_Ext_Socket_WriteInfo_Dev* write_info, PP_CompletionCallback callback) argument 132 RecvFrom(PP_Instance instance, PP_Var socket_id, PP_Var buffer_size, PP_Ext_Socket_RecvFromInfo_Dev* recv_from_info, PP_CompletionCallback callback) argument 150 SendTo(PP_Instance instance, PP_Var socket_id, PP_Var data, PP_Var address, PP_Var port, PP_Ext_Socket_WriteInfo_Dev* write_info, PP_CompletionCallback callback) argument 172 Listen(PP_Instance instance, PP_Var socket_id, PP_Var address, PP_Var port, PP_Var backlog, PP_Var* result, PP_CompletionCallback callback) argument 194 Accept(PP_Instance instance, PP_Var socket_id, PP_Ext_Socket_AcceptInfo_Dev* accept_info, PP_CompletionCallback callback) argument 210 SetKeepAlive(PP_Instance instance, PP_Var socket_id, PP_Var enable, PP_Var delay, PP_Var* result, PP_CompletionCallback callback) argument 230 SetNoDelay(PP_Instance instance, PP_Var socket_id, PP_Var no_delay, PP_Var* result, PP_CompletionCallback callback) argument 248 GetInfo(PP_Instance instance, PP_Var socket_id, PP_Ext_Socket_SocketInfo_Dev* result, PP_CompletionCallback callback) argument 278 JoinGroup(PP_Instance instance, PP_Var socket_id, PP_Var address, PP_Var* result, PP_CompletionCallback callback) argument 296 LeaveGroup(PP_Instance instance, PP_Var socket_id, PP_Var address, PP_Var* result, PP_CompletionCallback callback) argument 314 SetMulticastTimeToLive(PP_Instance instance, PP_Var socket_id, PP_Var ttl, PP_Var* result, PP_CompletionCallback callback) argument 333 SetMulticastLoopbackMode(PP_Instance instance, PP_Var socket_id, PP_Var enabled, PP_Var* result, PP_CompletionCallback callback) argument 352 GetJoinedGroups(PP_Instance instance, PP_Var socket_id, PP_Var* groups, PP_CompletionCallback callback) argument [all...] |
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_dispatcher_host.cc | 150 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket(int socket_id) { argument 151 SocketsMap::iterator it = sockets_.find(socket_id); 186 P2PSocketType type, int socket_id, 189 if (LookupSocket(socket_id)) { 196 this, socket_id, type, url_context_.get(), &throttler_)); 199 Send(new P2PMsg_OnError(socket_id)); 204 sockets_[socket_id] = socket.release(); 214 "for invalid socket_id."; 224 void P2PSocketDispatcherHost::OnSend(int socket_id, argument 229 P2PSocketHost* socket = LookupSocket(socket_id); 185 OnCreateSocket( P2PSocketType type, int socket_id, const net::IPEndPoint& local_address, const net::IPEndPoint& remote_address) argument 247 OnDestroySocket(int socket_id) argument [all...] |
H A D | socket_dispatcher_host.h | 56 P2PSocketHost* LookupSocket(int socket_id); 66 int socket_id, 72 void OnSend(int socket_id, 77 void OnDestroySocket(int socket_id);
|