1 write to ConsumerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
131ConsumerUdsPath = parseResult.GetValue(consumerOption)!,
29 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 (26)
TerminalHostAppTests.cs (24)
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); 416await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(10)); 422var stream = await Hmp1Transports.ConnectUnixSocket(args.ConsumerUdsPath, ct); 495await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(10)); 497Assert.True(File.Exists(args.ConsumerUdsPath), "Consumer socket should be bound while the replica waits."); 512File.Exists(args.ConsumerUdsPath), 513$"Consumer socket '{args.ConsumerUdsPath}' should be deleted after graceful shutdown."); 579await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 581args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 611await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 614StreamFactory = ct => Hmp1Transports.ConnectUnixSocket(args.ConsumerUdsPath, ct), 645await using var lateConsumer = await TestHmp1Consumer.ConnectAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 704await WaitForFileAsync(args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 715args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 849args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 887args.ConsumerUdsPath, TimeSpan.FromSeconds(5)); 1295args.ConsumerUdsPath, 1299AssertSocketIsRestrictedToOwningUser(args.ConsumerUdsPath); 1305args.ConsumerUdsPath, TimeSpan.FromSeconds(10)); 1368_ => args.ConsumerUdsPath
TerminalHostArgsTests.cs (2)
18Assert.Equal("/tmp/c.sock", args.ConsumerUdsPath); 50Assert.Equal("/tmp/c.sock", args.ConsumerUdsPath);