13internal class IpcSocket : Socket

320var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

256var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

223var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

133using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

137var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

709var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

625using var unreachableSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 670using var unreachableSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

856var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

72_listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

26private readonly Socket _listener = new(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

26var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

12private readonly Socket _listener = new(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

166using var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

68using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

61var serverSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

62var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

524var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

269var socket = new Socket(addressFamily, socketType, protocolType)

85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

228: new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

148var socket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Unspecified);

40using var canary = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

18using var listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

63var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

36var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

21private readonly Socket _listener = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 83_socket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Unspecified);

46_listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

82_listener = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Unspecified);

85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

160_listenSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

313var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

357socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

60var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 98var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

42var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 81var client1Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 82var client2Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 83var client3Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 132using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 166var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 201var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 244var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 286var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 366var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 407var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 444var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 493var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 535var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 578var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 622var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

445var sock = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

41using var client = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

128using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

32using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 52using var client = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 74using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 168using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 392using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

51using var socket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

226var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

72var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

605using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

178rawSockets[i] = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1028var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1077var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1204var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1258using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

927socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp); 944socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);

24using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 37using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))

45_portSelector = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

56var socket = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)

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);

467clientSocket = new Socket(SocketType.Stream, ProtocolType.Tcp);

63Socket socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);

48using (var socket = new Socket(AddressFamily.Unix, SocketType.Dgram, ProtocolType.Unspecified))

740using var socket = new Socket(serverEndPoint.AddressFamily, SocketType.Dgram, ProtocolType.Udp); 790using var socket = new Socket(serverEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

22_dnsSocket = new(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 79_tcpSocket = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

316using Socket socket = new Socket(clientAddress.AddressFamily, SocketType.Dgram, ProtocolType.Udp);

143testSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 147testSocket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);

84socket = SetPipeSocketInterlocked(new Socket(new SafeSocketHandle(handle, ownsHandle)), ownsHandle);

51var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

335var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

702Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp) { NoDelay = true };

63_socket = new Socket(addr.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

169Socket = new Socket(sh);

25new Socket(addressFamily, SocketType.Raw, addressFamily == AddressFamily.InterNetwork ? ProtocolType.Icmp : ProtocolType.IcmpV6).Dispose();

69Socket socket = new Socket(addrFamily, socketType, socketConfig.ProtocolType);

1170Socket socket = new Socket(templateSocket.AddressFamily, templateSocket.SocketType, templateSocket.ProtocolType);

958var client = new Socket(SocketType.Stream, ProtocolType.Tcp); 975var client = new Socket(SocketType.Stream, ProtocolType.Tcp);

1791var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);

165_socket = new Socket(socket);

337_socket ??= new Socket(_socketHandle!);

3026Socket? attemptSocket = dnsEP.AddressFamily != AddressFamily.Unspecified ? new Socket(dnsEP.AddressFamily, socketType, protocolType) : null; 3041Socket attemptSocket = new Socket(endPointSnapshot.AddressFamily, socketType, protocolType); 3811Socket socket = new Socket(fd, loadPropertiesFromHandle: false);

773attemptSocket = tempSocketIPv6 ??= (Socket.OSSupportsIPv6 ? new Socket(AddressFamily.InterNetworkV6, socketType, protocolType) : null); 782attemptSocket = tempSocketIPv4 ??= (Socket.OSSupportsIPv4 ? new Socket(AddressFamily.InterNetwork, socketType, protocolType) : null);

374_clientSocket = new Socket(SocketType.Stream, ProtocolType.Tcp); 382_clientSocket = new Socket(_family, SocketType.Stream, ProtocolType.Tcp);

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); 273_serverSocket ??= new Socket(_serverSocketEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

668_clientSocket = new Socket(_family, SocketType.Dgram, ProtocolType.Udp); 719ipv4Socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 723ipv6Socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Dgram, ProtocolType.Udp);

814socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp);

778socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.IP);

161Socket? socket, 170Socket? socket,

320var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

504Socket? socket = null;

256var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

223var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

29ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken); 85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 265public async ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken) 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 301Socket socket, 306public Socket Socket { get; } = socket;

108internal static void Bind(Socket socket, string socketPath)

133using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

137var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 140var serverSocket = await acceptTask.DefaultTimeout();

707private async ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken) 709var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 713var serverSocket = await _listener.AcceptSocketAsync(cancellationToken);

464ConnectAsyncCallback = _ => ValueTask.FromException<Socket>(new SocketException((int)SocketError.ConnectionRefused)) 625using var unreachableSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 670using var unreachableSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

856var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 859var serverSocket = await acceptTask.DefaultTimeout();

65private readonly Socket _listener; 90var serverSocket = await _listener.AcceptAsync(_cts.Token).ConfigureAwait(false);

26private readonly Socket _listener = new(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 66var socket = await _listener.AcceptAsync(_stopping.Token);

15public Func<CancellationToken, ValueTask<Socket>>? ConnectAsyncCallback { get; init; } 19public async ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken) 26var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

12private readonly Socket _listener = new(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 28var socket = await _listener.AcceptAsync(cancellationToken);

166using var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

68using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 83using var connection = await listener.AcceptAsync(timeout.Token);

11internal sealed class AuxiliaryBackchannelConnectedEvent(IServiceProvider serviceProvider, string socketPath, System.Net.Sockets.Socket clientSocket) : IDistributedApplicationEvent 26public System.Net.Sockets.Socket ClientSocket { get; } = clientSocket;

65var clientSocket = await _appHostSocket.Socket.AcceptAsync(stoppingToken).ConfigureAwait(false); 121private async Task HandleClientConnectionAsync(Socket clientSocket, CancellationToken stoppingToken) 123using var ownedClientSocket = clientSocket;

26private Socket? _serverSocket; 61var serverSocket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 74var clientSocket = await serverSocket.AcceptAsync(stoppingToken).ConfigureAwait(false);

62var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

268var loggingSocket = CreateLoggingSocket(_locations.DcpLogSocket); 520internal static Socket CreateLoggingSocket(string socketPath) 524var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 537private async Task StartLoggingSocketAsync(Socket socket) 544var acceptedSocket = await socket.AcceptAsync(_shutdownCts.Token).ConfigureAwait(false); 557private async Task LogSocketOutputAsync(Socket socket, CancellationToken cancellationToken)

243var sockets = new List<Socket>(); 249if (Socket.OSSupportsIPv6) 267private static Socket CreateBoundSocket(AddressFamily addressFamily, SocketType socketType, ProtocolType protocolType, IPEndPoint endPoint) 269var socket = new Socket(addressFamily, socketType, protocolType) 336private static void DisposeSockets(IEnumerable<Socket> sockets) 338foreach (var socket in sockets)

29ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken); 85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 265public async ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken) 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 301Socket socket, 306public Socket Socket { get; } = socket;

108internal static void Bind(Socket socket, string socketPath)

226using var socket = OperatingSystem.IsWindows()

148var socket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Unspecified);

181using var accepted = await listener.AcceptSocketAsync().WaitAsync(TimeSpan.FromSeconds(10));

40using var canary = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

18using var listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

31using var socket = await _listener.AcceptSocketAsync(_lifetime.Token);

63var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

36var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

21private readonly Socket _listener = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 62private readonly Socket? _socket; 63public Socket Socket => _socket ?? throw new InvalidOperationException("This client uses a named pipe.");

19private readonly Socket _listener;

18private readonly Socket? _listener;

29ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken); 85var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 265public async ValueTask<Socket> ConnectAsync(CancellationToken cancellationToken) 267var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 301Socket socket, 306public Socket Socket { get; } = socket;

108internal static void Bind(Socket socket, string socketPath)

11public static async Task RunAsync(Socket listener, int maximumConnections, 23var socket = await listener.AcceptAsync(lifetime.Token).ConfigureAwait(false); 52async Task ServeAsync(Socket socket) 54using var owned = socket;

28private Socket? _listenSocket; 172var clientSocket = await _listenSocket.AcceptAsync(cancellationToken).ConfigureAwait(false);

108internal static void Bind(Socket socket, string socketPath)

313var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

346Socket? socket = null;

60var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 98var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

42var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 81var client1Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 82var client2Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 83var client3Socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 132using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 166var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 201var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 244var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 286var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 366var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 407var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 444var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 493var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 535var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 578var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 622var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

430private Socket? _listenSocket; 445var sock = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 459Socket client;

30using var listener = DcpHost.CreateLoggingSocket(socketPath); 41using var client = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 43using var accepted = await listener.AcceptAsync(timeout.Token).DefaultTimeout();

128using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 136using var peer = await listener.AcceptAsync().DefaultTimeout();

32using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 52using var client = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 54using var accepted = await listener.AcceptAsync(timeout.Token); 74using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 168using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 392using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

51using var socket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

26private Socket? _listener; 123private async Task RunListenerAsync(Socket listener, CancellationToken ct) 134var socket = await listener.AcceptAsync(ct).ConfigureAwait(false); 213private static Socket BindListener(string socketPath) 226var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 242Socket? listener;

108internal static void Bind(Socket socket, string socketPath)

21private Socket? _socket; 72var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 115Socket client; 187private async Task ServeClientAsync(Socket client, CancellationToken cancellationToken)

605using var listener = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 610var socket = await listener.AcceptAsync(ct).ConfigureAwait(false);

174var rawSockets = new Socket[concurrency]; 197foreach (var s in rawSockets) 210static async Task<bool> TryGetInfoAsync(Socket socket) 915private readonly Socket _socket; 919public TestHmp1Producer(Socket socket) 1028var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1059private readonly Socket _socket; 1065private TestHmp1Consumer(Socket socket) 1077var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1204var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified); 1258using var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

22private Socket _socket; 40public CoreClrSocketConnection(Socket socket, ConnectionBufferPool connectionBufferPool) 923Socket socket = null; 940Socket socket = null;

16Socket Socket { get; }

152var socket = await GetSocket(requestUri).ConfigureAwait(false); 171public static async Task<Socket> GetSocket(Uri requestUri) 173var tcs = new TaskCompletionSource<Socket>(); 180if (Socket.ConnectAsync(SocketType.Stream, ProtocolType.Tcp, socketArgs)) 185var socket = socketArgs.ConnectSocket;

24using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)) 37using (var socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp))

21private Socket _portSelector;

15: base(new IPEndPoint(Socket.OSSupportsIPv6 ? IPAddress.IPv6Any : IPAddress.Any, port))

56var socket = new Socket(ipEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp)

19private readonly Socket _socket; 36internal SocketConnection(Socket socket,

11public Socket Socket => _socket;

15public ValueTask<SocketOperationResult> WaitForDataAsync(Socket socket) 32public ValueTask<SocketOperationResult> ReceiveAsync(Socket socket, Memory<byte> buffer)

20public ValueTask<SocketOperationResult> SendAsync(Socket socket, in ReadOnlySequence<byte> buffers) 59private ValueTask<SocketOperationResult> SendAsync(Socket socket, ReadOnlyMemory<byte> memory)

88public ConnectionContext Create(Socket socket)

17private Socket? _listenSocket; 41Socket listenSocket; 67var acceptSocket = await _listenSocket.AcceptAsync(cancellationToken);

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;

11public ExposedSocketNetworkStream(Socket socket, bool ownsSocket) 16public new Socket Socket => base.Socket;

203Socket socket = await _socket.AcceptAsync(linkedSource.Token).ConfigureAwait(false); 224internal abstract bool OnAccept(Socket socket); 242internal override bool OnAccept(Socket socket) 277internal override bool OnAccept(Socket socket)

27public async Task<Socket> AcceptAsync(CancellationToken token)

127if (Socket.OSSupportsIPv6)

29Type type = typeof(Socket).Assembly.GetType("System.Net.Sockets.UnixDomainSocketEndPoint")

464Socket clientSocket; 514private async Task ConnectAsyncInternal(Socket clientSocket, EndPoint remoteEP, CancellationToken token)

384Socket socket = networkStream.Socket;

57var sockets = new List<Socket>(); 63Socket socket = new Socket(addressFamily, SocketType.Stream, ProtocolType.Tcp); 85foreach (var socket in sockets)

48using (var socket = new Socket(AddressFamily.Unix, SocketType.Dgram, ProtocolType.Unspecified))

330bool doIpv6 = Socket.OSSupportsIPv6 && (addressFamily == null || addressFamily == AddressFamily.InterNetworkV6); 331bool doIpv4 = Socket.OSSupportsIPv4 && (addressFamily == null || addressFamily == AddressFamily.InterNetwork); 740using var socket = new Socket(serverEndPoint.AddressFamily, SocketType.Dgram, ProtocolType.Udp); 790using var socket = new Socket(serverEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

15private readonly Socket _dnsSocket; 16private Socket? _tcpSocket; 84using Socket tcpClient = await _tcpSocket.AcceptAsync();

316using Socket socket = new Socket(clientAddress.AddressFamily, SocketType.Dgram, ProtocolType.Udp);

134Socket? testSocket = null; 141if (Socket.OSSupportsIPv4) 145else if (Socket.OSSupportsIPv6)

77private Socket? _socket;

1268[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]

758[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]

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);

51var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

64Socket accepted = _instance!.ListeningSocket.AcceptAsync().GetAwaiter().GetResult(); 82Socket acceptedSocket; 101private void HandleAcceptedSocket(Socket acceptedSocket) 241internal Socket ListeningSocket { get; } 335var socket = new Socket(AddressFamily.Unix, SocketType.Stream, ProtocolType.Unspecified);

489Socket s, SafePipeHandle _,

39[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.Socket))]

702Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp) { NoDelay = true }; 711using (cancellationToken.UnsafeRegister(static s => ((Socket)s!).Dispose(), socket))

49private Socket? _socket; 74public HttpConnection(Socket sock, HttpEndPointListener epl, bool secure, X509Certificate cert) 540Socket s = _socket;

44private readonly Socket _socket; 110Socket? accepted = args.SocketError == SocketError.Success ? args.AcceptSocket : null;

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);

18private static Socket? s_socket; 20private static Socket? Socket 185private static async Task ReadEventsAsync(Socket socket) 219static unsafe Interop.Error ReadEvents(Socket socket)

61private static Socket GetRawSocket(SocketConfig socketConfig) 69Socket socket = new Socket(addrFamily, socketType, socketConfig.ProtocolType); 250using (Socket socket = GetRawSocket(socketConfig)) 297private static unsafe PingReply CreatePingReplyForUnreachableHost(IPAddress address, Socket socket) 322using Socket socket = GetRawSocket(socketConfig);

84if (!Socket.OSSupportsIPv6)

31private Socket? _dataSocket; 89Socket? socket = _dataSocket; 108Socket listenSocket = connection._dataSocket!; 743Socket listenSocket = _dataSocket!; 1167private static Socket CreateFtpDataSocket(Socket templateSocket) 1170Socket socket = new Socket(templateSocket.AddressFamily, templateSocket.SocketType, templateSocket.ProtocolType);

958var client = new Socket(SocketType.Stream, ProtocolType.Tcp); 975var client = new Socket(SocketType.Stream, ProtocolType.Tcp);

1791var socket = new Socket(SocketType.Stream, ProtocolType.Tcp); 1814static void BindHelper(ServicePoint servicePoint, ref IPAddress[] addresses, Socket socket, int port) 1861using (cancellationToken.UnsafeRegister(s => ((Socket)s!).Dispose(), socket))

39internal Socket Socket

138private Socket? _socket;

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) =>

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; 229if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 250if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 275if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 299if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 322if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 349private int _closeTimeout = Socket.DefaultCloseTimeout; // -1 = respect linger options 435if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 470if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 501if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 533if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185

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"/>. 178if (!Socket.OSSupportsUnixDomainSockets) throw new PlatformNotSupportedException(); 212if (!Socket.OSSupportsUnixDomainSockets) throw new PlatformNotSupportedException(); 839if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 883if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 908if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 939if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1006/// Places a <see cref="Socket"/> in a listening state. 1014/// Places a <see cref="Socket"/> in a listening state. 1034public Socket Accept() 1036if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1099Socket socket = CreateAcceptSocket(acceptedSocketHandle, remoteEndPoint); 1107if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1114if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1121if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1128if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1135if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1148if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1186if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1199if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1240if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1250if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1277if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1283/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 1298/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1299/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 1300/// <exception cref="InvalidOperationException">The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</exception> 1305if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1311/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 1326/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1327/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 1328/// <exception cref="InvalidOperationException">The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</exception> 1333if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1359if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1397if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1404if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1411if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1424/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1427if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1441/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1444if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1484/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1487if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1516if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1523if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1530if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1538if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1551if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1585if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1595if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1622if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1629if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1642if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1681if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1750/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 1753/// <see cref="Socket.ReceiveMessageFrom(Span{byte}, ref SocketFlags, ref EndPoint, out IPPacketInformation)"/> 1756/// <para>The <see cref="Socket"/> object is not in blocking mode and cannot accept this synchronous call.</para> 1760if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1822if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1903if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1910if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1917if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 1930/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1945/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 1948if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2028/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2031if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2176/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2179/// In general, the SetSocketOption method should be used whenever setting a <see cref="Socket"/> option. 2296/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2299/// In general, the GetSocketOption method should be used whenever getting a <see cref="Socket"/> option. 2342/// <summary>Determines the status of the <see cref="Socket"/>.</summary> 2346/// The status of the <see cref="Socket"/> based on the polling mode value passed in the <paramref name="mode"/> parameter. 2356/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2359if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2376/// <summary>Determines the status of the <see cref="Socket"/>.</summary> 2380/// The status of the <see cref="Socket"/> based on the polling mode value passed in the <paramref name="mode"/> parameter. 2391/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> has been closed.</exception> 2396/// <param name="checkRead">An <see cref="IList"/> of <see cref="Socket"/> instances to check for readability.</param> 2397/// <param name="checkWrite">An <see cref="IList"/> of <see cref="Socket"/> instances to check for writability.</param> 2398/// <param name="checkError">An <see cref="IList"/> of <see cref="Socket"/> instances to check for errors.</param> 2406if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2438/// <param name="checkRead">An <see cref="IList"/> of <see cref="Socket"/> instances to check for readability.</param> 2439/// <param name="checkWrite">An <see cref="IList"/> of <see cref="Socket"/> instances to check for writability.</param> 2440/// <param name="checkError">An <see cref="IList"/> of <see cref="Socket"/> instances to check for errors.</param> 2506if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2516if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2534if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2543if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2565if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2572if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2590if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2604if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2613if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2631if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2639if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2661if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2679if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2702if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2722if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2742if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2761public Socket EndAccept(IAsyncResult asyncResult) => TaskToAsyncResult.End<Socket>(asyncResult); 2766private async Task<(Socket s, byte[] buffer, int bytesReceived)> AcceptAndReceiveHelperAsync(Socket? acceptSocket, int receiveSize) 2770Socket s = await AcceptAsync(acceptSocket).ConfigureAwait(false); 2799public IAsyncResult BeginAccept(Socket? acceptSocket, int receiveSize, AsyncCallback? callback, object? state) => 2802public Socket EndAccept(out byte[] buffer, IAsyncResult asyncResult) 2804if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2806Socket socket = EndAccept(out byte[] innerBuffer, out int bytesTransferred, asyncResult); 2812public Socket EndAccept(out byte[] buffer, out int bytesTransferred, IAsyncResult asyncResult) 2814if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 2816Socket s; 2817(s, buffer, bytesTransferred) = TaskToAsyncResult.End<(Socket, byte[], int)>(asyncResult); 3026Socket? attemptSocket = dnsEP.AddressFamily != AddressFamily.Unspecified ? new Socket(dnsEP.AddressFamily, socketType, protocolType) : null; 3041Socket attemptSocket = new Socket(endPointSnapshot.AddressFamily, socketType, protocolType); 3807internal Socket CreateAcceptSocket(SafeSocketHandle fd, EndPoint? remoteEP) 3811Socket socket = new Socket(fd, loadPropertiesFromHandle: false); 3815internal Socket UpdateAcceptSocket(Socket socket, EndPoint? remoteEP) 4079Socket socket = (Socket)socketList[i]!;

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); 330saea.Completed += (s, e) => CompleteSendReceive((Socket)s!, (TaskSocketAsyncEventArgs<int>)e, isReceive: true); 594saea.Completed += (s, e) => CompleteSendReceive((Socket)s!, (TaskSocketAsyncEventArgs<int>)e, isReceive: false); 703/// Sends the file <paramref name="fileName"/> to a connected <see cref="Socket"/> object. 707/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 708/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 717/// Sends the file <paramref name="fileName"/> and buffers of data to a connected <see cref="Socket"/> object 725/// <exception cref="ObjectDisposedException">The <see cref="Socket"/> object has been closed.</exception> 726/// <exception cref="NotSupportedException">The <see cref="Socket"/> object is not connected to a remote host.</exception> 872private static void CompleteSendReceive(Socket s, TaskSocketAsyncEventArgs<int> saea, bool isReceive) 977internal sealed class AwaitableSocketAsyncEventArgs : SocketAsyncEventArgs, IValueTaskSource, IValueTaskSource<int>, IValueTaskSource<Socket>, IValueTaskSource<SocketReceiveFromResult>, IValueTaskSource<SocketReceiveMessageFromResult> 980private readonly Socket _owner; 989public AwaitableSocketAsyncEventArgs(Socket owner, bool isReceiveForCaching) : 1021public ValueTask<Socket> AcceptAsync(Socket socket, CancellationToken cancellationToken) 1026return new ValueTask<Socket>(this, _mrvtsc.Version); 1029Socket acceptSocket = AcceptSocket!; 1037new ValueTask<Socket>(acceptSocket) : 1038ValueTask.FromException<Socket>(CreateException(error)); 1043public ValueTask<int> ReceiveAsync(Socket socket, CancellationToken cancellationToken) 1061public ValueTask<SocketReceiveFromResult> ReceiveFromAsync(Socket socket, CancellationToken cancellationToken) 1080internal ValueTask<int> ReceiveFromSocketAddressAsync(Socket socket, CancellationToken cancellationToken) 1098public ValueTask<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(Socket socket, CancellationToken cancellationToken) 1121public ValueTask<int> SendAsync(Socket socket, CancellationToken cancellationToken) 1139public ValueTask SendAsyncForNetworkStream(Socket socket, CancellationToken cancellationToken) 1156public ValueTask SendPacketsAsync(Socket socket, CancellationToken cancellationToken) 1173public ValueTask<int> SendToAsync(Socket socket, CancellationToken cancellationToken) 1191public ValueTask ConnectAsync(Socket socket, CancellationToken cancellationToken) 1216public ValueTask DisconnectAsync(Socket socket, CancellationToken cancellationToken) 1285Socket IValueTaskSource<Socket>.GetResult(short token) 1293Socket acceptSocket = AcceptSocket!;

186private Socket? GetOrCreateAcceptSocket(Socket? acceptSocket, bool checkDisconnected, string propertyName, out SafeSocketHandle? handle) 266internal Socket CopyStateFromSource(Socket source)

539[DynamicDependency("set_PreferInlineCompletions", typeof(Socket))] 629if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 724if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 838if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 871if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 987if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1058if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1095if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1190if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1222if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1303if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); 1375if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException();

17private Socket? _acceptSocket; 18private Socket? _connectSocket; 76private Socket? _currentSocket; 106public Socket? AcceptSocket 112public Socket? ConnectSocket 550internal void StartOperationCommon(Socket? socket, SocketAsyncOperation operation) 581_acceptAddressBufferCount = 2 * (Socket.GetAddressSize(_currentSocket!._rightEndPoint!) + 16); 639Socket? currentSocket = _currentSocket; 703Socket.OSSupportsIPv6 && Socket.OSSupportsIPv4; 742Socket? tempSocketIPv4 = null, tempSocketIPv6 = null; 751Socket? attemptSocket = null; 760(Socket.OSSupportsIPv6DualMode || !_currentSocket.TryReplaceHandleForAddressFamily(address.AddressFamily))) 773attemptSocket = tempSocketIPv6 ??= (Socket.OSSupportsIPv6 ? new Socket(AddressFamily.InterNetworkV6, socketType, protocolType) : null); 782attemptSocket = tempSocketIPv4 ??= (Socket.OSSupportsIPv4 ? new Socket(AddressFamily.InterNetwork, socketType, protocolType) : null); 955public void SetResults(Socket? socket, SocketError socketError, int bytesTransferred, SocketFlags flags, Exception? exception)

46internal SocketError DoOperationAccept(Socket _ /*socket*/, SafeSocketHandle handle, SafeSocketHandle? acceptHandle, CancellationToken cancellationToken) 74internal SocketError DoOperationConnectEx(Socket _ /*socket*/, SafeSocketHandle handle, CancellationToken cancellationToken) 94internal SocketError DoOperationDisconnect(Socket socket, SafeSocketHandle handle, CancellationToken _ /*cancellationToken*/) 196internal SocketError DoOperationReceiveMessageFrom(Socket socket, SafeSocketHandle handle, CancellationToken cancellationToken) 203Socket.GetIPProtocolInformation(socket.AddressFamily, _socketAddress!, out isIPv4, out isIPv6); 244internal SocketError DoOperationSendPackets(Socket socket, SafeSocketHandle _1 /*handle*/, CancellationToken cancellationToken) 351Socket acceptedSocket = _currentSocket!.CreateAcceptSocket(

35public static void CheckDualModePacketInfoSupport(Socket socket) 1338public 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) 1343Socket.GetIPProtocolInformation(socket.AddressFamily, socketAddress, out isIPv4, out isIPv6); 1364public static SocketError ReceiveMessageFrom(Socket socket, SafeSocketHandle handle, Span<byte> buffer, ref SocketFlags socketFlags, SocketAddress socketAddress, out SocketAddress receiveAddress, out IPPacketInformation ipPacketInformation, out int bytesTransferred) 1369Socket.GetIPProtocolInformation(socket.AddressFamily, socketAddress, out isIPv4, out isIPv6); 1617public static void SetReceivingDualModeIPv4PacketInformation(Socket socket) 1628public static void SetIPProtectionLevel(Socket socket, SocketOptionLevel optionLevel, int protectionLevel) 1891Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 1892Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 1893Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 1912Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 1913Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 1914Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 1931Socket? socket = socketList[i] as Socket; 1934throw new ArgumentException(SR.Format(SR.net_sockets_select, socket?.GetType().FullName ?? "null", typeof(Socket).FullName), nameof(socketList)); 1999Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 2000Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 2001Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 2020Socket.SocketListDangerousReleaseRefs(checkRead, ref refsAdded); 2021Socket.SocketListDangerousReleaseRefs(checkWrite, ref refsAdded); 2022Socket.SocketListDangerousReleaseRefs(checkError, ref refsAdded); 2038Socket? socket = socketList[i] as Socket; 2041throw new ArgumentException(SR.Format(SR.net_sockets_select, socket?.GetType().FullName ?? "null", typeof(Socket).FullName), nameof(socketList)); 2075Socket socket = (Socket)socketList[i]!; 2116Socket socket, TransmitFileOptions options, SendPacketsElement[] elements, SafeFileHandle[] fileHandles, CancellationToken cancellationToken, Action<long, SocketError> callback) 2191internal static SocketError Disconnect(Socket socket, SafeSocketHandle handle, bool reuseSocket)

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) =>

18private Socket _clientSocket = null!; // initialized by helper called from ctor 79internal TcpClient(Socket acceptedSocket) 95public Socket Client 123if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 142if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 159if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 172if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 239if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 279Socket chkClientSocket = Volatile.Read(ref _clientSocket);

17private Socket? _serverSocket; 62public Socket Server 184public Socket AcceptSocket() 205Socket acceptedSocket = _serverSocket!.Accept(); 212public Socket EndAcceptSocket(IAsyncResult asyncResult) => 213EndAcceptCore<Socket>(asyncResult); 221public Task<Socket> AcceptSocketAsync() => AcceptSocketAsync(CancellationToken.None).AsTask(); 223public ValueTask<Socket> AcceptSocketAsync(CancellationToken cancellationToken) 239static async ValueTask<TcpClient> WaitAndWrap(ValueTask<Socket> task) => 252if (Socket.OSSupportsIPv6) 290if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 300throw new ObjectDisposedException(typeof(Socket).FullName);

18private Socket _clientSocket = null!; // initialized by helper called from ctor 117public Socket Client 234Socket chkClientSocket = _clientSocket; 292if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 309if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 366if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 382if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 644/// <exception cref="ObjectDisposedException">The underlying <see cref="Socket"/> has been closed.</exception> 693if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 710Socket? ipv6Socket = null; 711Socket? ipv4Socket = null; 717if (Socket.OSSupportsIPv4) 721if (Socket.OSSupportsIPv6) 808if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 825if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 838if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 861if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 897if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 941if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185 967if (!Socket.OSSupportsThreads) throw new PlatformNotSupportedException(); // TODO remove with https://github.com/dotnet/runtime/pull/107185

59if (!Socket.OSSupportsUnixDomainSockets)

31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer) 48public ValueTask SendAsync(Socket socket, ReadOnlyMemory<byte> memory)

21private Socket _socket; 72public SocketConnection(Socket socket, int bufferSize) 810Socket socket = null; 883if (Socket.OSSupportsIPv6)

31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer) 48public ValueTask SendAsync(Socket socket, ReadOnlyMemory<byte> memory)

19private Socket _socket; 54public SocketConnection(Socket socket, int bufferSize) 774Socket socket = null;