1 write to ProducerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
130
ProducerUdsPath
= parseResult.GetValue(producerOption)!,
20 references to ProducerUdsPath
Aspire.TerminalHost (3)
TerminalHostApp.cs (3)
67
ProducerUdsPath = _args.
ProducerUdsPath
,
104
_args.Columns, _args.Rows, _args.
ProducerUdsPath
, _args.ConsumerUdsPath);
115
_args.
ProducerUdsPath
,
Aspire.TerminalHost.Tests (17)
TerminalHostAppTests.cs (15)
90
Assert.Equal(args.
ProducerUdsPath
, session.ProducerUdsPath);
221
Assert.Equal(args.
ProducerUdsPath
, snap.ProducerUdsPath);
260
File.WriteAllBytes(args.
ProducerUdsPath
, []);
262
Assert.True(File.Exists(args.
ProducerUdsPath
));
277
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
318
await using (var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5)))
342
await using (var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10)))
364
Assert.Equal(args.
ProducerUdsPath
, afterCycle2.ProducerUdsPath);
403
await WaitForFileAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
405
Assert.True(File.Exists(args.
ProducerUdsPath
), "Producer socket should be bound while the replica waits.");
418
File.Exists(args.
ProducerUdsPath
),
419
$"Producer socket '{args.
ProducerUdsPath
}' should be deleted after graceful shutdown.");
483
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5));
873
await WaitForFileAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
877
args.
ProducerUdsPath
,
TerminalHostArgsTests.cs (2)
17
Assert.Equal("/tmp/p.sock", args.
ProducerUdsPath
);
49
Assert.Equal("/tmp/p.sock", args.
ProducerUdsPath
);