| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| HttpTransport.java | 28 import java.net.Socket;
57 * we can save socket writes, which in turn saves a packet transmission.
190 Socket socket = connection.getSocket();
191 if (socket == null) return false;
193 int socketTimeout = socket.getSoTimeout();
194 socket.setSoTimeout(DISCARD_STREAM_TIMEOUT_MILLIS);
199 socket.setSoTimeout(socketTimeout);
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/test/ |
| ModelInterpreter.java | 29 import java.net.Socket;
202 Socket s;
208 "IOException on socket.accept(); stopping", ex);
217 "IOException on accepted socket(); re-listening", ex);
|
| /libcore/luni/src/test/java/tests/api/javax/net/ssl/ |
| X509KeyManagerTest.java | 4 import java.net.Socket;
[all...] |
| /development/apps/Development/src/com/android/development/ |
| Connectivity.java | 68 import java.net.Socket;
511 onRoutedRequest(SOCKET);
514 private final static int SOCKET = 1;
531 case SOCKET:
619 Socket socket = null; local
621 socket = new Socket(remote, 80, local, 6000);
623 Log.e(TAG, "Exception creating socket: " + e);
627 PrintWriter out = new PrintWriter(socket.getOutputStream(), true)
656 Socket socket = null; local
[all...] |
| /external/antlr/antlr-3.4/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/ |
| RemoteDebugEventSocketListener.cs | 42 using Socket = System.Net.Sockets.Socket;
52 Socket channel = null;
271 //channel = new Socket( machine, port );
|
| /external/antlr/antlr-3.4/runtime/CSharp3/Sources/Antlr3.Runtime.Debug/ |
| RemoteDebugEventSocketListener.cs | 44 using Socket = System.Net.Sockets.Socket;
55 Socket channel = null;
334 //channel = new Socket( machine, port );
|
| /external/antlr/antlr-3.4/runtime/Java/src/main/java/org/antlr/runtime/debug/ |
| RemoteDebugEventSocketListener.java | 38 import java.net.Socket;
46 Socket channel = null;
193 channel = new Socket(machine, port);
|
| /external/ganymed-ssh2/src/main/java/ch/ethz/ssh2/transport/ |
| TransportManager.java | 13 import java.net.Socket;
133 private final Socket sock = new Socket();
155 * address in the Socket constructor. That is why we
727 log.debug("Ignoring socket timeout");
|
| /libcore/luni/src/main/java/org/apache/harmony/xnet/provider/jsse/ |
| OpenSSLSocketImpl.java | 26 import java.net.Socket;
84 private final Socket socket; field in class:OpenSSLSocketImpl
103 * getSoTimeout to delegate to the wrapped socket.
113 this.socket = this;
120 this.socket = this;
127 this.socket = this;
134 this.socket = this;
143 this.socket = this;
151 this.socket = this
[all...] |
| /packages/experimental/StrictModeTest/src/com/android/strictmodetest/ |
| StrictModeActivity.java | 72 import java.net.Socket;
410 Log.d(TAG, "Socket linger test; linger=" + linger);
412 Socket socket = new Socket(); local
413 socket.setSoLinger(linger, 5);
414 socket.close();
|
| /external/chromium/third_party/libjingle/source/talk/session/tunnel/ |
| pseudotcpchannel.cc | 134 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1);
373 talk_base::scoped_ptr<Socket> mtu_socket(
|
| /external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
| Socks5BytestreamManager.java | 18 import java.net.Socket;
55 * socket. The actual transfer though takes place over a separately created socket.
62 * negotiate a SOCKS5 Bytestream with the given target JID and return a socket.
388 * Establishes a SOCKS5 Bytestream with the given user and returns the Socket to send/receive
399 * @return the Socket to send/receive data to/from the user
413 * the Socket to send/receive data to/from the user.
417 * @return the Socket to send/receive data to/from the user
494 Socket socket = socks5Client.getSocket(getProxyConnectionTimeout()); local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| firewallsocketserver.cc | 40 FirewallSocket(FirewallSocketServer* server, AsyncSocket* socket, int type)
41 : AsyncSocketAdapter(socket), server_(server), type_(type) {
193 Socket* FirewallSocketServer::CreateSocket(int type) {
205 LOG(LS_VERBOSE) << "FirewallSocketServer socket creation denied";
|
| openssladapter.cc | 60 "socket",
73 BIO* BIO_new_socket(talk_base::AsyncSocket* socket) {
78 ret->ptr = socket;
85 b->num = 0; // 1 means socket closed
99 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr);
101 int result = socket->Recv(out, outl);
106 } else if (socket->IsBlocking()) {
115 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr);
117 int result = socket->Send(in, inl);
120 } else if (socket->IsBlocking())
[all...] |
| schanneladapter.cc | 108 SChannelAdapter::SChannelAdapter(AsyncSocket* socket)
109 : SSLAdapter(socket), state_(SSL_NONE),
126 if (socket_->GetState() != Socket::CS_CONNECTED) {
610 // socket api doesn't support nice shutdown at this point, we don't bother.
620 Socket::ConnState
632 SChannelAdapter::OnConnectEvent(AsyncSocket* socket) {
636 AsyncSocketAdapter::OnConnectEvent(socket);
647 SChannelAdapter::OnReadEvent(AsyncSocket* socket) {
649 AsyncSocketAdapter::OnReadEvent(socket);
675 SChannelAdapter::OnWriteEvent(AsyncSocket* socket) {
[all...] |
| win32socketserver.cc | 82 description = "Using a non-blocking socket, will notify later";
215 parent_->OnSocketNotify(static_cast<SOCKET>(wParam), wsa_event, wsa_error);
260 int Win32Socket::Attach(SOCKET s) {
293 LOG(LS_WARNING) << "GetLocalAddress: unable to get local addr, socket="
310 LOG(LS_WARNING) << "GetRemoteAddress: unable to get remote addr, socket="
391 Socket::ConnState Win32Socket::GetState() const {
468 SOCKET s = ::accept(socket_, reinterpret_cast<sockaddr*>(&saddr), &cbAddr);
474 Win32Socket* socket = new Win32Socket; local
475 if (0 == socket->Attach(s))
476 return socket;
715 Win32Socket* socket = new Win32Socket; local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| stunport.cc | 145 LOG_J(LS_WARNING, this) << "UDP socket creation failed";
196 int StunPort::SetOption(talk_base::Socket::Option opt, int value) {
204 void StunPort::OnReadPacket(talk_base::AsyncPacketSocket* socket,
207 ASSERT(socket == socket_);
|
| 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...] |
| port.h | 179 // Functions on the underlying socket(s).
180 virtual int SetOption(talk_base::Socket::Option opt, int value) = 0;
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TLSMessageProcessor.java | 60 * accept socket).
122 * Run method for the thread that gets created for each accept socket.
125 // Accept new connectins on our socket.
147 Socket newsock = sock.accept();
|
| UDPMessageChannel.java | 56 import java.net.Socket;
83 * and invoking it on the message read from the UDP socket. The parsed structure
709 // Use the socket from the message processor (for firewall
710 // support use the same socket as the message processor
711 // socket -- feature request # 18 from java.net). This also
715 // Bind the socket to the stack address in case there
793 Socket outputSocket = sipStack.ioHandler.sendBytes(
799 // The socket is cached (dont close it!);
[all...] |
| /external/qemu/android/ |
| console.c | 92 typedef int Socket;
97 Socket sock; /* socket used for communication */
108 /* listening socket */
109 Socket listen_fd;
193 /* Detach the socket descriptor from a given ControlClient
195 * the client, or redirecting the socket to another service.
197 * NOTE: this does not close the socket.
216 /* Reattach a control client to a given socket.
217 * Return the old socket descriptor for the client
[all...] |
| /cts/suite/audio_quality/client/src/com/android/cts/audiotest/ |
| AudioProtocol.java | 34 import java.net.Socket;
66 // all socket access (accept / read) set this timeout to check exit periodically.
68 private Socket mClient = null;
71 // lock to use to write to socket, I/O streams, and also change socket (create, destroy)
98 // wake up from socket read
106 mThread.interrupt(); // this does not bail out from socket in android
123 // maybe socket already closed. don't do anything
384 // maybe socket already closed. don't do anything
508 Log.d(TAG, "get new server socket");
[all...] |
| /development/cmds/monkey/src/com/android/commands/monkey/ |
| MonkeySourceNetwork.java | 36 import java.net.Socket;
554 private Socket clientSocket;
|
| /external/chromium/net/socket/ |
| ssl_server_socket_nss.cc | 5 #include "net/socket/ssl_server_socket_nss.h"
39 #include "net/socket/nss_ssl_util.h"
40 #include "net/socket/ssl_error_params.h"
49 Socket* socket, X509Certificate* cert, crypto::RSAPrivateKey* key,
51 return new SSLServerSocketNSS(socket, cert, key, ssl_config);
55 Socket* transport_socket,
190 /* Push SSL onto our fake I/O socket */
232 // Server socket doesn't need session tickets.
343 // Tell SSL we're a server; needed if not letting NSPR do socket I/
[all...] |
