| /external/apache-http/android/src/android/net/http/ |
| AndroidHttpClientConnection.java | 54 import java.net.Socket;
75 private Socket socket = null; field in class:AndroidHttpClientConnection
83 * Bind socket and set HttpParams to AndroidHttpClientConnection
84 * @param socket outgoing socket
89 final Socket socket,
91 if (socket == null) {
92 throw new IllegalArgumentException("Socket may not be null")
[all...] |
| /external/jacoco/org.jacoco.examples/src/org/jacoco/examples/ |
| ExecutionDataServer.java | 18 import java.net.Socket;
29 * This example starts a socket server to collect coverage from agents that run
61 private final Socket socket; field in class:ExecutionDataServer.Handler
67 Handler(final Socket socket, final ExecutionDataWriter fileWriter)
69 this.socket = socket;
73 new RemoteControlWriter(socket.getOutputStream());
75 reader = new RemoteControlReader(socket.getInputStream())
[all...] |
| /sdk/hierarchyviewer/src/com/android/hierarchyviewer/scene/ |
| ProfilesLoader.java | 24 import java.net.Socket;
38 Socket socket = null; local
43 socket = new Socket();
44 socket.connect(new InetSocketAddress("127.0.0.1",
47 out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
48 in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
72 if (socket != null) {
73 socket.close()
[all...] |
| 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...] |
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/net/ |
| SocketFacade.java | 37 import java.net.Socket;
43 * This class has APIs for various socket types
44 * android.system.Os socket used for UDP and TCP sockets
46 * java.net.Socket and java.net.ServerSocket for TCP sockets
52 private static HashMap<String, Socket> sSocketHashMap =
53 new HashMap<String, Socket>();
69 private String getDatagramSocketId(DatagramSocket socket) {
70 return "DATAGRAMSOCKET:" + socket.hashCode();
74 * Method to return hash value of a Socket object
78 private String getSocketId(Socket socket)
158 Socket socket = new Socket(remoteAddr, remotePort.intValue(), localAddr, local
176 Socket socket = sSocketHashMap.get(id); local
218 ServerSocket socket = sServerSocketHashMap.get(id); local
242 Socket socket = serverSocket.accept(); local
260 Socket socket = sSocketHashMap.get(id); local
282 Socket socket = sSocketHashMap.get(id); local
314 DatagramSocket socket = new DatagramSocket(port.intValue(), localAddr); local
331 DatagramSocket socket = sDatagramSocketHashMap.get(id); local
355 DatagramSocket socket = sDatagramSocketHashMap.get(id); local
374 DatagramSocket socket = sDatagramSocketHashMap.get(id); local
518 FileDescriptor socket = Os.accept(fd, null); local
[all...] |
| /external/webrtc/webrtc/base/ |
| asynctcpsocket.cc | 34 // Binds and connects |socket|
36 rtc::AsyncSocket* socket,
39 rtc::scoped_ptr<rtc::AsyncSocket> owned_socket(socket);
40 if (socket->Bind(bind_address) < 0) {
41 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
44 if (socket->Connect(remote_address) < 0) {
45 LOG(LS_ERROR) << "Connect() failed with error " << socket->GetError();
51 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, bool listen,
53 : socket_(socket),
95 case Socket::CS_CLOSED
[all...] |
| /sdk/apps/SdkController/src/com/android/tools/sdkcontroller/lib/ |
| Channel.java | 161 * Socket stuff.
164 /** Socket to use to to communicate with the emulator. */
165 private Socket mSocket = null;
298 // Use local copy of the socket, ensuring it's not going to NULL while
305 Socket socket = mSocket; local
306 return socket != null && socket.isConnected();
312 * gets registered, and there is a pending socket connection for it.
314 * @param socket Channel connection socket
348 Socket socket; local
431 Socket socket = mSocket; local
455 Socket socket = mSocket; local
483 Socket socket = mSocket; local
558 Socket socket = mSocket; local
629 Socket socket = mSocket; local
[all...] |
| /external/autotest/client/cros/cellular/ |
| ether_io_rf_switch.py | 17 import socket
32 self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
33 self.socket.bind(('', 0))
35 self.socket.settimeout(3) # In seconds
38 self.socket.sendto(payload, self.destination)
62 except socket.timeout
[all...] |
| /external/v8/tools/testrunner/server/ |
| presence_handler.py | 29 import socket
47 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
104 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
109 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| tcpport.h | 55 int GetOption(rtc::Socket::Option opt, int* value) override;
56 int SetOption(rtc::Socket::Option opt, int value) override;
74 // Handles sending using the local TCP socket.
82 void OnNewConnection(rtc::AsyncPacketSocket* socket,
88 rtc::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming
94 // Receives packet signal from the local TCP Socket.
95 void OnReadPacket(rtc::AsyncPacketSocket* socket,
100 void OnSentPacket(rtc::AsyncPacketSocket* socket,
103 void OnReadyToSend(rtc::AsyncPacketSocket* socket);
105 void OnAddressReady(rtc::AsyncPacketSocket* socket,
130 rtc::AsyncPacketSocket* socket() { return socket_.get(); } function in class:cricket::TCPConnection
[all...] |
| /external/autotest/server/cros/network/rf_switch/ |
| scpi_ssh_tunnel.py | 31 import socket
68 # to connect to the socket connection
84 # Open a socket connection for communication with chassis
87 self.socket = socket.socket()
88 self.socket.connect(('127.0.0.1', self.proxy_port))
89 except (socket.error, socket.timeout) as e:
107 self.socket.close(
[all...] |
| /external/wayland/tests/ |
| compositor-introspection-test.c | 84 const char *socket; local
89 socket = wl_display_add_socket_auto(compositor->display);
94 return socket;
106 const char *socket; local
112 socket = setup_compositor(&compositor);
114 client.display = wl_display_connect(socket);
143 const char *socket; local
151 socket = setup_compositor(&compositor);
152 client.display = wl_display_connect(socket);
|
| /external/parameter-framework/upstream/remote-process/ |
| main.cpp | 39 #include "Socket.h"
43 bool sendAndDisplayCommand(asio::ip::tcp::socket &socket, CRequestMessage &requestMessage)
47 if (requestMessage.serialize(Socket(socket), true, strError) != CRequestMessage::success) {
55 if (answerMessage.serialize(Socket(socket), false, strError) != CRequestMessage::success) {
94 tcp::socket connectionSocket(io_service);
|
| /external/syslinux/efi/ |
| tcp.c | 15 int core_tcp_open(struct pxe_pvt_inode *socket)
23 socket->net.efi.binding = b;
50 int core_tcp_connect(struct pxe_pvt_inode *socket, uint32_t ip, uint16_t port)
55 struct efi_binding *b = socket->net.efi.binding;
116 bool core_tcp_is_connected(struct pxe_pvt_inode *socket)
118 if (socket->net.efi.binding)
124 int core_tcp_write(struct pxe_pvt_inode *socket, const void *data,
129 struct efi_binding *b = socket->net.efi.binding;
176 struct pxe_pvt_inode *socket = PVT(inode); local
177 struct efi_binding *b = socket->net.efi.binding
204 struct pxe_pvt_inode *socket = PVT(inode); local
[all...] |
| /system/core/adb/ |
| test_adb.py | 27 import socket
146 # Use SO_LINGER to cause TCP RST segment to be sent on socket close.
153 sock.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER,
156 linger = sock.getsockopt(socket.SOL_SOCKET, socket.SO_LINGER, 16)
168 socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as listener
[all...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| DatagramChannelTest.java | 75 dc.socket().bind(null);
86 DatagramSocket socket = dc.socket(); local
87 assertFalse(socket.isBound());
88 assertFalse(socket.getBroadcast());
89 assertFalse(socket.isClosed());
90 assertFalse(socket.isConnected());
91 assertEquals(0, socket.getLocalPort());
92 assertTrue(socket.getLocalAddress().isAnyLocalAddress());
93 assertNull(socket.getLocalSocketAddress())
[all...] |
| /external/compiler-rt/test/sanitizer_common/TestCases/Linux/ |
| recv_msg_trunc.cc | 10 #include <sys/socket.h>
15 int fd_0 = socket(AF_INET, SOCK_DGRAM, 0);
16 int fd_1 = socket(AF_INET, SOCK_DGRAM, 0);
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| PSKKeyManager.java | 19 import java.net.Socket;
117 * socket.
121 String chooseServerKeyIdentityHint(Socket socket);
133 * socket.
140 String chooseClientKeyIdentity(String identityHint, Socket socket);
154 * Gets the PSK to use for the provided socket.
163 SecretKey getKey(String identityHint, String identity, Socket socket);
[all...] |
| ConscryptServerSocket.java | 21 import java.net.Socket;
58 * Configures the socket to be created for this instance.
120 * Enables/disables the TLS Channel ID extension for this server socket.
127 * Checks whether the TLS Channel ID extension is enabled for this server socket.
177 public Socket accept() throws IOException {
178 final ConscryptSocketBase socket; local
180 socket = Platform.createEngineSocket(sslParameters);
182 socket = Platform.createFileDescriptorSocket(sslParameters);
185 socket.setChannelIdEnabled(channelIdEnabled);
186 implAccept(socket);
[all...] |
| /external/deqp/execserver/ |
| xsTcpServer.hpp | 44 virtual ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) = DE_NULL;
52 de::Socket m_socket;
69 ConnectionHandler (TcpServer* server, de::Socket* socket) : m_server(server), m_socket(socket) {}
79 de::Socket* m_socket;
|
| /external/python/cpython3/Tools/demo/ |
| rpython.py | 9 from socket import socket, AF_INET, SOCK_STREAM, SHUT_WR
25 s = socket(AF_INET, SOCK_STREAM)
|
| /external/scapy/scapy/ |
| utils6.py | 14 import socket
165 naddr = inet_pton(socket.AF_INET6, addr)
166 paddr = inet_ntop(socket.AF_INET6, naddr) # normalize
221 ifaceid = inet_pton(socket.AF_INET6, "::"+ifaceid)[8:16]
239 mask = inet_pton(socket.AF_INET6, "::ffff:ffff:ffff:ffff")
240 x = in6_and(mask, inet_pton(socket.AF_INET6, addr))
241 ifaceid = inet_ntop(socket.AF_INET6, x)[2:]
288 addr = inet_pton(socket.AF_INET6, addr)
318 return inet_ntop(socket.AF_INET6, a)
327 addr = inet_pton(socket.AF_INET, addr
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldAndroidDatagramTest.java | 42 DatagramSocket socket; field in class:OldAndroidDatagramTest.Reflector
59 socket.receive(packet);
74 socket.send(packet);
81 socket.close();
91 socket = new DatagramSocket(port, address);
121 DatagramSocket socket = null; local
131 socket = new DatagramSocket(2345, InetAddress.getLocalHost());
141 socket.send(packet);
150 socket.receive(packet);
161 if (socket != null)
[all...] |
| /test/vts/runners/host/tcp_server/ |
| callback_server_test.py | 17 import socket
21 from socket import error as socket_error
72 # Create a socket (SOCK_STREAM means a TCP socket)
73 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
114 # Create a socket (SOCK_STREAM means a TCP socket)
[all...] |
| /external/python/cpython2/Lib/test/ |
| test_nntplib.py | 1 import socket
22 except socket.timeout:
38 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
