salfter/fluxengine
1
0
Fork 0
mirror of https://github.com/davidgiven/fluxengine.git synced 2025-10-31 11:17:01 -07:00
Code Issues Packages Projects Releases Wiki Activity

Split the encoder/decoder configuration away from inputs and outputs. Make the

Browse Source 
test pattern creator a flux source.
This commit is contained in:
David Given
2021-05-13 17:23:06 +02:00
parent 3a8ddf8025
commit f9510c54b2
25 changed files with 197 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
lib/fluxsource/fluxsource.cc
View File

@@ -11,27 +11,19 @@ static bool ends_with(const std::string& value, const std::string& ending)
return std::equal(ending.rbegin(), ending.rend(), value.rbegin());
}
std::unique_ptr<FluxSource> FluxSource::create(const FluxSpec& spec)
{
const auto& filename = spec.filename;
if (filename.empty())
return createHardwareFluxSource(spec.drive);
else if (ends_with(filename, ".flux"))
return createSqliteFluxSource(filename);
else if (ends_with(filename, "/"))
return createStreamFluxSource(filename);
Error() << "unrecognised flux filename extension";
return std::unique_ptr<FluxSource>();
}
std::unique_ptr<FluxSource> FluxSource::create(const Config_InputDisk& config)
{
if (config.has_fluxfile())
return createSqliteFluxSource(config.fluxfile());
else
return createHardwareFluxSource(config.drive());
switch (config.source_case())
{
case Config_InputDisk::kFluxfile:
return createSqliteFluxSource(config.fluxfile());
case Config_InputDisk::kDrive:
return createHardwareFluxSource(config.drive());
case Config_InputDisk::kTestPattern:
return createTestPatternFluxSource(config.test_pattern());
}
Error() << "bad input disk configuration";
return std::unique_ptr<FluxSource>();