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

12

/external/chromium_org/content/browser/renderer_host/
H A Dsocket_stream_dispatcher_host.cc61 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 Dsocket_stream_host.cc19 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 Dsocket_stream_host.h24 // 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 Dsocket_stream_dispatcher_host.h79 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 Dsocket_stream_dispatcher.h42 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 Dsocket_stream_dispatcher.cc198 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 Dppb_ext_socket_dev.h166 * @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 Dtcp_socket_event_dispatcher.cc60 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 Dtcp_socket_event_dispatcher.h29 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 Dsockets_tcp_api.cc22 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 Dppb_ext_socket_dev.idl142 * @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 Dsocket_dev.h66 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 Dsocket_dev.cc69 : 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 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);
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 Dtcp_server_socket_event_dispatcher.h30 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 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...]
/external/chromium_org/content/renderer/p2p/
H A Dsocket_dispatcher.cc141 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 Dsocket_dispatcher.h98 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 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;
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 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);
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 Dudp_socket_event_dispatcher.h29 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 Dtest_socket.cc100 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 Dppb_ext_socket_thunk.cc36 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 Dsocket_dispatcher_host.cc150 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 Dsocket_dispatcher_host.h56 P2PSocketHost* LookupSocket(int socket_id);
66 int socket_id,
72 void OnSend(int socket_id,
77 void OnDestroySocket(int socket_id);

Completed in 756 milliseconds

12