/dports/audio/musicpd/mpd-0.23.6/src/db/update/ |
H A D | InotifySource.cxx | 39 auto ifd = socket_event.GetFileDescriptor(); in OnSocketReady() 49 socket_event.Cancel(); in OnSocketReady() 86 :socket_event(_loop, BIND_THIS_METHOD(OnSocketReady), in InotifySource() 90 socket_event.ScheduleRead(); in InotifySource() 96 auto ifd = socket_event.GetFileDescriptor(); in Add() 107 auto ifd = socket_event.GetFileDescriptor(); in Remove()
|
H A D | InotifySource.hxx | 29 PipeEvent socket_event; member in InotifySource 48 socket_event.Close(); in ~InotifySource()
|
/dports/audio/ncmpc/ncmpc-0.41/src/ |
H A D | plugin.cxx | 45 SocketEvent socket_event; member in PluginPipe 54 socket_event(event_loop, BIND_THIS_METHOD(OnRead)) {} in PluginPipe() 57 socket_event.Close(); in ~PluginPipe() 61 socket_event.Open(SocketDescriptor::FromFileDescriptor(fd.Release())); in Start() 62 socket_event.ScheduleRead(); in Start() 66 socket_event.Close(); in Close() 70 return socket_event.IsDefined(); in IsOpen() 219 ssize_t nbytes = read(socket_event.GetSocket().Get(), in OnRead() 222 socket_event.Close(); in OnRead() 228 socket_event.ScheduleRead(); in OnRead()
|
H A D | AsyncUserInput.cxx | 74 if (!do_input_event(socket_event.GetEventLoop(), cmd)) in OnSocketReady() 82 :socket_event(event_loop, BIND_THIS_METHOD(OnSocketReady), in AsyncUserInput() 86 socket_event.ScheduleRead(); in AsyncUserInput()
|
/dports/multimedia/gstreamer1/gstreamer-1.16.2/libs/gst/helpers/ |
H A D | gst-ptp-helper.c | 85 static GSocket *socket_event, *socket_general; variable 106 (socket == socket_event ? "event" : "general")); in have_socket_data_cb() 109 header.type = (socket == socket_event) ? TYPE_EVENT : TYPE_GENERAL; in have_socket_data_cb() 194 TYPE_EVENT ? socket_event : socket_general, in have_stdin_data_cb() 223 socket_event = in setup_sockets() 226 if (!socket_event) in setup_sockets() 229 g_socket_set_multicast_loopback (socket_event, FALSE); in setup_sockets() 242 if (!g_socket_bind (socket_event, bind_saddr, TRUE, &err)) in setup_sockets() 260 if (ioctl (g_socket_get_fd (socket_event), SIOCGIFCONF, &ifc) != -1) { in setup_sockets() 351 if (ioctl (g_socket_get_fd (socket_event), SIOCGIFHWADDR, in setup_sockets() [all …]
|
/dports/ftp/filezilla/filezilla-3.55.1/src/engine/ |
H A D | proxy.cpp | 194 fz::dispatch<fz::socket_event, fz::hostaddress_event>(ev, this, in operator ()() 252 event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, error); in OnReceive() 263 …event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, ECONNABORTED… in OnReceive() 286 … event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, ENOMEM); in OnReceive() 302 … event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, ECONNRESET); in OnReceive() 308 event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, 0); in OnReceive() 347 event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, 0); in OnReceive() 361 …event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, ECONNABORTED… in OnReceive() 518 event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, 0); in OnReceive() 606 …event_handler_->send_event<fz::socket_event>(this, fz::socket_event_flag::connection, ECONNABORTED… in OnReceive() [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/ngs/src/ |
H A D | socket_events.cc | 138 Socket_data *socket_event = m_socket_events.back(); in listen() local 140 socket_event->callback = callback; in listen() 141 socket_event->socket = sock; in listen() 143 event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), in listen() 145 socket_event); in listen() 146 event_base_set(m_evbase, &socket_event->ev); in listen() 148 return 0 == event_add(&socket_event->ev, nullptr); in listen()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/ngs/src/ |
H A D | socket_events.cc | 137 Socket_data *socket_event = m_socket_events.back(); in listen() local 139 socket_event->callback = callback; in listen() 140 socket_event->socket = sock; in listen() 142 …event_set(&socket_event->ev, static_cast<int>(sock->get_socket_fd()), EV_READ|EV_PERSIST, &Socket_… in listen() 143 event_base_set(m_evbase, &socket_event->ev); in listen() 145 return 0 == event_add(&socket_event->ev, NULL); in listen()
|
/dports/audio/musicpd/mpd-0.23.6/src/event/ |
H A D | Loop.cxx | 255 auto &socket_event = *(SocketEvent *)poll_result.GetObject(i); in Wait() local 256 socket_event.SetReadyFlags(poll_result.GetEvents(i)); in Wait() 259 socket_event.unlink(); in Wait() 260 ready_sockets.push_back(socket_event); in Wait() 356 auto &socket_event = ready_sockets.front(); in Run() local 359 socket_event.unlink(); in Run() 360 sockets.push_back(socket_event); in Run() 362 socket_event.Dispatch(); in Run()
|
/dports/audio/musicpd/mpd-0.23.6/src/lib/curl/ |
H A D | Global.cxx | 44 SocketEvent socket_event; member in CurlSocket 49 socket_event(_loop, BIND_THIS_METHOD(OnSocketReady), _fd) {} in CurlSocket() 65 return socket_event.GetEventLoop(); in GetEventLoop() 77 return socket_event.GetSocket(); in GetSocket() 143 cs->socket_event.Schedule(flags); in SocketFunction()
|
/dports/irc/ezbounce/ezbounce-1.99.15/include/ |
H A D | dcc.h | 142 virtual int socket_event(int s, int events, int extra) = 0; 159 virtual int socket_event(int, int, int) = 0; 213 virtual int socket_event(int, int, int); 243 virtual int socket_event(int, int, int); 278 virtual int socket_event(int, int, int);
|
/dports/net-im/telepathy-gabble/telepathy-gabble-0.18.4/tests/twisted/tubes/ |
H A D | accept-muc-stream-tube.py | 158 socket_event, si_event, conn_id = t.connect_to_cm_socket(q, 'chat@conf.localhost/bob', 161 protocol = socket_event.protocol 201 socket_event, si_event, conn_id = t.connect_to_cm_socket(q, 'chat@conf.localhost/bob', 213 socket_event, si_event, conn_id = t.connect_to_cm_socket(q, 'chat@conf.localhost/bob', 216 protocol = socket_event.protocol
|
H A D | offer-private-stream-tube.py | 207 si_reply_event, _, new_conn_event, socket_event = q.expect_many( 221 protocol = socket_event.protocol 240 si_reply_event, new_conn_event, socket_event = q.expect_many( 252 protocol = socket_event.protocol
|
/dports/audio/musicpd/mpd-0.23.6/src/zeroconf/ |
H A D | Bonjour.hxx | 34 SocketEvent socket_event; member in BonjourHelper 49 socket_event.Cancel(); in Cancel()
|
H A D | Bonjour.cxx | 59 socket_event(_loop, in BonjourHelper() 63 socket_event.ScheduleRead(); in BonjourHelper()
|
/dports/irc/ezbounce/ezbounce-1.99.15/src/ |
H A D | dcc.cc | 116 owner()->socket_event(role(), dcc::SOCK_CONNECTED, 0); in on_connect() 124 owner()->socket_event(role(), dcc::SOCK_WRITEABLE, 0); in on_writeable() 135 owner()->socket_event(role(), dcc::SOCK_READABLE, 0); in on_readable() 142 owner()->socket_event(role(), dcc::SOCK_CLOSED, 0); in on_readable() 145 owner()->socket_event(role(), dcc::SOCK_READABLE, 0); in on_readable() 153 owner()->socket_event(role(), dcc::SOCK_CLOSED, e); in on_disconnect() 159 owner()->socket_event(role(), dcc::SOCK_CLOSED, e); in on_connect_fail() 435 int dccsend::socket_event(int r, int events, int extra) in socket_event() function in dccsend 683 int dccpipe::socket_event(int r, int event, int extra) in socket_event() function in dccpipe 878 int dccget::socket_event(int r, int events, int extra) in socket_event() function in dccget
|
/dports/ftp/libfilezilla/libfilezilla-0.31.1/lib/ |
H A D | socket.cpp | 103 else if (ev.second->derived_type() == socket_event::type()) { in remove_socket_events() 104 return std::get<0>(static_cast<socket_event const&>(*ev.second).v_) == source; in remove_socket_events() 135 if (ev.second->derived_type() == socket_event::type()) { in change_socket_event_handler() 136 auto & sev = static_cast<socket_event const&>(*ev.second); in change_socket_event_handler() 173 if (ev.first == handler && ev.second->derived_type() == socket_event::type()) { in has_pending_event() 174 auto const& socket_ev = static_cast<socket_event const&>(*ev.second).v_; in has_pending_event() 691 …socket_->evt_handler_->send_event<socket_event>(socket_->ev_source_, socket_event_flag::connection… in try_connect_host() 772 …socket_->evt_handler_->send_event<socket_event>(socket_->ev_source_, socket_event_flag::connection… in do_connect() 1915 pEvtHandler->send_event<socket_event>(ev_source_, socket_event_flag::write, 0); in set_event_handler() 1919 pEvtHandler->send_event<socket_event>(ev_source_, socket_event_flag::read, 0); in set_event_handler() [all …]
|
H A D | rate_limited_layer.cpp | 37 event_handler_->send_event<socket_event>(this, socket_event_flag::read, 0); in wakeup() 40 event_handler_->send_event<socket_event>(this, socket_event_flag::write, 0); in wakeup() 133 parent_.event_handler_->send_event<socket_event>(&parent_, socket_event_flag::read, 0); in wakeup() 136 parent_.event_handler_->send_event<socket_event>(&parent_, socket_event_flag::write, 0); in wakeup()
|
/dports/audio/musicpd/mpd-0.23.6/src/lib/nfs/ |
H A D | Connection.hxx | 95 SocketEvent socket_event; member in NfsConnection 144 :socket_event(_loop, BIND_THIS_METHOD(OnSocketReady)), in NfsConnection() 156 return socket_event.GetEventLoop(); in GetEventLoop()
|
H A D | Connection.cxx | 406 socket_event.ReleaseSocket(); in DestroyContext() 443 socket_event.ReleaseSocket(); in ScheduleSocket() 445 if (!socket_event.IsDefined()) { in ScheduleSocket() 451 socket_event.Open(_fd); in ScheduleSocket() 454 socket_event.Schedule(libnfs_to_events(which_events)); in ScheduleSocket() 497 socket_event.ReleaseSocket(); in OnSocketReady()
|