Fix MP desync caused by incorrect FlowStat::ScaleToMonthly scaling
Fixes: 51a66b95
This commit is contained in:
@@ -53,7 +53,7 @@ void FlowMapper::Run(LinkGraphJob &job) const
|
|||||||
/* Scale by time the graph has been running without being compressed. Add 1 to avoid
|
/* Scale by time the graph has been running without being compressed. Add 1 to avoid
|
||||||
* division by 0 if spawn date == last compression date. This matches
|
* division by 0 if spawn date == last compression date. This matches
|
||||||
* LinkGraph::Monthly(). */
|
* LinkGraph::Monthly(). */
|
||||||
uint runtime = _scaled_date_ticks - job.LastCompression() + 1;
|
uint runtime = ClampTo<uint>(DateTicksToScaledDateTicks(job.StartDateTicks()) - job.LastCompression() + 1);
|
||||||
for (auto &it : flows) {
|
for (auto &it : flows) {
|
||||||
it.ScaleToMonthly(runtime);
|
it.ScaleToMonthly(runtime);
|
||||||
}
|
}
|
||||||
|
@@ -346,7 +346,7 @@ public:
|
|||||||
* Get the date when the underlying link graph was last compressed.
|
* Get the date when the underlying link graph was last compressed.
|
||||||
* @return Compression date.
|
* @return Compression date.
|
||||||
*/
|
*/
|
||||||
inline Date LastCompression() const { return this->link_graph.LastCompression(); }
|
inline DateTicksScaled LastCompression() const { return this->link_graph.LastCompression(); }
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get the ID of the underlying link graph.
|
* Get the ID of the underlying link graph.
|
||||||
|
Reference in New Issue
Block a user