Home
last modified time | relevance | path

Searched refs:Sock (Results 226 – 250 of 1268) sorted by relevance

12345678910>>...51

/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/common_test/src/
H A Dtest_server_node.erl60 nodedown(Sock) ->
93 {ok,Sock} ->
103 {ok,Sock};
128 receive_ack(Sock) ->
146 receive {tcp_closed,Sock} -> gen_tcp:close(Sock) end,
172 {ok,Sock} ->
182 {tcp,Sock,Bin} ->
196 {tcp_closed,Sock} ->
415 {ok,Sock} ->
491 {ok,Sock} ->
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/common_test/src/
H A Dtest_server_node.erl60 nodedown(Sock) ->
93 {ok,Sock} ->
103 {ok,Sock};
128 receive_ack(Sock) ->
146 receive {tcp_closed,Sock} -> gen_tcp:close(Sock) end,
172 {ok,Sock} ->
182 {tcp,Sock,Bin} ->
196 {tcp_closed,Sock} ->
415 {ok,Sock} ->
491 {ok,Sock} ->
[all …]
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/common_test/src/
H A Dtest_server_node.erl60 nodedown(Sock) ->
93 {ok,Sock} ->
103 {ok,Sock};
128 receive_ack(Sock) ->
146 receive {tcp_closed,Sock} -> gen_tcp:close(Sock) end,
172 {ok,Sock} ->
182 {tcp,Sock,Bin} ->
196 {tcp_closed,Sock} ->
415 {ok,Sock} ->
491 {ok,Sock} ->
[all …]
/dports/lang/erlang/otp-OTP-24.1.7/lib/common_test/src/
H A Dtest_server_node.erl60 nodedown(Sock) ->
93 {ok,Sock} ->
103 {ok,Sock};
128 receive_ack(Sock) ->
146 receive {tcp_closed,Sock} -> gen_tcp:close(Sock) end,
172 {ok,Sock} ->
182 {tcp,Sock,Bin} ->
196 {tcp_closed,Sock} ->
415 {ok,Sock} ->
491 {ok,Sock} ->
[all …]
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/common_test/src/
H A Dtest_server_node.erl60 nodedown(Sock) ->
93 {ok,Sock} ->
103 {ok,Sock};
128 receive_ack(Sock) ->
146 receive {tcp_closed,Sock} -> gen_tcp:close(Sock) end,
172 {ok,Sock} ->
182 {tcp,Sock,Bin} ->
196 {tcp_closed,Sock} ->
415 {ok,Sock} ->
491 {ok,Sock} ->
[all …]
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_amqp1_0/src/
H A Drabbit_amqp1_0_writer.erl75 start(Sock, Channel, FrameMax, Protocol, ReaderPid) ->
76 start(Sock, Channel, FrameMax, Protocol, ReaderPid, false).
78 start_link(Sock, Channel, FrameMax, Protocol, ReaderPid) ->
79 start_link(Sock, Channel, FrameMax, Protocol, ReaderPid, false).
95 end)(#wstate{sock = Sock,
222 tcp_send(Sock, Data) ->
226 internal_send_command(Sock, Channel, MethodRecord, Protocol) ->
266 flush(State = #wstate{sock = Sock, pending = Pending}) ->
267 ok = port_cmd(Sock, lists:reverse(Pending)),
288 port_cmd(Sock, Data) ->
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/preloaded/src/
H A Dsocket_registry.erl84 handle_add_socket(DB, Sock) ->
85 [#esock_info{sock = Sock, atime = timestamp()} | DB].
87 handle_delete_socket(DB, Sock) ->
88 lists:keydelete(Sock, #esock_info.sock, DB).
159 [{Sock, socket:info(Sock)} || #esock_info{sock = Sock} <- DB],
160 [Sock || {Sock, SockInfo} <- SocksInfo, Filter(SockInfo)]
164 [Sock || #esock_info{sock = Sock} <- DB]
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/erts/preloaded/src/
H A Dsocket_registry.erl84 handle_add_socket(DB, Sock) ->
85 [#esock_info{sock = Sock, atime = timestamp()} | DB].
87 handle_delete_socket(DB, Sock) ->
88 lists:keydelete(Sock, #esock_info.sock, DB).
159 [{Sock, socket:info(Sock)} || #esock_info{sock = Sock} <- DB],
160 [Sock || {Sock, SockInfo} <- SocksInfo, Filter(SockInfo)]
164 [Sock || #esock_info{sock = Sock} <- DB]
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/ssh/src/
H A Dssh_tcpip_forward_client.erl40 handle_msg({tcp,Sock,Data}, #state{fwd_socket = Sock,
44 inet:setopts(Sock, [{active,once}]),
47 handle_msg({tcp_closed,Sock}, #state{fwd_socket = Sock,
55 handle_ssh_msg({ssh_cm, _CM, {data, _ChannelId, _Type, Data}}, #state{fwd_socket=Sock} = State) ->
56 gen_tcp:send(Sock, Data),
73 terminate(_Reason, #state{fwd_socket=Sock}) ->
74 gen_tcp:close(Sock),
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_tcpip_forward_client.erl40 handle_msg({tcp,Sock,Data}, #state{fwd_socket = Sock,
44 inet:setopts(Sock, [{active,once}]),
47 handle_msg({tcp_closed,Sock}, #state{fwd_socket = Sock,
55 handle_ssh_msg({ssh_cm, _CM, {data, _ChannelId, _Type, Data}}, #state{fwd_socket=Sock} = State) ->
56 gen_tcp:send(Sock, Data),
73 terminate(_Reason, #state{fwd_socket=Sock}) ->
74 gen_tcp:close(Sock),
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_tcpip_forward_client.erl40 handle_msg({tcp,Sock,Data}, #state{fwd_socket = Sock,
44 inet:setopts(Sock, [{active,once}]),
47 handle_msg({tcp_closed,Sock}, #state{fwd_socket = Sock,
55 handle_ssh_msg({ssh_cm, _CM, {data, _ChannelId, _Type, Data}}, #state{fwd_socket=Sock} = State) ->
56 gen_tcp:send(Sock, Data),
73 terminate(_Reason, #state{fwd_socket=Sock}) ->
74 gen_tcp:close(Sock),
/dports/lang/erlang/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_tcpip_forward_client.erl40 handle_msg({tcp,Sock,Data}, #state{fwd_socket = Sock,
44 inet:setopts(Sock, [{active,once}]),
47 handle_msg({tcp_closed,Sock}, #state{fwd_socket = Sock,
55 handle_ssh_msg({ssh_cm, _CM, {data, _ChannelId, _Type, Data}}, #state{fwd_socket=Sock} = State) ->
56 gen_tcp:send(Sock, Data),
73 terminate(_Reason, #state{fwd_socket=Sock}) ->
74 gen_tcp:close(Sock),
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/ssh/src/
H A Dssh_tcpip_forward_client.erl40 handle_msg({tcp,Sock,Data}, #state{fwd_socket = Sock,
44 inet:setopts(Sock, [{active,once}]),
47 handle_msg({tcp_closed,Sock}, #state{fwd_socket = Sock,
55 handle_ssh_msg({ssh_cm, _CM, {data, _ChannelId, _Type, Data}}, #state{fwd_socket=Sock} = State) ->
56 gen_tcp:send(Sock, Data),
73 terminate(_Reason, #state{fwd_socket=Sock}) ->
74 gen_tcp:close(Sock),
/dports/net/netembryo/netembryo-0.1.1/tests/
H A Dtest_sock.c37 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_connect_lscube()
46 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_remote_host_lscube()
57 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL);
72 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_remote_port_lscube()
82 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_local_port_lscube()
92 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_flags_lscube()
101 Sock *socket = Sock_connect(test_host, test_port, NULL, TCP, NULL); in test_type_lscube()
111 Sock *pair[2]; in test_socket_pair_forwards()
130 Sock *pair[2]; in test_socket_pair_backwards()
149 Sock *pair[2]; in test_socket_pair_crosstalk()
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/src/
H A Damqp_main_reader.erl31 start_link(Sock, Connection, ChMgr, AState, ConnName) ->
33 ?MODULE, [Sock, Connection, ConnName, ChMgr, AState], []).
47 init([Sock, Connection, ConnName, ChMgr, AState]) ->
49 State = #state{sock = Sock,
63 handle_call(post_init, _From, State = #state{sock = Sock}) ->
64 case rabbit_net:setopts(Sock, [{active, once}]) of
74 handle_info({Tag, Sock, Data}, State = #state{sock = Sock})
77 case rabbit_net:setopts(Sock, [{active, once}]) of
81 handle_info({Tag, Sock}, State = #state{sock = Sock})
84 handle_info({Tag, Sock, Reason}, State = #state{sock = Sock})
[all …]
/dports/devel/florist-gpl/florist-gpl-2017-src/gnatsocks/
H A Dsockets.ads59 procedure Close (Sock : in out Socket'Class);
78 (Sock : in out Stream_Socket;
82 function Get_Input_Stream (Sock : Stream_Socket) return Input_Stream_Ptr;
84 function Get_Output_Stream (Sock : Stream_Socket) return Output_Stream_Ptr;
91 (Sock : in out Server_Socket;
112 (Sock : in out Datagram_Socket;
118 (Sock : in Datagram_Socket;
124 (Sock : in Datagram_Socket;
158 procedure Finalize (Sock : in out Socket);
/dports/net/netembryo/netembryo-0.1.1/wsocket/
H A DSock.c80 Sock * Sock_accept(Sock *s, void * octx) in Sock_accept()
87 Sock *new_s = NULL; in Sock_accept()
211 Sock * Sock_bind(char const *host, char const *port, Sock *sock, in Sock_bind()
215 Sock *s = NULL; in Sock_bind()
298 int Sock_close(Sock *s) in Sock_close()
332 int Sock_compare(Sock *p, Sock *q) in Sock_compare()
334 return memcmp(p, q, sizeof(Sock)); in Sock_compare()
347 Sock * Sock_connect(char const *host, char const *port, Sock *binded, in Sock_connect()
350 Sock *s; in Sock_connect()
556 int Sock_listen(Sock *s, int backlog) in Sock_listen()
[all …]
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/megaco/test/
H A Dmegaco_test_tcp_generator.erl252 connection = Sock,
282 {ok, Sock} ->
311 #state{connection = Sock,
328 {ok, Sock} ->
339 #state{connection = Sock,
355 #state{connection = Sock,
379 #state{connection = Sock,
412 #state{connection = Sock,
418 {tcp_closed, Sock} ->
461 connection = Sock,
[all …]
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/kernel/test/
H A Dsocket_test_ttest_tcp_client.erl241 {ok, Sock} ->
253 sock => Sock,
266 (catch Mod:close(Sock)),
386 sock := Sock,
399 case Mod:send(Sock, Req) of
414 sock := Sock,
435 sock := Sock,
445 maybe_activate(Mod, Sock, Active),
470 recv_reply_message1(Mod, Sock, ID) ->
609 Mod:active(Sock, Active).
[all …]
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/megaco/test/
H A Dmegaco_test_tcp_generator.erl252 connection = Sock,
282 {ok, Sock} ->
311 #state{connection = Sock,
328 {ok, Sock} ->
339 #state{connection = Sock,
355 #state{connection = Sock,
379 #state{connection = Sock,
412 #state{connection = Sock,
418 {tcp_closed, Sock} ->
461 connection = Sock,
[all …]
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/kernel/test/
H A Dsocket_test_ttest_tcp_client.erl241 {ok, Sock} ->
253 sock => Sock,
266 (catch Mod:close(Sock)),
386 sock := Sock,
399 case Mod:send(Sock, Req) of
414 sock := Sock,
435 sock := Sock,
445 maybe_activate(Mod, Sock, Active),
470 recv_reply_message1(Mod, Sock, ID) ->
609 Mod:active(Sock, Active).
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/emulator/test/
H A Dsocket_test_ttest_tcp_client.erl241 {ok, Sock} ->
253 sock => Sock,
266 (catch Mod:close(Sock)),
386 sock := Sock,
399 case Mod:send(Sock, Req) of
414 sock := Sock,
435 sock := Sock,
445 maybe_activate(Mod, Sock, Active),
470 recv_reply_message1(Mod, Sock, ID) ->
609 Mod:active(Sock, Active).
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/megaco/test/
H A Dmegaco_test_tcp_generator.erl252 connection = Sock,
282 {ok, Sock} ->
311 #state{connection = Sock,
328 {ok, Sock} ->
339 #state{connection = Sock,
355 #state{connection = Sock,
379 #state{connection = Sock,
412 #state{connection = Sock,
418 {tcp_closed, Sock} ->
461 connection = Sock,
[all …]
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/megaco/test/
H A Dmegaco_test_tcp_generator.erl252 connection = Sock,
282 {ok, Sock} ->
311 #state{connection = Sock,
328 {ok, Sock} ->
339 #state{connection = Sock,
355 #state{connection = Sock,
379 #state{connection = Sock,
412 #state{connection = Sock,
418 {tcp_closed, Sock} ->
461 connection = Sock,
[all …]
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/kernel/test/
H A Dsocket_test_ttest_tcp_client.erl241 {ok, Sock} ->
253 sock => Sock,
266 (catch Mod:close(Sock)),
386 sock := Sock,
399 case Mod:send(Sock, Req) of
414 sock := Sock,
435 sock := Sock,
445 maybe_activate(Mod, Sock, Active),
470 recv_reply_message1(Mod, Sock, ID) ->
609 Mod:active(Sock, Active).
[all …]

12345678910>>...51