Home
last modified time | relevance | path

Searched refs:send_string_expect_success (Results 1 – 25 of 54) sorted by relevance

123

/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_metadata.cpp64 send_string_expect_success (handler_, version, ZMQ_SNDMORE); in zap_handler()
65 send_string_expect_success (handler_, sequence, ZMQ_SNDMORE); in zap_handler()
67 send_string_expect_success (handler_, "200", ZMQ_SNDMORE); in zap_handler()
68 send_string_expect_success (handler_, "OK", ZMQ_SNDMORE); in zap_handler()
69 send_string_expect_success (handler_, "anonymous", ZMQ_SNDMORE); in zap_handler()
72 send_string_expect_success (handler_, "400", ZMQ_SNDMORE); in zap_handler()
73 send_string_expect_success (handler_, "BAD DOMAIN", ZMQ_SNDMORE); in zap_handler()
74 send_string_expect_success (handler_, "", ZMQ_SNDMORE); in zap_handler()
75 send_string_expect_success (handler_, "", 0); in zap_handler()
107 send_string_expect_success (client, "This is a message", 0); in test_metadata()
H A Dtest_security_null.cpp64 send_string_expect_success (handler_, version, ZMQ_SNDMORE); in zap_handler()
65 send_string_expect_success (handler_, sequence, ZMQ_SNDMORE); in zap_handler()
67 send_string_expect_success (handler_, "200", ZMQ_SNDMORE); in zap_handler()
68 send_string_expect_success (handler_, "OK", ZMQ_SNDMORE); in zap_handler()
69 send_string_expect_success (handler_, "anonymous", ZMQ_SNDMORE); in zap_handler()
70 send_string_expect_success (handler_, "", 0); in zap_handler()
72 send_string_expect_success (handler_, "400", ZMQ_SNDMORE); in zap_handler()
73 send_string_expect_success (handler_, "BAD DOMAIN", ZMQ_SNDMORE); in zap_handler()
74 send_string_expect_success (handler_, "", ZMQ_SNDMORE); in zap_handler()
75 send_string_expect_success (handler_, "", 0); in zap_handler()
H A Dtest_xpub_manual_last_value.cpp59 send_string_expect_success (pub, "A", 0); in test_basic()
60 send_string_expect_success (pub, "B", 0); in test_basic()
117 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_manual()
118 send_string_expect_success (pub, "XB", 0); in test_unsubscribe_manual()
336 send_string_expect_success (pub, payload, 0); in test_missing_subscriptions()
397 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_cleanup()
398 send_string_expect_success (pub, "XB", 0); in test_unsubscribe_cleanup()
432 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_cleanup()
433 send_string_expect_success (pub, "XB", 0); in test_unsubscribe_cleanup()
480 send_string_expect_success (pub, "A", 0); in test_manual_last_value()
[all …]
H A Dtest_xpub_manual.cpp50 send_string_expect_success (sub, subscription, 0); in test_basic()
59 send_string_expect_success (pub, "A", 0); in test_basic()
60 send_string_expect_success (pub, "B", 0); in test_basic()
117 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_manual()
118 send_string_expect_success (pub, "XB", 0); in test_unsubscribe_manual()
329 send_string_expect_success (pub, payload, 0); in test_missing_subscriptions()
331 send_string_expect_success (pub, payload, 0); in test_missing_subscriptions()
390 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_cleanup()
391 send_string_expect_success (pub, "XB", 0); in test_unsubscribe_cleanup()
425 send_string_expect_success (pub, "XA", 0); in test_unsubscribe_cleanup()
[all …]
H A Dtest_security_plain.cpp55 send_string_expect_success (zap_, version, ZMQ_SNDMORE); in zap_handler()
56 send_string_expect_success (zap_, sequence, ZMQ_SNDMORE); in zap_handler()
58 send_string_expect_success (zap_, "200", ZMQ_SNDMORE); in zap_handler()
59 send_string_expect_success (zap_, "OK", ZMQ_SNDMORE); in zap_handler()
60 send_string_expect_success (zap_, "anonymous", ZMQ_SNDMORE); in zap_handler()
61 send_string_expect_success (zap_, "", 0); in zap_handler()
63 send_string_expect_success (zap_, "400", ZMQ_SNDMORE); in zap_handler()
64 send_string_expect_success (zap_, "Invalid username or password", in zap_handler()
66 send_string_expect_success (zap_, "", ZMQ_SNDMORE); in zap_handler()
67 send_string_expect_success (zap_, "", 0); in zap_handler()
H A Dtest_router_handover.cpp54 send_string_expect_success (dealer_one, "Hello", 0); in test_with_handover()
66 send_string_expect_success (dealer_two, "Hello", 0); in test_with_handover()
73 send_string_expect_success (router, "X", ZMQ_SNDMORE); in test_with_handover()
74 send_string_expect_success (router, "Hello", 0); in test_with_handover()
109 send_string_expect_success (dealer_one, "Hello", 0); in test_without_handover()
121 send_string_expect_success (dealer_two, "Hello", 0); in test_without_handover()
131 send_string_expect_success (router, "X", ZMQ_SNDMORE); in test_without_handover()
132 send_string_expect_success (router, "Hello", 0); in test_without_handover()
H A Dtestutil_security.cpp138 send_string_expect_success (control, "GO", 0); in zap_handler_generic()
206 send_string_expect_success ( in zap_handler_generic()
210 send_string_expect_success (handler, in zap_handler_generic()
232 send_string_expect_success (handler, "OK", ZMQ_SNDMORE); in zap_handler_generic()
235 send_string_expect_success (handler, "", ZMQ_SNDMORE); in zap_handler_generic()
238 send_string_expect_success (handler, "", 0); in zap_handler_generic()
240 send_string_expect_success (handler, "400", ZMQ_SNDMORE); in zap_handler_generic()
243 send_string_expect_success (handler, "", ZMQ_SNDMORE); in zap_handler_generic()
245 send_string_expect_success (handler, "", 0); in zap_handler_generic()
260 send_string_expect_success (control, "STOPPED", 0); in zap_handler_generic()
[all …]
H A Dtest_security_gssapi.cpp75 send_string_expect_success (handler_, version, ZMQ_SNDMORE); in zap_handler()
76 send_string_expect_success (handler_, sequence, ZMQ_SNDMORE); in zap_handler()
79 send_string_expect_success (handler_, "200", ZMQ_SNDMORE); in zap_handler()
80 send_string_expect_success (handler_, "OK", ZMQ_SNDMORE); in zap_handler()
81 send_string_expect_success (handler_, "anonymous", ZMQ_SNDMORE); in zap_handler()
82 send_string_expect_success (handler_, "", 0); in zap_handler()
85 send_string_expect_success (handler_, "400", ZMQ_SNDMORE); in zap_handler()
86 send_string_expect_success (handler_, "Denied", ZMQ_SNDMORE); in zap_handler()
87 send_string_expect_success (handler_, "", ZMQ_SNDMORE); in zap_handler()
88 send_string_expect_success (handler_, "", 0); in zap_handler()
H A Dtest_router_mandatory.cpp44 send_string_expect_success (router_, peer_routing_id_, in send_msg_to_peer_if_ready()
46 send_string_expect_success (router_, "Hello", ZMQ_DONTWAIT); in send_msg_to_peer_if_ready()
92 send_string_expect_success (dealer1, "Hello", 0); in test_get_peer_state()
96 send_string_expect_success (dealer2, "Hello", 0); in test_get_peer_state()
193 send_string_expect_success (router, "UNKNOWN", ZMQ_SNDMORE); in test_basic()
194 send_string_expect_success (router, "DATA", 0); in test_basic()
211 send_string_expect_success (dealer, "Hello", 0); in test_basic()
216 send_string_expect_success (router, "X", ZMQ_SNDMORE); in test_basic()
217 send_string_expect_success (router, "Hello", 0); in test_basic()
H A Dtest_connect_rid.cpp76 send_string_expect_success (rconn1, rconn1routing_id, ZMQ_SNDMORE); in test_stream_2_stream()
77 send_string_expect_success (rconn1, msg, 0); in test_stream_2_stream()
129 send_string_expect_success (rconn1, rconn1routing_id, ZMQ_SNDMORE); in test_router_2_router()
130 send_string_expect_success (rconn1, msg, 0); in test_router_2_router()
147 send_string_expect_success (rbind, "ok", 0); in test_router_2_router()
197 send_string_expect_success (yconn, x_routing_id, ZMQ_SNDMORE); in test_router_2_router_while_receiving()
198 send_string_expect_success (yconn, msg, 0); in test_router_2_router_while_receiving()
209 send_string_expect_success (xbind, z_routing_id, ZMQ_SNDMORE); in test_router_2_router_while_receiving()
210 send_string_expect_success (xbind, msg, 0); in test_router_2_router_while_receiving()
H A Dtest_proxy_terminate.cpp60 send_string_expect_success (control, my_endpoint, 0); in server_task()
93 send_string_expect_success (publisher, "This is a test", 0); in test_proxy_terminate()
96 send_string_expect_success (publisher, "This is a test", 0); in test_proxy_terminate()
99 send_string_expect_success (publisher, "This is a test", 0); in test_proxy_terminate()
100 send_string_expect_success (control, "TERMINATE", 0); in test_proxy_terminate()
H A Dtest_spec_pushpull.cpp270 send_string_expect_success (push, "0", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
271 send_string_expect_success (push, "0", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
283 send_string_expect_success (push, "1", 0); in test_push_multipart_atomic_drop()
285 send_string_expect_success (push, "2", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
286 send_string_expect_success (push, "2", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
308 send_string_expect_success (push, "3", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
309 send_string_expect_success (push, "3", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
320 send_string_expect_success (push, "3", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
326 send_string_expect_success (push, "3b", 0); in test_push_multipart_atomic_drop()
334 send_string_expect_success (push, "5", ZMQ_SNDMORE); in test_push_multipart_atomic_drop()
[all …]
H A Dtest_immediate.cpp73 send_string_expect_success (from, "Hello", 0); in test_immediate_1()
134 send_string_expect_success (from, "Hello", 0); in test_immediate_2()
181 send_string_expect_success (backend, "Hello", 0); in test_immediate_3()
185 send_string_expect_success (frontend, "Hello", ZMQ_DONTWAIT); in test_immediate_3()
203 send_string_expect_success (backend, "Hello", 0); in test_immediate_3()
207 send_string_expect_success (frontend, "Hello", ZMQ_DONTWAIT); in test_immediate_3()
H A Dtest_proxy_single_socket.cpp51 send_string_expect_success (control, my_endpoint, 0); in server_task()
79 send_string_expect_success (req, "msg1", 0); in test_proxy_single_socket()
82 send_string_expect_success (req, "msg22", 0); in test_proxy_single_socket()
85 send_string_expect_success (control, "TERMINATE", 0); in test_proxy_single_socket()
H A Dtest_connect_delay_tipc.cpp74 send_string_expect_success (from, "Hello", 0); in test_send_one_connected_one_unconnected()
144 send_string_expect_success (from, "Hello", 0); in test_send_one_connected_one_unconnected_with_delay()
199 send_string_expect_success (backend, "Hello", 0); in test_send_disconnected_with_delay()
203 send_string_expect_success (frontend, "Hello", ZMQ_DONTWAIT); in test_send_disconnected_with_delay()
223 send_string_expect_success (backend, "Hello", 0); in test_send_disconnected_with_delay()
227 send_string_expect_success (frontend, "Hello", ZMQ_DONTWAIT); in test_send_disconnected_with_delay()
H A Dtest_probe_router.cpp58 send_string_expect_success (server, "X", ZMQ_SNDMORE); in test_probe_router_router()
59 send_string_expect_success (server, "Hello", 0); in test_probe_router_router()
94 send_string_expect_success (server, "X", ZMQ_SNDMORE); in test_probe_router_dealer()
95 send_string_expect_success (server, "Hello", 0); in test_probe_router_dealer()
H A Dtest_inproc_connect.cpp44 send_string_expect_success (connect_socket, "foobar", 0); in pusher()
89 send_string_expect_success (connect_socket, "foobar", 0); in test_bind_before_connect()
106 send_string_expect_success (connect_socket, "foobar", 0); in test_connect_before_bind()
127 send_string_expect_success (connect_socket, "before", 0); in test_connect_before_bind_pub_sub()
139 send_string_expect_success (connect_socket, "after", 0); in test_connect_before_bind_pub_sub()
177 send_string_expect_success (connect_socket[i], "foobar", 0); in test_multiple_connects()
313 send_string_expect_success (connect_socket, "foobar", 0); in test_unbind()
H A Dtest_pub_invert_matching.cpp61 send_string_expect_success (pub, prefi_x1, 0); in test()
70 send_string_expect_success (pub, prefi_x2, 0); in test()
90 send_string_expect_success (pub, prefi_x1, 0); in test()
99 send_string_expect_success (pub, prefi_x2, 0); in test()
H A Dtest_bind_after_connect_tcp.cpp42 send_string_expect_success (sc, "foobar", 0); in test_x()
43 send_string_expect_success (sc, "baz", 0); in test_x()
44 send_string_expect_success (sc, "buzz", 0); in test_x()
H A Dtest_reqrep_device_tipc.cpp53 send_string_expect_success (req, "ABC", ZMQ_SNDMORE); in test_roundtrip()
54 send_string_expect_success (req, "DEF", 0); in test_roundtrip()
82 send_string_expect_success (rep, "GHI", ZMQ_SNDMORE); in test_roundtrip()
83 send_string_expect_success (rep, "JKL", 0); in test_roundtrip()
H A Dtest_reqrep_device.cpp56 send_string_expect_success (req, "ABC", ZMQ_SNDMORE); in test_roundtrip()
57 send_string_expect_success (req, "DEF", 0); in test_roundtrip()
85 send_string_expect_success (rep, "GHI", ZMQ_SNDMORE); in test_roundtrip()
86 send_string_expect_success (rep, "JKL", 0); in test_roundtrip()
H A Dtest_xpub_verbose.cpp80 send_string_expect_success (pub, topic_a, 0); in test_xpub_verbose_one_sub()
81 send_string_expect_success (pub, topic_b, 0); in test_xpub_verbose_one_sub()
145 send_string_expect_success (pub, topic_a, 0); in test_xpub_verbose_two_subs()
147 send_string_expect_success (pub, topic_b, 0); in test_xpub_verbose_two_subs()
221 send_string_expect_success (pub, topic_a, 0); in test_xpub_verboser_one_sub()
287 send_string_expect_success (pub, topic_a, 0); in test_xpub_verboser_two_subs()
H A Dtest_router_mandatory_tipc.cpp49 send_string_expect_success (sa, "UNKNOWN", ZMQ_SNDMORE); in test_router_mandatory_tipc()
50 send_string_expect_success (sa, "DATA", 0); in test_router_mandatory_tipc()
H A Dtest_rebind_ipc.cpp48 send_string_expect_success (sb0, "42", 0); in test_rebind_ipc()
55 send_string_expect_success (sb1, "42", 0); in test_rebind_ipc()
H A Dtest_channel.cpp59 send_string_expect_success (sb, "HELLO", 0); in test_roundtrip()
62 send_string_expect_success (sc, "WORLD", 0); in test_roundtrip()

123