#include <queued_action_server.h>
Public Types | |
using | ExecuteCallback = boost::function< void(GoalConstPtr const &)> |
using | GoalHandle = typename actionlib::ActionServer< ActionSpec >::GoalHandle |
Public Member Functions | |
bool | isPreemptRequested () |
void | publishFeedback (FeedbackConstPtr const &feedback) |
void | publishFeedback (Feedback const &feedback) |
QueuedActionServer (ros::NodeHandle nodeHandle, std::string const &name, ExecuteCallback callback, bool autoStart=false) | |
void | setAborted (Result const &result=Result(), std::string const &text="") |
void | setPreempted (Result const &result=Result(), std::string const &text="") |
void | setSucceeded (Result const &result=Result(), std::string const &text="") |
void | shutdown () |
void | start () |
~QueuedActionServer () | |
Private Member Functions | |
void | loop () |
void | onCancelReceived (GoalHandle goal) |
void | onGoalReceived (GoalHandle goal) |
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 |
ros::NodeHandle | nodeHandle |
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 24 of file queued_action_server.h.
using QueuedActionServer< ActionSpec >::ExecuteCallback = boost::function<void(GoalConstPtr const&)> |
Definition at line 30 of file queued_action_server.h.
using QueuedActionServer< ActionSpec >::GoalHandle = typename actionlib::ActionServer<ActionSpec>::GoalHandle |
Definition at line 28 of file queued_action_server.h.
|
inline |
Definition at line 33 of file queued_action_server.h.
|
inline |
Definition at line 47 of file queued_action_server.h.
|
inline |
Definition at line 67 of file queued_action_server.h.
|
inlineprivate |
Definition at line 136 of file queued_action_server.h.
|
inlineprivate |
Definition at line 116 of file queued_action_server.h.
|
inlineprivate |
Definition at line 107 of file queued_action_server.h.
|
inline |
Definition at line 96 of file queued_action_server.h.
|
inline |
Definition at line 101 of file queued_action_server.h.
|
inline |
Definition at line 80 of file queued_action_server.h.
|
inline |
Definition at line 88 of file queued_action_server.h.
|
inline |
Definition at line 72 of file queued_action_server.h.
|
inline |
Definition at line 58 of file queued_action_server.h.
|
inline |
Definition at line 52 of file queued_action_server.h.
|
private |
Definition at line 189 of file queued_action_server.h.
|
private |
Definition at line 196 of file queued_action_server.h.
|
private |
Definition at line 198 of file queued_action_server.h.
|
private |
Definition at line 199 of file queued_action_server.h.
|
private |
Definition at line 194 of file queued_action_server.h.
|
private |
Definition at line 191 of file queued_action_server.h.
|
private |
Definition at line 193 of file queued_action_server.h.
|
private |
Definition at line 188 of file queued_action_server.h.
|
private |
Definition at line 202 of file queued_action_server.h.
|
private |
Definition at line 204 of file queued_action_server.h.