#include <networkWrappers/RemoteControlBoard/stateExtendedReader.h>
Public Member Functions | |
StateExtendedInputPort () | |
void | resetStat () |
void | init (int numberOfJoints) |
void | onRead (yarp::dev::impl::jointData &v) override |
void | setTimeout (const double &timeout) |
setTimeout, set the timeout for retrieving data | |
bool | getLastSingle (int j, int field, double *data, Stamp &stamp, double &localArrivalTime) |
bool | getLastSingle (int j, int field, int *data, Stamp &stamp, double &localArrivalTime) |
bool | getLastVector (int field, double *data, Stamp &stamp, double &localArrivalTime) |
bool | getLastVector (int field, int *data, Stamp &stamp, double &localArrivalTime) |
int | getIterations () |
void | getEstFrequency (int &ite, double &av, double &min, double &max) |
![]() | |
BufferedPort () | |
Constructor. | |
BufferedPort (Port &port) | |
Wrap an existing unbuffered port. | |
virtual | ~BufferedPort () |
Destructor. | |
bool | open (const std::string &name) override |
Start port operation, with a specific name, with automatically-chosen network parameters. | |
bool | open (const Contact &contact, bool registerName=true) override |
Start port operation with user-chosen network parameters. | |
bool | addOutput (const std::string &name) override |
Add an output connection to the specified port. | |
bool | addOutput (const std::string &name, const std::string &carrier) override |
Add an output connection to the specified port, using a specified carrier. | |
bool | addOutput (const Contact &contact) override |
Add an output connection to the specified port, using specified network parameters. | |
void | close () override |
Stop port activity. | |
void | interrupt () override |
Interrupt any current reads or writes attached to the port. | |
void | resume () override |
Put the port back in an operative state after interrupt() has been called. | |
int | getPendingReads () override |
Get the number of objects ready to be read. | |
Contact | where () const override |
Returns information about how this port can be reached. | |
std::string | getName () const override |
Get name of port. | |
yarp::dev::impl::jointData & | prepare () |
Access the object which will be transmitted by the next call to yarp::os::BufferedPort::write. | |
bool | unprepare () |
Give the last prepared object back to YARP without writing it. | |
void | write (bool forceStrict=false) |
Write the current object being returned by BufferedPort::prepare. | |
void | writeStrict () |
Write the current object being returned by BufferedPort::prepare, waiting until any previous sends are complete. | |
void | waitForWrite () |
Wait for any pending writes to complete. | |
void | setStrict (bool strict=true) override |
Call this to strictly keep all messages, or allow old ones to be quietly dropped. | |
yarp::dev::impl::jointData * | read (bool shouldWait=true) override |
Read an available object from the port. | |
yarp::dev::impl::jointData * | lastRead () override |
Get the last data returned by read() | |
bool | isClosed () override |
Returns whether the port associated with this reader has been closed. | |
void | setReplier (PortReader &reader) override |
If a message is received that requires a reply, use this handler. | |
void | setReader (PortReader &reader) override |
Set an external reader for port data. | |
void | setAdminReader (PortReader &reader) override |
Set an external reader for unrecognized administrative port messages. | |
void | onRead (yarp::dev::impl::jointData &datum) override |
Callback method. | |
void | useCallback (TypedReaderCallback< yarp::dev::impl::jointData > &callback) override |
Set an object whose onRead method will be called when data is available. | |
void | useCallback () |
Use own onRead() method as callback. | |
void | disableCallback () override |
Remove a callback set up with useCallback() | |
bool | setEnvelope (PortWriter &envelope) override |
Set an envelope (e.g., a timestamp) to the next message which will be sent. | |
bool | getEnvelope (PortReader &envelope) override |
Get the envelope information (e.g., a timestamp) from the last message received on the port. | |
int | getInputCount () override |
Determine how many connections are arriving into this port. | |
int | getOutputCount () override |
Determine how many output connections this port has. | |
bool | isWriting () override |
Report whether the port is currently writing data. | |
void | getReport (PortReport &reporter) override |
Get information on the state of the port - connections etc. | |
void | setReporter (PortReport &reporter) override |
Set a callback to be called upon any future connections and disconnections to/from the port. | |
void | resetReporter () override |
Remove the callback which is called upon any future connections and disconnections to/from the port. | |
void * | acquire () override |
Take control of the last object read. | |
void | release (void *handle) override |
Return control to YARP of an object previously taken control of with the acquire() method. | |
void | setTargetPeriod (double period) override |
Try to provide data periodically. | |
Type | getType () override |
Get the type of data the port has committed to send/receive. | |
void | promiseType (const Type &typ) override |
Commit the port to a particular type of data. | |
void | setInputMode (bool expectInput) override |
Configure the port to allow or forbid inputs. | |
void | setOutputMode (bool expectOutput) override |
Configure the port to allow or forbid outputs. | |
void | setRpcMode (bool expectRpc) override |
Configure the port to be RPC only. | |
Property * | acquireProperties (bool readOnly) override |
Access unstructured port properties. | |
void | releaseProperties (Property *prop) override |
End access unstructured port properties. | |
void | includeNodeInName (bool flag) override |
Choose whether to prepend a node name (if one is available) to the port's name. | |
bool | setCallbackLock (std::mutex *mutex) override |
Add a lock to use when invoking callbacks. | |
bool | removeCallbackLock () override |
Remove a lock on callbacks added with setCallbackLock() | |
bool | lockCallback () override |
Lock callbacks until unlockCallback() is called. | |
bool | tryLockCallback () override |
Try to lock callbacks until unlockCallback() is called. | |
void | unlockCallback () override |
Unlock callbacks. | |
![]() | |
virtual | ~Contactable () |
Destructor. | |
void | setReadOnly () |
Shorthand for setInputMode(true), setOutputMode(false), setRpcMode(false) | |
void | setWriteOnly () |
Shorthand for setInputMode(false), setOutputMode(true), setRpcMode(false) | |
void | setRpcServer () |
Shorthand for setInputMode(true), setOutputMode(false), setRpcMode(true) | |
void | setRpcClient () |
Shorthand for setInputMode(false), setOutputMode(true), setRpcMode(true) | |
![]() | |
virtual | ~TypedReader ()=default |
Destructor. | |
![]() | |
virtual | ~TypedReaderCallback () |
Destructor. | |
virtual void | onRead (T &datum, const yarp::os::TypedReader< T > &reader) |
Callback method. | |
Additional Inherited Members | |
![]() | |
typedef yarp::dev::impl::jointData | ContentType |
The type of content stored by this BufferedPort. | |
Definition at line 39 of file stateExtendedReader.h.
StateExtendedInputPort::StateExtendedInputPort | ( | ) |
Definition at line 44 of file stateExtendedReader.cpp.
Definition at line 315 of file stateExtendedReader.cpp.
int StateExtendedInputPort::getIterations | ( | ) |
Definition at line 306 of file stateExtendedReader.cpp.
bool StateExtendedInputPort::getLastSingle | ( | int | j, |
int | field, | ||
double * | data, | ||
Stamp & | stamp, | ||
double & | localArrivalTime | ||
) |
Definition at line 104 of file stateExtendedReader.cpp.
bool StateExtendedInputPort::getLastSingle | ( | int | j, |
int | field, | ||
int * | data, | ||
Stamp & | stamp, | ||
double & | localArrivalTime | ||
) |
Definition at line 173 of file stateExtendedReader.cpp.
bool StateExtendedInputPort::getLastVector | ( | int | field, |
double * | data, | ||
Stamp & | stamp, | ||
double & | localArrivalTime | ||
) |
Definition at line 205 of file stateExtendedReader.cpp.
bool StateExtendedInputPort::getLastVector | ( | int | field, |
int * | data, | ||
Stamp & | stamp, | ||
double & | localArrivalTime | ||
) |
Definition at line 274 of file stateExtendedReader.cpp.
Definition at line 55 of file stateExtendedReader.cpp.
|
override |
Definition at line 70 of file stateExtendedReader.cpp.
void StateExtendedInputPort::resetStat | ( | ) |
Definition at line 32 of file stateExtendedReader.cpp.
setTimeout, set the timeout for retrieving data
timeout | in seconds |
Definition at line 100 of file stateExtendedReader.cpp.