#include <queued_action_server.h>
Public Types | |
using | ExecuteCallback = ensenso::std::function< void(GoalConstPtr const &)> |
using | GoalHandle = typename actionlib::ActionServer< ActionSpec >::GoalHandle |
Public Member Functions | |
bool | isPreemptRequested () |
void | publishFeedback (Feedback const &feedback) |
void | publishFeedback (FeedbackConstPtr const &feedback) |
QueuedActionServer (ensenso::ros::NodeHandle &nh, std::string const &name, ExecuteCallback callback, bool autoStart=false) | |
void | setAborted (Result result=Result()) |
void | setPreempted (Result result=Result()) |
void | setSucceeded (Result result=Result()) |
void | start () |
~QueuedActionServer () | |
Private Member Functions | |
std::string | getLoggerName () |
void | loop () |
void | onCancelReceived (GoalHandle goal) |
void | onGoalReceived (GoalHandle goal) |
void | shutdown () |
Private Attributes | |
std::unique_ptr< actionlib::ActionServer< ActionSpec > > | actionServer |
ExecuteCallback | callback |
GoalHandle | currentGoal |
std::queue< GoalHandle > | goalQueue |
std::condition_variable | loopCondition |
std::thread | loopThread |
std::mutex | mutex |
std::string | name |
ensenso::ros::NodeHandle | nh |
bool | preemptRequested = false |
volatile bool | shutdownRequested = false |
An action server that remembers a queue of goals that still have to be processed. This server will never reject or cancel any requests on its own.
The API is the same as for the SimpleActionServer.
Definition at line 26 of file queued_action_server.h.
using QueuedActionServer< ActionSpec >::ExecuteCallback = ensenso::std::function<void(GoalConstPtr const&)> |
Definition at line 32 of file queued_action_server.h.
using QueuedActionServer< ActionSpec >::GoalHandle = typename actionlib::ActionServer<ActionSpec>::GoalHandle |
Definition at line 30 of file queued_action_server.h.
|
inline |
Definition at line 35 of file queued_action_server.h.
|
inline |
Definition at line 49 of file queued_action_server.h.
|
inlineprivate |
Definition at line 109 of file queued_action_server.h.
|
inline |
Definition at line 60 of file queued_action_server.h.
|
inlineprivate |
Definition at line 141 of file queued_action_server.h.
|
inlineprivate |
Definition at line 123 of file queued_action_server.h.
|
inlineprivate |
Definition at line 114 of file queued_action_server.h.
|
inline |
Definition at line 94 of file queued_action_server.h.
|
inline |
Definition at line 89 of file queued_action_server.h.
|
inline |
Definition at line 73 of file queued_action_server.h.
|
inline |
Definition at line 81 of file queued_action_server.h.
|
inline |
Definition at line 65 of file queued_action_server.h.
|
inlineprivate |
Definition at line 100 of file queued_action_server.h.
|
inline |
Definition at line 54 of file queued_action_server.h.
|
private |
Definition at line 193 of file queued_action_server.h.
|
private |
Definition at line 200 of file queued_action_server.h.
|
private |
Definition at line 202 of file queued_action_server.h.
|
private |
Definition at line 203 of file queued_action_server.h.
|
private |
Definition at line 198 of file queued_action_server.h.
|
private |
Definition at line 195 of file queued_action_server.h.
|
private |
Definition at line 197 of file queued_action_server.h.
|
private |
Definition at line 192 of file queued_action_server.h.
|
private |
Definition at line 191 of file queued_action_server.h.
|
private |
Definition at line 206 of file queued_action_server.h.
|
private |
Definition at line 208 of file queued_action_server.h.