| /packages/apps/Nfc/nci/src/com/android/nfc/dhimpl/ |
| NativeLlcpServiceSocket.java | 41 LlcpSocket socket = doAccept(mLocalMiu, mLocalRw, mLocalLinearBufferLength); local
42 if (socket == null) throw new IOException();
43 return socket;
|
| /packages/apps/Nfc/nxp/src/com/android/nfc/dhimpl/ |
| NativeLlcpServiceSocket.java | 41 LlcpSocket socket = doAccept(mLocalMiu, mLocalRw, mLocalLinearBufferLength); local
42 if (socket == null) throw new IOException();
43 return socket;
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_epoll.py | 24 import socket namespace
44 self.serverSocket = socket.socket()
55 client = socket.socket()
59 except socket.error, e:
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_epoll.py | 24 import socket namespace
44 self.serverSocket = socket.socket()
55 client = socket.socket()
59 except socket.error, e:
|
| /libcore/crypto/src/main/java/org/conscrypt/ |
| SSLSocketWrapper.java | 23 import java.net.Socket;
28 * This class wraps the SSL fuctionality over existing conneted socket.
32 private final Socket socket; field in class:SSLSocketWrapper
35 protected SSLSocketWrapper(Socket socket, String host, int port, boolean autoClose,
38 if (!socket.isConnected()) {
39 throw new SocketException("Socket is not connected.");
41 this.socket = socket;
[all...] |
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Connection.java | 34 * the device side, the connection is bound to the UNIX-domain socket named
37 * 'android.sdk.controller' socket on the device. Typically, the port forwarding
52 * 2. Channels are connected to emulator via separate socket instance (though all
53 * of the connections share the same socket address).
61 * 1. Bind to "android.sdk.controller" socket, listening to emulator connections.
79 /** Server socket used to listen to emulator connections. */
91 private List<Socket> mPendingSockets = new ArrayList<Socket>();
110 * Binds to the socket, and starts the listening thread.
124 * Stops the listener, and closes the socket
133 LocalServerSocket socket; local
269 LocalServerSocket socket = mServerSocket; local
[all...] |
| /sdk/hierarchyviewer/src/com/android/hierarchyviewer/scene/ |
| CaptureLoader.java | 37 import java.net.Socket;
42 Socket socket = null; local
48 socket = new Socket();
49 socket.connect(new InetSocketAddress("127.0.0.1",
52 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
53 in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
80 if (socket != null) {
81 socket.close()
130 Socket socket = null; local
[all...] |
| ViewHierarchyLoader.java | 31 import java.net.Socket;
42 Socket socket = null; local
51 socket = new Socket();
52 socket.connect(new InetSocketAddress("127.0.0.1",
55 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
56 in = new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8"));
125 socket.close();
|
| /frameworks/base/core/java/android/net/ |
| DnsPinger.java | 59 /** Short socket timeout so we don't block one any 'receive' call */
90 * Send a new ping via a socket. arg1 is ID, arg2 is timeout, obj is InetAddress to ping
100 DatagramSocket socket; field in class:DnsPinger.ActivePing
148 newActivePing.socket = new DatagramSocket();
149 // Set some socket properties
150 newActivePing.socket.setSoTimeout(SOCKET_TIMEOUT_MS);
154 newActivePing.socket.setNetworkInterface(NetworkInterface.getByName(
157 loge("sendDnsPing::Error binding to socket " + e);
174 newActivePing.socket.send(packet);
189 /** Each socket will block for {@link #SOCKET_TIMEOUT_MS} in receive() *
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| ThreadSafeClientConnManager.java | 35 import java.net.Socket;
178 // When using a recycled Socket, we need to re-tag it with any
181 final Socket socket = entry.getConnection().getSocket(); local
182 if (socket != null) {
183 SocketTagger.get().tag(socket);
186 log.debug("Problem tagging socket.", iox);
213 // When recycling a Socket, we un-tag it to avoid collecting
216 final Socket socket = entry.getConnection().getSocket()
[all...] |
| /external/chromium/third_party/libjingle/source/talk/examples/login/ |
| xmppsocket.cc | 50 talk_base::AsyncSocket* socket = local
55 socket = talk_base::SSLAdapter::Create(socket);
58 cricket_socket_ = socket;
65 cricket_socket_ = socket;
87 void XmppSocket::OnReadEvent(talk_base::AsyncSocket * socket) {
91 void XmppSocket::OnWriteEvent(talk_base::AsyncSocket * socket) {
105 void XmppSocket::OnConnectEvent(talk_base::AsyncSocket * socket) {
118 void XmppSocket::OnCloseEvent(talk_base::AsyncSocket * socket, int error) {
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.cc | 48 // Treat failure to create or bind a TCP socket as fatal. This
54 LOG_J(LS_ERROR, this) << "TCP socket creation failed.";
84 if (talk_base::AsyncPacketSocket* socket =
86 socket->SignalReadPacket.disconnect(this);
87 conn = new TCPConnection(this, address, socket);
112 talk_base::AsyncPacketSocket * socket = NULL; local
114 socket = conn->socket();
116 socket = GetIncoming(addr);
118 if (!socket) {
157 talk_base::AsyncPacketSocket* socket = NULL; local
[all...] |
| /external/chromium_org/build/android/ |
| lighttpd_server.py | 19 import socket namespace
136 except (httplib.HTTPException, socket.error) as client_error:
|
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp/ |
| tcp_socket_event_dispatcher.cc | 8 #include "chrome/browser/extensions/api/socket/tcp_socket.h"
42 : thread_id_(Socket::kThreadId),
46 DCHECK(manager) << "There is no socket manager. "
91 ResumableTCPSocket* socket = local
93 if (!socket) {
94 // This can happen if the socket is closed while our callback is active.
97 DCHECK(params.extension_id == socket->owner_extension_id())
98 << "Socket has wrong owner.";
100 // Don't start another read if the socket has been paused.
101 if (socket->paused()
160 ResumableTCPSocket* socket = local
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/ |
| tcp_server_socket_event_dispatcher.cc | 8 #include "chrome/browser/extensions/api/socket/tcp_socket.h"
40 : thread_id_(Socket::kThreadId),
44 DCHECK(server_manager) << "There is no server socket manager. "
52 DCHECK(client_manager) << "There is no client socket manager. "
101 ResumableTCPServerSocket* socket = local
103 if (!socket) {
104 // This can happen if the socket is closed while our callback is active.
107 DCHECK(params.extension_id == socket->owner_extension_id())
108 << "Socket has wrong owner.";
110 // Don't start another accept if the socket has been paused
160 ResumableTCPServerSocket* socket = local
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/sockets_udp/ |
| udp_socket_event_dispatcher.cc | 8 #include "chrome/browser/extensions/api/socket/udp_socket.h"
38 : thread_id_(Socket::kThreadId),
42 DCHECK(manager) << "There is no socket manager. "
78 ResumableUDPSocket* socket = local
80 if (socket == NULL) {
81 // This can happen if the socket is closed while our callback is active.
84 DCHECK(params.extension_id == socket->owner_extension_id())
85 << "Socket has wrong owner.";
87 // Don't start another read if the socket has been paused.
88 if (socket->paused()
145 ResumableUDPSocket* socket = local
[all...] |
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| socket_host_tcp_server_unittest.cc | 33 void AddIncoming(net::StreamSocket* socket) {
36 accept_socket_->reset(socket);
46 incoming_sockets_.push_back(socket);
61 virtual int Accept(scoped_ptr<net::StreamSocket>* socket,
63 DCHECK(socket); variable
65 socket->reset(incoming_sockets_.front());
69 accept_socket_ = socket;
|
| /external/chromium_org/net/dns/ |
| dns_socket_pool.cc | 14 #include "net/socket/client_socket_factory.h"
15 #include "net/socket/stream_socket.h"
23 // When we allocate a socket, we ensure we have at least kAllocateMinSize
73 scoped_ptr<DatagramClientSocket> socket; local
76 socket = socket_factory_->CreateDatagramClientSocket(
79 if (socket.get()) {
80 int rv = socket->Connect((*nameservers_)[server_index]);
82 VLOG(1) << "Failed to connect socket: " << rv;
83 socket.reset();
86 LOG(WARNING) << "Failed to create socket."
197 DatagramClientSocket* socket = pool[socket_index]; local
214 DatagramClientSocket* socket = local
[all...] |
| /external/chromium_org/ppapi/native_client/tools/browser_tester/ |
| browser_tester.py | 9 import socket namespace
153 help='Pass --allow-nacl-socket-api=<host> to Chrome, where '
194 host = socket.gethostbyname(socket.gethostname())
227 # socket directly.
228 host, port = server.socket.getsockname()
340 # loop to shut down before closing the socket FD it is
342 # to close the socket FD.
|
| /external/chromium_org/ppapi/proxy/ |
| ppapi_param_traits.cc | 237 case ppapi::proxy::SerializedHandle::SOCKET:
264 case ppapi::proxy::SerializedHandle::SOCKET: {
265 IPC::PlatformFileForTransit socket; local
266 if (ParamTraits<IPC::PlatformFileForTransit>::Read(m, iter, &socket)) {
267 r->set_socket(socket);
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/servers/ |
| http_server_base.py | 33 import socket namespace
188 s = socket.socket()
204 s = socket.socket()
205 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| asyncudpsocket.cc | 36 AsyncSocket* socket,
38 scoped_ptr<AsyncSocket> owned_socket(socket);
39 if (socket->Bind(bind_address) < 0) {
40 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
48 AsyncSocket* socket = local
50 if (!socket)
52 return Create(socket, bind_address);
55 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket)
56 : socket_(socket) {
61 // The socket should start out readable but not writable
[all...] |
| natserver.cc | 109 AsyncPacketSocket* socket, const char* buf, size_t size,
129 iter->second->socket->SendTo(buf + length, size - length, dest_addr,
134 AsyncPacketSocket* socket, const char* buf, size_t size,
137 SocketAddress local_addr = socket->GetLocalAddress();
163 AsyncUDPSocket* socket = AsyncUDPSocket::Create(external_, external_ip_); local
165 if (!socket) {
170 TransEntry* entry = new TransEntry(route, socket, nat_);
172 (*ext_map_)[socket->GetLocalAddress()] = entry;
173 socket->SignalReadPacket.connect(this, &NATServer::OnExternalPacket);
183 : route(r), socket(s)
[all...] |
| natserver.h | 81 void OnInternalPacket(AsyncPacketSocket* socket, const char* buf,
84 void OnExternalPacket(AsyncPacketSocket* socket, const char* buf,
91 /* Records a translation and the associated external socket. */
100 AsyncUDPSocket* socket; member in struct:talk_base::NATServer::TransEntry
|
| socketpool.cc | 138 AsyncSocket* socket = local
140 if (!socket) {
145 if ((socket->Connect(remote) != 0) && !socket->IsBlocking()) {
147 *err = socket->GetError();
148 delete socket;
153 return new SocketStream(socket);
176 // Only one socket can be used from this "pool" at a time
179 LOG_F(LS_VERBOSE) << "Creating new socket";
185 AsyncSocket* socket local
[all...] |
