| /dports/net/rabbitmq-c/rabbitmq-c-0.11.0/examples/ |
| H A D | amqp_producer.c | 48 static void send_batch(amqp_connection_state_t conn, char const *queue_name, in send_batch() function
142 send_batch(conn, "test queue", rate_limit, message_count); in main()
|
| /dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/examples/ |
| H A D | amqp_producer.c | 48 static void send_batch(amqp_connection_state_t conn, char const *queue_name, in send_batch() function
142 send_batch(conn, "test queue", rate_limit, message_count); in main()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/innobase/row/ |
| H A D | row0pread-adapter.cc | 133 dberr_t Parallel_reader_adapter::send_batch( in send_batch() function in Parallel_reader_adapter
177 err = send_batch(reader_thread_ctx, part_id, n_pending); in process_rows()
238 ? send_batch(reader_thread_ctx, in end()
|
| /dports/x11-toolkits/gtk20/gtk+-2.24.33/gtk/ |
| H A D | gtksearchenginesimple.c | 177 send_batch (SearchThreadData *data) in send_batch() function
255 send_batch (data); in search_visit_func()
284 send_batch (data); in search_thread_func()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/java-modules/elastic-v2/src/main/java/org/syslog_ng/elasticsearch_v2/ |
| H A D | ElasticSearchDestination.java | 94 private int send_batch(ESIndex index) { in send_batch() method in ElasticSearchDestination
116 return send_batch(index); in send()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/integration-testing/src/flight_client_scenarios/ |
| H A D | integration_test.rs | 86 send_batch(&mut upload_tx, &metadata, first_batch, &options).await?; in upload_data()
101 send_batch(&mut upload_tx, &metadata, batch, &options).await?; in upload_data()
123 async fn send_batch( in send_batch() function
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/examples/ |
| H A D | console-producer.rs | 134 try!(send_batch(producer, &rec_stash)); in produce_impl_inbatches()
150 try!(send_batch(producer, &rec_stash[..next_rec])); in produce_impl_inbatches()
155 fn send_batch(producer: &mut Producer, batch: &[Record<(), Trimmed>]) -> Result<()> { in send_batch() function
|
| /dports/x11-toolkits/gtk30/gtk+-3.24.31/gtk/ |
| H A D | gtksearchenginesimple.c | 174 send_batch (SearchThreadData *data) in send_batch() function
266 send_batch (data); in visit_directory()
294 send_batch (data); in search_thread_func()
|
| /dports/x11-fm/nemo/nemo-4.8.3/libnemo-private/ |
| H A D | nemo-search-engine-simple.c | 264 send_batch (SearchThreadData *data) in send_batch() function
387 send_batch (data); in visit_directory()
442 send_batch (data); in search_thread_func()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/innobase/include/ |
| H A D | row0pread-adapter.h | 112 dberr_t send_batch(Parallel_reader::Thread_ctx *reader_thread_ctx,
|
| /dports/mail/rspamd-devel/rspamd-93430bb/lualib/ |
| H A D | lua_stat.lua | 236 local function send_batch(tokens, prefix) function
277 local ret,err_str = send_batch(tokens, 'RS')
292 local ret,err_str = send_batch(tokens, 'RS')
|
| /dports/mail/rspamd/rspamd-3.1/lualib/ |
| H A D | lua_stat.lua | 236 local function send_batch(tokens, prefix) function
277 local ret,err_str = send_batch(tokens, 'RS')
292 local ret,err_str = send_batch(tokens, 'RS')
|
| /dports/x11-fm/caja/caja-1.26.0/libcaja-private/ |
| H A D | caja-search-engine-simple.c | 197 send_batch (SearchThreadData *data) in send_batch() function
588 send_batch (data); in visit_directory()
654 send_batch (data); in search_thread_func()
|
| /dports/devel/boost-docs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 498 send_batch(dest,batch); in maybe_send_batch()
504 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
512 send_batch(dest,batch); in send_batch()
518 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
880 send_batch(dest); in synchronize()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 498 send_batch(dest,batch); in maybe_send_batch()
504 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
512 send_batch(dest,batch); in send_batch()
518 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
880 send_batch(dest); in synchronize()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 497 send_batch(dest,batch); in maybe_send_batch()
503 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
511 send_batch(dest,batch); in send_batch()
517 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
879 send_batch(dest); in synchronize()
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 498 send_batch(dest,batch); in maybe_send_batch()
504 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
512 send_batch(dest,batch); in send_batch()
518 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
880 send_batch(dest); in synchronize()
|
| /dports/databases/percona57-server/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 497 send_batch(dest,batch); in maybe_send_batch()
503 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
511 send_batch(dest,batch); in send_batch()
517 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
879 send_batch(dest); in synchronize()
|
| /dports/databases/xtrabackup/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 497 send_batch(dest,batch); in maybe_send_batch()
503 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
511 send_batch(dest,batch); in send_batch()
517 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
879 send_batch(dest); in synchronize()
|
| /dports/databases/percona57-client/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 497 send_batch(dest,batch); in maybe_send_batch()
503 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
511 send_batch(dest,batch); in send_batch()
517 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
879 send_batch(dest); in synchronize()
|
| /dports/devel/boost-libs/boost_1_72_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 498 send_batch(dest,batch); in maybe_send_batch()
504 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
512 send_batch(dest,batch); in send_batch()
518 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
880 send_batch(dest); in synchronize()
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 497 send_batch(dest,batch); in maybe_send_batch()
503 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
511 send_batch(dest,batch); in send_batch()
517 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
879 send_batch(dest); in synchronize()
|
| /dports/devel/hyperscan/boost_1_75_0/libs/graph_parallel/src/ |
| H A D | mpi_process_group.cpp | 498 send_batch(dest,batch); in maybe_send_batch()
504 mpi_process_group::send_batch(process_id_type dest) const in send_batch() function in boost::graph::distributed::mpi_process_group
512 send_batch(dest,batch); in send_batch()
518 mpi_process_group::send_batch(process_id_type dest, in send_batch() function in boost::graph::distributed::mpi_process_group
880 send_batch(dest); in synchronize()
|
| /dports/net/miniupnpd/miniupnpd-2.1.20200510/netfilter_nft/ |
| H A D | nftnlrdr_misc.h | 152 send_batch(struct mnl_nlmsg_batch * batch);
|
| /dports/emulators/ppsspp/ppsspp-1.12.3/ext/miniupnp/miniupnpd/netfilter_nft/ |
| H A D | nftnlrdr_misc.h | 152 send_batch(struct mnl_nlmsg_batch * batch);
|