Home
last modified time | relevance | path

Searched refs:my_endpoint (Results 1 – 25 of 115) sorted by relevance

12345

/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_term_endpoint.cpp49 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 Dtest_security_null.cpp123 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 Dtest_reqrep_ipc.cpp39 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 Dtest_security_no_zap_handler.cpp44 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 Dtest_proxy_single_socket.cpp42 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 Dtest_reconnect_ivl.cpp64 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 Dtest_proxy_terminate.cpp44 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 Dtest_probe_router.cpp40 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 Dtest_router_handover.cpp37 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 Dtest_immediate.cpp41 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 Dtest_security_zap.cpp195 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 Dtest_security_curve.cpp62 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 Dtest_bind_ws_fuzzer.cpp42 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 Dtest_stream_timeout.cpp41 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 Dtest_connect_rid.cpp48 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 Dtest_rebind_ipc.cpp37 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 Dtest_router_mandatory.cpp63 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 Dtest_security_gssapi.cpp102 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 Dtest_bind_null_fuzzer.cpp42 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 Dtest_security_plain.cpp83 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 Dtest_pair_tcp_cap_net_admin.cpp52 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 Dtest_stream_empty.cpp37 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 Dtest_conflate.cpp37 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 Dtest_pair_ipc.cpp39 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 Dtest_diffserv.cpp40 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()

12345