1 write to ProducerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
130
ProducerUdsPath
= parseResult.GetValue(producerOption)!,
30 references to ProducerUdsPath
Aspire.TerminalHost (3)
TerminalHostApp.cs (3)
69
ProducerUdsPath = _args.
ProducerUdsPath
,
106
_args.Columns, _args.Rows, _args.
ProducerUdsPath
, _args.ConsumerUdsPath);
117
_args.
ProducerUdsPath
,
Aspire.TerminalHost.Tests (27)
TerminalHostAppTests.cs (25)
116
Assert.Equal(args.
ProducerUdsPath
, session.ProducerUdsPath);
247
Assert.Equal(args.
ProducerUdsPath
, snap.ProducerUdsPath);
286
File.WriteAllBytes(args.
ProducerUdsPath
, []);
288
Assert.True(File.Exists(args.
ProducerUdsPath
));
303
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
344
await using (var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5)))
368
await using (var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10)))
390
Assert.Equal(args.
ProducerUdsPath
, afterCycle2.ProducerUdsPath);
429
await WaitForFileAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
431
Assert.True(File.Exists(args.
ProducerUdsPath
), "Producer socket should be bound while the replica waits.");
444
File.Exists(args.
ProducerUdsPath
),
445
$"Producer socket '{args.
ProducerUdsPath
}' should be deleted after graceful shutdown.");
498
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5));
544
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5));
629
await using var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5));
775
await using (var producer = await ConnectProducerAsync(args.
ProducerUdsPath
, TimeSpan.FromSeconds(5)))
811
args.
ProducerUdsPath
, TimeSpan.FromSeconds(10));
1184
File.Delete(args.
ProducerUdsPath
);
1186
var acceptTask = TerminalReplica.AcceptProducerAsync(args.
ProducerUdsPath
, cts.Token);
1192
AssertSocketIsRestrictedToOwningUser(args.
ProducerUdsPath
);
1194
await socket.ConnectAsync(new UnixDomainSocketEndPoint(args.
ProducerUdsPath
), cts.Token);
1271
File.Delete(args.
ProducerUdsPath
);
1273
var acceptTask = TerminalReplica.AcceptProducerAsync(args.
ProducerUdsPath
, cts.Token);
1276
AssertSocketIsRestrictedToOwningUser(args.
ProducerUdsPath
);
1302
"producer" => args.
ProducerUdsPath
,
TerminalHostArgsTests.cs (2)
17
Assert.Equal("/tmp/p.sock", args.
ProducerUdsPath
);
49
Assert.Equal("/tmp/p.sock", args.
ProducerUdsPath
);