Lines Matching refs:deadline
1521 Mutexed<NamedTimePoint>::Locked deadline(mQueueDeadline); in onMessageReceived() local
1522 deadline->set(TimePoint::max(), "none"); in onMessageReceived()
1661 Mutexed<NamedTimePoint>::Locked deadline(mDeadline); in setDeadline() local
1662 deadline->set(now + (timeout * mult), name); in setDeadline()
1669 Mutexed<NamedTimePoint>::Locked deadline(*deadlinePtr); in initiateReleaseIfStuck() local
1670 if (deadline->get() < std::chrono::steady_clock::now()) { in initiateReleaseIfStuck()
1671 name = deadline->getName(); in initiateReleaseIfStuck()
1674 if (deadline->get() != TimePoint::max()) { in initiateReleaseIfStuck()
1698 Mutexed<NamedTimePoint>::Locked deadline(mEosDeadline); in onWorkQueued() local
1699 deadline->set(std::chrono::steady_clock::now() + 3s, "eos"); in onWorkQueued()
1704 Mutexed<NamedTimePoint>::Locked deadline(mQueueDeadline); in onWorkQueued() local
1705 deadline->set(std::chrono::steady_clock::now() + 3s, "queue"); in onWorkQueued()
1713 Mutexed<NamedTimePoint>::Locked deadline(mEosDeadline); in subQueuedWorkCount() local
1714 deadline->set(TimePoint::max(), "none"); in subQueuedWorkCount()
1716 Mutexed<NamedTimePoint>::Locked deadline(mQueueDeadline); in subQueuedWorkCount() local
1717 deadline->set(TimePoint::max(), "none"); in subQueuedWorkCount()