Home
last modified time | relevance | path

Searched refs:AcceptAsync (Results 1 – 25 of 93) sorted by relevance

1234

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/FunctionalTests/
H A DSocketTestHelper.cs15 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 DAccept.cs22 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 DSocketAsyncEventArgsTest.cs78 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 DSelectAndPollTests.cs171 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 DSendReceive.cs135 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 DNetworkStreamTest.cs52 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 DUnixDomainSocketTest.netcoreapp.cs171 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 DArgumentValidationTests.cs510 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 DTServerTransport.cs37 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 DTServerTransport.cs37 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 DTServerTransport.cs37 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 DTServerTransport.cs37 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 DTServerTransport.cs46 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 DTServerTransport.cs46 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 DTServerTransport.cs46 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 DTServerTransport.cs46 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 DTServerTransport.cs46 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 DTServerTransport.cs46 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 DSocketTaskExtensions.cs13 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 DManagedHandlerTest.cs148 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 Dlib.rs57 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 Dincoming.rs17 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 DNamedPipeServerStream.Unix.cs63 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 DServer.cs105 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 DSocketAcceptAsyncTest.cs48 if (listenSocket.AcceptAsync(asyncEventArgs)) in AcceptAsyncShouldUseAcceptSocketFromEventArgs()

1234