| /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/chromium_org/third_party/libjingle/source/talk/base/ |
| testutils.h | 82 void Monitor(AsyncSocket* socket) {
83 socket->SignalConnectEvent.connect(this, &StreamSink::OnConnectEvent);
84 socket->SignalReadEvent.connect(this, &StreamSink::OnReadEvent);
85 socket->SignalWriteEvent.connect(this, &StreamSink::OnWriteEvent);
86 socket->SignalCloseEvent.connect(this, &StreamSink::OnCloseEvent);
88 events_.erase(socket);
90 void Unmonitor(AsyncSocket* socket) {
91 socket->SignalConnectEvent.disconnect(this);
92 socket->SignalReadEvent.disconnect(this);
93 socket->SignalWriteEvent.disconnect(this)
294 AsyncSocket* socket() { return socket_.get(); } function in class:testing::SocketTestClient
[all...] |
| win32socketserver.cc | 83 description = "Using a non-blocking socket, will notify later";
216 parent_->OnSocketNotify(static_cast<SOCKET>(wParam), wsa_event, wsa_error);
266 int Win32Socket::Attach(SOCKET s) {
298 LOG(LS_WARNING) << "GetLocalAddress: unable to get local addr, socket="
313 LOG(LS_WARNING) << "GetRemoteAddress: unable to get remote addr, socket="
409 Socket::ConnState Win32Socket::GetState() const {
493 SOCKET s = ::accept(socket_, reinterpret_cast<sockaddr*>(&saddr), &addr_len);
499 Win32Socket* socket = new Win32Socket; local
500 if (0 == socket->Attach(s))
501 return socket;
759 Win32Socket* socket = new Win32Socket; local
[all...] |
| virtualsocketserver.cc | 111 // Implements the socket interface using the virtual network. Packets are
112 // passed as messages using the message queue of the socket server.
180 // Disconnect listening socket.
189 // Disconnect remote socket, check if it is a child of a server socket.
190 VirtualSocket* socket = local
192 if (!socket) {
193 // Not a server socket child, then see if it is bound.
194 // TODO: If this is indeed a server socket that has no
195 // children this will cause the server socket to b
215 VirtualSocket* socket = server_->LookupConnection(local_addr_, local
328 VirtualSocket* socket = new VirtualSocket(server_, AF_INET, type_, local
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/session/tunnel/ |
| pseudotcpchannel.cc | 137 channel_->SetOption(Socket::OPT_DONTFRAGMENT, 1);
377 Socket* socket = local
379 talk_base::scoped_ptr<Socket> mtu_socket(socket);
380 if (socket == NULL) {
381 LOG_F(LS_WARNING) << "Couldn't create socket while estimating MTU.";
|
| /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");
|
| /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/chromium_org/net/test/android/javatests/src/org/chromium/net/test/util/ |
| TestWebServer.java | 31 import java.net.Socket;
500 // sleep in case server socket is still being closed
512 Socket socket = mSocket.accept(); local
514 conn.bind(socket, params);
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| turnport_unittest.cc | 123 talk_base::AsyncSocket* socket = ss_->CreateAsyncSocket(SOCK_STREAM); local
124 EXPECT_GE(socket->Bind(addr), 0);
125 EXPECT_GE(socket->Listen(5), 0);
126 return socket;
257 EXPECT_EQ(0, turn_port_->SetOption(talk_base::Socket::OPT_SNDBUF, 10*1024));
272 EXPECT_EQ(0, turn_port_->SetOption(talk_base::Socket::OPT_SNDBUF, 10*1024));
|
| transportchannelproxy.cc | 105 int TransportChannelProxy::SetOption(talk_base::Socket::Option opt, int value) {
|
| /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";
|
| /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...] |
| /external/chromium_org/chrome/browser/extensions/api/bluetooth/ |
| bluetooth_event_router.cc | 83 scoped_refptr<device::BluetoothSocket> socket) {
84 // If there is a socket registered with the same fd, just return it's id
87 if (i->second.get() == socket.get())
91 socket_map_[return_id] = socket;
175 scoped_refptr<device::BluetoothSocket> socket) {
179 int socket_id = RegisterSocket(socket);
180 api::bluetooth::Socket result_socket;
|
| /external/chromium_org/chrome/browser/profiles/ |
| chrome_browser_main_extra_parts_profiles.cc | 48 #include "chrome/browser/extensions/api/socket/socket.h"
202 extensions::ApiResourceManager<extensions::Socket>::GetFactoryInstance();
|
| /external/chromium_org/remoting/protocol/ |
| fake_session.h | 15 #include "net/socket/socket.h"
16 #include "net/socket/stream_socket.h"
29 // FakeSocket implement net::Socket interface for FakeConnection. All data
55 // net::Socket implementation.
109 // FakeUdpSocket is similar to FakeSocket but behaves as UDP socket. All written
112 class FakeUdpSocket : public net::Socket {
124 // net::Socket implementation.
|
| /external/chromium_org/third_party/libjingle/source/talk/media/sctp/ |
| sctpdataengine_unittest.cc | 96 virtual int SetOption(SocketType type, talk_base::Socket::Option opt,
309 // Disconnects and closes socket, including setting receiving to false.
|
| /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();
|
| /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;
|
