Home
last modified time | relevance | path

Searched refs:connect_socket (Results 1 – 25 of 150) sorted by relevance

123456

/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_inproc_connect.cpp47 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 Dtest_hwm.cpp50 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 Dtest_tcp_accept_filter.cpp112 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 Dtest_sockopt_hwm.cpp42 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 Dwebtest.c49 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 Dunittest_poller.cpp232 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp152 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp157 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 DSocket.cpp157 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 Dcontext.c223 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 Dattach.c50 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 Dtestbench.cc58 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 Dzmq4_test.go730 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 Dzmq4_test.go730 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 Dzmq4_test.go730 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 Dzmq4_test.go730 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 Dzmq4_test.go730 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 Dzmq4_test.go730 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 …]

123456