mirror of
https://gitee.com/mirrors_PX4/PX4-Autopilot.git
synced 2026-07-06 06:40:35 +08:00
Renaming: Timer --> TimerBase, see the next commit
This commit is contained in:
@@ -14,7 +14,7 @@
|
||||
namespace uavcan
|
||||
{
|
||||
|
||||
class Timer;
|
||||
class TimerBase;
|
||||
|
||||
struct TimerEvent
|
||||
{
|
||||
@@ -28,7 +28,7 @@ struct TimerEvent
|
||||
};
|
||||
|
||||
|
||||
class Timer : private DeadlineHandler
|
||||
class TimerBase : private DeadlineHandler
|
||||
{
|
||||
MonotonicDuration period_;
|
||||
|
||||
@@ -40,7 +40,7 @@ public:
|
||||
using DeadlineHandler::getDeadline;
|
||||
using DeadlineHandler::getScheduler;
|
||||
|
||||
explicit Timer(INode& node)
|
||||
explicit TimerBase(INode& node)
|
||||
: DeadlineHandler(node.getScheduler())
|
||||
, period_(MonotonicDuration::getInfinite())
|
||||
{ }
|
||||
@@ -56,7 +56,7 @@ public:
|
||||
|
||||
|
||||
template <typename Callback>
|
||||
class TimerEventForwarder : public Timer
|
||||
class TimerEventForwarder : public TimerBase
|
||||
{
|
||||
Callback callback_;
|
||||
|
||||
@@ -74,12 +74,12 @@ class TimerEventForwarder : public Timer
|
||||
|
||||
public:
|
||||
explicit TimerEventForwarder(INode& node)
|
||||
: Timer(node)
|
||||
: TimerBase(node)
|
||||
, callback_()
|
||||
{ }
|
||||
|
||||
TimerEventForwarder(INode& node, Callback callback)
|
||||
: Timer(node)
|
||||
: TimerBase(node)
|
||||
, callback_(callback)
|
||||
{ }
|
||||
|
||||
|
||||
@@ -12,7 +12,7 @@
|
||||
namespace uavcan
|
||||
{
|
||||
|
||||
class NodeStatusMonitor : protected Timer
|
||||
class NodeStatusMonitor : protected TimerBase
|
||||
{
|
||||
public:
|
||||
typedef typename StorageType<typename protocol::NodeStatus::FieldTypes::status_code>::Type NodeStatusCode;
|
||||
@@ -83,7 +83,7 @@ protected:
|
||||
|
||||
public:
|
||||
explicit NodeStatusMonitor(INode& node)
|
||||
: Timer(node)
|
||||
: TimerBase(node)
|
||||
, sub_(node)
|
||||
{ }
|
||||
|
||||
|
||||
@@ -17,7 +17,7 @@
|
||||
namespace uavcan
|
||||
{
|
||||
|
||||
class NodeStatusProvider : private Timer
|
||||
class NodeStatusProvider : private TimerBase
|
||||
{
|
||||
typedef MethodBinder<NodeStatusProvider*, void (NodeStatusProvider::*)(const protocol::GlobalDiscoveryRequest&)>
|
||||
GlobalDiscoveryRequestCallback;
|
||||
@@ -46,7 +46,7 @@ class NodeStatusProvider : private Timer
|
||||
|
||||
public:
|
||||
NodeStatusProvider(INode& node)
|
||||
: Timer(node)
|
||||
: TimerBase(node)
|
||||
, creation_timestamp_(node.getMonotonicTime())
|
||||
, node_status_pub_(node)
|
||||
, gdr_sub_(node)
|
||||
|
||||
@@ -11,7 +11,7 @@
|
||||
namespace uavcan
|
||||
{
|
||||
|
||||
class PanicBroadcaster : private Timer
|
||||
class PanicBroadcaster : private TimerBase
|
||||
{
|
||||
Publisher<protocol::Panic> pub_;
|
||||
protocol::Panic msg_;
|
||||
@@ -22,7 +22,7 @@ class PanicBroadcaster : private Timer
|
||||
|
||||
public:
|
||||
PanicBroadcaster(INode& node)
|
||||
: Timer(node)
|
||||
: TimerBase(node)
|
||||
, pub_(node)
|
||||
{
|
||||
pub_.setTxTimeout(MonotonicDuration::fromMSec(protocol::Panic::BROADCASTING_INTERVAL_MS - 10));
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
namespace uavcan
|
||||
{
|
||||
|
||||
void Timer::handleDeadline(MonotonicTime current)
|
||||
void TimerBase::handleDeadline(MonotonicTime current)
|
||||
{
|
||||
assert(!isRunning());
|
||||
|
||||
@@ -23,21 +23,21 @@ void Timer::handleDeadline(MonotonicTime current)
|
||||
handleTimerEvent(TimerEvent(scheduled_time, current));
|
||||
}
|
||||
|
||||
void Timer::startOneShotWithDeadline(MonotonicTime deadline)
|
||||
void TimerBase::startOneShotWithDeadline(MonotonicTime deadline)
|
||||
{
|
||||
stop();
|
||||
period_ = MonotonicDuration::getInfinite();
|
||||
DeadlineHandler::startWithDeadline(deadline);
|
||||
}
|
||||
|
||||
void Timer::startOneShotWithDelay(MonotonicDuration delay)
|
||||
void TimerBase::startOneShotWithDelay(MonotonicDuration delay)
|
||||
{
|
||||
stop();
|
||||
period_ = MonotonicDuration::getInfinite();
|
||||
DeadlineHandler::startWithDelay(delay);
|
||||
}
|
||||
|
||||
void Timer::startPeriodic(MonotonicDuration period)
|
||||
void TimerBase::startPeriodic(MonotonicDuration period)
|
||||
{
|
||||
assert(period < MonotonicDuration::getInfinite());
|
||||
stop();
|
||||
|
||||
@@ -83,7 +83,7 @@ int NodeStatusMonitor::start()
|
||||
const int res = sub_.start(NodeStatusCallback(this, &NodeStatusMonitor::handleNodeStatus));
|
||||
if (res >= 0)
|
||||
{
|
||||
Timer::startPeriodic(MonotonicDuration::fromMSec(TimerPeriodMs100 * 100));
|
||||
TimerBase::startPeriodic(MonotonicDuration::fromMSec(TimerPeriodMs100 * 100));
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -85,7 +85,7 @@ int NodeStatusProvider::startAndPublish()
|
||||
goto fail;
|
||||
}
|
||||
|
||||
Timer::startPeriodic(MonotonicDuration::fromMSec(protocol::NodeStatus::PUBLICATION_PERIOD_MS));
|
||||
TimerBase::startPeriodic(MonotonicDuration::fromMSec(protocol::NodeStatus::PUBLICATION_PERIOD_MS));
|
||||
|
||||
return res;
|
||||
|
||||
@@ -93,7 +93,7 @@ fail:
|
||||
assert(res < 0);
|
||||
gdr_sub_.stop();
|
||||
gni_srv_.stop();
|
||||
Timer::stop();
|
||||
TimerBase::stop();
|
||||
return res;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user