Home
last modified time | relevance | path

Searched refs:socket_event (Results 1 – 25 of 141) sorted by relevance

123456

/dports/audio/musicpd/mpd-0.23.6/src/db/update/
H A DInotifySource.cxx39 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 DInotifySource.hxx29 PipeEvent socket_event; member in InotifySource
48 socket_event.Close(); in ~InotifySource()
/dports/audio/ncmpc/ncmpc-0.41/src/
H A Dplugin.cxx45 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 DAsyncUserInput.cxx74 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 Dgst-ptp-helper.c85 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 Dproxy.cpp194 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 Dsocket_events.cc137 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 Dsocket_events.cc137 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 Dsocket_events.cc137 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 Dsocket_events.cc138 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 Dsocket_events.cc137 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 Dsocket_events.cc137 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 Dsocket_events.cc137 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 DLoop.cxx255 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 DGlobal.cxx44 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 Ddcc.h142 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 Daccept-muc-stream-tube.py158 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 Doffer-private-stream-tube.py207 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 DBonjour.hxx34 SocketEvent socket_event; member in BonjourHelper
49 socket_event.Cancel(); in Cancel()
H A DBonjour.cxx59 socket_event(_loop, in BonjourHelper()
63 socket_event.ScheduleRead(); in BonjourHelper()
/dports/irc/ezbounce/ezbounce-1.99.15/src/
H A Ddcc.cc116 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 Dsocket.cpp103 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 Drate_limited_layer.cpp37 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 DConnection.hxx95 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 DConnection.cxx406 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()

123456