DUNE: Uniform Navigational Environment
2019.02.0
|
Public Member Functions | |
Task (const std::string &name, Tasks::Context &ctx) | |
void | onUpdateParameters (void) |
void | onResourceAcquisition (void) |
void | onResourceInitialization (void) |
void | onResourceRelease (void) |
void | consume (const IMC::IoEvent *msg) |
void | sendSmsStatus (const SmsRequest *sms_req, IMC::SmsStatus::StatusEnum status, const std::string &info="") |
void | consume (const IMC::Sms *msg) |
void | consume (const IMC::SmsRequest *msg) |
void | processQueue (void) |
void | pollStatus (void) |
void | onMain (void) |
std::string | getMessage (Status::Code code) |
Public Member Functions inherited from DUNE::Tasks::Task | |
Task (const std::string &name, Context &context) | |
virtual | ~Task (void) |
const char * | getName (void) const |
const char * | getSystemName (void) const |
unsigned int | getSystemId (void) const |
unsigned int | getEntityId (void) const |
unsigned int | resolveEntity (const std::string &label) const |
std::string | resolveEntity (unsigned int id) const |
DebugLevel | getDebugLevel (void) const |
uint16_t | getActivationTime (void) const |
uint16_t | getDeactivationTime (void) const |
unsigned int | resolveSystemName (const std::string &name) const |
const char * | resolveSystemId (unsigned int id) const |
void | loadConfig (void) |
void | setPriority (unsigned int value) |
unsigned int | getPriority (void) const |
void | inf (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void | war (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void | err (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void void | cri (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void void void | debug (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void void void void | trace (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void void void void void | spew (const char *format,...) DUNE_PRINTF_FORMAT(2 |
void void void void void void void void | dispatch (IMC::Message *msg, unsigned int flags=0) |
void | dispatch (IMC::Message &msg, unsigned int flags=0) |
void | dispatchReply (const IMC::Message &original, IMC::Message &msg, unsigned int flags=0) |
void | receive (const IMC::Message *msg) |
void | reserveEntities (void) |
void | resolveEntities (void) |
void | acquireResources (void) |
void | releaseResources (void) |
void | initializeResources (void) |
void | updateParameters (bool act_deact=true) |
void | writeParamsXML (std::ostream &os) const |
const char * | getEntityLabel (void) const |
void | setEntityLabel (const std::string &label) |
Public Member Functions inherited from DUNE::Tasks::AbstractTask | |
AbstractTask (void) | |
virtual | ~AbstractTask (void) |
Public Member Functions inherited from DUNE::Concurrency::Thread | |
Thread (void) | |
virtual | ~Thread (void) |
int | getProcessorUsage (void) |
Public Member Functions inherited from DUNE::Concurrency::Runnable | |
Runnable (void) | |
virtual | ~Runnable (void) |
void | start (void) |
void | stop (void) |
void | join (void) |
void | stopAndJoin (void) |
void | setPriority (Scheduler::Policy policy, unsigned priority) |
unsigned | getPriority (void) |
State | getState (void) |
bool | isCreated (void) |
bool | isStopping (void) |
bool | isRunning (void) |
bool | isStarting (void) |
bool | isDead (void) |
Public Attributes | |
SerialPort * | m_uart |
Driver * | m_driver |
std::priority_queue< SmsRequest > | m_queue |
Counter< double > | m_rssi_timer |
Counter< double > | m_rsms_timer |
unsigned | m_req_id |
Arguments | m_args |
std::string | m_balance |
Time::Counter< int > | m_balance_timer |
int | m_balance_per |
bool | m_success_balance |
int | m_rssi |
Additional Inherited Members | |
Public Types inherited from DUNE::Concurrency::Runnable | |
enum | State { StateStarting, StateRunning, StateStopping, StateDead, StateUnknown } |
Protected Member Functions inherited from DUNE::Tasks::Task | |
void | setEntityState (IMC::EntityState::StateEnum state, Status::Code code) |
void | setEntityState (IMC::EntityState::StateEnum state, const std::string &description) |
IMC::EntityState::StateEnum | getEntityState (void) const |
unsigned int | reserveEntity (const std::string &label) |
template<typename E > | |
E * | reserveEntity (const std::string &label) |
Entities::BasicEntity * | getLocalEntity (const std::string &label) |
bool | stopping (void) |
bool | isActive (void) const |
bool | isActivating (void) const |
bool | isDeactivating (void) const |
void | waitForMessages (double timeout) |
void | consumeMessages (void) |
template<typename T > | |
Parameter & | param (const std::string &name, T &var) |
template<typename Y , typename T > | |
Parameter & | param (const std::string &name, T &var) |
template<typename T > | |
bool | paramChanged (T &var) |
void | paramActive (Parameter::Scope def_scope, Parameter::Visibility def_visibility, bool def_value=false) |
void | setParamSectionEditor (const std::string &name) |
template<typename M , typename T > | |
void | bind (T *task_obj, void(T::*consumer)(const M *)=&T::consume) |
template<typename T > | |
void | bind (T *task_obj, const std::vector< uint32_t > &list) |
template<typename T , typename M > | |
void | bind (T *task_obj, const std::vector< uint32_t > &list, void(T::*consumer)(const M *)=&T::consume) |
template<typename T > | |
void | bind (T *task_obj, const std::vector< std::string > &list) |
void | requestActivation (void) |
void | requestDeactivation (void) |
void | activate (void) |
void | activationFailed (const std::string &reason) |
void | deactivate (void) |
void | deactivationFailed (const std::string &reason) |
virtual bool | onWriteParamsXML (std::ostream &os) const |
virtual void | onEntityReservation (void) |
virtual void | onEntityResolution (void) |
virtual void | onReportEntityState (void) |
virtual void | onRequestActivation (void) |
virtual void | onRequestDeactivation (void) |
virtual void | onActivation (void) |
virtual void | onDeactivation (void) |
virtual void | onQueryEntityParameters (const IMC::QueryEntityParameters *msg) |
virtual void | onSetEntityParameters (const IMC::SetEntityParameters *msg) |
virtual void | onPushEntityParameters (const IMC::PushEntityParameters *msg) |
virtual void | onPopEntityParameters (const IMC::PopEntityParameters *msg) |
Protected Member Functions inherited from DUNE::Concurrency::Thread | |
void | startImpl (void) |
void | stopImpl (void) |
void | joinImpl (void) |
void | setPriorityImpl (Scheduler::Policy policy, unsigned priority) |
unsigned | getPriorityImpl (void) |
Protected Attributes inherited from DUNE::Tasks::Task | |
Context & | m_ctx |
std::vector < Entities::BasicEntity * > | m_entities |
|
inline |
References Transports::GSM::Arguments::balance_per, DUNE::Tasks::Parameter::defaultValue(), m_args, DUNE::Tasks::Task::param(), Transports::GSM::Arguments::pin, Transports::GSM::Arguments::reply_tout, Transports::GSM::Arguments::request_balance, Transports::GSM::Arguments::rsms_per, Transports::GSM::Arguments::rssi_per, Transports::GSM::Arguments::sms_tout, Transports::GSM::Arguments::uart_baud, Transports::GSM::Arguments::uart_dev, and Transports::GSM::Arguments::ussd_code.
|
inline |
References DUNE::Tasks::Task::getEntityId(), and DUNE::Tasks::Task::getSystemId().
|
inline |
References DUNE::Tasks::Task::dispatch(), and m_req_id.
|
inline |
|
inline |
References m_balance.
Referenced by onMain(), onResourceInitialization(), and processQueue().
|
inlinevirtual |
Implements DUNE::Tasks::Task.
References Transports::GSM::Driver::getBalance(), getMessage(), m_args, m_balance, m_balance_timer, m_driver, m_rssi, m_success_balance, pollStatus(), processQueue(), Transports::GSM::Arguments::request_balance, DUNE::Tasks::Task::setEntityState(), DUNE::Tasks::Task::stopping(), Transports::GSM::Arguments::ussd_code, and DUNE::Tasks::Task::waitForMessages().
|
inlinevirtual |
Called when the task is instructed to acquire resources whose configuration is defined by run-time parameters.
Reimplemented from DUNE::Tasks::Task.
References DUNE::Tasks::Task::debug(), DUNE::Tasks::Task::inf(), m_args, m_driver, m_uart, Transports::GSM::Arguments::pin, Transports::GSM::Arguments::uart_baud, and Transports::GSM::Arguments::uart_dev.
|
inlinevirtual |
Called when the task is instructed to initialize resources acquired previously or whose initialization depends on run-time parameters.
Reimplemented from DUNE::Tasks::Task.
References Transports::GSM::Driver::getBalance(), getMessage(), m_args, m_balance, m_balance_timer, m_driver, m_success_balance, Transports::GSM::Arguments::request_balance, DUNE::Tasks::Task::setEntityState(), and Transports::GSM::Arguments::ussd_code.
|
inlinevirtual |
Called when the task is instructed to release resources.
Derived classes that override this function must not assume that any resource was previously acquired. This function must be implemented in such a way that it can be called at any time.
Reimplemented from DUNE::Tasks::Task.
|
inlinevirtual |
Called when the task is instructed to update its run-time parameters.
Derived classes that need to compute auxiliary values based on run-time parameters should override this function.
Reimplemented from DUNE::Tasks::Task.
References Transports::GSM::Arguments::balance_per, m_args, m_balance_timer, m_rsms_timer, m_rssi_timer, DUNE::Tasks::Task::paramChanged(), Transports::GSM::Arguments::rsms_per, Transports::GSM::Arguments::rssi_per, and DUNE::Time::Counter< T >::setTop().
|
inline |
References Transports::GSM::Driver::checkMessages(), m_driver, m_rsms_timer, m_rssi, m_rssi_timer, DUNE::Time::Counter< T >::overflow(), and DUNE::Time::Counter< T >::reset().
Referenced by onMain().
|
inline |
References Transports::GSM::SmsRequest::deadline, Transports::GSM::SmsRequest::destination, getMessage(), DUNE::Tasks::Task::inf(), m_args, m_driver, m_queue, Transports::GSM::Driver::sendSMS(), sendSmsStatus(), DUNE::Tasks::Task::setEntityState(), Transports::GSM::SmsRequest::sms_text, Transports::GSM::Arguments::sms_tout, and DUNE::Tasks::Task::war().
Referenced by onMain().
|
inline |
References DUNE::Tasks::Task::dispatch(), Transports::GSM::SmsRequest::req_id, Transports::GSM::SmsRequest::src_adr, and Transports::GSM::SmsRequest::src_eid.
Referenced by consume(), and processQueue().
Arguments Transports::GSM::Task::m_args |
Task arguments.
Referenced by onMain(), onResourceAcquisition(), onResourceInitialization(), onUpdateParameters(), processQueue(), and Task().
std::string Transports::GSM::Task::m_balance |
Balance of card.
Referenced by getMessage(), onMain(), and onResourceInitialization().
int Transports::GSM::Task::m_balance_per |
Balance periodicity (s).
Time::Counter<int> Transports::GSM::Task::m_balance_timer |
Balance timer count.
Referenced by onMain(), onResourceInitialization(), and onUpdateParameters().
Driver* Transports::GSM::Task::m_driver |
GSM driver.
Referenced by onMain(), onResourceAcquisition(), onResourceInitialization(), onResourceRelease(), pollStatus(), and processQueue().
std::priority_queue<SmsRequest> Transports::GSM::Task::m_queue |
SMS queue.
Referenced by consume(), and processQueue().
Counter<double> Transports::GSM::Task::m_rsms_timer |
SMS reception query timer.
Referenced by onUpdateParameters(), and pollStatus().
int Transports::GSM::Task::m_rssi |
Referenced by onMain(), and pollStatus().
Counter<double> Transports::GSM::Task::m_rssi_timer |
RSSI query timer.
Referenced by onUpdateParameters(), and pollStatus().
bool Transports::GSM::Task::m_success_balance |
Referenced by onMain(), and onResourceInitialization().
SerialPort* Transports::GSM::Task::m_uart |
Serial port handle.
Referenced by onResourceAcquisition(), and onResourceRelease().