• Home
  • Raw
  • Download

Lines Matching refs:socket

115     delete it->socket;  in ~TCPPort()
148 if (rtc::AsyncPacketSocket* socket = GetIncoming(address.address(), true)) { in CreateConnection() local
152 socket->SignalReadPacket.disconnect(this); in CreateConnection()
153 conn = new TCPConnection(this, address, socket); in CreateConnection()
158 if (conn->socket()) { in CreateConnection()
159 conn->socket()->SignalReadyToSend.connect(this, &TCPPort::OnReadyToSend); in CreateConnection()
160 conn->socket()->SignalSentPacket.connect(this, &TCPPort::OnSentPacket); in CreateConnection()
203 rtc::AsyncPacketSocket* socket = NULL; in SendTo() local
214 socket = conn->socket(); in SendTo()
215 if (!socket) { in SendTo()
225 socket = GetIncoming(addr); in SendTo()
226 if (!socket) { in SendTo()
236 int sent = socket->Send(data, size, modified_options); in SendTo()
238 error_ = socket->GetError(); in SendTo()
276 void TCPPort::OnNewConnection(rtc::AsyncPacketSocket* socket, in OnNewConnection() argument
278 RTC_DCHECK(socket == socket_); in OnNewConnection()
282 incoming.socket = new_socket; in OnNewConnection()
283 incoming.socket->SignalReadPacket.connect(this, &TCPPort::OnReadPacket); in OnNewConnection()
284 incoming.socket->SignalReadyToSend.connect(this, &TCPPort::OnReadyToSend); in OnNewConnection()
285 incoming.socket->SignalSentPacket.connect(this, &TCPPort::OnSentPacket); in OnNewConnection()
308 rtc::AsyncPacketSocket* socket = NULL; in GetIncoming() local
312 socket = it->socket; in GetIncoming()
318 return socket; in GetIncoming()
321 void TCPPort::OnReadPacket(rtc::AsyncPacketSocket* socket, in OnReadPacket() argument
329 void TCPPort::OnSentPacket(rtc::AsyncPacketSocket* socket, in OnSentPacket() argument
334 void TCPPort::OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend() argument
338 void TCPPort::OnAddressReady(rtc::AsyncPacketSocket* socket, in OnAddressReady() argument
351 rtc::AsyncPacketSocket* socket) in TCPConnection() argument
353 socket_(socket), in TCPConnection()
355 outgoing_(socket == NULL), in TCPConnection()
371 ConnectSocketSignals(socket); in TCPConnection()
434 void TCPConnection::OnConnect(rtc::AsyncPacketSocket* socket) { in OnConnect() argument
435 RTC_DCHECK(socket == socket_.get()); in OnConnect()
450 const rtc::SocketAddress& socket_address = socket->GetLocalAddress(); in OnConnect()
456 << socket->GetRemoteAddress().ToSensitiveString(); in OnConnect()
458 if (socket->GetLocalAddress().IsLoopbackIP()) { in OnConnect()
477 OnClose(socket, 0); in OnConnect()
487 void TCPConnection::OnClose(rtc::AsyncPacketSocket* socket, int error) { in OnClose() argument
488 RTC_DCHECK(socket == socket_.get()); in OnClose()
547 void TCPConnection::OnReadPacket(rtc::AsyncPacketSocket* socket, in OnReadPacket() argument
552 RTC_DCHECK(socket == socket_.get()); in OnReadPacket()
556 void TCPConnection::OnReadyToSend(rtc::AsyncPacketSocket* socket) { in OnReadyToSend() argument
557 RTC_DCHECK(socket == socket_.get()); in OnReadyToSend()
593 void TCPConnection::ConnectSocketSignals(rtc::AsyncPacketSocket* socket) { in ConnectSocketSignals() argument
595 socket->SignalConnect.connect(this, &TCPConnection::OnConnect); in ConnectSocketSignals()
597 socket->SignalReadPacket.connect(this, &TCPConnection::OnReadPacket); in ConnectSocketSignals()
598 socket->SignalReadyToSend.connect(this, &TCPConnection::OnReadyToSend); in ConnectSocketSignals()
599 socket->SignalClose.connect(this, &TCPConnection::OnClose); in ConnectSocketSignals()