/dports/misc/actiona/actiona-3.10.1/actions/actionpackdata/code/ |
H A D | tcp.cpp | 30 Tcp *tcp = new Tcp; in constructor() 58 Tcp::Tcp() in Tcp() function in Code::Tcp 69 Tcp::Tcp(QTcpSocket *tcpSocket) in Tcp() function in Code::Tcp 80 Tcp::~Tcp() = default; 146 QScriptValue Tcp::read() in read() 151 QString Tcp::readText(Encoding encoding) in readText() 156 QScriptValue Tcp::disconnect() in disconnect() 163 void Tcp::connected() in connected() 169 void Tcp::disconnected() in disconnected() 175 void Tcp::readyRead() in readyRead() [all …]
|
/dports/misc/py-xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/test/scala/ml/dmlc/xgboost4j/scala/rabit/ |
H A D | RabitTrackerConnectionHandlerTest.scala | 22 import akka.io.Tcp 63 fsm ! Tcp.Received(magic) 64 connProbe.expectMsg(Tcp.Write(magic)) 116 connProbe.expectMsg(Tcp.Write( 130 fsm ! Tcp.PeerClosed 161 fsm ! Tcp.Received(magic) 170 fsm ! Tcp.Received(printCmd.encode) 183 fsm ! Tcp.Received(magic) 200 fsm ! Tcp.Received(partialMessage) 201 fsm ! Tcp.Received(remainder) [all …]
|
/dports/misc/xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/test/scala/ml/dmlc/xgboost4j/scala/rabit/ |
H A D | RabitTrackerConnectionHandlerTest.scala | 22 import akka.io.Tcp 63 fsm ! Tcp.Received(magic) 64 connProbe.expectMsg(Tcp.Write(magic)) 116 connProbe.expectMsg(Tcp.Write( 130 fsm ! Tcp.PeerClosed 161 fsm ! Tcp.Received(magic) 170 fsm ! Tcp.Received(printCmd.encode) 183 fsm ! Tcp.Received(magic) 200 fsm ! Tcp.Received(partialMessage) 201 fsm ! Tcp.Received(remainder) [all …]
|
/dports/dns/dnsjit/dnsjit-1.2.2/src/core/object/ |
H A D | tcp.lua | 73 local Tcp = {} 76 function Tcp:type() 81 function Tcp:prev() 86 function Tcp:cast() 91 function Tcp:uncast() 96 function Tcp:copy() 101 function Tcp:free() 105 core_object_tcp_t = ffi.metatype(t_name, { __index = Tcp }) 110 return Tcp
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-server-1.0.3/src/ |
H A D | socket.rs | 7 Tcp(net::TcpListener), enumerator 13 Tcp(net::SocketAddr), enumerator 21 SocketAddr::Tcp(ref addr) => write!(f, "{}", addr), in fmt() 31 SocketAddr::Tcp(ref addr) => write!(f, "{:?}", addr), in fmt() 51 StdListener::Tcp(lst) => SocketAddr::Tcp(lst.local_addr().unwrap()), in local_addr() 59 StdListener::Tcp(lst) => SocketListener::Tcp( in into_listener() 74 Tcp(std::net::TcpStream), enumerator 80 Tcp(mio::net::TcpListener), enumerator 88 SocketListener::Tcp(ref lst) => lst in accept() 90 .map(|(stream, addr)| Some((StdStream::Tcp(stream), SocketAddr::Tcp(addr)))), in accept() [all …]
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/FunctionalTests/ |
H A D | CreateSocketTests.cs | 12 new object[] { SocketType.Stream, ProtocolType.Tcp }, 17 new object[] { SocketType.Dgram, ProtocolType.Tcp }, 19 new object[] { SocketType.Rdm, ProtocolType.Tcp }, 20 new object[] { SocketType.Seqpacket, ProtocolType.Tcp }, 21 new object[] { SocketType.Unknown, ProtocolType.Tcp }, 51 new object[] { AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp }, 52 new object[] { AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp }, 67 new object[] { AddressFamily.Unknown, SocketType.Stream, ProtocolType.Tcp }, 69 new object[] { AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Tcp }, 70 new object[] { AddressFamily.InterNetwork, SocketType.Rdm, ProtocolType.Tcp }, [all …]
|
H A D | Accept.cs | 17 … using (Socket listen = new Socket(listenAt.AddressFamily, SocketType.Stream, ProtocolType.Tcp)) in Accept_Success() 25 … using (Socket client = new Socket(listenAt.AddressFamily, SocketType.Stream, ProtocolType.Tcp)) in Accept_Success() 50 …ing (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_ConcurrentAcceptsBeforeConnects_Success() 62 … clients[i] = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); in Accept_ConcurrentAcceptsBeforeConnects_Success() 107 …ing (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_ConcurrentAcceptsAfterConnects_Success() 164 …using (Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_WithTargetSocket_Success() 165 …using (Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_WithTargetSocket_Success() 194 … using (var listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_WithTargetSocket_ReuseAfterDisconnect_Success() 195 … using (var server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_WithTargetSocket_ReuseAfterDisconnect_Success() 242 …using (Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) in Accept_WithAlreadyBoundTargetSocket_Fails() [all …]
|
/dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-server-2.0.0-beta.5/src/ |
H A D | socket.rs | 18 Tcp(MioTcpListener), enumerator 26 MioListener::Tcp(ref lst) => SocketAddr::Tcp(lst.local_addr().unwrap()), in local_addr() 34 MioListener::Tcp(ref lst) => lst.accept().map(|(stream, _)| MioStream::Tcp(stream)), in accept() 89 MioListener::Tcp(MioTcpListener::from_std(lst)) in from() 103 MioListener::Tcp(ref lst) => write!(f, "{:?}", lst), in fmt() 121 Tcp(StdSocketAddr), enumerator 129 SocketAddr::Tcp(ref addr) => write!(f, "{}", addr), in fmt() 148 Tcp(mio::net::TcpStream), enumerator 168 MioStream::Tcp(mio) => { in from_mio() 190 MioStream::Tcp(mio) => { in from_mio() [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net.Sockets/ |
H A D | SocketTest.cs | 135 ProtocolType.Tcp); in BlockingConnect() 2922 ProtocolType.Tcp); in Receive1_Buffer_Null() 2941 ProtocolType.Tcp); in Receive1_Socket_Closed() 2960 ProtocolType.Tcp); in Receive2_Buffer_Null() 2979 ProtocolType.Tcp); in Receive2_Socket_Closed() 2998 ProtocolType.Tcp); in Receive3_Buffer_Null() 3017 ProtocolType.Tcp); in Receive3_Socket_Closed() 3036 ProtocolType.Tcp); in Receive4_Buffer_Null() 3055 ProtocolType.Tcp); in Receive4_Socket_Closed() 3074 ProtocolType.Tcp); in Receive5_Buffer_Null() [all …]
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/trust-dns-resolver-0.19.5/src/name_server/ |
H A D | connection_provider.rs | 126 Protocol::Tcp => { in new_connection() 141 ConnectionConnect::Tcp(exchange) in new_connection() 219 Tcp( 299 ConnectionConnect::Tcp(ref mut conn) => { 349 Tcp(DnsExchange<DnsMultiplexerSerialResponse>), 366 ConnectionConnected::Tcp(ref mut conn) => { 391 Tcp(DnsExchangeSend<DnsMultiplexerSerialResponse>), 409 Tcp(ref mut resp) => resp.poll_unpin(cx), 457 Tcp( 502 Tcp(ref mut bg) => bg.poll_unpin(cx), [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net/ |
H A D | SocketPermissionTest.cs | 32 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in GetReady() 49 …s2.AddPermission(NetworkAccess.Accept, TransportType.Tcp, "216.239.*.*", SocketPermission.AllPorts… in GetReady() 61 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in IsSubsetOf() 69 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in IsSubsetOf() 76 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.*.*", 80); in IsSubsetOf() 81 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in IsSubsetOf() 82 s1.AddPermission(NetworkAccess.Accept, TransportType.Tcp, "10.11.*.*", 9090); in IsSubsetOf() 83 s2 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in IsSubsetOf() 93 s1 = new SocketPermission(NetworkAccess.Connect, TransportType.Tcp, "12.13.14.15", 80); in IsSubsetOf2()
|
/dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/logr/v2/targets/ |
H A D | tcp.go | 26 type Tcp struct { struct 57 func NewTcpTarget(options *TcpOptions) *Tcp { 58 tcp := &Tcp{ 68 func (tcp *Tcp) Init() error { argument 74 func (tcp *Tcp) getConn(reporter func(err interface{})) (net.Conn, error) { argument 113 func (tcp *Tcp) dial(ctx context.Context) (net.Conn, error) { argument 144 func (tcp *Tcp) close() error { argument 158 func (tcp *Tcp) Shutdown() error { argument 166 func (tcp *Tcp) Write(p []byte, rec *logr.LogRec) (int, error) { argument 236 func (tcp *Tcp) String() string { argument [all …]
|
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/mattermost/logr/v2/targets/ |
H A D | tcp.go | 26 type Tcp struct { struct 57 func NewTcpTarget(options *TcpOptions) *Tcp { 58 tcp := &Tcp{ 68 func (tcp *Tcp) Init() error { argument 74 func (tcp *Tcp) getConn(reporter func(err interface{})) (net.Conn, error) { argument 113 func (tcp *Tcp) dial(ctx context.Context) (net.Conn, error) { argument 144 func (tcp *Tcp) close() error { argument 158 func (tcp *Tcp) Shutdown() error { argument 166 func (tcp *Tcp) Write(p []byte, rec *logr.LogRec) (int, error) { argument 236 func (tcp *Tcp) String() string { argument [all …]
|
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/lettre-0.10.0-rc.4/src/transport/smtp/client/ |
H A D | net.rs | 32 Tcp(TcpStream), enumerator 55 InnerNetworkStream::Tcp(ref s) => s.peer_addr(), in peer_addr() 73 InnerNetworkStream::Tcp(ref s) => s.shutdown(how), in shutdown() 116 let mut stream = NetworkStream::new(InnerNetworkStream::Tcp(tcp_stream)); in connect() 126 InnerNetworkStream::Tcp(_) => { in upgrade_tls() 132 InnerNetworkStream::Tcp(_) => { in upgrade_tls() 136 InnerNetworkStream::Tcp(tcp_stream) => tcp_stream, in upgrade_tls() 174 InnerNetworkStream::Tcp(_) => false, in is_encrypted() 229 InnerNetworkStream::Tcp(ref mut s) => s.read(buf), in read() 245 InnerNetworkStream::Tcp(ref mut s) => s.write(buf), in write() [all …]
|
/dports/misc/py-xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/main/scala/ml/dmlc/xgboost4j/scala/rabit/handler/ |
H A D | RabitWorkerHandler.scala | 21 import akka.io.Tcp 115 case Event(Tcp.Received(magic), _) => 121 connection ! Tcp.Write(magic) 159 connection ! Tcp.SuspendReading 201 connection ! Tcp.SuspendReading 226 connection ! Tcp.SuspendReading 235 case Event(Tcp.Received(numErrors), _) => 256 case Event(Tcp.PeerClosed, _) => 294 connection ! Tcp.ResumeReading 300 connection ! Tcp.ResumeReading [all …]
|
H A D | RabitTrackerHandler.scala | 25 import akka.io.{IO, Tcp} 47 private[this] val tcpManager = IO(Tcp) 81 private def handleTcpEvents(event: Tcp.Event): Unit = event match { 82 case Tcp.Bound(local) => 96 case Tcp.CommandFailed(cmd: Tcp.Bind) => 99 tcpManager ! Tcp.Bind(self, 104 case Tcp.Connected(remote, local) => 111 connection ! Tcp.Register(workerHandler, keepOpenOnPeerClosed = true) 131 tcpManager ! Tcp.Bind(self, 135 tcpManager ! Tcp.Bind(self, msg.addr, backlog = 256) [all …]
|
/dports/misc/xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/main/scala/ml/dmlc/xgboost4j/scala/rabit/handler/ |
H A D | RabitWorkerHandler.scala | 21 import akka.io.Tcp 115 case Event(Tcp.Received(magic), _) => 121 connection ! Tcp.Write(magic) 159 connection ! Tcp.SuspendReading 201 connection ! Tcp.SuspendReading 226 connection ! Tcp.SuspendReading 235 case Event(Tcp.Received(numErrors), _) => 256 case Event(Tcp.PeerClosed, _) => 294 connection ! Tcp.ResumeReading 300 connection ! Tcp.ResumeReading [all …]
|
H A D | RabitTrackerHandler.scala | 25 import akka.io.{IO, Tcp} 47 private[this] val tcpManager = IO(Tcp) 81 private def handleTcpEvents(event: Tcp.Event): Unit = event match { 82 case Tcp.Bound(local) => 96 case Tcp.CommandFailed(cmd: Tcp.Bind) => 99 tcpManager ! Tcp.Bind(self, 104 case Tcp.Connected(remote, local) => 111 connection ! Tcp.Register(workerHandler, keepOpenOnPeerClosed = true) 131 tcpManager ! Tcp.Bind(self, 135 tcpManager ! Tcp.Bind(self, msg.addr, backlog = 256) [all …]
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/azure/azcollection/tests/integration/targets/azure_rm_securitygroup/tasks/ |
H A D | main.yml | 21 protocol: Tcp 27 protocol: Tcp 54 protocol: Tcp 60 protocol: Tcp 65 protocol: Tcp 84 protocol: Tcp 90 protocol: Tcp 95 protocol: Tcp 169 protocol: Tcp 197 protocol: Tcp [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/xplugin/xcl/ |
H A D | auth_chaining_t.cc | 110 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 125 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 142 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 158 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 174 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 191 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 211 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 231 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 248 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() 264 .WillOnce(Return(Connection_type::Tcp)); in TEST_F() [all …]
|
/dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/trust-dns-resolver-0.20.3/src/name_server/ |
H A D | connection_provider.rs | 86 type Tcp: Connect; typedef 109 <R as RuntimeProvider>::Tcp: Connect, 129 Protocol::Tcp => { in new_connection() 134 TcpClientStream::<R::Tcp>::with_timeout(socket_addr, timeout); in new_connection() 144 ConnectionConnect::Tcp(exchange) in new_connection() 218 Tcp( enumerator 221 TcpClientConnect<<R as RuntimeProvider>::Tcp>, 222 TcpClientStream<<R as RuntimeProvider>::Tcp>, 244 TlsClientStream<<R as RuntimeProvider>::Tcp>, 280 ConnectionConnect::Tcp(ref mut conn) => { [all …]
|
/dports/net/oha/oha-0.4.7/cargo-crates/trust-dns-resolver-0.20.3/src/name_server/ |
H A D | connection_provider.rs | 86 type Tcp: Connect; typedef 109 <R as RuntimeProvider>::Tcp: Connect, 129 Protocol::Tcp => { in new_connection() 134 TcpClientStream::<R::Tcp>::with_timeout(socket_addr, timeout); in new_connection() 144 ConnectionConnect::Tcp(exchange) in new_connection() 218 Tcp( enumerator 221 TcpClientConnect<<R as RuntimeProvider>::Tcp>, 222 TcpClientStream<<R as RuntimeProvider>::Tcp>, 244 TlsClientStream<<R as RuntimeProvider>::Tcp>, 280 ConnectionConnect::Tcp(ref mut conn) => { [all …]
|
/dports/databases/py-pymssql/pymssql-2.1.4/dev/appveyor/ |
H A D | sql-server-activate-tcp-fixed-port.ps1 | 22 $Tcp = $wmi.GetSmoObject($uri) variable 23 $Tcp.IsEnabled = $true 24 foreach ($ipAddress in $Tcp.IPAddresses) 29 $Tcp.alter()
|
/dports/sysutils/ansible2/ansible-2.9.27/test/integration/targets/azure_rm_loadbalancer/tasks/ |
H A D | main.yml | 70 probe_protocol: Tcp 74 protocol: Tcp 82 natpool_protocol: Tcp 97 probe_protocol: Tcp 101 protocol: Tcp 109 natpool_protocol: Tcp 123 probe_protocol: Tcp 127 protocol: Tcp 164 protocol: Tcp 209 protocol: Tcp [all …]
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/azure/azcollection/tests/integration/targets/azure_rm_loadbalancer/tasks/ |
H A D | main.yml | 94 probe_protocol: Tcp 98 protocol: Tcp 106 natpool_protocol: Tcp 121 probe_protocol: Tcp 125 protocol: Tcp 133 natpool_protocol: Tcp 147 probe_protocol: Tcp 151 protocol: Tcp 188 protocol: Tcp 233 protocol: Tcp [all …]
|