/dports/net/libzmq4/zeromq-4.3.4/tests/ |
H A D | test_inproc_connect.cpp | 47 TEST_ASSERT_SUCCESS_ERRNO (zmq_close (connect_socket)); in pusher() 95 test_context_socket_close (connect_socket); in test_bind_before_connect() 116 test_context_socket_close (connect_socket); in test_connect_before_bind() 123 void *connect_socket = test_context_socket (ZMQ_PUB); in test_connect_before_bind_pub_sub() local 145 test_context_socket_close (connect_socket); in test_connect_before_bind_pub_sub() 160 test_context_socket_close (connect_socket); in test_connect_before_bind_ctx_term() 168 void *connect_socket[no_of_connects]; in test_multiple_connects() local 190 test_context_socket_close (connect_socket[i]); in test_multiple_connects() 293 test_context_socket_close (connect_socket); in test_connect_only() 319 test_context_socket_close (connect_socket); in test_unbind() [all …]
|
H A D | test_hwm.cpp | 50 void *connect_socket = test_context_socket (ZMQ_PUSH); in test_defaults() local 56 && zmq_send (connect_socket, NULL, 0, ZMQ_DONTWAIT) == 0) in test_defaults() 69 test_context_socket_close (connect_socket); in test_defaults() 79 void *connect_socket; in count_msg() local 88 connect_socket = test_context_socket (ZMQ_PUSH); in count_msg() 98 connect_socket = test_context_socket (ZMQ_PUSH); in count_msg() 113 && zmq_send (connect_socket, NULL, 0, ZMQ_DONTWAIT) == 0) in count_msg() 124 send_string_expect_success (connect_socket, NULL, 0); in count_msg() 130 test_context_socket_close (connect_socket); in count_msg() 149 void *connect_socket = test_context_socket (ZMQ_PUSH); in test_inproc_connect_and_close_first() local [all …]
|
H A D | test_tcp_accept_filter.cpp | 112 void *connect_socket = test_context_socket (ZMQ_PAIR); in test_clear() local 115 bounce (bind_socket, connect_socket); in test_clear() 117 test_context_socket_close (connect_socket); in test_clear() 137 void *connect_socket = test_context_socket (ZMQ_PAIR); in test_set_non_matching_and_clear() local 140 bounce (bind_socket, connect_socket); in test_set_non_matching_and_clear() 142 test_context_socket_close (connect_socket); in test_set_non_matching_and_clear() 156 void *connect_socket = test_context_socket (ZMQ_PAIR); in test_set_matching() local 159 bounce (bind_socket, connect_socket); in test_set_matching() 161 test_context_socket_close (connect_socket); in test_set_matching() 186 void *connect_socket = test_context_socket (ZMQ_PAIR); in test_set_non_matching() local [all …]
|
H A D | test_sockopt_hwm.cpp | 42 void *connect_socket = test_context_socket (ZMQ_PULL); in test_change_before_connected() local 45 rc = zmq_setsockopt (connect_socket, ZMQ_RCVHWM, &val, sizeof (val)); in test_change_before_connected() 50 zmq_connect (connect_socket, "inproc://a"); in test_change_before_connected() 67 test_context_socket_close (connect_socket); in test_change_before_connected() 75 void *connect_socket = test_context_socket (ZMQ_PULL); in test_change_after_connected() local 78 rc = zmq_setsockopt (connect_socket, ZMQ_RCVHWM, &val, sizeof (val)); in test_change_after_connected() 83 zmq_connect (connect_socket, "inproc://a"); in test_change_after_connected() 104 test_context_socket_close (connect_socket); in test_change_after_connected() 132 void *connect_socket = test_context_socket (ZMQ_PULL); in test_decrease_when_full() local 143 zmq_connect (connect_socket, "inproc://a"); in test_decrease_when_full() [all …]
|
/dports/net/gofish/gofish/ |
H A D | webtest.c | 49 int connect_socket(int port, unsigned addr); 84 if((sock = connect_socket(HTTP_PORT, hostaddr)) < 0) { in main() 143 if((sock = connect_socket(HTTP_PORT, hostaddr)) < 0) { in main() 174 if((sock = connect_socket(HTTP_PORT, hostaddr)) < 0) { in main() 188 if((sock = connect_socket(HTTP_PORT, hostaddr)) < 0) { in main() 220 if((sock = connect_socket(GOPHER_PORT, hostaddr)) < 0) { in main() 255 if((sock = connect_socket(GOPHER_PORT, hostaddr)) < 0) { in main() 273 if((sock = connect_socket(GOPHER_PORT, hostaddr)) < 0) { in main() 299 if((sock = connect_socket(GOPHER_PORT, hostaddr)) < 0) { in main() 315 if((sock = connect_socket(GOPHER_PORT, hostaddr)) < 0) { in main() [all …]
|
/dports/net/libzmq4/zeromq-4.3.4/unittests/ |
H A D | unittest_poller.cpp | 232 zmq::fd_t connect_socket = socket (AF_INET, SOCK_STREAM, 0); in test_add_fd_with_pending_failing_connect() local 233 zmq::unblock_socket (connect_socket); in test_add_fd_with_pending_failing_connect() 236 -1, connect (connect_socket, reinterpret_cast<const sockaddr *> (&addr), in test_add_fd_with_pending_failing_connect() 240 test_events_t events (connect_socket, poller); in test_add_fd_with_pending_failing_connect() 242 zmq::poller_t::handle_t handle = poller.add_fd (connect_socket, &events); in test_add_fd_with_pending_failing_connect() 251 TEST_ASSERT_EQUAL_INT (0, getsockopt (connect_socket, SOL_SOCKET, SO_ERROR, in test_add_fd_with_pending_failing_connect() 257 close (connect_socket); in test_add_fd_with_pending_failing_connect()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/wasi-libcxx/llvm-project-13.0.1.src/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( 162 error = connect_socket->Connect(host_and_port); 164 return std::move(connect_socket); 215 std::unique_ptr<Socket> connect_socket( 220 error = connect_socket->Connect(name); 222 socket = connect_socket.release(); 247 std::unique_ptr<Socket> connect_socket( 252 error = connect_socket->Connect(name); 254 socket = connect_socket.release();
|
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/llvm12/llvm-project-12.0.1.src/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/lang/rust/rustc-1.58.1-src/src/llvm-project/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/lldb/source/Host/common/ |
H A D | Socket.cpp | 152 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 157 error = connect_socket->Connect(host_and_port); in TcpConnect() 159 return std::move(connect_socket); in TcpConnect() 210 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 215 error = connect_socket->Connect(name); in UnixDomainConnect() 217 socket = connect_socket.release(); in UnixDomainConnect() 242 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 247 error = connect_socket->Connect(name); in UnixAbstractConnect() 249 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/wasi-compiler-rt13/llvm-project-13.0.1.src/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/wasi-compiler-rt12/llvm-project-12.0.1.src/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/tinygo/tinygo-0.14.1/llvm-project/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 socket = connect_socket.release(); in TcpConnect() 221 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 226 error = connect_socket->Connect(name); in UnixDomainConnect() 228 socket = connect_socket.release(); in UnixDomainConnect() 253 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 258 error = connect_socket->Connect(name); in UnixAbstractConnect() 260 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/devel/llvm13/llvm-project-13.0.1.src/lldb/source/Host/common/ |
H A D | Socket.cpp | 157 std::unique_ptr<Socket> connect_socket( in TcpConnect() local 162 error = connect_socket->Connect(host_and_port); in TcpConnect() 164 return std::move(connect_socket); in TcpConnect() 215 std::unique_ptr<Socket> connect_socket( in UnixDomainConnect() local 220 error = connect_socket->Connect(name); in UnixDomainConnect() 222 socket = connect_socket.release(); in UnixDomainConnect() 247 std::unique_ptr<Socket> connect_socket( in UnixAbstractConnect() local 252 error = connect_socket->Connect(name); in UnixAbstractConnect() 254 socket = connect_socket.release(); in UnixAbstractConnect()
|
/dports/net/usockets/uSockets-0.8.1/src/ |
H A D | context.c | 223 struct us_socket_t *connect_socket = (struct us_socket_t *) p; in us_socket_context_connect() local 226 connect_socket->context = context; in us_socket_context_connect() 227 connect_socket->timeout = 0; in us_socket_context_connect() 228 connect_socket->low_prio_state = 0; in us_socket_context_connect() 229 us_internal_socket_context_link(context, connect_socket); in us_socket_context_connect() 231 return connect_socket; in us_socket_context_connect()
|
/dports/misc/dtach/dtach-0.9/ |
H A D | attach.c | 50 connect_socket(char *name) in connect_socket() function 158 s = connect_socket(sockname); in attach_main() 173 s = connect_socket(slash + 1); in attach_main() 303 s = connect_socket(sockname); in push_main() 318 s = connect_socket(slash + 1); in push_main()
|
/dports/audio/epos-devel/epos-2.5.37/src/tests/ |
H A D | testbench.cc | 58 int connect_socket(unsigned int, int); 73 connect_socket(0, TTSCP_PORT); in shriek() 282 ctrld[i] = connect_socket(0, TTSCP_PORT); // This will be the data connection... in init_connection_pair() 289 ctrld[i] = connect_socket(0, TTSCP_PORT); // This will be the control connection. in init_connection_pair() 299 ctrld[UNUSED_PAIR] = connect_socket(0, TTSCP_PORT); in init()
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/ |
H A D | zmq4_test.go | 730 err := connect_socket.Close() 808 err := connect_socket.Close() 814 err = connect_socket.SetSndhwm(send_hwm) 833 err := connect_socket.Close() 839 err = connect_socket.SetSndhwm(send_hwm) 901 _, err = connect_socket.Send("", 0) 935 if connect_socket != nil { 936 connect_socket.Close() 940 err = connect_socket.SetSndhwm(send_hwm) 963 err = connect_socket.Close() [all …]
|