| /external/chromium/third_party/libjingle/source/talk/base/ |
| asyncsocket.cc | 38 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(NULL) {
43 delete socket_;
47 ASSERT(!socket_);
48 socket_ = socket;
49 if (socket_) {
50 socket_->SignalConnectEvent.connect(this,
52 socket_->SignalReadEvent.connect(this,
54 socket_->SignalWriteEvent.connect(this,
56 socket_->SignalCloseEvent.connect(this,
|
| socketstream.cc | 32 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
37 delete socket_;
41 if (socket_)
42 delete socket_;
43 socket_ = socket;
44 if (socket_) {
45 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent);
46 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent);
47 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent);
48 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent)
[all...] |
| asyncsocket.h | 63 return socket_->GetLocalAddress();
66 return socket_->GetRemoteAddress();
69 return socket_->Bind(addr);
72 return socket_->Connect(addr);
75 return socket_->Send(pv, cb);
78 return socket_->SendTo(pv, cb, addr);
81 return socket_->Recv(pv, cb);
84 return socket_->RecvFrom(pv, cb, paddr);
87 return socket_->Listen(backlog);
90 return socket_->Accept(paddr)
128 AsyncSocket* socket_; member in class:talk_base::AsyncSocketAdapter
[all...] |
| asyncudpsocket.cc | 52 : socket_(socket) {
53 ASSERT(socket_.get() != NULL);
58 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent);
68 return socket_->GetLocalAddress();
72 return socket_->GetRemoteAddress();
76 return socket_->Send(pv, cb);
81 return socket_->SendTo(pv, cb, addr);
85 return socket_->Close();
89 return socket_->GetState();
93 return socket_->GetOption(opt, value)
[all...] |
| asynctcpsocket.cc | 64 : socket_(socket),
73 ASSERT(socket_.get() != NULL);
74 socket_->SignalConnectEvent.connect(this, &AsyncTCPSocket::OnConnectEvent);
75 socket_->SignalReadEvent.connect(this, &AsyncTCPSocket::OnReadEvent);
76 socket_->SignalWriteEvent.connect(this, &AsyncTCPSocket::OnWriteEvent);
77 socket_->SignalCloseEvent.connect(this, &AsyncTCPSocket::OnCloseEvent);
80 if (socket_->Listen(LISTEN_BACKLOG) < 0) {
81 LOG(LS_ERROR) << "Listen() failed with error " << socket_->GetError();
94 return socket_->GetLocalAddress();
98 return socket_->GetRemoteAddress()
[all...] |
| autodetectproxy.cc | 42 : agent_(user_agent), socket_(NULL), next_(0) {
67 delete socket_;
76 OnCloseEvent(socket_, ETIMEDOUT);
91 if (socket_) {
93 socket_->Close();
94 Thread::Current()->Dispose(socket_);
95 socket_ = NULL;
98 socket_ = Thread::Current()->socketserver()->CreateAsyncSocket(SOCK_STREAM);
99 socket_->SignalConnectEvent.connect(this, &AutoDetectProxy::OnConnectEvent);
100 socket_->SignalReadEvent.connect(this, &AutoDetectProxy::OnReadEvent)
[all...] |
| sslsocketfactory.cc | 56 ASSERT(NULL == socket_);
71 if (socket_) {
72 return socket_->GetError();
77 if (socket_) {
78 return socket_->Close();
87 if (socket_) {
88 return socket_->GetState();
102 } else if (!IsBlockingError(socket_->GetError())) {
103 SignalCloseEvent(this, socket_->GetError());
|
| socketstream.h | 47 AsyncSocket* GetSocket() { return socket_; }
65 AsyncSocket* socket_; member in class:talk_base::SocketStream
|
| /external/chromium/net/udp/ |
| udp_client_socket.cc | 14 : socket_(net_log, source) {
21 return socket_.Connect(address);
27 return socket_.Read(buf, buf_len, callback);
33 return socket_.Write(buf, buf_len, callback);
37 socket_.Close();
41 return socket_.GetPeerAddress(address);
45 return socket_.GetLocalAddress(address);
|
| udp_server_socket.cc | 11 : socket_(net_log, source) {
18 return socket_.Bind(address);
25 return socket_.RecvFrom(buf, buf_len, address, callback);
32 return socket_.SendTo(buf, buf_len, address, callback);
36 socket_.Close();
40 return socket_.GetPeerAddress(address);
44 return socket_.GetLocalAddress(address);
|
| udp_socket_libevent.h | 94 bool is_connected() const { return socket_ != kInvalidSocket; }
101 explicit ReadWatcher(UDPSocketLibevent* socket) : socket_(socket) {}
106 if (socket_->read_callback_)
107 socket_->DidCompleteRead();
113 UDPSocketLibevent* const socket_; member in class:net::UDPSocketLibevent::ReadWatcher
120 explicit WriteWatcher(UDPSocketLibevent* socket) : socket_(socket) {}
127 if (socket_->write_callback_)
128 socket_->DidCompleteWrite();
132 UDPSocketLibevent* const socket_; member in class:net::UDPSocketLibevent::WriteWatcher
156 int socket_; member in class:net::UDPSocketLibevent
[all...] |
| udp_socket_win.cc | 25 DCHECK_EQ(object, socket_->read_overlapped_.hEvent);
26 socket_->DidCompleteRead();
30 DCHECK_EQ(object, socket_->write_overlapped_.hEvent);
31 socket_->DidCompleteWrite();
36 : socket_(INVALID_SOCKET),
73 closesocket(socket_);
74 socket_ = INVALID_SOCKET;
87 if (getpeername(socket_, addr, &addr_len))
109 if (getsockname(socket_, addr, &addr_len))
132 DCHECK_NE(INVALID_SOCKET, socket_);
[all...] |
| udp_socket_win.h | 96 bool is_connected() const { return socket_ != INVALID_SOCKET; }
101 explicit ReadDelegate(UDPSocketWin* socket) : socket_(socket) {}
108 UDPSocketWin* const socket_; member in class:net::UDPSocketWin::ReadDelegate
113 explicit WriteDelegate(UDPSocketWin* socket) : socket_(socket) {}
120 UDPSocketWin* const socket_; member in class:net::UDPSocketWin::WriteDelegate
144 SOCKET socket_; member in class:net::UDPSocketWin
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| udpport.cc | 43 socket_(NULL),
48 socket_ = factory_->CreateUdpSocket(
50 if (!socket_) {
54 socket_->SignalReadPacket.connect(this, &UDPPort::OnReadPacket);
59 delete socket_;
64 talk_base::SocketAddress address = socket_->GetLocalAddress(&allocated);
68 socket_->SignalAddressReady.connect(this, &UDPPort::OnAddresReady);
84 int sent = socket_->SendTo(data, size, addr);
86 error_ = socket_->GetError();
94 return socket_->SetOption(opt, value)
[all...] |
| tcpport.cc | 43 socket_(NULL),
50 socket_ = factory_->CreateServerTcpSocket(
53 if (!socket_) {
57 socket_->SignalNewConnection.connect(this, &TCPPort::OnNewConnection);
62 delete socket_;
102 talk_base::SocketAddress address = socket_->GetLocalAddress(&allocated);
106 socket_->SignalAddressReady.connect(this, &TCPPort::OnAddresReady);
134 return socket_->SetOption(opt, value);
143 ASSERT(socket == socket_);
183 : Connection(port, 0, candidate), socket_(socket), error_(0)
[all...] |
| /external/chromium/net/socket_stream/ |
| socket_stream_job.cc | 45 return socket_->GetUserData(key);
50 socket_->SetUserData(key, data);
54 socket_->Connect();
58 return socket_->SendData(data, len);
62 socket_->Close();
67 socket_->RestartWithAuth(username, password);
71 socket_->DetachDelegate();
|
| socket_stream_job.h | 41 socket_ = socket;
48 return socket_->context();
51 socket_->set_context(context);
70 scoped_refptr<SocketStream> socket_; member in class:net::SocketStreamJob
|
| /external/chromium/net/socket/ |
| tcp_client_socket_libevent.h | 80 explicit ReadWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {}
85 if (socket_->read_callback_)
86 socket_->DidCompleteRead();
92 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::ReadWatcher
99 explicit WriteWatcher(TCPClientSocketLibevent* socket) : socket_(socket) {}
106 if (socket_->waiting_connect()) {
107 socket_->DidCompleteConnect();
108 } else if (socket_->write_callback_) {
109 socket_->DidCompleteWrite();
114 TCPClientSocketLibevent* const socket_; member in class:net::TCPClientSocketLibevent::WriteWatcher
151 int socket_; member in class:net::TCPClientSocketLibevent
[all...] |
| tcp_server_socket_libevent.cc | 40 : socket_(kInvalidSocket),
51 if (socket_ != kInvalidSocket)
59 DCHECK_EQ(socket_, kInvalidSocket);
61 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
62 if (socket_ < 0) {
67 if (SetNonBlocking(socket_)) {
79 int result = bind(socket_, addr, addr_len);
87 result = listen(socket_, backlog);
105 if (getsockname(socket_, addr, &addr_len) < 0)
126 socket_, true, MessageLoopForIO::WATCH_READ
[all...] |
| tcp_server_socket_win.cc | 20 : socket_(INVALID_SOCKET),
40 DCHECK_EQ(socket_, INVALID_SOCKET);
49 socket_ = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
50 if (socket_ < 0) {
55 if (SetNonBlocking(socket_)) {
67 int result = bind(socket_, addr, addr_len);
75 result = listen(socket_, backlog);
93 if (getsockname(socket_, addr, &addr_len))
114 WSAEventSelect(socket_, socket_event_, FD_ACCEPT);
129 int result = accept(socket_, addr, &addr_len)
[all...] |
| tcp_client_socket_libevent.cc | 109 : socket_(kInvalidSocket),
143 DCHECK_EQ(socket_, kInvalidSocket);
144 socket_ = socket;
169 if (socket_ != kInvalidSocket)
246 if (!HANDLE_EINTR(connect(socket_, current_ai_->ai_addr,
254 FD_SET(socket_, &writeset);
258 int res = HANDLE_EINTR(select(socket_ + 1, 0, &writeset, 0, &tv));
278 socket_, true, MessageLoopForIO::WATCH_WRITE, &write_socket_watcher_,
326 if (socket_ == kInvalidSocket)
336 qtaguid_untagSocket(socket_);
[all...] |
| tcp_client_socket_win.cc | 74 void Detach() { socket_ = NULL; }
129 TCPClientSocketWin* socket_; member in class:net::TCPClientSocketWin::Core
154 socket_(socket),
190 if (core_->socket_) {
191 if (core_->socket_->waiting_connect()) {
192 core_->socket_->DidCompleteConnect();
194 core_->socket_->DidCompleteRead();
204 if (core_->socket_)
205 core_->socket_->DidCompleteWrite();
215 : socket_(INVALID_SOCKET)
[all...] |
| /external/chromium/net/tools/fetch/ |
| http_session.h | 23 scoped_refptr<HttpListenSocket> socket_; member in class:HttpSession
|
| /external/chromium/net/websockets/ |
| websocket_job.cc | 78 DCHECK(!socket_.get());
82 DCHECK(socket_.get());
85 socket_->Connect();
115 return socket_->SendData(
135 socket_->Close();
142 socket_->RestartWithAuth(username, password);
153 if (socket_)
154 socket_->DetachDelegate();
155 socket_ = NULL;
247 socket_ = NULL
[all...] |
| /external/chromium/chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/ |
| IRCProxyWebSocket.java | 39 Socket socket_ = null; field in class:IRCProxyWebSocket.ChatWebSocket
53 if (socket_ == null) {
58 socket_ = SocketFactory.getDefault().createSocket(tokens[0],
60 out_ = new OutputStreamWriter(socket_.getOutputStream());
62 socket_.getInputStream());
89 socket_.close();
|
