martinzink commented on code in PR #1581:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1581#discussion_r1211802167
##########
libminifi/src/core/Processor.cpp:
##########
@@ -372,26 +372,26 @@ void Processor::setMaxConcurrentTasks(const uint8_t
tasks) {
}
void Processor::yield() {
- yield_expiration_ = std::chrono::system_clock::now() +
yield_period_msec_.load();
+ yield_expiration_ = std::chrono::steady_clock::now() +
yield_period_msec_.load();
}
void Processor::yield(std::chrono::milliseconds delta_time) {
- yield_expiration_ = std::chrono::system_clock::now() + delta_time;
+ yield_expiration_ = std::chrono::steady_clock::now() + delta_time;
}
bool Processor::isYield() {
- return yield_expiration_.load() >= std::chrono::system_clock::now();
+ return getYieldTime() > 0ms;
}
void Processor::clearYield() {
- yield_expiration_ = std::chrono::system_clock::time_point();
+ yield_expiration_ = std::chrono::steady_clock::time_point();
}
std::chrono::milliseconds Processor::getYieldTime() const {
auto yield_expiration = yield_expiration_.load();
- auto current_time = std::chrono::system_clock::now();
+ auto current_time = std::chrono::steady_clock::now();
Review Comment:
afaik we dont serialize these anywhere
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
