/dports/net/libzmq4/zeromq-4.3.4/tests/ |
H A D | test_term_endpoint.cpp | 49 char my_endpoint[BUF_SIZE]; in test_send_after_unbind_fails() local 53 bind_loopback_ipv4 (push, my_endpoint, BUF_SIZE); in test_send_after_unbind_fails() 56 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (pull, my_endpoint)); in test_send_after_unbind_fails() 63 TEST_ASSERT_SUCCESS_ERRNO (zmq_unbind (push, my_endpoint)); in test_send_after_unbind_fails() 80 char my_endpoint[BUF_SIZE]; in test_send_after_disconnect_fails() local 81 bind_loopback_ipv4 (pull, my_endpoint, BUF_SIZE); in test_send_after_disconnect_fails() 108 char my_endpoint[BUF_SIZE]; in test_unbind_via_last_endpoint() local 109 bind_loopback_ipv4 (push, my_endpoint, BUF_SIZE); in test_unbind_via_last_endpoint() 128 buf_size = sizeof (my_endpoint); in test_unbind_via_last_endpoint() 134 buf_size = sizeof (my_endpoint); in test_unbind_via_last_endpoint() [all …]
|
H A D | test_security_null.cpp | 123 char my_endpoint[MAX_SOCKET_STRING]; in test_no_domain() local 124 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_no_domain() 125 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_no_domain() 140 char my_endpoint[MAX_SOCKET_STRING]; in test_wrong_domain_fails() local 141 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_wrong_domain_fails() 142 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_wrong_domain_fails() 155 char my_endpoint[MAX_SOCKET_STRING]; in test_success() local 156 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_success() 169 char my_endpoint[MAX_SOCKET_STRING]; in test_vanilla_socket() local 170 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_vanilla_socket() [all …]
|
H A D | test_reqrep_ipc.cpp | 39 char my_endpoint[256]; in test_leak() local 42 bind_loopback_ipc (sb, my_endpoint, sizeof my_endpoint); in test_leak() 45 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_leak() 64 char my_endpoint[256]; in test_simple() local 67 bind_loopback_ipc (sb, my_endpoint, sizeof my_endpoint); in test_simple() 70 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_simple()
|
H A D | test_security_no_zap_handler.cpp | 44 char my_endpoint[MAX_SOCKET_STRING]; in test_no_zap_handler() local 45 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_no_zap_handler() 46 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_no_zap_handler() 64 char my_endpoint[MAX_SOCKET_STRING]; in test_no_zap_handler_enforce_domain() local 65 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in test_no_zap_handler_enforce_domain() 67 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_no_zap_handler_enforce_domain()
|
H A D | test_proxy_single_socket.cpp | 42 char my_endpoint[MAX_SOCKET_STRING]; in server_task() local 45 bind_loopback_ipv4 (rep, my_endpoint, sizeof my_endpoint); in server_task() 51 send_string_expect_success (control, my_endpoint, 0); in server_task() 71 char *my_endpoint = s_recv (control); in test_proxy_single_socket() local 72 TEST_ASSERT_NOT_NULL (my_endpoint); in test_proxy_single_socket() 77 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (req, my_endpoint)); in test_proxy_single_socket() 89 free (my_endpoint); in test_proxy_single_socket()
|
H A D | test_reconnect_ivl.cpp | 64 char my_endpoint[256]; in test_reconnect_ivl_ipc() local 65 make_random_ipc_endpoint (my_endpoint); in test_reconnect_ivl_ipc() 68 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (sb, my_endpoint)); in test_reconnect_ivl_ipc() 70 test_reconnect_ivl_against_pair_socket (my_endpoint, sb); in test_reconnect_ivl_ipc() 77 char my_endpoint[MAX_SOCKET_STRING]; in test_reconnect_ivl_tcp() local 80 bind_function_ (sb, my_endpoint, sizeof my_endpoint); in test_reconnect_ivl_tcp() 82 test_reconnect_ivl_against_pair_socket (my_endpoint, sb); in test_reconnect_ivl_tcp()
|
H A D | test_proxy_terminate.cpp | 44 char my_endpoint[MAX_SOCKET_STRING]; in server_task() local 49 bind_loopback_ipv4 (frontend, my_endpoint, sizeof my_endpoint); in server_task() 60 send_string_expect_success (control, my_endpoint, 0); in server_task() 82 char *my_endpoint = s_recv (control); in test_proxy_terminate() local 83 TEST_ASSERT_NOT_NULL (my_endpoint); in test_proxy_terminate() 90 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (publisher, my_endpoint)); in test_proxy_terminate() 104 free (my_endpoint); in test_proxy_terminate()
|
H A D | test_probe_router.cpp | 40 char my_endpoint[MAX_SOCKET_STRING]; in test_probe_router_router() local 41 bind_loopback_ipv4 (server, my_endpoint, sizeof (my_endpoint)); in test_probe_router_router() 49 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_probe_router_router() 77 char my_endpoint[MAX_SOCKET_STRING]; in test_probe_router_dealer() local 78 bind_loopback_ipv4 (server, my_endpoint, sizeof (my_endpoint)); in test_probe_router_dealer() 86 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_probe_router_dealer()
|
H A D | test_router_handover.cpp | 37 char my_endpoint[MAX_SOCKET_STRING]; in test_with_handover() local 39 bind_loopback_ipv4 (router, my_endpoint, sizeof my_endpoint); in test_with_handover() 50 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer_one, my_endpoint)); in test_with_handover() 63 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer_two, my_endpoint)); in test_with_handover() 93 char my_endpoint[MAX_SOCKET_STRING]; in test_without_handover() local 99 zmq_getsockopt (router, ZMQ_LAST_ENDPOINT, my_endpoint, &len)); in test_without_handover() 105 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer_one, my_endpoint)); in test_without_handover() 118 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer_two, my_endpoint)); in test_without_handover()
|
H A D | test_immediate.cpp | 41 char my_endpoint[MAX_SOCKET_STRING]; in test_immediate_1() local 55 bind_loopback_ipv4 (to, my_endpoint, len); in test_immediate_1() 66 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (from, my_endpoint)); in test_immediate_1() 108 char my_endpoint[MAX_SOCKET_STRING]; in test_immediate_2() local 109 bind_loopback_ipv4 (to, my_endpoint, len); in test_immediate_2() 130 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (from, my_endpoint)); in test_immediate_2() 175 char my_endpoint[MAX_SOCKET_STRING]; in test_immediate_3() local 176 bind_loopback_ipv4 (backend, my_endpoint, len); in test_immediate_3() 178 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (frontend, my_endpoint)); in test_immediate_3() 200 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (backend, my_endpoint)); in test_immediate_3()
|
H A D | test_security_zap.cpp | 195 char my_endpoint[MAX_SOCKET_STRING]; in test_zap_protocol_error_closure() local 200 test_zap_protocol_error (my_endpoint, server, server_mon, in test_zap_protocol_error_closure() 264 char my_endpoint[MAX_SOCKET_STRING]; in test_zap_wrong_status_temporary_failure() local 266 &handler, &zap_thread, &server, &server_mon, my_endpoint, in test_zap_wrong_status_temporary_failure() 269 test_zap_unsuccessful_status_300 (my_endpoint, server, server_mon, in test_zap_wrong_status_temporary_failure() 281 char my_endpoint[MAX_SOCKET_STRING]; in test_zap_wrong_status_internal_error() local 283 &handler, &zap_thread, &server, &server_mon, my_endpoint, in test_zap_wrong_status_internal_error() 299 char my_endpoint[MAX_SOCKET_STRING]; in test_zap_unsuccesful_no_handler_started() local 305 &handler, &zap_thread, &server, &server_mon, my_endpoint, NULL, in test_zap_unsuccesful_no_handler_started() 323 char my_endpoint[MAX_SOCKET_STRING]; in test_zap_unsuccesful_no_handler_closure() local [all …]
|
H A D | test_security_curve.cpp | 62 char my_endpoint[MAX_SOCKET_STRING]; variable 68 my_endpoint); in setUp() 218 fd_t s = connect_socket (my_endpoint); in test_curve_security_unauthenticated_message() 252 fd_t s = connect_socket (my_endpoint); in test_curve_security_invalid_hello_wrong_length() 318 fd_t s = connect_socket (my_endpoint); in test_curve_security_invalid_hello_command_name() 340 fd_t s = connect_socket (my_endpoint); in test_curve_security_invalid_hello_version() 453 my_endpoint, server_mon, timeout, tools); in test_curve_security_invalid_initiate_command_name() 473 my_endpoint, server_mon, timeout, tools); in test_curve_security_invalid_initiate_command_encrypted_cookie() 493 my_endpoint, server_mon, timeout, tools); in test_curve_security_invalid_initiate_command_encrypted_content() 534 test_null_key (server, server_mon, my_endpoint, null_key, in test_null_server_key() [all …]
|
H A D | test_bind_ws_fuzzer.cpp | 42 char my_endpoint[MAX_SOCKET_STRING]; in LLVMFuzzerTestOneInput() local 43 size_t my_endpoint_size = sizeof (my_endpoint); in LLVMFuzzerTestOneInput() 52 my_endpoint, &my_endpoint_size)); in LLVMFuzzerTestOneInput() 54 my_endpoint[my_endpoint_size - 2] = '\0'; in LLVMFuzzerTestOneInput() 55 fd_t client = connect_socket (my_endpoint, AF_INET, IPPROTO_WS); in LLVMFuzzerTestOneInput() 58 my_endpoint[my_endpoint_size - 2] = '/'; in LLVMFuzzerTestOneInput() 59 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client_good, my_endpoint)); in LLVMFuzzerTestOneInput()
|
H A D | test_stream_timeout.cpp | 41 char my_endpoint[MAX_SOCKET_STRING]; in test_stream_handshake_timeout_accept() local 84 bind_loopback_ipv4 (dealer, my_endpoint, sizeof my_endpoint); in test_stream_handshake_timeout_accept() 86 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (stream, my_endpoint)); in test_stream_handshake_timeout_accept() 101 char my_endpoint[MAX_SOCKET_STRING]; in test_stream_handshake_timeout_connect() local 110 bind_loopback_ipv4 (stream, my_endpoint, sizeof my_endpoint); in test_stream_handshake_timeout_connect() 146 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_stream_handshake_timeout_connect()
|
H A D | test_connect_rid.cpp | 48 char my_endpoint[MAX_SOCKET_STRING]; in test_stream_2_stream() local 57 bind_loopback_ipv4 (rbind, my_endpoint, sizeof my_endpoint); in test_stream_2_stream() 68 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (rconn1, my_endpoint)); in test_stream_2_stream() 86 TEST_ASSERT_SUCCESS_ERRNO (zmq_unbind (rbind, my_endpoint)); in test_stream_2_stream() 96 char my_endpoint[MAX_SOCKET_STRING]; in test_router_2_router() local 102 bind_loopback_ipv4 (rbind, my_endpoint, sizeof my_endpoint); in test_router_2_router() 121 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (rconn1, my_endpoint)); in test_router_2_router() 153 TEST_ASSERT_SUCCESS_ERRNO (zmq_unbind (rbind, my_endpoint)); in test_router_2_router()
|
H A D | test_rebind_ipc.cpp | 37 char my_endpoint[MAX_SOCKET_STRING]; in test_rebind_ipc() local 38 make_random_ipc_endpoint (my_endpoint); in test_rebind_ipc() 43 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (sb0, my_endpoint)); in test_rebind_ipc() 46 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_rebind_ipc() 53 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (sb1, my_endpoint)); in test_rebind_ipc()
|
H A D | test_router_mandatory.cpp | 63 const char *my_endpoint = "inproc://test_get_peer_state"; in test_get_peer_state() local 64 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (router, my_endpoint)); in test_get_peer_state() 84 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer1, my_endpoint)); in test_get_peer_state() 89 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer2, my_endpoint)); in test_get_peer_state() 187 char my_endpoint[MAX_SOCKET_STRING]; in test_basic() local 189 bind_loopback_ipv4 (router, my_endpoint, sizeof my_endpoint); in test_basic() 208 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_basic()
|
H A D | test_security_gssapi.cpp | 102 static char my_endpoint[MAX_SOCKET_STRING]; variable 141 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in setUp() 181 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_valid_creds() 204 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_unauth_creds() 218 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_null_creds() 237 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_plain_creds() 245 fd_t s = connect_socket (my_endpoint); in test_vanilla_socket()
|
H A D | test_bind_null_fuzzer.cpp | 42 char my_endpoint[MAX_SOCKET_STRING]; in LLVMFuzzerTestOneInput() local 49 bind_loopback_ipv4 (server, my_endpoint, sizeof (my_endpoint)); in LLVMFuzzerTestOneInput() 50 fd_t client = connect_socket (my_endpoint); in LLVMFuzzerTestOneInput() 55 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client_good, my_endpoint)); in LLVMFuzzerTestOneInput()
|
H A D | test_security_plain.cpp | 83 char my_endpoint[MAX_SOCKET_STRING]; variable 116 bind_loopback_ipv4 (server, my_endpoint, sizeof my_endpoint); in setup_server() 148 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_plain_success() 163 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_plain_client_as_server_fails() 178 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (client, my_endpoint)); in test_plain_wrong_credentials_fails() 186 fd_t s = connect_socket (my_endpoint); in test_plain_vanilla_socket()
|
H A D | test_pair_tcp_cap_net_admin.cpp | 52 char my_endpoint[MAX_SOCKET_STRING]; in test_pair_tcp() local 53 bind_loopback_ipv4 (sb, my_endpoint, sizeof my_endpoint); in test_pair_tcp() 59 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_pair_tcp()
|
H A D | test_stream_empty.cpp | 37 char my_endpoint[MAX_SOCKET_STRING]; in test_stream_empty() local 42 bind_loopback_ipv4 (stream, my_endpoint, sizeof my_endpoint); in test_stream_empty() 43 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_stream_empty()
|
H A D | test_conflate.cpp | 37 char my_endpoint[MAX_SOCKET_STRING]; in test_conflate() local 46 bind_loopback_ipv4 (s_in, my_endpoint, sizeof my_endpoint); in test_conflate() 50 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (s_out, my_endpoint)); in test_conflate()
|
H A D | test_pair_ipc.cpp | 39 char my_endpoint[256]; in test_roundtrip() local 42 bind_loopback_ipc (sb, my_endpoint, sizeof my_endpoint); in test_roundtrip() 45 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_roundtrip()
|
H A D | test_diffserv.cpp | 40 char my_endpoint[MAX_SOCKET_STRING]; in test_diffserv() local 44 bind_loopback_ipv4 (sb, my_endpoint, sizeof (my_endpoint)); in test_diffserv() 52 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (sc, my_endpoint)); in test_diffserv()
|