Home
last modified time | relevance | path

Searched refs:tcp_listener (Results 1 – 25 of 80) sorted by relevance

1234

/dports/lang/mono/mono-5.10.1.57/mcs/class/System.ServiceModel/System.ServiceModel.Channels.NetTcp/
H A DTcpChannelListener.cs48 TcpListener tcp_listener; field in System.ServiceModel.Channels.NetTcp.TcpChannelListener
165 if (tcp_listener == null) in ProcessClose()
168 tcp_listener.Stop (); in ProcessClose()
172 tcp_listener = null; in ProcessClose()
189 …tcp_listener = new TcpListener (address, explicitPort <= 0 ? TcpTransportBindingElement.DefaultPor… in OnOpen()
190 tcp_listener.Start (); in OnOpen()
191 tcp_listener.BeginAcceptTcpClient (TcpListenerAcceptedClient, tcp_listener); in OnOpen()
/dports/net/nng/nng-1.5.2/src/core/
H A Dtcp.c281 } tcp_listener; typedef
286 tcp_listener *l = arg; in tcp_listener_close()
293 tcp_listener *l = arg; in tcp_listener_free()
301 tcp_listener *l = arg; in tcp_listener_listen()
308 tcp_listener *l = arg; in tcp_listener_accept()
315 tcp_listener *l = arg; in tcp_listener_get_port()
355 tcp_listener *l = arg; in tcp_listener_get()
366 tcp_listener *l = arg; in tcp_listener_set()
373 tcp_listener *l; in tcp_listener_alloc_addr()
/dports/net/libzmq2/zeromq-2.2.0/src/
H A Dzmq_listener.cpp42 return tcp_listener.set_address (protocol_, addr_, options.backlog); in set_address()
48 handle = add_fd (tcp_listener.get_fd ()); in process_plug()
60 fd_t fd = tcp_listener.accept (); in in_event()
/dports/devel/upp/upp/bazaar/ZMQ/lib/src/
H A Dzmq_listener.cpp41 return tcp_listener.set_address (protocol_, addr_, options.backlog); in set_address()
47 handle = add_fd (tcp_listener.get_fd ()); in process_plug()
59 fd_t fd = tcp_listener.accept (); in in_event()
/dports/devel/py-gevent/gevent-21.8.0/src/gevent/tests/
H A Dtest__greenio.py25 from gevent.testing import TestCase, tcp_listener
84 server = tcp_listener()
89 server = tcp_listener()
129 server = tcp_listener()
H A Dtest__makefile_ref.py14 from gevent.testing.sockets import tcp_listener
186 listener = closer(tcp_listener(backlog=1))
204 listener = closer(tcp_listener(backlog=1))
232 listener = closer(tcp_listener(backlog=1))
326 listener = closer(tcp_listener(backlog=1))
346 listener = closer(tcp_listener(backlog=1))
370 listener = closer(tcp_listener(backlog=1))
394 raw_listener = tcp_listener(backlog=1)
415 raw_listener = tcp_listener(backlog=1)
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Dtcp_listener_sup.erl51 OurChildSpecStart = {tcp_listener, start_link, [IPAddress, Port, OnStartup, OnShutdown, Label]},
52 … OurChildSpec = {tcp_listener, OurChildSpecStart, transient, 16#ffffffff, worker, [tcp_listener]},
/dports/net/pjsip/pjproject-2.11.1/pjsip/src/pjsip/
H A Dsip_transport_tcp.c45 struct tcp_listener;
53 struct tcp_listener struct
375 struct tcp_listener *listener; in pjsip_tcp_transport_start3()
509 struct tcp_listener *listener = (struct tcp_listener *)arg; in lis_on_destroy()
523 static void lis_close(struct tcp_listener *listener) in lis_close()
539 struct tcp_listener *listener = (struct tcp_listener *)factory; in lis_destroy()
988 struct tcp_listener *listener; in lis_create_transport()
1005 listener = (struct tcp_listener*)factory; in lis_create_transport()
1117 struct tcp_listener *listener; in on_accept_complete()
1659 struct tcp_listener *listener = (struct tcp_listener *)factory; in pjsip_tcp_transport_lis_start()
[all …]
/dports/devel/silc-toolkit/silc-toolkit-1.1.12/lib/silcclient/
H A Dclient_listener.c35 SilcNetListener tcp_listener; /* TCP listener */ member
355 listener->tcp_listener = in silc_client_listener_add()
362 if (!listener->tcp_listener) { in silc_client_listener_add()
376 ports = silc_net_listener_get_port(listener->tcp_listener, NULL); in silc_client_listener_add()
393 if (listener->tcp_listener) in silc_client_listener_free()
394 silc_net_close_listener(listener->tcp_listener); in silc_client_listener_free()
/dports/net/pjsip/pjproject-2.11.1/pjnath/src/pjturn-srv/
H A Dlistener_tcp.c33 struct tcp_listener struct
72 struct tcp_listener *tcp_lis; in pj_turn_listener_create_tcp()
79 tcp_lis = PJ_POOL_ZALLOC_T(pool, struct tcp_listener); in pj_turn_listener_create_tcp()
152 struct tcp_listener *tcp_lis = (struct tcp_listener *)listener; in lis_destroy()
189 struct tcp_listener *tcp_lis; in lis_on_accept_complete()
192 tcp_lis = (struct tcp_listener*) pj_ioqueue_get_user_data(key); in lis_on_accept_complete()
/dports/net/routinator/routinator-0.10.2/cargo-crates/tokio-stream-0.1.7/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/editors/helix/helix-0.5.0/cargo-crates/tokio-stream-0.1.7/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/net/oha/oha-0.4.7/cargo-crates/tokio-stream-0.1.7/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/tokio-stream-0.1.7/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/tokio-stream-0.1.7/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/lang/rust/rustc-1.58.1-src/vendor/tokio-stream/src/
H A Dwrappers.rs51 mod tcp_listener;
52 pub use tcp_listener::TcpListenerStream;
/dports/audio/ncspot/ncspot-0.9.3/cargo-crates/tokio-stream-0.1.8/src/
H A Dwrappers.rs42 mod tcp_listener;
43 pub use tcp_listener::TcpListenerStream;
/dports/net/py-trio/trio-0.19.0/trio/
H A D_highlevel_ssl_helpers.py78 trio.SSLListener(tcp_listener, ssl_context, https_compatible=https_compatible)
79 for tcp_listener in tcp_listeners
/dports/multimedia/librav1e/rav1e-0.5.1/cargo-crates/rust_hawktracer_sys-0.4.2/hawktracer/lib/listeners/
H A Dtcp_listener.c32 HT_TCPListener* tcp_listener = (HT_TCPListener*)listener; in ht_tcp_listener_f_flush() local
33 ht_tcp_server_write(tcp_listener->_tcp_server, (char*)data, size); in ht_tcp_listener_f_flush()
34 tcp_listener->_was_flushed = HT_TRUE; in ht_tcp_listener_f_flush()
/dports/multimedia/rav1e/rav1e-0.5.1/cargo-crates/rust_hawktracer_sys-0.4.2/hawktracer/lib/listeners/
H A Dtcp_listener.c32 HT_TCPListener* tcp_listener = (HT_TCPListener*)listener; in ht_tcp_listener_f_flush() local
33 ht_tcp_server_write(tcp_listener->_tcp_server, (char*)data, size); in ht_tcp_listener_f_flush()
34 tcp_listener->_was_flushed = HT_TRUE; in ht_tcp_listener_f_flush()
/dports/net/py-sshuttle/sshuttle-0.78.5/sshuttle/
H A Dclient.py433 def _main(tcp_listener, udp_listener, fw, ssh_cmd, remotename, argument
503 if family == socket.AF_INET6 and tcp_listener.v6 is None:
505 if family == socket.AF_INET and tcp_listener.v4 is None:
530 tcp_listener.add_handler(handlers, onaccept_tcp, method, mux)
653 tcp_listener = MultiListener()
681 tcp_listener.bind(lv6, lv4)
698 tcp_listener.listen(10)
699 tcp_listener.print_listening("TCP redirector")
772 fw.method.setup_tcp_listener(tcp_listener)
785 return _main(tcp_listener, udp_listener, fw, ssh_cmd, remotename,
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/tcp/
H A Dtcp_listener.c185 uct_tcp_listener_t *tcp_listener = ucs_derived_of(listener, in uct_tcp_listener_query() local
193 if (getsockname(tcp_listener->listen_fd, (struct sockaddr *)&addr, in uct_tcp_listener_query()
195 ucs_error("getsockname failed (listener=%p) %m", tcp_listener); in uct_tcp_listener_query()
/dports/security/py-asyncssh/asyncssh-2.8.1/asyncssh/
H A Dx11.py317 def __init__(self, tcp_listener, display): argument
318 self._tcp_listener = tcp_listener
501 tcp_listener = await create_tcp_forward_listener(
513 tcp_listener.close()
516 return SSHX11ServerListener(tcp_listener, display)
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/
H A DMakefile.am46 tcp/tcp_listener.h \
78 tcp/tcp_listener.c \
/dports/lang/rust/rustc-1.58.1-src/library/std/src/os/windows/io/
H A Dsocket.rs185 fn from(tcp_listener: crate::net::TcpListener) -> OwnedSocket { in from()
186 unsafe { OwnedSocket::from_raw_socket(tcp_listener.into_raw_socket()) } in from()

1234