Job.cpp

#include <xrpl/beast/core/CurrentThreadName.h>
#include <xrpl/core/Job.h>
 
namespace xrpl {
 
Job::Job() : mType(jtINVALID), mJobIndex(0)
{
}
 
Job::Job(JobType type, std::uint64_t index) : mType(type), mJobIndex(index)
{
}
 
Job::Job(
    JobType type,
    std::string const& name,
    std::uint64_t index,
    LoadMonitor& lm,
    std::function<void()> const& job)
    : mType(type)
    , mJobIndex(index)
    , mJob(job)
    , mName(name)
    , m_queue_time(clock_type::now())
{
    m_loadEvent = std::make_shared<LoadEvent>(std::ref(lm), name, false);
}
 
JobType
Job::getType() const
{
    return mType;
}
 
Job::clock_type::time_point const&
Job::queue_time() const
{
    return m_queue_time;
}
 
void
Job::doJob()
{
    beast::setCurrentThreadName("doJob: " + mName);
    m_loadEvent->start();
    m_loadEvent->setName(mName);
 
    mJob();
 
    // Destroy the lambda, otherwise we won't include
    // its duration in the time measurement
    mJob = nullptr;
}
 
bool
Job::operator>(Job const& j) const
{
    if (mType < j.mType)
        return true;
 
    if (mType > j.mType)
        return false;
 
    return mJobIndex > j.mJobIndex;
}
 
bool
Job::operator>=(Job const& j) const
{
    if (mType < j.mType)
        return true;
 
    if (mType > j.mType)
        return false;
 
    return mJobIndex >= j.mJobIndex;
}
 
bool
Job::operator<(Job const& j) const
{
    if (mType < j.mType)
        return false;
 
    if (mType > j.mType)
        return true;
 
    return mJobIndex < j.mJobIndex;
}
 
bool
Job::operator<=(Job const& j) const
{
    if (mType < j.mType)
        return false;
 
    if (mType > j.mType)
        return true;
 
    return mJobIndex <= j.mJobIndex;
}
 
}  // namespace xrpl