83 instantiations of Socket
ClientSample (1)
Tcp\TcpConnection.cs (1)
29_socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
dotnet-svcutil-lib (2)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CoreClrSocketConnection.cs (2)
927socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp); 944socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
IIS.Common.TestLib (1)
TestConnections.cs (1)
245var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
IIS.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\AspNetCorePortTests.cs (1)
161using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.LongTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.NewHandler.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.NewShim.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IISExpress.FunctionalTests (2)
src\Servers\IIS\IIS\test\Common.FunctionalTests\AspNetCorePortTests.cs (1)
161using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
InMemory.FunctionalTests (3)
src\Servers\Kestrel\shared\test\CertHelper.cs (2)
48using (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 53var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TestConnection.cs (1)
65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (8)
Listener\RequestHeaderTests.cs (1)
224Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Listener\RequestTests.cs (1)
189using (var socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
RequestHeaderTests.cs (2)
73using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 273using (Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
RequestTests.cs (3)
511using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 558using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 607using (var socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
ResponseTests.cs (1)
266using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.IntegrationTesting (3)
Common\TestPortHelper.cs (2)
24using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 37using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
Deployers\NginxDeployer.cs (1)
45_portSelector = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (3)
src\Servers\Kestrel\shared\test\CertHelper.cs (2)
48using (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 53var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TestConnection.cs (1)
65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (1)
QuicConnectionListenerTests.cs (1)
289using var socket = new Socket(endpoint.AddressFamily, SocketType.Dgram, ProtocolType.Udp);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (5)
Client\SocketConnectionFactory.cs (1)
56var socket = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)
SocketTransportOptions.cs (4)
135listenSocket = new Socket( 140listenSocket = new Socket(unix.AddressFamily, SocketType.Stream, ProtocolType.Unspecified); 143listenSocket = new Socket(ip.AddressFamily, SocketType.Stream, ProtocolType.Tcp); 153listenSocket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.StaticFiles.FunctionalTests (1)
StaticFileMiddlewareTests.cs (1)
302var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Microsoft.Extensions.Hosting.Systemd (1)
SystemdNotifier.cs (1)
44using (var socket = new Socket(AddressFamily.Unix, SocketType.Dgram, ProtocolType.Unspecified))
Sockets.BindTests (10)
SocketTransportOptionsTests.cs (1)
106var fileHandleSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TestConnection.cs (1)
65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TransportTestHelpers\IPv6SupportedConditionAttribute.cs (1)
24using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\BindTests\AddressRegistrationTests.cs (7)
538using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 573using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp)) 940using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp)) 948using (var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp)) 1195using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 1211using (var serverSocket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)) 1250using (var socket = new Socket(address.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
Sockets.FunctionalTests (10)
src\Servers\Kestrel\shared\test\TestConnection.cs (1)
65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TransportTestHelpers\IPv6SupportedConditionAttribute.cs (1)
24using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\FunctionalTests\ListenHandleTests.cs (1)
29new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\test\FunctionalTests\MaxRequestBufferSizeTests.cs (1)
374var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (4)
114using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 566using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 609using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 697using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (2)
97using (var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified)) 165using (var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified))
System.IO.Pipes (3)
Microsoft\Win32\SafeHandles\SafePipeHandle.Unix.cs (1)
84socket = SetPipeSocketInterlocked(new Socket(new SafeSocketHandle(handle, ownsHandle)), ownsHandle);
System\IO\Pipes\NamedPipeClientStream.Unix.cs (1)
38var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
System\IO\Pipes\NamedPipeServerStream.Unix.cs (1)
326var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
664Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp) { NoDelay = true };
System.Net.HttpListener (1)
System\Net\Managed\HttpEndPointListener.cs (1)
63_socket = new Socket(addr.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
System.Net.NetworkInformation (1)
System\Net\NetworkInformation\NetworkAddressChange.Unix.cs (1)
167Socket = new Socket(sh);
System.Net.Ping (2)
src\libraries\Common\src\System\Net\RawSocketPermissions.cs (1)
25new Socket(addressFamily, SocketType.Raw, addressFamily == AddressFamily.InterNetwork ? ProtocolType.Icmp : ProtocolType.IcmpV6).Dispose();
System\Net\NetworkInformation\Ping.RawSocket.cs (1)
69Socket socket = new Socket(addrFamily, socketType, socketConfig.ProtocolType);
System.Net.Requests (4)
System\Net\FtpControlStream.cs (1)
1139Socket socket = new Socket(templateSocket.AddressFamily, templateSocket.SocketType, templateSocket.ProtocolType);
System\Net\FtpWebRequest.cs (2)
955var client = new Socket(SocketType.Stream, ProtocolType.Tcp); 972var client = new Socket(SocketType.Stream, ProtocolType.Tcp);
System\Net\HttpWebRequest.cs (1)
1758var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
System.Net.Sockets (14)
System\Net\Sockets\Socket.cs (3)
2843Socket? attemptSocket = dnsEP.AddressFamily != AddressFamily.Unspecified ? new Socket(dnsEP.AddressFamily, socketType, protocolType) : null; 2858Socket attemptSocket = new Socket(endPointSnapshot.AddressFamily, socketType, protocolType); 3607Socket socket = new Socket(fd, loadPropertiesFromHandle: false);
System\Net\Sockets\SocketAsyncEventArgs.cs (2)
707attemptSocket = tempSocketIPv6 ??= (Socket.OSSupportsIPv6 ? new Socket(AddressFamily.InterNetworkV6, socketType, protocolType) : null); 716attemptSocket = tempSocketIPv4 ??= (Socket.OSSupportsIPv4 ? new Socket(AddressFamily.InterNetwork, socketType, protocolType) : null);
System\Net\Sockets\TCPClient.cs (2)
342_clientSocket = new Socket(SocketType.Stream, ProtocolType.Tcp); 350_clientSocket = new Socket(_family, SocketType.Stream, ProtocolType.Tcp);
System\Net\Sockets\TCPListener.cs (4)
29_serverSocket = new Socket(_serverSocketEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp); 45_serverSocket = new Socket(_serverSocketEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp); 58_serverSocket = new Socket(_serverSocketEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp); 272_serverSocket ??= new Socket(_serverSocketEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
System\Net\Sockets\UDPClient.cs (3)
655_clientSocket = new Socket(_family, SocketType.Dgram, ProtocolType.Udp); 704ipv4Socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 708ipv6Socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp);
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketConnection.cs (1)
816socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketConnection.cs (1)
778socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.IP);
411 references to Socket
ClientSample (5)
Tcp\SocketReceiver.cs (2)
14private readonly Socket _socket; 18public SocketReceiver(Socket socket, PipeScheduler scheduler)
Tcp\SocketSender.cs (2)
17private readonly Socket _socket; 23public SocketSender(Socket socket, PipeScheduler scheduler)
Tcp\TcpConnection.cs (1)
20private readonly Socket _socket;
dotnet-svcutil-lib (4)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CoreClrSocketConnection.cs (4)
22private Socket _socket; 40public CoreClrSocketConnection(Socket socket, ConnectionBufferPool connectionBufferPool) 923Socket socket = null; 940Socket socket = null;
IIS.Common.TestLib (6)
TestConnections.cs (6)
26private readonly Socket _socket; 39public TestConnection(Socket socket) 44private TestConnection(Socket socket, bool ownsSocket) 51public Socket Socket => _socket; 238public static Socket CreateConnectedLoopbackSocket(int port, AddressFamily addressFamily) 245var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
IIS.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\AspNetCorePortTests.cs (1)
161using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.LongTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.NewHandler.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IIS.NewShim.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
IISExpress.FunctionalTests (2)
src\Servers\IIS\IIS\test\Common.FunctionalTests\AspNetCorePortTests.cs (1)
161using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
src\Servers\IIS\IIS\test\Common.LongTests\StartupTests.cs (1)
1442using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
InMemory.FunctionalTests (10)
src\Servers\Kestrel\shared\test\CertHelper.cs (3)
48using (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 53var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 55Socket serverSocket = listener.Accept();
src\Servers\Kestrel\shared\test\TestConnection.cs (7)
15private readonly Socket _socket; 27public TestConnection(Socket socket) 32private TestConnection(Socket socket, bool ownsSocket) 38public Socket Socket => _socket; 56public static Socket CreateConnectedLoopbackSocket(int port) => CreateConnectedLoopbackSocket(port, AddressFamily.InterNetwork); 58public static Socket CreateConnectedLoopbackSocket(int port, AddressFamily addressFamily) 65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Connections.Abstractions (1)
Features\IConnectionSocketFeature.cs (1)
16Socket Socket { get; }
Microsoft.AspNetCore.InternalTesting (5)
HttpClientSlim.cs (5)
156var socket = await GetSocket(requestUri).ConfigureAwait(false); 175public static async Task<Socket> GetSocket(Uri requestUri) 177var tcs = new TaskCompletionSource<Socket>(); 184if (Socket.ConnectAsync(SocketType.Stream, ProtocolType.Tcp, socketArgs)) 189var socket = socketArgs.ConnectSocket;
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (8)
Listener\RequestHeaderTests.cs (1)
224Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Listener\RequestTests.cs (1)
189using (var socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
RequestHeaderTests.cs (2)
73using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 273using (Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
RequestTests.cs (3)
511using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 558using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 607using (var socket = new Socket(SocketType.Stream, ProtocolType.Tcp))
ResponseTests.cs (1)
266using var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.IntegrationTesting (3)
Common\TestPortHelper.cs (2)
24using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 37using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
Deployers\NginxDeployer.cs (1)
21private Socket _portSelector;
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (10)
src\Servers\Kestrel\shared\test\CertHelper.cs (3)
48using (Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 53var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 55Socket serverSocket = listener.Accept();
src\Servers\Kestrel\shared\test\TestConnection.cs (7)
15private readonly Socket _socket; 27public TestConnection(Socket socket) 32private TestConnection(Socket socket, bool ownsSocket) 38public Socket Socket => _socket; 56public static Socket CreateConnectedLoopbackSocket(int port) => CreateConnectedLoopbackSocket(port, AddressFamily.InterNetwork); 58public static Socket CreateConnectedLoopbackSocket(int port, AddressFamily addressFamily) 65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (2)
QuicConnectionListenerTests.cs (2)
133var serverStream = await serverStreamTask.DefaultTimeout(); 289using var socket = new Socket(endpoint.AddressFamily, SocketType.Dgram, ProtocolType.Udp);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (22)
Client\SocketConnectionFactory.cs (1)
56var socket = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)
Internal\SocketConnection.cs (2)
17private readonly Socket _socket; 34internal SocketConnection(Socket socket,
Internal\SocketConnection.FeatureCollection.cs (1)
11public Socket Socket => _socket;
Internal\SocketReceiver.cs (2)
15public ValueTask<SocketOperationResult> WaitForDataAsync(Socket socket) 32public ValueTask<SocketOperationResult> ReceiveAsync(Socket socket, Memory<byte> buffer)
Internal\SocketSender.cs (2)
20public ValueTask<SocketOperationResult> SendAsync(Socket socket, in ReadOnlySequence<byte> buffers) 59private ValueTask<SocketOperationResult> SendAsync(Socket socket, ReadOnlyMemory<byte> memory)
SocketConnectionContextFactory.cs (1)
88public ConnectionContext Create(Socket socket)
SocketConnectionListener.cs (3)
17private Socket? _listenSocket; 41Socket listenSocket; 67var acceptSocket = await _listenSocket.AcceptAsync(cancellationToken);
SocketTransportOptions.cs (10)
99/// A function used to create a new <see cref="Socket"/> to listen with. If 103/// Implementors are expected to call <see cref="Socket.Bind"/> on the 104/// <see cref="Socket"/>. Please note that <see cref="CreateDefaultBoundListenSocket"/> 105/// calls <see cref="Socket.Bind"/> as part of its implementation, so implementors 111public Func<EndPoint, Socket> CreateBoundListenSocket { get; set; } = CreateDefaultBoundListenSocket; 114/// Creates a default instance of <see cref="Socket"/> for the given <see cref="EndPoint"/> 115/// that can be used by a connection listener to listen for inbound requests. <see cref="Socket.Bind"/> 122/// A <see cref="Socket"/> instance. 124public static Socket CreateDefaultBoundListenSocket(EndPoint endpoint) 126Socket listenSocket;
Microsoft.AspNetCore.StaticFiles.FunctionalTests (3)
StaticFileMiddlewareTests.cs (3)
282var socket = SendSocketRequestAsync(Helpers.GetAddress(host), "/TestDocument1MB.txt"); 293private Socket SendSocketRequestAsync(string address, string path, string method = "GET") 302var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
Microsoft.Extensions.Hosting.Systemd (1)
SystemdNotifier.cs (1)
44using (var socket = new Socket(AddressFamily.Unix, SocketType.Dgram, ProtocolType.Unspecified))
netstandard (1)
netstandard.cs (1)
1268[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]
Sockets.BindTests (27)
SocketTransportOptionsTests.cs (7)
28Socket CreateListenSocket(EndPoint endpoint) 57using var fileHandleSocket = CreateBoundSocket(); 67using var listenSocket = SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint); 74using var fileHandleSocket = CreateBoundSocket(); 77using var listenSocket = SocketTransportOptions.CreateDefaultBoundListenSocket(endpoint); 101private static Socket CreateBoundSocket() 106var fileHandleSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TestConnection.cs (7)
15private readonly Socket _socket; 27public TestConnection(Socket socket) 32private TestConnection(Socket socket, bool ownsSocket) 38public Socket Socket => _socket; 56public static Socket CreateConnectedLoopbackSocket(int port) => CreateConnectedLoopbackSocket(port, AddressFamily.InterNetwork); 58public static Socket CreateConnectedLoopbackSocket(int port, AddressFamily addressFamily) 65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (4)
62public static async Task<Socket> ConnectToHost(string hostName, int port) 64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously); 71if (Socket.ConnectAsync(SocketType.Stream, ProtocolType.Tcp, socketArgs)) 76var socket = socketArgs.ConnectSocket;
src\Servers\Kestrel\shared\test\TransportTestHelpers\IPv6SupportedConditionAttribute.cs (1)
24using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\BindTests\AddressRegistrationTests.cs (8)
538using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 573using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp)) 940using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp)) 948using (var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp)) 1195using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 1211using (var serverSocket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)) 1229if (Socket.ConnectAsync(SocketType.Stream, ProtocolType.Tcp, socketArgs)) 1250using (var socket = new Socket(address.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
Sockets.FunctionalTests (24)
SocketTransportTests.cs (1)
37var socket = context.Features.Get<IConnectionSocketFeature>().Socket;
src\Servers\Kestrel\shared\test\TestConnection.cs (7)
15private readonly Socket _socket; 27public TestConnection(Socket socket) 32private TestConnection(Socket socket, bool ownsSocket) 38public Socket Socket => _socket; 56public static Socket CreateConnectedLoopbackSocket(int port) => CreateConnectedLoopbackSocket(port, AddressFamily.InterNetwork); 58public static Socket CreateConnectedLoopbackSocket(int port, AddressFamily addressFamily) 65var socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (4)
62public static async Task<Socket> ConnectToHost(string hostName, int port) 64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously); 71if (Socket.ConnectAsync(SocketType.Stream, ProtocolType.Tcp, socketArgs)) 76var socket = socketArgs.ConnectSocket;
src\Servers\Kestrel\shared\test\TransportTestHelpers\IPv6SupportedConditionAttribute.cs (1)
24using (var socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\FunctionalTests\ListenHandleTests.cs (1)
28private static readonly Socket _canListenToOpenTcpSocketHandleSocket =
src\Servers\Kestrel\test\FunctionalTests\MaxRequestBufferSizeTests.cs (4)
138using (var socket = CreateSocket(port)) 231using (var socket = CreateSocket(port)) 372private static Socket CreateSocket(int port) 374var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (4)
114using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 566using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 609using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 697using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (2)
97using (var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified)) 165using (var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified))
System (1)
src\libraries\shims\System\ref\System.cs (1)
758[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]
System.IO.Pipes (16)
Microsoft\Win32\SafeHandles\SafePipeHandle.Unix.cs (9)
25private Socket? _pipeSocket; 29internal SafePipeHandle(Socket namedPipeSocket) : base(ownsHandle: true) 35internal Socket PipeSocket => _pipeSocket ?? CreatePipeSocket(); 43if (disposing && Volatile.Read(ref _pipeSocket) is Socket socket) 74private Socket CreatePipeSocket(bool ownsHandle = true) 76Socket? socket = null; 108private Socket SetPipeSocketInterlocked(Socket socket, bool ownsHandle) 113Socket? current = Interlocked.CompareExchange(ref _pipeSocket, socket, null);
System\IO\Pipes\NamedPipeClientStream.Unix.cs (1)
38var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
System\IO\Pipes\NamedPipeServerStream.Unix.cs (5)
64Socket accepted = _instance!.ListeningSocket.AcceptAsync().GetAwaiter().GetResult(); 82Socket acceptedSocket; 101private void HandleAcceptedSocket(Socket acceptedSocket) 244internal Socket ListeningSocket { get; } 326var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);
System\IO\Pipes\PipeStream.Unix.cs (1)
489Socket s, SafePipeHandle _,
System.Net (1)
System.Net.cs (1)
39[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (2)
664Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp) { NoDelay = true }; 673using (cancellationToken.UnsafeRegister(static s => ((Socket)s!).Dispose(), socket))
System.Net.HttpListener (5)
System\Net\Managed\HttpConnection.cs (3)
48private Socket? _socket; 73public HttpConnection(Socket sock, HttpEndPointListener epl, bool secure, X509Certificate cert) 523Socket s = _socket;
System\Net\Managed\HttpEndPointListener.cs (2)
44private readonly Socket _socket; 110Socket? accepted = args.SocketError == SocketError.Success ? args.AcceptSocket : null;
System.Net.Mail (1)
src\libraries\Common\src\System\Net\TlsStream.cs (1)
19public TlsStream(NetworkStream stream, Socket socket, string host, X509CertificateCollection? clientCertificates) : base(socket)
System.Net.NetworkInformation (10)
System\Net\NetworkInformation\LinuxIPGlobalProperties.cs (6)
11return StringParsingHelpers.ParseActiveTcpConnectionsFromFiles(Socket.OSSupportsIPv4 ? NetworkFiles.Tcp4ConnectionsFile : null, 12Socket.OSSupportsIPv6 ? NetworkFiles.Tcp6ConnectionsFile : null); 17return StringParsingHelpers.ParseActiveTcpListenersFromFiles(Socket.OSSupportsIPv4 ? NetworkFiles.Tcp4ConnectionsFile : null, 18Socket.OSSupportsIPv6 ? NetworkFiles.Tcp6ConnectionsFile : null); 23return StringParsingHelpers.ParseActiveUdpListenersFromFiles(Socket.OSSupportsIPv4 ? NetworkFiles.Udp4ConnectionsFile : null, 24Socket.OSSupportsIPv6 ? NetworkFiles.Udp6ConnectionsFile : null);
System\Net\NetworkInformation\NetworkAddressChange.Unix.cs (4)
18private static Socket? s_socket; 20private static Socket? Socket 183private static async Task ReadEventsAsync(Socket socket) 217static unsafe Interop.Error ReadEvents(Socket socket)
System.Net.Ping (5)
System\Net\NetworkInformation\Ping.RawSocket.cs (5)
61private static Socket GetRawSocket(SocketConfig socketConfig) 69Socket socket = new Socket(addrFamily, socketType, socketConfig.ProtocolType); 253using (Socket socket = GetRawSocket(socketConfig)) 300private static PingReply CreatePingReplyForUnreachableHost(IPAddress address, Socket socket) 325using Socket socket = GetRawSocket(socketConfig);
System.Net.Quic (1)
System\Net\Quic\Internal\MsQuicApi.cs (1)
80if (!Socket.OSSupportsIPv6)
System.Net.Requests (14)
src\libraries\Common\src\System\Net\TlsStream.cs (1)
19public TlsStream(NetworkStream stream, Socket socket, string host, X509CertificateCollection? clientCertificates) : base(socket)
System\Net\FtpControlStream.cs (7)
29private Socket? _dataSocket; 86Socket? socket = _dataSocket; 105Socket listenSocket = connection._dataSocket!; 712Socket listenSocket = _dataSocket!; 1136private static Socket CreateFtpDataSocket(Socket templateSocket) 1139Socket socket = new Socket(templateSocket.AddressFamily, templateSocket.SocketType, templateSocket.ProtocolType);
System\Net\FtpWebRequest.cs (2)
955var client = new Socket(SocketType.Stream, ProtocolType.Tcp); 972var client = new Socket(SocketType.Stream, ProtocolType.Tcp);
System\Net\HttpWebRequest.cs (3)
1758var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 1781static void BindHelper(ServicePoint servicePoint, ref IPAddress[] addresses, Socket socket, int port) 1828using (cancellationToken.UnsafeRegister(s => ((Socket)s!).Dispose(), socket))
System\Net\NetworkStreamWrapper.cs (1)
36internal Socket Socket
System.Net.Sockets (206)
System\Net\Sockets\NetEventSource.Sockets.cs (4)
19public static void Accepted(Socket socket, object? remoteEp, object? localEp) => 27public static void Connected(Socket socket, object? localEp, object? remoteEp) => 35public static void ConnectedAsyncDns(Socket socket) => 43public static void NotLoggedFile(string filePath, Socket socket, SocketAsyncOperation completedOperation) =>
System\Net\Sockets\NetworkStream.cs (7)
15private readonly Socket _streamSocket; 30public NetworkStream(Socket socket) 35public NetworkStream(Socket socket, bool ownsSocket) 40public NetworkStream(Socket socket, FileAccess access) 45public NetworkStream(Socket socket, FileAccess access, bool ownsSocket) 85public Socket Socket => _streamSocket; 331private int _closeTimeout = Socket.DefaultCloseTimeout; // -1 = respect linger options
System\Net\Sockets\Socket.cs (63)
69private int _closeTimeout = Socket.DefaultCloseTimeout; 103/// <summary>Initializes a new instance of the <see cref="Socket"/> class for the specified socket handle.</summary> 104/// <param name="handle">The socket handle for the socket that the <see cref="Socket"/> object will encapsulate.</param> 109/// This method populates the <see cref="Socket"/> instance with data gathered from the supplied <see cref="SafeSocketHandle"/>. 111/// properties and configuration, which means some of the public APIs on the resulting <see cref="Socket"/> instance may 112/// differ based on operating system, such as <see cref="Socket.ProtocolType"/> and <see cref="Socket.Blocking"/>. 960/// Places a <see cref="Socket"/> in a listening state. 968/// Places a <see cref="Socket"/> in a listening state. 988public Socket Accept() 1049Socket socket = CreateAcceptSocket(acceptedSocketHandle, _rightEndPoint.Create(socketAddress)); 1211/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 1226/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1227/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 1228/// <exception cref="InvalidOperationException">The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</exception> 1237/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 1252/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1253/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 1254/// <exception cref="InvalidOperationException">The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</exception> 1333/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1348/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1389/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1631/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1634/// <see cref="Socket.ReceiveMessageFrom(Span{byte}, ref SocketFlags, ref EndPoint, out IPPacketInformation)"/> 1637/// <para>The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</para> 1801/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1816/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1897/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2043/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2046/// In general, the SetSocketOption method should be used whenever setting a <see cref="Socket"/> option. 2163/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2166/// In general, the GetSocketOption method should be used whenever getting a <see cref="Socket"/> option. 2209/// <summary>Determines the status of the <see cref="Socket"/>.</summary> 2213/// The status of the <see cref="Socket"/> based on the polling mode value passed in the <paramref name="mode"/> parameter. 2223/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2241/// <summary>Determines the status of the <see cref="Socket"/>.</summary> 2245/// The status of the <see cref="Socket"/> based on the polling mode value passed in the <paramref name="mode"/> parameter. 2256/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2261/// <param name="checkRead">An <see cref="IList"/> of <see cref="Socket"/> instances to check for readability.</param> 2262/// <param name="checkWrite">An <see cref="IList"/> of <see cref="Socket"/> instances to check for writability.</param> 2263/// <param name="checkError">An <see cref="IList"/> of <see cref="Socket"/> instances to check for errors.</param> 2301/// <param name="checkRead">An <see cref="IList"/> of <see cref="Socket"/> instances to check for readability.</param> 2302/// <param name="checkWrite">An <see cref="IList"/> of <see cref="Socket"/> instances to check for writability.</param> 2303/// <param name="checkError">An <see cref="IList"/> of <see cref="Socket"/> instances to check for errors.</param> 2592public Socket EndAccept(IAsyncResult asyncResult) => TaskToAsyncResult.End<Socket>(asyncResult); 2597private async Task<(Socket s, byte[] buffer, int bytesReceived)> AcceptAndReceiveHelperAsync(Socket? acceptSocket, int receiveSize) 2601Socket s = await AcceptAsync(acceptSocket).ConfigureAwait(false); 2630public IAsyncResult BeginAccept(Socket? acceptSocket, int receiveSize, AsyncCallback? callback, object? state) => 2633public Socket EndAccept(out byte[] buffer, IAsyncResult asyncResult) 2635Socket socket = EndAccept(out byte[] innerBuffer, out int bytesTransferred, asyncResult); 2641public Socket EndAccept(out byte[] buffer, out int bytesTransferred, IAsyncResult asyncResult) 2643Socket s; 2644(s, buffer, bytesTransferred) = TaskToAsyncResult.End<(Socket, byte[], int)>(asyncResult); 2843Socket? attemptSocket = dnsEP.AddressFamily != AddressFamily.Unspecified ? new Socket(dnsEP.AddressFamily, socketType, protocolType) : null; 2858Socket attemptSocket = new Socket(endPointSnapshot.AddressFamily, socketType, protocolType); 3603internal Socket CreateAcceptSocket(SafeSocketHandle fd, EndPoint remoteEP) 3607Socket socket = new Socket(fd, loadPropertiesFromHandle: false); 3611internal Socket UpdateAcceptSocket(Socket socket, EndPoint remoteEP) 3875Socket socket = (Socket)socketList[i]!;
System\Net\Sockets\Socket.Tasks.cs (40)
32public Task<Socket> AcceptAsync() => AcceptAsync((Socket?)null, CancellationToken.None).AsTask(); 39public ValueTask<Socket> AcceptAsync(CancellationToken cancellationToken) => AcceptAsync((Socket?)null, cancellationToken); 46public Task<Socket> AcceptAsync(Socket? acceptSocket) => AcceptAsync(acceptSocket, CancellationToken.None).AsTask(); 54public ValueTask<Socket> AcceptAsync(Socket? acceptSocket, CancellationToken cancellationToken) 58return ValueTask.FromCanceled<Socket>(cancellationToken); 352saea.Completed += (s, e) => CompleteSendReceive((Socket)s!, (TaskSocketAsyncEventArgs<int>)e, isReceive: true); 616saea.Completed += (s, e) => CompleteSendReceive((Socket)s!, (TaskSocketAsyncEventArgs<int>)e, isReceive: false); 725/// Sends the file <paramref name="fileName"/> to a connected <see cref="Socket"/> object. 729/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 730/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 739/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 747/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 748/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 894private static void CompleteSendReceive(Socket s, TaskSocketAsyncEventArgs<int> saea, bool isReceive) 999internal sealed class AwaitableSocketAsyncEventArgs : SocketAsyncEventArgs, IValueTaskSource, IValueTaskSource<int>, IValueTaskSource<Socket>, IValueTaskSource<SocketReceiveFromResult>, IValueTaskSource<SocketReceiveMessageFromResult> 1002private readonly Socket _owner; 1011public AwaitableSocketAsyncEventArgs(Socket owner, bool isReceiveForCaching) : 1043public ValueTask<Socket> AcceptAsync(Socket socket, CancellationToken cancellationToken) 1048return new ValueTask<Socket>(this, _mrvtsc.Version); 1051Socket acceptSocket = AcceptSocket!; 1059new ValueTask<Socket>(acceptSocket) : 1060ValueTask.FromException<Socket>(CreateException(error)); 1065public ValueTask<int> ReceiveAsync(Socket socket, CancellationToken cancellationToken) 1083public ValueTask<SocketReceiveFromResult> ReceiveFromAsync(Socket socket, CancellationToken cancellationToken) 1102internal ValueTask<int> ReceiveFromSocketAddressAsync(Socket socket, CancellationToken cancellationToken) 1120public ValueTask<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(Socket socket, CancellationToken cancellationToken) 1143public ValueTask<int> SendAsync(Socket socket, CancellationToken cancellationToken) 1161public ValueTask SendAsyncForNetworkStream(Socket socket, CancellationToken cancellationToken) 1178public ValueTask SendPacketsAsync(Socket socket, CancellationToken cancellationToken) 1195public ValueTask<int> SendToAsync(Socket socket, CancellationToken cancellationToken) 1213public ValueTask ConnectAsync(Socket socket) 1237public ValueTask DisconnectAsync(Socket socket, CancellationToken cancellationToken) 1306Socket IValueTaskSource<Socket>.GetResult(short token) 1314Socket acceptSocket = AcceptSocket!;
System\Net\Sockets\Socket.Unix.cs (5)
180private Socket? GetOrCreateAcceptSocket(Socket? acceptSocket, bool checkDisconnected, string propertyName, out SafeSocketHandle? handle) 260internal Socket CopyStateFromSource(Socket source) 284foreach (PropertyInfo pi in typeof(Socket).GetProperties(BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance | BindingFlags.DeclaredOnly))
System\Net\Sockets\SocketAsyncContext.Unix.cs (1)
1280[DynamicDependency("set_PreferInlineCompletions", typeof(Socket))]
System\Net\Sockets\SocketAsyncEventArgs.cs (13)
16private Socket? _acceptSocket; 17private Socket? _connectSocket; 74private Socket? _currentSocket; 102public Socket? AcceptSocket 108public Socket? ConnectSocket 515internal void StartOperationCommon(Socket? socket, SocketAsyncOperation operation) 546_acceptAddressBufferCount = 2 * (Socket.GetAddressSize(_currentSocket!._rightEndPoint!) + 16); 604Socket? currentSocket = _currentSocket; 680Socket? tempSocketIPv4 = null, tempSocketIPv6 = null; 689Socket? attemptSocket = null; 707attemptSocket = tempSocketIPv6 ??= (Socket.OSSupportsIPv6 ? new Socket(AddressFamily.InterNetworkV6, socketType, protocolType) : null); 716attemptSocket = tempSocketIPv4 ??= (Socket.OSSupportsIPv4 ? new Socket(AddressFamily.InterNetwork, socketType, protocolType) : null); 746using (cancellationToken.UnsafeRegister(s => Socket.CancelConnectAsync((SocketAsyncEventArgs)s!), internalArgs))
System\Net\Sockets\SocketAsyncEventArgs.Unix.cs (7)
47internal unsafe SocketError DoOperationAccept(Socket _ /*socket*/, SafeSocketHandle handle, SafeSocketHandle? acceptHandle, CancellationToken cancellationToken) 75internal unsafe SocketError DoOperationConnectEx(Socket _ /*socket*/, SafeSocketHandle handle) 95internal SocketError DoOperationDisconnect(Socket socket, SafeSocketHandle handle, CancellationToken _ /*cancellationToken*/) 197internal unsafe SocketError DoOperationReceiveMessageFrom(Socket socket, SafeSocketHandle handle, CancellationToken cancellationToken) 204Socket.GetIPProtocolInformation(socket.AddressFamily, _socketAddress!, out isIPv4, out isIPv6); 245internal SocketError DoOperationSendPackets(Socket socket, SafeSocketHandle _1 /*handle*/, CancellationToken cancellationToken) 351Socket acceptedSocket = _currentSocket!.CreateAcceptSocket(
System\Net\Sockets\SocketPal.Unix.cs (20)
33public static void CheckDualModePacketInfoSupport(Socket socket) 1283public static SocketError ReceiveMessageFrom(Socket socket, SafeSocketHandle handle, byte[] buffer, int offset, int count, ref SocketFlags socketFlags, SocketAddress socketAddress, out SocketAddress receiveAddress, out IPPacketInformation ipPacketInformation, out int bytesTransferred) 1288Socket.GetIPProtocolInformation(socket.AddressFamily, socketAddress, out isIPv4, out isIPv6); 1309public static SocketError ReceiveMessageFrom(Socket socket, SafeSocketHandle handle, Span<byte> buffer, ref SocketFlags socketFlags, SocketAddress socketAddress, out SocketAddress receiveAddress, out IPPacketInformation ipPacketInformation, out int bytesTransferred) 1314Socket.GetIPProtocolInformation(socket.AddressFamily, socketAddress, out isIPv4, out isIPv6); 1562public static void SetReceivingDualModeIPv4PacketInformation(Socket socket) 1573public static void SetIPProtectionLevel(Socket socket, SocketOptionLevel optionLevel, int protectionLevel) 1842Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 1843Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 1844Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 1863Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 1864Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 1865Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 1881Socket? socket = socketList[i] as Socket; 1884throw new ArgumentException(SR.Format(SR.net_sockets_select, socket?.GetType().FullName ?? "null", typeof(Socket).FullName), nameof(socketList)); 1918Socket socket = (Socket)socketList[i]!; 1959Socket socket, TransmitFileOptions options, SendPacketsElement[] elements, SafeFileHandle[] fileHandles, CancellationToken cancellationToken, Action<long, SocketError> callback) 2034internal static SocketError Disconnect(Socket socket, SafeSocketHandle handle, bool reuseSocket)
System\Net\Sockets\SocketTaskExtensions.cs (22)
15public static Task<Socket> AcceptAsync(this Socket socket) => 18public static Task<Socket> AcceptAsync(this Socket socket, Socket? acceptSocket) => 22public static Task ConnectAsync(this Socket socket, EndPoint remoteEP) => 25public static ValueTask ConnectAsync(this Socket socket, EndPoint remoteEP, CancellationToken cancellationToken) => 28public static Task ConnectAsync(this Socket socket, IPAddress address, int port) => 31public static ValueTask ConnectAsync(this Socket socket, IPAddress address, int port, CancellationToken cancellationToken) => 34public static Task ConnectAsync(this Socket socket, IPAddress[] addresses, int port) => 37public static ValueTask ConnectAsync(this Socket socket, IPAddress[] addresses, int port, CancellationToken cancellationToken) => 40public static Task ConnectAsync(this Socket socket, string host, int port) => 43public static ValueTask ConnectAsync(this Socket socket, string host, int port, CancellationToken cancellationToken) => 47public static Task<int> ReceiveAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags) => 50public static ValueTask<int> ReceiveAsync(this Socket socket, Memory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) => 53public static Task<int> ReceiveAsync(this Socket socket, IList<ArraySegment<byte>> buffers, SocketFlags socketFlags) => 56public static Task<SocketReceiveFromResult> ReceiveFromAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint) => 59public static Task<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint) => 63public static Task<int> SendAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags) => 66public static ValueTask<int> SendAsync(this Socket socket, ReadOnlyMemory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) => 69public static Task<int> SendAsync(this Socket socket, IList<ArraySegment<byte>> buffers, SocketFlags socketFlags) => 73public static Task<int> SendToAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEP) =>
System\Net\Sockets\TCPClient.cs (4)
18private Socket _clientSocket = null!; // initialized by helper called from ctor 79internal TcpClient(Socket acceptedSocket) 95public Socket Client 270Socket chkClientSocket = Volatile.Read(ref _clientSocket);
System\Net\Sockets\TCPListener.cs (11)
17private Socket? _serverSocket; 62public Socket Server 187public Socket AcceptSocket() 204Socket acceptedSocket = _serverSocket!.Accept(); 211public Socket EndAcceptSocket(IAsyncResult asyncResult) => 212EndAcceptCore<Socket>(asyncResult); 220public Task<Socket> AcceptSocketAsync() => AcceptSocketAsync(CancellationToken.None).AsTask(); 222public ValueTask<Socket> AcceptSocketAsync(CancellationToken cancellationToken) 238static async ValueTask<TcpClient> WaitAndWrap(ValueTask<Socket> task) => 251if (Socket.OSSupportsIPv6) 297throw new ObjectDisposedException(typeof(Socket).FullName);
System\Net\Sockets\UDPClient.cs (8)
18private Socket _clientSocket = null!; // initialized by helper called from ctor 117public Socket Client 233Socket chkClientSocket = _clientSocket; 631/// <exception cref="ObjectDisposedException">The underlying <see cref="Socket"/> has been closed.</exception> 695Socket? ipv6Socket = null; 696Socket? ipv4Socket = null; 702if (Socket.OSSupportsIPv4) 706if (Socket.OSSupportsIPv6)
System\Net\Sockets\UnixDomainSocketEndPoint.cs (1)
59if (!Socket.OSSupportsUnixDomainSockets)
System.ServiceModel.NetTcp (6)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (2)
31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer) 48public ValueTask SendAsync(Socket socket, ReadOnlyMemory<byte> memory)
System\ServiceModel\Channels\SocketConnection.cs (4)
23private Socket _socket; 74public SocketConnection(Socket socket, int bufferSize) 812Socket socket = null; 885if (Socket.OSSupportsIPv6)
System.ServiceModel.UnixDomainSocket (5)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (2)
31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer) 48public ValueTask SendAsync(Socket socket, ReadOnlyMemory<byte> memory)
System\ServiceModel\Channels\SocketConnection.cs (3)
19private Socket _socket; 54public SocketConnection(Socket socket, int bufferSize) 774Socket socket = null;