1 write to ProducerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
130ProducerUdsPath = parseResult.GetValue(producerOption)!,
32 references to ProducerUdsPath
Aspire.TerminalHost (3)
TerminalHostApp.cs (3)
69ProducerUdsPath = _args.ProducerUdsPath, 106_args.Columns, _args.Rows, _args.ProducerUdsPath, _args.ConsumerUdsPath); 117_args.ProducerUdsPath,
Aspire.TerminalHost.Tests (29)
TerminalHostAppTests.cs (27)
116Assert.Equal(args.ProducerUdsPath, session.ProducerUdsPath); 247Assert.Equal(args.ProducerUdsPath, snap.ProducerUdsPath); 286File.WriteAllBytes(args.ProducerUdsPath, []); 288Assert.True(File.Exists(args.ProducerUdsPath)); 303await using var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(10)); 344await using (var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5))) 368await using (var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(10))) 390Assert.Equal(args.ProducerUdsPath, afterCycle2.ProducerUdsPath); 415await WaitForFileAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(10)); 437await using var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5)); 494await WaitForFileAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(10)); 496Assert.True(File.Exists(args.ProducerUdsPath), "Producer socket should be bound while the replica waits."); 509File.Exists(args.ProducerUdsPath), 510$"Producer socket '{args.ProducerUdsPath}' should be deleted after graceful shutdown."); 563await using var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5)); 609await using var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5)); 694await using var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5)); 840await using (var producer = await ConnectProducerAsync(args.ProducerUdsPath, TimeSpan.FromSeconds(5))) 876args.ProducerUdsPath, TimeSpan.FromSeconds(10)); 1249File.Delete(args.ProducerUdsPath); 1251var acceptTask = TerminalReplica.AcceptProducerAsync(args.ProducerUdsPath, cts.Token); 1257AssertSocketIsRestrictedToOwningUser(args.ProducerUdsPath); 1259await socket.ConnectAsync(new UnixDomainSocketEndPoint(args.ProducerUdsPath), cts.Token); 1336File.Delete(args.ProducerUdsPath); 1338var acceptTask = TerminalReplica.AcceptProducerAsync(args.ProducerUdsPath, cts.Token); 1341AssertSocketIsRestrictedToOwningUser(args.ProducerUdsPath); 1367"producer" => args.ProducerUdsPath,
TerminalHostArgsTests.cs (2)
17Assert.Equal("/tmp/p.sock", args.ProducerUdsPath); 49Assert.Equal("/tmp/p.sock", args.ProducerUdsPath);