| /dports/devel/opendht/opendht-1.10.1/include/opendht/ |
| H A D | node.h | 42 Socket(SocketCb&& on_receive) : in Socket()
43 on_receive(std::move(on_receive)) {} in Socket()
44 SocketCb on_receive {};
|
| /dports/devel/py-opendht/opendht-1.10.1/include/opendht/ |
| H A D | node.h | 42 Socket(SocketCb&& on_receive) : in Socket()
43 on_receive(std::move(on_receive)) {} in Socket()
44 SocketCb on_receive {};
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/unimrcp/libs/mrcpv2-transport/include/ |
| H A D | mrcp_connection_types.h | 61 apt_bool_t (*on_receive)(mrcp_control_channel_t *channel, mrcp_message_t *message); member
132 if(vtable && vtable->on_receive) { in mrcp_connection_message_receive()
133 return vtable->on_receive(channel,message); in mrcp_connection_message_receive()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/xplugin/xpl/ |
| H A D | timeouts_t.cc | 104 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())); in TEST_F()
124 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())); in TEST_F()
148 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())); in TEST_F()
170 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())); in TEST_F()
191 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())).Times(1); in TEST_F()
225 EXPECT_CALL(mock_protocol_monitor, on_receive(k_msg.size())).Times(1); in TEST_F()
243 EXPECT_CALL(mock_protocol_monitor, on_receive(_)).Times(0); in TEST_F()
|
| H A D | protocol_decoder_t.cc | 110 EXPECT_CALL(m_mock_protocol_monitor, on_receive(_)); in TEST_F()
130 EXPECT_CALL(m_mock_protocol_monitor, on_receive(_)); in TEST_F()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/revocable_msg/simple_deliver/ |
| H A D | main.cpp | 48 .event( &test_case_t::on_receive )
61 on_receive( mhood_t<Message> ) in on_receive() function in test_case_t
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/revocable_msg/simple/ |
| H A D | main.cpp | 46 .event( &test_case_t::on_receive )
60 on_receive( mhood_t<Message> ) in on_receive() function in test_case_t
|
| /dports/finance/electrum/Electrum-4.1.5/electrum/plugins/email_requests/ |
| H A D | qt.py | 67 self.on_receive = callback
91 self.on_receive(pr_str)
153 … self.processor = Processor(self.imap_server, self.username, self.password, self.on_receive)
159 def on_receive(self, pr_str): member in Plugin
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/src/ |
| H A D | broadcast_socket.cpp | 220 , se.remote, std::bind(&broadcast_socket::on_receive, this, &se, _1, _2)); in open_multicast_socket()
242 , se.remote, std::bind(&broadcast_socket::on_receive, this, &se, _1, _2)); in open_unicast_socket()
314 void broadcast_socket::on_receive(socket_entry* s, error_code const& ec in on_receive() function in libtorrent::broadcast_socket
332 , s->remote, std::bind(&broadcast_socket::on_receive, this, s, _1, _2)); in on_receive()
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/src/ |
| H A D | broadcast_socket.cpp | 220 , se.remote, std::bind(&broadcast_socket::on_receive, this, &se, _1, _2)); in open_multicast_socket()
242 , se.remote, std::bind(&broadcast_socket::on_receive, this, &se, _1, _2)); in open_unicast_socket()
314 void broadcast_socket::on_receive(socket_entry* s, error_code const& ec in on_receive() function in libtorrent::broadcast_socket
332 , s->remote, std::bind(&broadcast_socket::on_receive, this, s, _1, _2)); in on_receive()
|
| /dports/www/py-starlette/starlette-0.17.1/starlette/ |
| H A D | endpoints.py | 68 await self.on_receive(websocket, data)
113 async def on_receive(self, websocket: WebSocket, data: typing.Any) -> None: member in WebSocketEndpoint
|
| /dports/devel/py-tinyrpc/tinyrpc-1.1.2/tinyrpc/transports/ |
| H A D | rabbitmq.py | 28 self.channel.basic_consume(queue=self.queue, on_message_callback=self.on_receive)
45 def on_receive(self, ch, method, props, body): member in RabbitMQServerTransport
|
| /dports/net-im/gajim/gajim-gajim-1.3.3/gajim/common/zeroconf/ |
| H A D | client_zeroconf.py | 350 self.on_receive = None
424 self.on_receive = self._owner.Dispatcher.ProcessNonBlocking
426 self.on_receive = None
428 _tmp = self.on_receive
430 if not recv_handler(None) and _tmp == self.on_receive:
431 self.on_receive = recv_handler
536 if self.on_receive:
543 self.on_receive(received)
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/simulation/ |
| H A D | test_dht_rate_limit.cpp | 183 std::function<void(error_code const&, std::size_t)> on_receive in TORRENT_TEST() local
192 , from, on_receive); in TORRENT_TEST()
195 , from, on_receive); in TORRENT_TEST()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/revocable_timer/simple/ |
| H A D | main.cpp | 46 .event( &test_case_t::on_receive )
61 on_receive( mhood_t<Message> ) in on_receive() function in test_case_t
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/ngs/include/ngs/ |
| H A D | protocol_monitor.h | 45 virtual void on_receive(long bytes_transferred) = 0;
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/interface/ |
| H A D | protocol_monitor.h | 46 virtual void on_receive(const uint32_t bytes_transferred) = 0;
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/include/libtorrent/ |
| H A D | http_seed_connection.hpp | 67 void on_receive(error_code const& error
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/include/libtorrent/ |
| H A D | http_seed_connection.hpp | 67 void on_receive(error_code const& error
|
| /dports/net/wayvnc/wayvnc-0.4.1/src/ |
| H A D | data-control.c | 51 static void on_receive(void* handler) in on_receive() function
109 struct aml_handler* handler = aml_handler_new(ctx->fd, on_receive, in receive_data()
|