Use an extra vertex radial with missing data to prevent stretching

This commit is contained in:
Dan Paulat 2024-10-02 05:56:27 -05:00
parent a548497767
commit fe4a324a04
3 changed files with 89 additions and 8 deletions

View file

@ -106,14 +106,17 @@ public:
threadPool_.join(); threadPool_.join();
}; };
void void ComputeCoordinates(
ComputeCoordinates(std::shared_ptr<wsr88d::rda::ElevationScan> radarData); const std::shared_ptr<wsr88d::rda::ElevationScan>& radarData);
void SetProduct(const std::string& productName); void SetProduct(const std::string& productName);
void SetProduct(common::Level2Product product); void SetProduct(common::Level2Product product);
void UpdateOtherUnits(const std::string& name); void UpdateOtherUnits(const std::string& name);
void UpdateSpeedUnits(const std::string& name); void UpdateSpeedUnits(const std::string& name);
static bool IsRadarDataIncomplete(
const std::shared_ptr<const wsr88d::rda::ElevationScan>& radarData);
Level2ProductView* self_; Level2ProductView* self_;
boost::asio::thread_pool threadPool_ {1u}; boost::asio::thread_pool threadPool_ {1u};
@ -536,7 +539,17 @@ void Level2ProductView::ComputeSweep()
return; return;
} }
const std::size_t radials = radarData->crbegin()->first; const std::size_t radials = radarData->crbegin()->first + 1;
std::size_t vertexRadials = radials;
// When there is missing data, insert another empty vertex radial at the end
// to avoid stretching
const bool isRadarDataIncomplete =
Level2ProductViewImpl::IsRadarDataIncomplete(radarData);
if (isRadarDataIncomplete)
{
++vertexRadials;
}
p->ComputeCoordinates(radarData); p->ComputeCoordinates(radarData);
@ -574,7 +587,8 @@ void Level2ProductView::ComputeSweep()
std::vector<float>& vertices = p->vertices_; std::vector<float>& vertices = p->vertices_;
size_t vIndex = 0; size_t vIndex = 0;
vertices.clear(); vertices.clear();
vertices.resize(radials * gates * VERTICES_PER_BIN * VALUES_PER_VERTEX); vertices.resize(vertexRadials * gates * VERTICES_PER_BIN *
VALUES_PER_VERTEX);
// Setup data moment vector // Setup data moment vector
std::vector<uint8_t>& dataMoments8 = p->dataMoments8_; std::vector<uint8_t>& dataMoments8 = p->dataMoments8_;
@ -807,7 +821,7 @@ void Level2ProductView::ComputeSweep()
} }
void Level2ProductViewImpl::ComputeCoordinates( void Level2ProductViewImpl::ComputeCoordinates(
std::shared_ptr<wsr88d::rda::ElevationScan> radarData) const std::shared_ptr<wsr88d::rda::ElevationScan>& radarData)
{ {
logger_->debug("ComputeCoordinates()"); logger_->debug("ComputeCoordinates()");
@ -828,12 +842,22 @@ void Level2ProductViewImpl::ComputeCoordinates(
auto& radarData0 = (*radarData)[0]; auto& radarData0 = (*radarData)[0];
auto momentData0 = radarData0->moment_data_block(dataBlockType_); auto momentData0 = radarData0->moment_data_block(dataBlockType_);
const std::uint16_t numRadials = std::uint16_t numRadials =
static_cast<std::uint16_t>(radarData->crbegin()->first + 1); static_cast<std::uint16_t>(radarData->crbegin()->first + 1);
const std::uint16_t numRangeBins = const std::uint16_t numRangeBins =
std::max(momentData0->number_of_data_moment_gates() + 1u, std::max(momentData0->number_of_data_moment_gates() + 1u,
common::MAX_DATA_MOMENT_GATES); common::MAX_DATA_MOMENT_GATES);
// Add an extra radial when incomplete data exists
if (IsRadarDataIncomplete(radarData))
{
++numRadials;
}
// Limit radials
numRadials =
std::min<std::uint16_t>(numRadials, common::MAX_0_5_DEGREE_RADIALS);
auto radials = boost::irange<std::uint32_t>(0u, numRadials); auto radials = boost::irange<std::uint32_t>(0u, numRadials);
auto gates = boost::irange<std::uint32_t>(0u, numRangeBins); auto gates = boost::irange<std::uint32_t>(0u, numRangeBins);
@ -878,8 +902,7 @@ void Level2ProductViewImpl::ComputeCoordinates(
// Assume a half degree delta if there aren't enough angles // Assume a half degree delta if there aren't enough angles
// to determine a delta angle // to determine a delta angle
constexpr units::degrees<float> deltaAngle = constexpr units::degrees<float> deltaAngle {0.5f};
units::degrees<float> {0.5};
angle = prevAngle1 + deltaAngle; angle = prevAngle1 + deltaAngle;
} }
@ -918,6 +941,23 @@ void Level2ProductViewImpl::ComputeCoordinates(
logger_->debug("Coordinates calculated in {}", timer.format(6, "%ws")); logger_->debug("Coordinates calculated in {}", timer.format(6, "%ws"));
} }
bool Level2ProductViewImpl::IsRadarDataIncomplete(
const std::shared_ptr<const wsr88d::rda::ElevationScan>& radarData)
{
// Assume the data is incomplete when the delta between the first and last
// angles is greater than 2.5 degrees.
constexpr units::degrees<float> kIncompleteDataAngleThreshold_ {2.5};
const units::degrees<float> firstAngle =
radarData->cbegin()->second->azimuth_angle();
const units::degrees<float> lastAngle =
radarData->crbegin()->second->azimuth_angle();
const units::degrees<float> angleDelta =
common::GetAngleDelta(firstAngle, lastAngle);
return angleDelta > kIncompleteDataAngleThreshold_;
}
std::optional<std::uint16_t> std::optional<std::uint16_t>
Level2ProductView::GetBinLevel(const common::Coordinate& coordinate) const Level2ProductView::GetBinLevel(const common::Coordinate& coordinate) const
{ {

View file

@ -3,6 +3,8 @@
#include <string> #include <string>
#include <vector> #include <vector>
#include <units/angle.h>
namespace scwx namespace scwx
{ {
namespace common namespace common
@ -46,6 +48,17 @@ enum class DistanceType
Miles Miles
}; };
/**
* Calculate the absolute angle delta between two angles.
*
* @param [in] angle1 First angle
* @param [in] angle2 Second angle
*
* @return Absolute angle delta normalized to [0, 360)
*/
units::degrees<float> GetAngleDelta(units::degrees<float> angle1,
units::degrees<float> angle2);
/** /**
* Calculate the geographic midpoint of a set of coordinates. Uses Method A * Calculate the geographic midpoint of a set of coordinates. Uses Method A
* described at http://www.geomidpoint.com/calculation.html. * described at http://www.geomidpoint.com/calculation.html.

View file

@ -14,6 +14,34 @@ static std::string GetDegreeString(double degrees,
DegreeStringType type, DegreeStringType type,
const std::string& suffix); const std::string& suffix);
units::degrees<float> GetAngleDelta(units::degrees<float> angle1,
units::degrees<float> angle2)
{
// Normalize angles to [0, 360)
while (angle1.value() < 0.0f)
{
angle1 += units::degrees<float> {360.0f};
}
while (angle2.value() < 0.0f)
{
angle2 += units::degrees<float> {360.0f};
}
angle1 = units::degrees<float> {std::fmod(angle1.value(), 360.f)};
angle2 = units::degrees<float> {std::fmod(angle2.value(), 360.f)};
// Calculate the absolute difference
auto delta = angle1 - angle2;
if (delta < units::degrees<float> {0.0f})
{
delta *= -1.0f;
}
// Account for wrapping
delta = std::min(delta, units::degrees<float> {360.0f} - delta);
return delta;
}
Coordinate GetCentroid(const std::vector<Coordinate>& coordinates) Coordinate GetCentroid(const std::vector<Coordinate>& coordinates)
{ {
double x = 0.0; double x = 0.0;