/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...] |