| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/src/ |
| H A D | xpl_client.cc | 276 void Protocol_monitor::on_receive(long bytes_transferred) in on_receive() function in Protocol_monitor
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/src/ |
| H A D | xpl_client.cc | 276 void Protocol_monitor::on_receive(long bytes_transferred) in on_receive() function in Protocol_monitor
|
| /dports/www/h2o-devel/h2o-dcc7134/fuzz/ |
| H A D | driver_h3.cc | 176 stream->callbacks->on_receive(stream, 0, Data, Size); in LLVMFuzzerTestOneInput()
|
| /dports/devel/boost-docs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
425 else if (block->on_receive) in emit_receive()
427 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
425 else if (block->on_receive) in emit_receive()
427 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 306 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
337 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
424 else if (block->on_receive) in emit_receive()
426 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
425 else if (block->on_receive) in emit_receive()
427 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/percona57-server/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 306 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
337 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
424 else if (block->on_receive) in emit_receive()
426 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/xtrabackup/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 306 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
337 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
424 else if (block->on_receive) in emit_receive()
426 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/percona57-client/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 306 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
337 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
424 else if (block->on_receive) in emit_receive()
426 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/devel/boost-libs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
425 else if (block->on_receive) in emit_receive()
427 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 306 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
337 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
424 else if (block->on_receive) in emit_receive()
426 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/devel/hyperscan/boost_1_75_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
425 else if (block->on_receive) in emit_receive()
427 block->on_receive(process, decoded.second); in emit_receive()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/ |
| H A D | xpl_client.cc | 267 void Protocol_monitor::on_receive(const uint32_t bytes_transferred) { in on_receive() function in xpl::Protocol_monitor
|
| /dports/sysutils/py-mitogen/mitogen-0.2.9/mitogen/ |
| H A D | unix.py | 87 def on_receive(self, broker):
|
| H A D | core.py | 1686 def on_receive(self, broker): member in Stream
1705 self.protocol.on_receive(broker, buf)
1824 def on_receive(self, broker, buf): member in DelimitedProtocol
1839 stream.protocol.on_receive(broker, self._trailer)
2080 def on_receive(self, broker, buf): member in MitogenProtocol
2775 def on_receive(self, broker, buf): member in Waker
3383 (self._waker.receive_side, self._waker.on_receive)
3415 side.fd, (side, stream.on_receive))
|
| H A D | fakessh.py | 154 def on_receive(self, stream, broker): member in IoPump
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/include/libtorrent/ |
| H A D | bt_peer_connection.hpp | 174 void on_receive(error_code const& error
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/include/libtorrent/ |
| H A D | bt_peer_connection.hpp | 174 void on_receive(error_code const& error
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/src/ |
| H A D | udp_tracker_connection.cpp | 310 return on_receive(m_target, buf); in on_receive_hostname()
313 bool udp_tracker_connection::on_receive(udp::endpoint const& ep in on_receive() function in libtorrent::udp_tracker_connection
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/src/ |
| H A D | udp_tracker_connection.cpp | 310 return on_receive(m_target, buf); in on_receive_hostname()
313 bool udp_tracker_connection::on_receive(udp::endpoint const& ep in on_receive() function in libtorrent::udp_tracker_connection
|
| /dports/devel/pecl-swoole/swoole-4.8.5/include/ |
| H A D | swoole_client.h | 290 void on_receive(std::function<void(AsyncClient *, const char *data, size_t length)> fn) { in on_receive() function
|
| /dports/devel/pecl-swoole/swoole-4.8.5/core-tests/src/network/ |
| H A D | client.cpp | 131 ac.on_receive([](AsyncClient *ac, const char *data, size_t len) { in TEST()
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdutils/td/utils/port/ |
| H A D | UdpSocketFd.cpp | 268 return on_receive(size); in on_iocp()
295 void on_receive(size_t size) { in on_receive() function in td::detail::UdpSocketFdImpl
|
| /dports/www/h2o-devel/h2o-dcc7134/lib/common/ |
| H A D | http3client.c | 633 static void on_receive(quicly_stream_t *qs, size_t off, const void *input, size_t len) in on_receive() function
888 … on_send_stop, on_receive, on_receive_reset}; in stream_open_cb()
|