blakeridgway/supercell-wx
1
0
Fork 0
mirror of https://github.com/ciphervance/supercell-wx.git synced 2025-10-30 21:10:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Support ARCHIVE2

Browse source
This commit is contained in:
Dan Paulat 2024-01-27 01:18:25 -06:00
parent 243a7c870c
commit 636f444c40
2 changed files with 13 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

16
scwx-qt/source/scwx/qt/manager/radar_product_manager.cpp
View file

@ -231,7 +231,8 @@ public:
LoadNexradFile(CreateNexradFileFunction load,
std::shared_ptr<request::NexradFileRequest> request,
std::mutex& mutex,
std::chrono::system_clock::time_point time = {});
std::chrono::system_clock::time_point time = {},
const std::string& radarId = {});
const std::string radarId_;
bool initialized_;
@ -957,14 +958,15 @@ void RadarProductManagerImpl::LoadNexradFileAsync(
{
boost::asio::post(threadPool_,
[=, &mutex]()
{ LoadNexradFile(load, request, mutex, time); });
{ LoadNexradFile(load, request, mutex, time, radarId_); });
}
void RadarProductManagerImpl::LoadNexradFile(
CreateNexradFileFunction load,
std::shared_ptr<request::NexradFileRequest> request,
std::mutex& mutex,
std::chrono::system_clock::time_point time)
std::chrono::system_clock::time_point time,
const std::string& radarId)
{
std::unique_lock lock {mutex};
@ -987,8 +989,14 @@ void RadarProductManagerImpl::LoadNexradFile(
record->set_time(time);
}
std::string recordRadarId = (record->radar_id());
if (recordRadarId.empty())
{
recordRadarId = radarId;
}
std::shared_ptr<RadarProductManager> manager =
RadarProductManager::Instance(record->radar_id());
RadarProductManager::Instance(recordRadarId);
manager->Initialize();
record = manager->p->StoreRadarProductRecord(record);

6
wxdata/source/scwx/wsr88d/nexrad_file_factory.cpp
View file

@ -114,14 +114,10 @@ std::shared_ptr<NexradFile> NexradFileFactory::Create(std::istream& is)
if (dataValid)
{
if (buffer.starts_with("AR2V"))
if (buffer.starts_with("AR2V") || buffer.starts_with("ARCHIVE2"))
{
message = std::make_shared<Ar2vFile>();
}
else if (buffer.starts_with("ARCHIVE2"))
{
logger_->warn("ARCHIVE2 format not supported");
}
else
{
message = std::make_shared<Level3File>();