/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/common_test/src/ |
H A D | test_server_node.erl | 60 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 D | test_server_node.erl | 60 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 D | test_server_node.erl | 60 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 D | test_server_node.erl | 60 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 D | test_server_node.erl | 60 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 D | rabbit_amqp1_0_writer.erl | 75 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 D | socket_registry.erl | 84 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 D | socket_registry.erl | 84 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 D | ssh_tcpip_forward_client.erl | 40 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 D | ssh_tcpip_forward_client.erl | 40 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 D | ssh_tcpip_forward_client.erl | 40 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 D | ssh_tcpip_forward_client.erl | 40 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 D | ssh_tcpip_forward_client.erl | 40 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 D | test_sock.c | 37 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 D | amqp_main_reader.erl | 31 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 D | sockets.ads | 59 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 D | Sock.c | 80 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 D | megaco_test_tcp_generator.erl | 252 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 D | socket_test_ttest_tcp_client.erl | 241 {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 D | megaco_test_tcp_generator.erl | 252 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 D | socket_test_ttest_tcp_client.erl | 241 {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 D | socket_test_ttest_tcp_client.erl | 241 {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 D | megaco_test_tcp_generator.erl | 252 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 D | megaco_test_tcp_generator.erl | 252 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 D | socket_test_ttest_tcp_client.erl | 241 {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 …]
|