/dports/net/libzmq4/zeromq-4.3.4/tests/ |
H A D | test_metadata.cpp | 64 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 D | test_security_null.cpp | 64 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 D | test_xpub_manual_last_value.cpp | 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() 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 D | test_xpub_manual.cpp | 50 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 D | test_security_plain.cpp | 55 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 D | test_router_handover.cpp | 54 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 D | testutil_security.cpp | 138 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 D | test_security_gssapi.cpp | 75 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 D | test_router_mandatory.cpp | 44 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 D | test_connect_rid.cpp | 76 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 D | test_proxy_terminate.cpp | 60 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 D | test_spec_pushpull.cpp | 270 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 D | test_immediate.cpp | 73 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 D | test_proxy_single_socket.cpp | 51 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 D | test_connect_delay_tipc.cpp | 74 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 D | test_probe_router.cpp | 58 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 D | test_inproc_connect.cpp | 44 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 D | test_pub_invert_matching.cpp | 61 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 D | test_bind_after_connect_tcp.cpp | 42 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 D | test_reqrep_device_tipc.cpp | 53 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 D | test_reqrep_device.cpp | 56 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 D | test_xpub_verbose.cpp | 80 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 D | test_router_mandatory_tipc.cpp | 49 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 D | test_rebind_ipc.cpp | 48 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 D | test_channel.cpp | 59 send_string_expect_success (sb, "HELLO", 0); in test_roundtrip() 62 send_string_expect_success (sc, "WORLD", 0); in test_roundtrip()
|