| /external/chromium_org/content/browser/renderer_host/ |
| 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 == kNoSocketId)
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
204 << " socket_id=" << socket_id; local
274 int socket_id = iter.GetCurrentKey(); local
[all...] |
| socket_stream_host.cc | 19 explicit SocketStreamId(int socket_id) : socket_id_(socket_id) {}
21 int socket_id() const { return socket_id_; } function in class:content::__anon7912::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_;
|
| 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
|
| 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/ |
| 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);
|
| socket_stream_dispatcher.cc | 198 void SocketStreamDispatcher::OnConnected(int socket_id,
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) {
213 << " bytes) to socket_id=" << socket_id; local
216 IPCWebSocketStreamHandleBridge::FromSocketId(socket_id);
[all...] |
| /external/chromium_org/ppapi/c/extensions/dev/ |
| 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/content/renderer/p2p/ |
| 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);
|
| 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) {
157 P2PSocketClientImpl* client = GetClient(socket_id);
163 void P2PSocketDispatcher::OnError(int socket_id) {
164 P2PSocketClientImpl* client = GetClient(socket_id);
171 int socket_id, const net::IPEndPoint& address,
174 P2PSocketClientImpl* client = GetClient(socket_id);
[all...] |
| /external/chromium_org/ppapi/api/extensions/dev/ |
| 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/ |
| 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...] |
| 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) {
338 internal::ToVarConverter<int32_t> socket_id_var(socket_id);
345 int32_t Socket_Dev::Connect(int32_t socket_id,
352 internal::ToVarConverter<int32_t> socket_id_var(socket_id);
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/ |
| sockets_tcp_server_api.cc | 26 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id,
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);
287 int socket_id = *it; local
[all...] |
| 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);
|
| 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;
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/sockets_udp/ |
| 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;
[all...] |
| sockets_udp_api.cc | 31 ResumableUDPSocket* UDPSocketAsyncApiFunction::GetUdpSocket(int socket_id) {
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);
350 int socket_id = *it; local
[all...] |
| 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/chrome/browser/extensions/api/sockets_tcp/ |
| 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);
|
| sockets_tcp_api.cc | 22 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id,
27 socket_info->socket_id = socket_id;
90 ResumableTCPSocket* TCPSocketAsyncApiFunction::GetTcpSocket(int socket_id) {
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);
433 int socket_id = *it; local
[all...] |
| 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;
[all...] |
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| 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);
|
| socket_dispatcher_host.cc | 150 P2PSocketHost* P2PSocketDispatcherHost::LookupSocket(int socket_id) {
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,
229 P2PSocketHost* socket = LookupSocket(socket_id);
[all...] |
| /external/chromium_org/ppapi/tests/extensions/socket/ |
| 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/ |
| ppb_ext_socket_thunk.cc | 36 void Destroy(PP_Instance instance, PP_Var socket_id) {
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) {
92 args.push_back(socket_id);
97 PP_Var socket_id,
107 input_args.push_back(socket_id);
[all...] |
