| /dports/net/py-kafka-python/kafka-python-1.4.5/test/ |
| H A D | test_consumer_integration.py | 154 self.send_messages(0, range(0, 100))
176 self.send_messages(0, range(0, 100))
187 self.send_messages(0, range(0, 100))
204 self.send_messages(0, range(0, 100))
271 self.send_messages(0, range(0, 5))
272 self.send_messages(1, range(5, 10))
288 self.send_messages(0, range(0, 3))
289 self.send_messages(1, range(3, 5))
305 self.send_messages(0, range(0, 10))
348 self.send_messages(0, range(0, 10))
[all …]
|
| H A D | test_producer_integration.py | 167 resp = producer.send_messages('new_topic', self.msg('foobar'))
182 resp = producer.send_messages(self.topic, self.msg("three"))
198 resp2 = producer.send_messages(self.topic, self.msg("three"))
207 resp2 = producer.send_messages(self.topic, self.msg("three"))
219 resp = producer.send_messages(self.topic, self.msg("one"))
243 resp = producer.send_messages(
259 resp = producer.send_messages(
309 resp = producer.send_messages(
324 resp = producer.send_messages(self.topic,
366 resp = producer.send_messages(self.topic, self.key("key2"), None)
[all …]
|
| H A D | test_producer_legacy.py | 34 producer.send_messages(topic, partition, m)
39 producer.send_messages(topic, partition, m)
53 producer.send_messages(topic, key, m)
58 producer.send_messages(topic, key, m)
70 producer.send_messages(topic, b'hi')
85 producer.send_messages(topic, partition, *message_list)
101 (response,) = producer.send_messages('foobar', b'test message')
106 producer.send_messages('foobar', b'test message')
|
| H A D | test_failover_integration.py | 79 producer.send_messages(topic, partition, b'success')
120 producer.send_messages(topic, partition, b'success')
121 producer.send_messages(topic, partition + 1, b'success')
155 producer.send_messages(topic, key, msg)
167 producer.send_messages(topic, key, msg)
182 producer.send_messages(topic, key, msg)
198 producer.send_messages(topic, partition, msg.encode('utf-8'))
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/msg_tracing/change_filter_1/ |
| H A D | main.cpp | 29 send_messages(); in so_evt_start()
38 send_messages() in send_messages() function in a_test_t
54 send_messages(); in first_event()
66 send_messages(); in second_event()
|
| /dports/security/s2n/s2n-tls-1.1.2/tests/unit/ |
| H A D | s2n_malformed_handshake_test.c | 203 void send_messages(int write_fd, uint8_t *server_hello, uint32_t server_hello_len, uint8_t *server_… in send_messages() function
271 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), good_certificate_list, siz… in main()
320 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), empty_certificate_list, si… in main()
369 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), empty_certificate, sizeof(… in main()
418 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), certificate_list_too_large… in main()
467 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), certificate_too_large, siz… in main()
516 …send_messages(p[1], server_hello_message, sizeof(server_hello_message), certificate_list_too_large… in main()
|
| /dports/net-im/libnice/libnice-0.1.18/tests/ |
| H A D | test-bsd.c | 257 NiceOutputMessage *send_messages; in test_multi_message_recv() local
265 send_messages = g_malloc0_n (n_sends, sizeof (NiceOutputMessage)); in test_multi_message_recv()
278 send_messages[i].buffers = send_bufs + i * n_bufs_per_message; in test_multi_message_recv()
279 send_messages[i].n_buffers = n_bufs_per_message; in test_multi_message_recv()
306 nice_socket_send_messages (client, &tmp, send_messages, n_sends), ==, in test_multi_message_recv()
360 g_free (send_messages); in test_multi_message_recv()
|
| /dports/net-im/libnice-gst1/libnice-0.1.18/tests/ |
| H A D | test-bsd.c | 257 NiceOutputMessage *send_messages; in test_multi_message_recv() local
265 send_messages = g_malloc0_n (n_sends, sizeof (NiceOutputMessage)); in test_multi_message_recv()
278 send_messages[i].buffers = send_bufs + i * n_bufs_per_message; in test_multi_message_recv()
279 send_messages[i].n_buffers = n_bufs_per_message; in test_multi_message_recv()
306 nice_socket_send_messages (client, &tmp, send_messages, n_sends), ==, in test_multi_message_recv()
360 g_free (send_messages); in test_multi_message_recv()
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/ |
| H A D | simple.py | 47 def send_messages(self, topic, *msg): member in SimpleProducer
49 return super(SimpleProducer, self).send_messages(
|
| H A D | keyed.py | 39 def send_messages(self, topic, key, *msg): member in KeyedProducer
46 return self.send_messages(topic, key, msg)
|
| /dports/misc/vxl/vxl-3.3.2/core/vgui/wx/ |
| H A D | wxSliderPanel.cxx | 283 wxSliderPanel::update_data(std::vector<double> & data, bool send_messages) in update_data() argument
287 update_data(i, data[i], send_messages); in update_data()
293 wxSliderPanel::update_data(unsigned int i, double val, bool send_messages) in update_data() argument
300 send_messages_ = send_messages; in update_data()
|
| H A D | wxSliderPanel.h | 81 bool send_messages = true);
84 bool send_messages = true);
|
| /dports/databases/db18/db-18.1.40/examples/c/ex_priority/ |
| H A D | priority_message_generator.c | 75 int send_messages() in send_messages() function
104 return send_messages(); in main()
|
| /dports/databases/db18/db-18.1.40/examples/c/ex_firewall/ |
| H A D | firewall_message_generator.c | 74 int send_messages() in send_messages() function
103 return send_messages(); in main()
|
| /dports/net/p5-Kafka/Kafka-0.8010/t/ |
| H A D | 92_mock_bench.t | 158 sub send_messages {
310 + send_messages( $producer, $TOPIC, $PARTITION, $messages );
345 $bench{send_single} += send_messages( $producer, $TOPIC, $PARTITION, [ $copy[ $idx ] ] );
378 $bench{send_mix} += send_messages( $producer, $TOPIC, $PARTITION, [ $copy[ $idx ] ] );
|
| H A D | 21_kafka_bench.t | 166 sub send_messages {
333 + send_messages( $producer, $topic, $partition, $messages );
368 $bench{send_single} += send_messages( $producer, $topic, $partition, [ $copy[ $idx ] ] );
401 $bench{send_mix} += send_messages( $producer, $topic, $partition, [ $copy[ $idx ] ] );
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/enveloped_msg/time_limited_delivery/ |
| H A D | main.cpp | 52 auto send_messages = [&] { in __anon6b62dc870102() local
82 send_messages(); in __anon6b62dc870102()
86 send_messages(); in __anon6b62dc870102()
|
| /dports/devel/hpx/hpx-1.2.1/hpx/plugins/parcelport/mpi/ |
| H A D | sender.hpp | 66 void send_messages( in send_messages() function
106 send_messages(std::move(connection)); in background_work()
|
| /dports/multimedia/gstreamer1-plugins-theora/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/multimedia/gstreamer1-plugins/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/audio/gstreamer1-plugins-ogg/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/audio/gstreamer1-plugins-vorbis/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/audio/gstreamer1-plugins-opus/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/audio/gstreamer1-plugins-cdparanoia/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|
| /dports/x11-toolkits/gstreamer1-plugins-pango/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gstsocketsrc.c | 180 this->send_messages = DEFAULT_SEND_MESSAGES; in gst_socket_src_init()
206 if (src->send_messages && gst_event_has_name (event, "GstNetworkMessage")) { in gst_socketsrc_event()
425 socketsrc->send_messages = g_value_get_boolean (value); in gst_socket_src_set_property()
449 g_value_set_boolean (value, socketsrc->send_messages); in gst_socket_src_get_property()
|