1 write to ConsumerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
131ConsumerUdsPath = parseResult.GetValue(consumerOption)!,
27 references to ConsumerUdsPath
Aspire.TerminalHost (3)
TerminalHostApp.cs (3)
70ConsumerUdsPath = _args.ConsumerUdsPath, 106_args.Columns, _args.Rows, _args.ProducerUdsPath, _args.ConsumerUdsPath); 118_args.ConsumerUdsPath,
Aspire.TerminalHost.Tests (24)
TerminalHostAppTests.cs (22)
117Assert.Equal(args.ConsumerUdsPath, session.ConsumerUdsPath); 248Assert.Equal(args.ConsumerUdsPath, snap.ConsumerUdsPath); 287File.WriteAllBytes(args.ConsumerUdsPath, []); 289Assert.True(File.Exists(args.ConsumerUdsPath)); 391Assert.Equal(args.ConsumerUdsPath, afterCycle2.ConsumerUdsPath); 430await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(10)); 432Assert.True(File.Exists(args.ConsumerUdsPath), "Consumer socket should be bound while the replica waits."); 447File.Exists(args.ConsumerUdsPath), 448$"Consumer socket '{args.ConsumerUdsPath}' should be deleted after graceful shutdown."); 514await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 516args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 546await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 549StreamFactory = ct => Hmp1Transports.ConnectUnixSocket(args.ConsumerUdsPath, ct), 580await using var lateConsumer = await TestHmp1Consumer.ConnectAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 639await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 650args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 784args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 822args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 1230args.ConsumerUdsPath, 1234AssertSocketIsRestrictedToOwningUser(args.ConsumerUdsPath); 1240args.ConsumerUdsPath, TimeSpan.FromSeconds(10)); 1303_ => args.ConsumerUdsPath
TerminalHostArgsTests.cs (2)
18Assert.Equal("/tmp/c.sock", args.ConsumerUdsPath); 50Assert.Equal("/tmp/c.sock", args.ConsumerUdsPath);