76 instantiations of UnixDomainSocketEndPoint
aspire (4)
Backchannel\AppHostCliBackchannel.cs (1)
331var endpoint = new UnixDomainSocketEndPoint(socketPath);
Projects\AppHostRpcClient.cs (1)
226var endpoint = new UnixDomainSocketEndPoint(socketPath);
src\Shared\AppHostSocketManager.cs (1)
270await socket.ConnectAsync(new UnixDomainSocketEndPoint(SocketPath), cancellationToken).ConfigureAwait(false);
src\Shared\SocketPermissionHelper.cs (1)
122socket.Bind(new UnixDomainSocketEndPoint(socketPath));
aspire-managed (1)
TerminalHostForwarder.cs (1)
135await socket.ConnectAsync(new UnixDomainSocketEndPoint(args[controlPathIndex + 1]), cancellationToken).ConfigureAwait(false);
Aspire.Cli.Tests (7)
Backchannel\AppHostCliBackchannelTests.cs (1)
170_listener.Bind(new UnixDomainSocketEndPoint(socketPath));
Backchannel\AuxiliaryBackchannelMonitorTests.cs (2)
626unreachableSocket.Bind(new UnixDomainSocketEndPoint(socketPath)); 671unreachableSocket.Bind(new UnixDomainSocketEndPoint(socketPath));
Projects\RunningInstanceManagerTests.cs (1)
73_listener.Bind(new UnixDomainSocketEndPoint(socketPath));
TestServices\TerminalTapeTestHost.cs (1)
47_listener.Bind(new UnixDomainSocketEndPoint(SocketPath));
TestServices\TestAppHostSocket.cs (1)
29await socket.ConnectAsync(new UnixDomainSocketEndPoint(SocketPath), cancellationToken);
TestServices\TestAuxiliaryBackchannelServer.cs (1)
22_listener.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.Dashboard.Tests (1)
Terminal\DefaultTerminalConnectionResolverTests.cs (1)
69listener.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.Hosting (4)
Backchannel\TerminalHostControlClient.cs (1)
65await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath), cancellationToken).ConfigureAwait(false);
src\Shared\AppHostSocketManager.cs (1)
270await socket.ConnectAsync(new UnixDomainSocketEndPoint(SocketPath), cancellationToken).ConfigureAwait(false);
src\Shared\SocketPermissionHelper.cs (1)
122socket.Bind(new UnixDomainSocketEndPoint(socketPath));
Utils\Hex1bPtySocketHelper.cs (1)
44_ = new UnixDomainSocketEndPoint(socketPath);
Aspire.Hosting.CodeGeneration.Go.Tests (1)
AtsGoCodeGeneratorTests.cs (1)
233socket.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.Hosting.Native.Client (1)
NativeProviderHost.cs (1)
25? new UnixDomainSocketEndPoint(socketPath)
Aspire.Hosting.Native.Core.Tests (13)
NativeAuxiliaryBackchannelTests.cs (1)
40using var silent = new NativeSocketTestClient(new UnixDomainSocketEndPoint(host.SocketPath));
NativeCliProtocolTests.cs (4)
91using var client = new NativeSocketTestClient(new UnixDomainSocketEndPoint(directory.SocketPath)); 106using var stalled = new NativeSocketTestClient(new UnixDomainSocketEndPoint(host.SocketPath)); 111using (var excess = new NativeSocketTestClient(new UnixDomainSocketEndPoint(host.SocketPath))) 119using var replacement = new NativeSocketTestClient(new UnixDomainSocketEndPoint(host.SocketPath));
NativeIpcSecurityTests.cs (3)
41canary.Bind(new UnixDomainSocketEndPoint(canaryPath)); 46using var rpc = new NativeRpcListener(new UnixDomainSocketEndPoint(rpcDirectory.SocketPath), Token, NullLogger.Instance); 51using var auxiliaryOwner = new NativeSocketTestClient(new UnixDomainSocketEndPoint(auxiliary.SocketPath));
NativeSocketIsolationTests.cs (3)
267Assert.Throws<IOException>(() => new NativeRpcListener(new UnixDomainSocketEndPoint(directory.SocketPath), Token, NullLogger.Instance)); 280var endPoint = new UnixDomainSocketEndPoint(directory.SocketPath); 308var endPoint = new UnixDomainSocketEndPoint(directory.SocketPath);
TestServices\NativeAuxiliaryTestHost.cs (1)
64socket.Connect(new UnixDomainSocketEndPoint(SocketPath));
TestServices\NativeCliTestHost.cs (1)
37socket.Connect(new UnixDomainSocketEndPoint(path));
Aspire.Hosting.Native.Server (3)
NativeServerConfiguration.cs (1)
158return new UnixDomainSocketEndPoint(path);
src\Shared\AppHostSocketManager.cs (1)
270await socket.ConnectAsync(new UnixDomainSocketEndPoint(SocketPath), cancellationToken).ConfigureAwait(false);
src\Shared\SocketPermissionHelper.cs (1)
122socket.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.Hosting.RemoteHost (1)
src\Shared\SocketPermissionHelper.cs (1)
122socket.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.Hosting.RemoteHost.Tests (2)
JsonRpcAuthenticationTests.cs (1)
400await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath), timeoutCts.Token);
TestServices\IntegrationHostProcessFixture.cs (1)
384await socket.ConnectAsync(new UnixDomainSocketEndPoint(_socketPath), timeout.Token);
Aspire.Hosting.Tests (21)
Backchannel\AppHostBackchannelTests.cs (2)
61var endpoint = new UnixDomainSocketEndPoint(backchannelReadyEvent.SocketPath); 99var endpoint = new UnixDomainSocketEndPoint(backchannelReadyEvent.SocketPath);
Backchannel\AuxiliaryBackchannelTests.cs (14)
43var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 85var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 133await socket.ConnectAsync(new UnixDomainSocketEndPoint(service.SocketPath)).DefaultTimeout(); 167var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 202var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 245var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 287var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 367var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 408var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 445var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 494var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 536var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 579var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 623var endpoint = new UnixDomainSocketEndPoint(service.SocketPath);
Backchannel\GetTerminalInfoAsyncTests.cs (1)
446sock.Bind(new UnixDomainSocketEndPoint(SocketPath));
Dcp\DcpSocketTests.cs (1)
42await client.ConnectAsync(new UnixDomainSocketEndPoint(socketPath), timeout.Token).DefaultTimeout();
Terminals\Hex1bPtySocketTests.cs (1)
243_ = new UnixDomainSocketEndPoint(Path.Combine(directory, $"hex1bpty-{new string('0', 32)}.socket"));
Terminals\ResourceAspireTerminalTests.cs (1)
129listener.Bind(new UnixDomainSocketEndPoint(socketPath));
Utils\SocketPermissionHelperTests.cs (1)
53await client.ConnectAsync(new UnixDomainSocketEndPoint(socketPath), timeout.Token);
Aspire.Managed.Tests (1)
TerminalHostSignalTests.cs (1)
113listener.Bind(new UnixDomainSocketEndPoint(controlPath));
Aspire.TerminalHost (1)
src\Shared\SocketPermissionHelper.cs (1)
122socket.Bind(new UnixDomainSocketEndPoint(socketPath));
Aspire.TerminalHost.Tests (5)
TerminalHostAppTests.cs (5)
179connectTasks[i] = rawSockets[i].ConnectAsync(new UnixDomainSocketEndPoint(control)); 1031await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath)).ConfigureAwait(false); 1080await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath)).ConfigureAwait(false); 1207await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath)); 1259await socket.ConnectAsync(new UnixDomainSocketEndPoint(args.ProducerUdsPath), cts.Token);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
ListenOptions.cs (1)
32EndPoint = new UnixDomainSocketEndPoint(socketPath);
Microsoft.Extensions.Hosting.Systemd (1)
SystemdNotifier.cs (1)
50var endPoint = new UnixDomainSocketEndPoint(_socketPath!);
System.IO.Pipes (2)
System\IO\Pipes\NamedPipeClientStream.Unix.cs (1)
55socket.Connect(new UnixDomainSocketEndPoint(_normalizedPipePath!));
System\IO\Pipes\NamedPipeServerStream.Unix.cs (1)
338socket.Bind(new UnixDomainSocketEndPoint(path));
System.Net.Sockets (5)
System\Net\Sockets\Socket.cs (2)
180_rightEndPoint = new UnixDomainSocketEndPoint(buffer.Slice(0, bufferLength)); 214_remoteEndPoint = new UnixDomainSocketEndPoint(buffer.Slice(0, bufferLength));
System\Net\Sockets\UnixDomainSocketEndPoint.cs (3)
115public override EndPoint Create(SocketAddress socketAddress) => new UnixDomainSocketEndPoint(socketAddress.Buffer.Span.Slice(0, socketAddress.Size)); 153return new UnixDomainSocketEndPoint(_path, Path.GetFullPath(_path)); 163return new UnixDomainSocketEndPoint(_path, null);
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketConnection.cs (1)
779var endpoint = new UnixDomainSocketEndPoint(uriPath.LocalPath);
55 references to UnixDomainSocketEndPoint
aspire (2)
Backchannel\AppHostCliBackchannel.cs (1)
331var endpoint = new UnixDomainSocketEndPoint(socketPath);
Projects\AppHostRpcClient.cs (1)
226var endpoint = new UnixDomainSocketEndPoint(socketPath);
Aspire.Hosting.Native.Client (3)
NativeClient.cs (1)
137if (endpoint is not UnixDomainSocketEndPoint &&
NativeProviderHost.cs (2)
89if (client.Endpoint is not IPEndPoint and not UnixDomainSocketEndPoint) 107if (client.Endpoint is UnixDomainSocketEndPoint socket)
Aspire.Hosting.Native.Core.Tests (2)
NativeSocketIsolationTests.cs (2)
280var endPoint = new UnixDomainSocketEndPoint(directory.SocketPath); 308var endPoint = new UnixDomainSocketEndPoint(directory.SocketPath);
Aspire.Hosting.Native.Server (3)
Rpc\NativeRpcListener.cs (3)
67if (endPoint is not UnixDomainSocketEndPoint and not NamedPipeEndPoint { ServerName: "." } && 85if (endPoint is UnixDomainSocketEndPoint unix) 100var ownedPath = _listener.IsBound && endPoint is UnixDomainSocketEndPoint unix ? unix.ToString() : null;
Aspire.Hosting.Tests (15)
Backchannel\AppHostBackchannelTests.cs (2)
61var endpoint = new UnixDomainSocketEndPoint(backchannelReadyEvent.SocketPath); 99var endpoint = new UnixDomainSocketEndPoint(backchannelReadyEvent.SocketPath);
Backchannel\AuxiliaryBackchannelTests.cs (13)
43var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 85var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 167var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 202var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 245var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 287var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 367var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 408var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 445var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 494var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 536var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 579var endpoint = new UnixDomainSocketEndPoint(service.SocketPath); 623var endpoint = new UnixDomainSocketEndPoint(service.SocketPath);
Aspire.StackExchange.Redis (1)
src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\Implementation\RedisProfilerEntryToActivityConverter.cs (1)
207else if (command.EndPoint is UnixDomainSocketEndPoint unixDomainSocketEndPoint)
Microsoft.AspNetCore.Http.Connections (1)
src\aspnetcore\src\Shared\ConnectionEndpointTags.cs (1)
83else if (localEndpoint is UnixDomainSocketEndPoint udsEndPoint)
Microsoft.AspNetCore.Server.Kestrel.Core (4)
ListenOptions.cs (3)
66/// Only set if the <see cref="ListenOptions"/> is bound to a <see cref="UnixDomainSocketEndPoint"/>. 68public string? SocketPath => (EndPoint as UnixDomainSocketEndPoint)?.ToString(); 153case UnixDomainSocketEndPoint _:
src\aspnetcore\src\Shared\ConnectionEndpointTags.cs (1)
83else if (localEndpoint is UnixDomainSocketEndPoint udsEndPoint)
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)
SocketTransportFactory.cs (1)
50UnixDomainSocketEndPoint _ => true,
SocketTransportOptions.cs (1)
139case UnixDomainSocketEndPoint unix:
Microsoft.AspNetCore.SignalR.Core (1)
src\aspnetcore\src\Shared\ConnectionEndpointTags.cs (1)
83else if (localEndpoint is UnixDomainSocketEndPoint udsEndPoint)
Microsoft.Extensions.Hosting.Systemd (1)
SystemdNotifier.cs (1)
50var endPoint = new UnixDomainSocketEndPoint(_socketPath!);
netstandard (1)
netstandard.cs (1)
1288[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.UnixDomainSocketEndPoint))]
System.Net.Sockets (14)
System\Net\Sockets\Socket.cs (3)
831_rightEndPoint = endPointSnapshot is UnixDomainSocketEndPoint unixEndPoint ? 3542if (_rightEndPoint is UnixDomainSocketEndPoint unixEndPoint && 3825if (_rightEndPoint is UnixDomainSocketEndPoint unixEndPoint &&
System\Net\Sockets\SocketsTelemetry.cs (1)
126else if (endPoint is UnixDomainSocketEndPoint udsEndPoint)
System\Net\Sockets\UnixDomainSocketEndPoint.cs (10)
22/// <summary>Initializes a new instance of the <see cref="UnixDomainSocketEndPoint"/> with the file path to connect a unix domain socket over.</summary> 121/// <summary>Gets the path represented by this <see cref="UnixDomainSocketEndPoint"/> instance.</summary> 122/// <returns>The path represented by this <see cref="UnixDomainSocketEndPoint"/> instance.</returns> 136/// <summary>Determines whether the specified <see cref="object"/> is equal to the current <see cref="UnixDomainSocketEndPoint"/>.</summary> 137/// <param name="obj">The <see cref="object"/> to compare with the current <see cref="UnixDomainSocketEndPoint"/>.</param> 138/// <returns><see langword="true"/> if the specified <see cref="object"/> is equal to the current <see cref="UnixDomainSocketEndPoint"/>; otherwise, <see langword="false"/>.</returns> 140=> obj is UnixDomainSocketEndPoint ep && _path == ep._path; 142/// <summary>Returns a hash value for a <see cref="UnixDomainSocketEndPoint"/> instance.</summary> 146internal UnixDomainSocketEndPoint CreateBoundEndPoint() 156internal UnixDomainSocketEndPoint CreateUnboundEndPoint()
System.ServiceModel.UnixDomainSocket (5)
System\ServiceModel\Channels\SocketConnection.cs (5)
50private UnixDomainSocketEndPoint _remoteEndpoint; 416if (TryGetEndpoints(out UnixDomainSocketEndPoint remote)) 439private bool TryGetEndpoints(out UnixDomainSocketEndPoint remoteIPEndpoint) 447remoteIPEndpoint = _remoteEndpoint ?? (UnixDomainSocketEndPoint)_socket.RemoteEndPoint; 779var endpoint = new UnixDomainSocketEndPoint(uriPath.LocalPath);