Lines Matching refs:socket
65 void Monitor(rtc::AsyncSocket* socket) { in Monitor() argument
66 socket->SignalConnectEvent.connect(this, &StreamSink::OnConnectEvent); in Monitor()
67 socket->SignalReadEvent.connect(this, &StreamSink::OnReadEvent); in Monitor()
68 socket->SignalWriteEvent.connect(this, &StreamSink::OnWriteEvent); in Monitor()
69 socket->SignalCloseEvent.connect(this, &StreamSink::OnCloseEvent); in Monitor()
71 events_.erase(socket); in Monitor()
73 void Unmonitor(rtc::AsyncSocket* socket) { in Unmonitor() argument
74 socket->SignalConnectEvent.disconnect(this); in Unmonitor()
75 socket->SignalReadEvent.disconnect(this); in Unmonitor()
76 socket->SignalWriteEvent.disconnect(this); in Unmonitor()
77 socket->SignalCloseEvent.disconnect(this); in Unmonitor()
78 events_.erase(socket); in Unmonitor()
80 bool Check(rtc::AsyncSocket* socket,
83 return DoCheck(socket, event, reset);
85 int Events(rtc::AsyncSocket* socket, bool reset = true) {
86 return DoEvents(socket, reset);
98 void OnConnectEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_OPEN); } in OnConnectEvent() argument
99 void OnReadEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_READ); } in OnReadEvent() argument
100 void OnWriteEvent(rtc::AsyncSocket* socket) { AddEvents(socket, SSE_WRITE); } in OnWriteEvent() argument
101 void OnCloseEvent(rtc::AsyncSocket* socket, int error) { in OnCloseEvent() argument
102 AddEvents(socket, (0 == error) ? SSE_CLOSE : SSE_ERROR); in OnCloseEvent()