| /external/chromium/third_party/libevent/sample/ |
| event-test.c | 74 HANDLE socket; local
76 socket = CreateFile("test.txt", // open File
84 if(socket == INVALID_HANDLE_VALUE)
90 int socket;
108 socket = open (fifo, O_RDWR | O_NONBLOCK, 0);
110 socket = open (fifo, O_RDONLY | O_NONBLOCK, 0);
113 if (socket == -1) {
125 event_set(&evfifo, (int)socket, EV_READ, fifo_read, &evfifo);
127 event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo);
135 CloseHandle(socket);
[all...] |
| /external/chromium_org/ipc/ |
| ipc_channel_handle.h | 27 // type that knows how to copy a socket endpoint over IPC.
48 : name(n), socket(s) {}
53 base::FileDescriptor socket; member in struct:IPC::ChannelHandle
|
| /external/chromium_org/ppapi/tests/ |
| test_tcp_server_socket_private_disallowed.cc | 60 PP_Resource socket = local
62 ASSERT_TRUE(socket != 0);
63 ASSERT_TRUE(tcp_server_socket_private_interface_->IsTCPServerSocket(socket));
71 socket,
|
| /external/chromium_org/third_party/libevent/sample/ |
| event-test.c | 74 HANDLE socket; local
76 socket = CreateFile("test.txt", // open File
84 if(socket == INVALID_HANDLE_VALUE)
90 int socket;
108 socket = open (fifo, O_RDWR | O_NONBLOCK, 0);
110 socket = open (fifo, O_RDONLY | O_NONBLOCK, 0);
113 if (socket == -1) {
125 event_set(&evfifo, (int)socket, EV_READ, fifo_read, &evfifo);
127 event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo);
135 CloseHandle(socket);
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| testclient_unittest.cc | 39 AsyncSocket* socket = main->socketserver() local
41 socket->Bind(loopback);
43 TestClient client(new AsyncUDPSocket(socket));
55 AsyncSocket* socket = main->socketserver() local
58 socket, loopback, server.address());
|
| /external/chromium_org/third_party/npapi/npspy/extern/nspr/ |
| prtpool.h | 52 PRFileDesc *socket; member in struct:PRJobIoDesc
70 /* queue a job, when a socket is readable */
75 /* queue a job, when a socket is writeable */
80 /* queue a job, when a socket has a pending connection */
85 /* queue a job, when the socket connection to addr succeeds or fails */
|
| /external/chromium_org/third_party/tlslite/tlslite/integration/ |
| HTTPTLSConnection.py | 3 import socket namespace
23 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
28 #Use a TLSConnection to emulate a socket
31 #When httplib closes this, close the socket
39 handshake. This method will be called after the socket has
|
| IMAP4_TLS.py | 3 import socket namespace
127 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
| /external/dropbear/ |
| configure | 2793 socket (); function
[all...] |
| /libcore/dalvik/src/main/java/dalvik/system/ |
| SocketTagger.java | 20 import java.net.Socket;
24 * Callbacks for socket assignment and reassignment.
37 * thread. The socket is either newly connected or reused from a connection
47 * <p><strong>Note:</strong> this method will not be invoked when the socket
52 public final void tag(Socket socket) throws SocketException {
53 if (!socket.isClosed()) {
54 tag(socket.getFileDescriptor$());
58 public final void untag(Socket socket) throws SocketException
[all...] |
| /libcore/luni/src/main/java/java/nio/channels/ |
| ServerSocketChannel.java | 27 * stream-oriented listening socket. Binding and manipulation of socket options
29 * by calling {@code socket()}. ServerSocketChannels can not be constructed for
30 * an already existing server-socket, nor can a {@link java.net.SocketImpl} be assigned.
32 * A server-socket channel is open but not bound when created by the {@code
50 * Creates an open and unbound server-socket channel.
64 * Gets the valid operations of this channel. Server-socket channels support
77 * Return the server-socket assigned this channel, which does not declare
80 * @return the server-socket assigned to this channel.
82 public abstract ServerSocket socket(); method in class:ServerSocketChannel
[all...] |
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Socket.java | 28 * Encapsulates a connection with the emulator over a UNIX-domain socket.
30 public class Socket {
31 /** UNIX-domain socket connected with the emulator. */
33 /** Channel name for the connection established via this socket. */
44 * Constructs Socket instance.
46 * @param socket Socket connection with the emulator.
50 public Socket(LocalSocket socket, String name, ByteOrder endian) {
51 mSocket = socket;
99 LocalSocket socket = mSocket; local
116 LocalSocket socket = mSocket; local
153 LocalSocket socket = mSocket; local
182 LocalSocket socket; local
[all...] |
| /external/apache-http/src/org/apache/http/impl/io/ |
| SocketInputBuffer.java | 36 import java.net.Socket;
44 * {@link Socket} bound session input buffer.
54 private final Socket socket; field in class:SocketInputBuffer
57 final Socket socket,
61 if (socket == null) {
62 throw new IllegalArgumentException("Socket may not be null");
64 this.socket = socket;
[all...] |
| /external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
| Socks5BytestreamSession.java | 23 import java.net.Socket;
35 /* the underlying socket of the SOCKS5 Bytestream */
36 private final Socket socket;
field in class:Socks5BytestreamSession
41 protected Socks5BytestreamSession(Socket socket, boolean isDirect) {
42 this.socket = socket;
69 return this.socket.getInputStream();
73 return this.socket.getOutputStream();
[all...] |
| Socks5ClientForInitiator.java | 17 import java.net.Socket;
63 public Socket getSocket(int timeout) throws IOException, XMPPException, InterruptedException,
65 Socket socket = null;
local
70 socket = socks5Server.getSocket(this.digest);
71 if (socket == null) {
76 socket = super.getSocket(timeout);
82 socket.close();
88 return socket;
|
| /cts/tests/tests/net/src/android/net/cts/ |
| SSLCertificateSocketFactoryTest.java | 21 import java.net.Socket;
72 Socket socket = new Socket(); local
73 mFactory.createSocket(socket, host, port, true);
78 Socket socket = null; local
79 socket = mFactory.createSocket(host, port);
80 assertNotNull(socket);
81 assertNotNull(socket.getOutputStream())
[all...] |
| /development/samples/WiFiDirectDemo/src/com/example/android/wifidirect/ |
| FileTransferService.java | 17 import java.net.Socket;
21 * socket connection with the WiFi Direct Group Owner and writing the file
50 Socket socket = new Socket(); local
54 Log.d(WiFiDirectActivity.TAG, "Opening client socket - ");
55 socket.bind(null);
56 socket.connect((new InetSocketAddress(host, port)), SOCKET_TIMEOUT);
58 Log.d(WiFiDirectActivity.TAG, "Client socket - " + socket.isConnected())
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ |
| ServerSocketFactoryTest.java | 25 import java.net.Socket;
67 Socket s = serverSocket.accept();
75 Socket socket = new Socket(InetAddress.getLocalHost(), serverSocket.getLocalPort()); local
79 InputStream in = socket.getInputStream();
83 socket.close();
93 List<Socket> backlog = new ArrayList<Socket>();
98 Socket socket = new Socket() local
[all...] |
| /sdk/hierarchyviewer/src/com/android/hierarchyviewer/scene/ |
| WindowsLoader.java | 29 import java.net.Socket;
34 Socket socket = null; local
42 socket = new Socket();
43 socket.connect(new InetSocketAddress("127.0.0.1",
46 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
47 in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
86 if (socket != null) {
87 socket.close()
[all...] |
| /development/samples/WiFiDirectServiceDiscovery/src/com/example/android/wifidirect/discovery/ |
| ChatManager.java | 10 import java.net.Socket;
13 * Handles reading and writing of messages with socket buffers. Uses a Handler
18 private Socket socket = null; field in class:ChatManager
21 public ChatManager(Socket socket, Handler handler) {
22 this.socket = socket;
34 iStream = socket.getInputStream();
35 oStream = socket.getOutputStream()
[all...] |
| GroupOwnerSocketHandler.java | 19 ServerSocket socket = null; field in class:GroupOwnerSocketHandler
26 socket = new ServerSocket(4545);
28 Log.d("GroupOwnerSocketHandler", "Socket Started");
50 pool.execute(new ChatManager(socket.accept(), handler));
55 if (socket != null && !socket.isClosed())
56 socket.close();
|
| /external/okhttp/android/main/java/com/squareup/okhttp/internal/ |
| Platform.java | 24 import java.net.Socket;
54 public void tagSocket(Socket socket) throws SocketException {
55 SocketTagger.get().tag(socket);
58 public void untagSocket(Socket socket) throws SocketException {
59 SocketTagger.get().untag(socket);
66 public void enableTlsExtensions(SSLSocket socket, String uriHost) {
67 if (socket instanceof OpenSSLSocketImpl) {
68 OpenSSLSocketImpl openSSLSocket = (OpenSSLSocketImpl) socket;
[all...] |
| /libcore/luni/src/main/java/java/util/logging/ |
| SocketHandler.java | 22 import java.net.Socket;
25 * A handler that writes log messages to a socket connection.
62 // the socket connection
63 private Socket socket; field in class:SocketHandler
102 // Initialize the socket connection and prepare the output stream
120 this.socket = new Socket(host, p);
126 super.internalSetOutputStream(new BufferedOutputStream(this.socket.getOutputStream()));
136 if (this.socket != null)
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| basicpacketsocketfactory.cc | 56 talk_base::AsyncSocket* socket = local
58 if (!socket) {
61 if (BindSocket(socket, address, min_port, max_port) < 0) {
63 << socket->GetError();
64 delete socket;
67 return new talk_base::AsyncUDPSocket(socket);
73 talk_base::AsyncSocket* socket = local
75 if (!socket) {
79 if (BindSocket(socket, local_address, min_port, max_port) < 0) {
81 << socket->GetError()
97 talk_base::AsyncSocket* socket = local
[all...] |
| socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
33 Attach(socket);
40 void SocketStream::Attach(AsyncSocket* socket) {
43 socket_ = socket;
53 AsyncSocket* socket = socket_; local
61 return socket;
67 case Socket::CS_CONNECTED:
69 case Socket::CS_CONNECTING:
71 case Socket::CS_CLOSED:
117 void SocketStream::OnConnectEvent(AsyncSocket* socket) {
[all...] |
