19 #include "rtc_base/socket.h"
26 // StreamSink - Monitor asynchronously signalled events from Socket.
45   void Monitor(rtc::Socket* socket) {  in Monitor()  argument
46     socket->SignalConnectEvent.connect(this, &StreamSink::OnConnectEvent);  in Monitor()
47     socket->SignalReadEvent.connect(this, &StreamSink::OnReadEvent);  in Monitor()
48     socket->SignalWriteEvent.connect(this, &StreamSink::OnWriteEvent);  in Monitor()
49     socket->SignalCloseEvent.connect(this, &StreamSink::OnCloseEvent);  in Monitor()
51     events_.erase(socket);  in Monitor()
53   void Unmonitor(rtc::Socket* socket) {  in Unmonitor()  argument
54     socket->SignalConnectEvent.disconnect(this);  in Unmonitor()
55     socket->SignalReadEvent.disconnect(this);  in Unmonitor()
56     socket->SignalWriteEvent.disconnect(this);  in Unmonitor()
57     socket->SignalCloseEvent.disconnect(this);  in Unmonitor()
58     events_.erase(socket);  in Unmonitor()
60   bool Check(rtc::Socket* socket, StreamSinkEvent event, bool reset = true) {
61     return DoCheck(socket, event, reset);
65   typedef std::map<rtc::Socket*, int> EventMap;
67   void OnConnectEvent(rtc::Socket* socket) { AddEvents(socket, SSE_OPEN); }  in OnConnectEvent()  argument
68   void OnReadEvent(rtc::Socket* socket) { AddEvents(socket, SSE_READ); }  in OnReadEvent()  argument
69   void OnWriteEvent(rtc::Socket* socket) { AddEvents(socket, SSE_WRITE); }  in OnWriteEvent()  argument
70   void OnCloseEvent(rtc::Socket* socket, int error) {  in OnCloseEvent()  argument
71     AddEvents(socket, (0 == error) ? SSE_CLOSE : SSE_ERROR);  in OnCloseEvent()
74   void AddEvents(rtc::Socket* obj, int events) {  in AddEvents()
82   bool DoCheck(rtc::Socket* obj, StreamSinkEvent event, bool reset) {  in DoCheck()