1 write to ConsumerUdsPath
Aspire.TerminalHost (1)
TerminalHostArgs.cs (1)
131
ConsumerUdsPath
= parseResult.GetValue(consumerOption)!,
18 references to ConsumerUdsPath
Aspire.TerminalHost (3)
TerminalHostApp.cs (3)
68
ConsumerUdsPath = _args.
ConsumerUdsPath
,
104
_args.Columns, _args.Rows, _args.ProducerUdsPath, _args.
ConsumerUdsPath
);
116
_args.
ConsumerUdsPath
,
Aspire.TerminalHost.Tests (15)
TerminalHostAppTests.cs (13)
91
Assert.Equal(args.
ConsumerUdsPath
, session.ConsumerUdsPath);
222
Assert.Equal(args.
ConsumerUdsPath
, snap.ConsumerUdsPath);
261
File.WriteAllBytes(args.
ConsumerUdsPath
, []);
263
Assert.True(File.Exists(args.
ConsumerUdsPath
));
365
Assert.Equal(args.
ConsumerUdsPath
, afterCycle2.ConsumerUdsPath);
404
await WaitForFileAsync(args.
ConsumerUdsPath
, TimeSpan.FromSeconds(10));
406
Assert.True(File.Exists(args.
ConsumerUdsPath
), "Consumer socket should be bound while the replica waits.");
421
File.Exists(args.
ConsumerUdsPath
),
422
$"Consumer socket '{args.
ConsumerUdsPath
}' should be deleted after graceful shutdown.");
493
await WaitForFileAsync(args.
ConsumerUdsPath
, TimeSpan.FromSeconds(5));
504
args.
ConsumerUdsPath
, TimeSpan.FromSeconds(5));
874
await WaitForFileAsync(args.
ConsumerUdsPath
, TimeSpan.FromSeconds(10));
881
args.
ConsumerUdsPath
,
TerminalHostArgsTests.cs (2)
18
Assert.Equal("/tmp/c.sock", args.
ConsumerUdsPath
);
50
Assert.Equal("/tmp/c.sock", args.
ConsumerUdsPath
);