Home
last modified time | relevance | path

Searched refs:Tcp (Results 1 – 25 of 1103) sorted by relevance

12345678910>>...45

/dports/misc/actiona/actiona-3.10.1/actions/actionpackdata/code/
H A Dtcp.cpp30 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 DRabitTrackerConnectionHandlerTest.scala22 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 DRabitTrackerConnectionHandlerTest.scala22 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 Dtcp.lua73 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 Dsocket.rs7 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 DCreateSocketTests.cs12 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 DAccept.cs17 … 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 Dsocket.rs18 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 DSocketTest.cs135 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 Dconnection_provider.rs126 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 DSocketPermissionTest.cs32 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 Dtcp.go26 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 Dtcp.go26 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 Dnet.rs32 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 DRabitWorkerHandler.scala21 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 DRabitTrackerHandler.scala25 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 DRabitWorkerHandler.scala21 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 DRabitTrackerHandler.scala25 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 Dmain.yml21 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 Dauth_chaining_t.cc110 .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 Dconnection_provider.rs86 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 Dconnection_provider.rs86 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 Dsql-server-activate-tcp-fixed-port.ps122 $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 Dmain.yml70 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 Dmain.yml94 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 …]

12345678910>>...45