/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/FunctionalTests/ |
H A D | SocketTestHelper.cs | 15 public abstract Task<Socket> AcceptAsync(Socket s); in AcceptAsync() method in System.Net.Sockets.Tests.SocketHelperBase 37 public override Task<Socket> AcceptAsync(Socket s) => 73 public override Task<Socket> AcceptAsync(Socket s) => 82 public override Task<Socket> AcceptAsync(Socket s) => 130 public override Task<Socket> AcceptAsync(Socket s) => 131 s.AcceptAsync(); 133 s.AcceptAsync(acceptSocket); in AcceptAsync() 156 public override Task<Socket> AcceptAsync(Socket s) => 162 return s.AcceptAsync(e); in AcceptAsync() 248 public Task<Socket> AcceptAsync(Socket s) => _socketHelper.AcceptAsync(s); [all …]
|
H A D | Accept.cs | 22 Task<Socket> acceptTask = AcceptAsync(listen); in Accept_Success() 63 servers[i] = AcceptAsync(listener); in Accept_ConcurrentAcceptsBeforeConnects_Success() 126 servers[i] = AcceptAsync(listener); in Accept_ConcurrentAcceptsAfterConnects_Success() 170 Task<Socket> acceptTask = AcceptAsync(listener, server); in Accept_WithTargetSocket_Success() 202 Task<Socket> acceptTask = AcceptAsync(listener, server); in Accept_WithTargetSocket_ReuseAfterDisconnect_Success() 217 Task<Socket> acceptTask = AcceptAsync(listener, server); in Accept_WithTargetSocket_ReuseAfterDisconnect_Success() 227 …SocketException se = await Assert.ThrowsAsync<SocketException>(() => AcceptAsync(listener, server)… in Accept_WithTargetSocket_ReuseAfterDisconnect_Success() 250 Assert.Throws<InvalidOperationException>(() => { AcceptAsync(listener, server); }); in Accept_WithAlreadyBoundTargetSocket_Fails() 269 Task<Socket> acceptTask = AcceptAsync(listener, server); in Accept_WithInUseTargetSocket_Fails() 276 Assert.Throws<InvalidOperationException>(() => { AcceptAsync(listener, server); }); in Accept_WithInUseTargetSocket_Fails()
|
H A D | SocketAsyncEventArgsTest.cs | 78 Task<Socket> acceptTask = listen.AcceptAsync(); in Dispose_WhileInUse_DisposeDelayed() 114 Task<Socket> acceptTask = listen.AcceptAsync(); in ExecutionContext_FlowsIfNotSuppressed() 285 Task<Socket> acceptTask = listen.AcceptAsync(); in Completed_RegisterThenInvoked_UnregisterThenNotInvoked() 382 Task<Socket> acceptTask = listen.AcceptAsync(); in ReuseSocketAsyncEventArgs_SameInstance_MultipleSockets() 428 Task<Socket> acceptTask = listen.AcceptAsync(); in ReuseSocketAsyncEventArgs_MutateBufferList() 516 Assert.True(server.AcceptAsync(acceptArgs)); in AcceptAsync_WithReceiveBuffer_Success() 557 … AssertExtensions.Throws<ArgumentException>(null, () => server.AcceptAsync(acceptArgs)); in AcceptAsync_WithTooSmallReceiveBuffer_Failure() 580 Assert.Throws<PlatformNotSupportedException>(() => server.AcceptAsync(acceptArgs)); in AcceptAsync_WithReceiveBuffer_Failure()
|
H A D | SelectAndPollTests.cs | 171 listener.AcceptAsync(); in SelectWrite_Single_Timeout() 203 firstListener.AcceptAsync(); in SelectWrite_Multiple_Timeout() 207 secondListener.AcceptAsync(); in SelectWrite_Multiple_Timeout() 224 listener.AcceptAsync(); in SelectWrite_Multiple_Mixed() 316 listener.AcceptAsync(); in PollWrite_Single_Timeout()
|
H A D | SendReceive.cs | 135 using (Socket remote = await AcceptAsync(server)) in SendRecv_Stream_TCP() 246 Task<Socket> acceptTask = AcceptAsync(listener); in SendRecv_Stream_TCP_LargeMultiBufferSends() 302 using (Socket remote = await AcceptAsync(server)) in SendRecv_Stream_TCP_AlternateBufferAndBufferList() 401 using (Socket remote = await AcceptAsync(server)) in SendRecv_Stream_TCP_MultipleConcurrentReceives() 509 using (Socket remote = await AcceptAsync(server)) in SendRecv_Stream_TCP_MultipleConcurrentSends() 647 Task<Socket> acceptTask = AcceptAsync(listener); in SendRecv_0ByteReceive_Success() 690 Task<Socket> acceptTask = AcceptAsync(listener); in Receive0ByteReturns_WhenPeerDisconnects() 730 Task<Socket> acceptTask = AcceptAsync(listener); in SendRecv_BlockingNonBlocking_LingerTimeout_Success() 759 Task<Socket> acceptTask = AcceptAsync(listener); in SendRecv_NoBuffering_Success() 798 Task<Socket> acceptTask = AcceptAsync(listener); in SendRecv_DisposeDuringPendingReceive_ThrowsSocketException()
|
H A D | NetworkStreamTest.cs | 52 Task<Socket> acceptTask = listener.AcceptAsync(); in Ctor_NonBlockingSocket_ThrowsIOException() 71 Task<Socket> acceptTask = listener.AcceptAsync(); in Ctor_Socket_CanReadAndWrite_DoesntOwn() 112 Task<Socket> acceptTask = listener.AcceptAsync(); in Ctor_SocketFileAccessBool_CanReadAndWrite_DoesntOwn() 153 Task<Socket> acceptTask = listener.AcceptAsync(); in Ctor_SocketBool_CanReadAndWrite() 207 Task<Socket> acceptTask = listener.AcceptAsync(); in Ctor_SocketFileAccess_CanReadAndWrite() 248 Task<Socket> acceptTask = listener.AcceptAsync(); in SocketProperty_SameAsProvidedSocket() 311 Task<Socket> acceptTask = listener.AcceptAsync(); in DisposeSocketDirectly_ReadWriteThrowIOException() 425 Task<Socket> acceptTask = listener.AcceptAsync(); in ReadableWriteableProperties_Roundtrip()
|
H A D | UnixDomainSocketTest.netcoreapp.cs | 171 using (Socket accepted = await server.AcceptAsync()) in Socket_SendReceiveAsync_Success() 217 Task<Socket> serverAccept = server.AcceptAsync(); in Socket_SendReceiveAsync_PropagateToStream_Success() 273 Task<Socket> acceptTask = server.AcceptAsync(); in ConcurrentSendReceive() 317 Task<Socket> acceptTask = server.AcceptAsync(); in ConcurrentSendReceiveAsync()
|
H A D | ArgumentValidationTests.cs | 510 Assert.Throws<ArgumentNullException>(() => GetSocket().AcceptAsync(null)); in AcceptAsync_NullAsyncEventArgs_Throws_ArgumentNull() 526 Assert.Throws<InvalidOperationException>(() => GetSocket().AcceptAsync(s_eventArgs)); in AcceptAsync_NotBound_Throws_InvalidOperation() 535 Assert.Throws<InvalidOperationException>(() => socket.AcceptAsync(s_eventArgs)); in AcceptAsync_NotListening_Throws_InvalidOperation() 728 Task accept = host.AcceptAsync(); in Socket_Connect_DnsEndPointWithIPAddressString_Supported() 757 Task accept = host.AcceptAsync(); in Socket_Connect_IPv4AddressAsStringHost_Supported() 775 Task accept = host.AcceptAsync(); in Socket_Connect_IPv6AddressAsStringHost_Supported() 819 host.AcceptAsync(), in Socket_ConnectAsync_DnsEndPointWithIPAddressString_Supported() 847 host.AcceptAsync(), in Socket_ConnectAsync_IPv4AddressAsStringHost_Supported() 864 host.AcceptAsync(), in Socket_ConnectAsync_IPv6AddressAsStringHost_Supported() 949 Assert.Throws<InvalidOperationException>(() => { GetSocket().AcceptAsync(); }); in BeginAccept_NotBound_Throws_InvalidOperation() [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/netcore/Thrift/Transports/ |
H A D | TServerTransport.cs | 37 public async Task<TClientTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transports.TServerTransport 39 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 42 public async Task<TClientTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transports.TServerTransport
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/netcore/Thrift/Transports/ |
H A D | TServerTransport.cs | 37 public async Task<TClientTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transports.TServerTransport 39 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 42 public async Task<TClientTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transports.TServerTransport
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/netcore/Thrift/Transports/ |
H A D | TServerTransport.cs | 37 public async Task<TClientTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transports.TServerTransport 39 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 42 public async Task<TClientTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transports.TServerTransport
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/netstd/Thrift/Transport/ |
H A D | TServerTransport.cs | 37 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 39 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 42 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/devel/py-thrift/thrift-0.14.0/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/devel/thrift-c_glib/thrift-0.14.0/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/devel/thrift-cpp/thrift-0.14.0/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/devel/thrift/thrift-0.14.0/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/devel/node-thrift/thrift-0.14.0/lib/netstd/Thrift/Transport/Server/ |
H A D | TServerTransport.cs | 46 public async ValueTask<TTransport> AcceptAsync() in AcceptAsync() method in Thrift.Transport.TServerTransport 48 return await AcceptAsync(CancellationToken.None); in AcceptAsync() 51 public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken) in AcceptAsync() method in Thrift.Transport.TServerTransport
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/src/System/Net/Sockets/ |
H A D | SocketTaskExtensions.cs | 13 public static Task<Socket> AcceptAsync(this Socket socket) => in AcceptAsync() method in System.Net.Sockets.SocketTaskExtensions 14 socket.AcceptAsync((Socket)null); in AcceptAsync() 15 public static Task<Socket> AcceptAsync(this Socket socket, Socket acceptSocket) => in AcceptAsync() method in System.Net.Sockets.SocketTaskExtensions 16 socket.AcceptAsync(acceptSocket); in AcceptAsync()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Http/tests/FunctionalTests/ |
H A D | ManagedHandlerTest.cs | 148 using (Socket server = await listener.AcceptAsync()) in SendBytesBackAndForthBetweenClientAndServer_Success() 283 using (Socket server = await listener.AcceptAsync()) in MultipleIterativeRequests_SameConnectionReused() 291 Task<Socket> secondAccept = listener.AcceptAsync(); // shouldn't complete in MultipleIterativeRequests_SameConnectionReused() 325 using (Socket server = await listener.AcceptAsync()) in ServerDisconnectsAfterInitialRequest_SubsequentRequestUsesDifferentConnection() 363 using (Socket server1 = await listener.AcceptAsync()) in ServerSendsConnectionClose_SubsequentRequestUsesDifferentConnection() 372 using (Socket server2 = await listener.AcceptAsync()) in ServerSendsConnectionClose_SubsequentRequestUsesDifferentConnection()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-openssl-0.3.0/src/ |
H A D | lib.rs | 57 pub struct AcceptAsync<S>(AcceptAsyncInner<S>); struct 118 fn accept_async<S>(&self, stream: S) -> AcceptAsync<S> in accept_async() 204 fn accept_async<S>(&self, stream: S) -> AcceptAsync<S> in accept_async() 207 AcceptAsync(AcceptAsyncInner::Start { in accept_async() 244 impl<S: Read + Write> Future for AcceptAsync<S> { implementation
|
/dports/sysutils/vector/vector-0.10.0/src/tls/ |
H A D | incoming.rs | 17 use tokio_openssl::{AcceptAsync, SslAcceptorExt}; 119 Accepting(AcceptAsync<S>), 159 fn poll_handshake<S: Read + Write>(acceptor: &mut AcceptAsync<S>) -> io::Result<StreamState<S>> { in poll_handshake()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.IO.Pipes/src/System/IO/Pipes/ |
H A D | NamedPipeServerStream.Unix.cs | 63 Socket accepted = _instance.ListeningSocket.AcceptAsync().GetAwaiter().GetResult(); in WaitForConnection() 80 … HandleAcceptedSocket(await _instance.ListeningSocket.AcceptAsync().ConfigureAwait(false)); in WaitForConnectionAsync()
|
/dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Messaging/Rcon/ |
H A D | Server.cs | 105 if (!_listener.AcceptAsync(acceptArgs)) in Start() 172 serverSock.AcceptAsync(e); in ProcessAccept()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net.Sockets/ |
H A D | SocketAcceptAsyncTest.cs | 48 if (listenSocket.AcceptAsync(asyncEventArgs)) in AcceptAsyncShouldUseAcceptSocketFromEventArgs()
|