NamedPipeClientStream

src\Compilers\Shared\BuildClient.cs (1)

323npcs = new NamedPipeClientStream(".", testPipeName, PipeDirection.InOut);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

Installer\Windows\InstallClientElevationContext.cs (1)

55InitializeDispatcher(new NamedPipeClientStream(".", WindowsUtils.CreatePipeName(_serverProcess.Id), PipeDirection.InOut));

Installer\Windows\TimestampedFileLogger.cs (1)

123NamedPipeClientStream logPipe = new(".", (string)logPipeName, PipeDirection.InOut);

NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

CommandTests\Test\NamedPipeClient.cs (1)

23_namedPipeClientStream = new(".", name, PipeDirection.InOut, PipeOptions.CurrentUserOnly);

WindowsInstallerTests.cs (1)

62NamedPipeClientStream clientPipe = new(".", pipeName, PipeDirection.InOut);

NamedPipesTransportBenchmark.cs (1)

125var clientStream = new NamedPipeClientStream(

BackEnd\Client\MSBuildClient.cs (1)

142_nodeStream = new NamedPipeClientStream(

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (1)

456NamedPipeClientStream nodeStream = new NamedPipeClientStream(

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

NodePipeClient.cs (1)

25_pipeClient = new(

Interactive\Core\InteractiveHost.LazyRemoteService.cs (1)

183var clientStream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous);

Utilities\AbstractLanguageServerClientTests.TestLspClient.cs (1)

143var pipeClient = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous | PipeOptions.CurrentUserOnly);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

PipeListener.cs (1)

24var pipeClient = new NamedPipeClientStream(serverName: ".", pipeName, PipeDirection.InOut, PipeOptions.CurrentUserOnly | PipeOptions.Asynchronous);

Client.cs (1)

51var stream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, _pipeOptions);

Microsoft\VisualBasic\ApplicationServices\SingleInstanceTests.cs (1)

361NamedPipeClientStream pipeClient = new(".", pipeName, PipeDirection.Out);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

Client.cs (1)

51var stream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, _pipeOptions);

System\ServiceModel\Channels\PipeConnectionInitiator.cs (1)

180namedPipeClient = new NamedPipeClientStream(".", resolvedAddress, PipeDirection.InOut, PipeOptions.Asynchronous, TokenImpersonationLevel.Anonymous, HandleInheritability.None);

src\Compilers\Shared\BuildClient.cs (1)

323npcs = new NamedPipeClientStream(".", testPipeName, PipeDirection.InOut);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

src\Compilers\Shared\BuildClient.cs (1)

323npcs = new NamedPipeClientStream(".", testPipeName, PipeDirection.InOut);

src\Compilers\Shared\NamedPipeUtil.cs (1)

48=> new NamedPipeClientStream(serverName, GetPipeNameOrPath(pipeName), direction, options | CurrentUserOption);

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

BuildServerConnection.cs (8)

185using var pipe = await tryConnectToServerAsync(pipeName, timeoutOverride, logger, tryCreateServerFunc, cancellationToken).ConfigureAwait(false); 198static Task<NamedPipeClientStream?> tryConnectToServerAsync( 224return Task.FromResult<NamedPipeClientStream?>(null); 235return Task.FromResult<NamedPipeClientStream?>(null); 255return Task.FromResult<NamedPipeClientStream?>(null); 276NamedPipeClientStream pipeStream, 369internal static async Task<NamedPipeClientStream?> TryConnectToServerAsync( 375NamedPipeClientStream? pipeStream = null;

Installer\Windows\PipeStreamMessageDispatcherBase.cs (2)

68else if (_pipeStream is NamedPipeClientStream) 70((NamedPipeClientStream)_pipeStream).Connect(ConnectionTimeout);

Installer\Windows\TimestampedFileLogger.cs (1)

123NamedPipeClientStream logPipe = new(".", (string)logPipeName, PipeDirection.InOut);

NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

CommandTests\Test\NamedPipeClient.cs (1)

12private readonly NamedPipeClientStream _namedPipeClientStream;

WindowsInstallerTests.cs (1)

62NamedPipeClientStream clientPipe = new(".", pipeName, PipeDirection.InOut);

NamedPipesTransportBenchmark.cs (4)

67var clientStream = CreateClientStream(_pipeName); 105var namedPipeClient = CreateClientStream(_pipeName); 123private static NamedPipeClientStream CreateClientStream(string pipeName) 125var clientStream = new NamedPipeClientStream(

BackEnd\Client\MSBuildClient.cs (1)

80private NamedPipeClientStream _nodeStream = null!;

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (3)

429private static void ValidateRemotePipeSecurityOnWindows(NamedPipeClientStream nodeStream) 456NamedPipeClientStream nodeStream = new NamedPipeClientStream( 503internal static bool TryConnectToPipeStream(NamedPipeClientStream nodeStream, string pipeName, Handshake handshake, int timeout, out HandshakeResult result)

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 132internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream)

NodePipeClient.cs (1)

20private readonly NamedPipeClientStream _pipeClient;

Interactive\Core\InteractiveHost.LazyRemoteService.cs (1)

183var clientStream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous);

Utilities\AbstractLanguageServerClientTests.TestLspClient.cs (1)

143var pipeClient = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous | PipeOptions.CurrentUserOnly);

MSBuild\BuildHostProcessManager.cs (1)

448var pipeClient = NamedPipeUtil.CreateClient(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous);

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

RpcTests.cs (1)

33var pipeClient = NamedPipeUtil.CreateClient(".", pipeName, PipeDirection.InOut, PipeOptions.Asynchronous);

PipeListener.cs (5)

24var pipeClient = new NamedPipeClientStream(serverName: ".", pipeName, PipeDirection.InOut, PipeOptions.CurrentUserOnly | PipeOptions.Asynchronous); 73private async Task InitializeAsync(NamedPipeClientStream pipeClient, CancellationToken cancellationToken) 88private async Task ReceiveAndApplyUpdatesAsync(NamedPipeClientStream pipeClient, bool initialUpdates, CancellationToken cancellationToken) 114NamedPipeClientStream pipeClient, 139NamedPipeClientStream pipeClient,

Client.cs (2)

51var stream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, _pipeOptions); 148public NamedPipeClient(NamedPipeClientStream stream, string identifier)

Microsoft\VisualBasic\ApplicationServices\SingleInstanceTests.cs (7)

264var pipeClient = CreateClientConnection(pipeName, SendTimeout); 309using var pipeClient = CreateClientConnection(pipeName, SendTimeout); 314var pipeClient = CreateClientConnection(pipeName, SendTimeout); 332NamedPipeClientStream pipeClient = null; 356using var _ = CreateClientConnection(pipeName, SendTimeout); 359private static NamedPipeClientStream CreateClientConnection(string pipeName, int timeout) 361NamedPipeClientStream pipeClient = new(".", pipeName, PipeDirection.Out);

netstandard.cs (1)

952[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.IO.Pipes.NamedPipeClientStream))]

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

Client.cs (2)

51var stream = new NamedPipeClientStream(".", pipeName, PipeDirection.InOut, _pipeOptions); 148public NamedPipeClient(NamedPipeClientStream stream, string identifier)

System.Core.cs (1)

107[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.IO.Pipes.NamedPipeClientStream))]

System\IO\Pipes\NamedPipeClientStream.cs (1)

196var tuple = ((NamedPipeClientStream stream, int timeout, CancellationToken cancellationToken, int startTime))state!;

System\ServiceModel\Channels\PipeConnection.cs (2)

17private readonly NamedPipeClientStream _pipe; 39public PipeConnection(NamedPipeClientStream namedPipeClient, int connectionBufferSize)

System\ServiceModel\Channels\PipeConnectionInitiator.cs (1)

177NamedPipeClientStream namedPipeClient;

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

src\Compilers\Shared\BuildServerConnection.cs (9)

src\Compilers\Shared\NamedPipeUtil.cs (2)

47internal static NamedPipeClientStream CreateClient(string serverName, string pipeName, PipeDirection direction, PipeOptions options) 175internal static bool CheckPipeConnectionOwnership(NamedPipeClientStream pipeStream) => true;

BuildClientTests.cs (1)

162using var pipeStream = await BuildServerConnection.TryConnectToServerAsync(pipeName, timeoutMs, _logger, cancellationToken);

NamedPipeClientConnectionHostTests.cs (7)

36private Task<NamedPipeClientStream?> ConnectAsync(CancellationToken cancellationToken = default) => BuildServerConnection.TryConnectToServerAsync( 53using var clientStream = await ConnectAsync(); 78using var clientStream = await ConnectAsync(); 93var list = new List<Task<NamedPipeClientStream?>>(); 123var list = new List<Task<NamedPipeClientStream?>>(); 136using var stream = await streamTask; 151using var client = await ConnectAsync();