|
| InputPortProcessor (const InputPortProcessor &alt) |
|
| InputPortProcessor () |
|
void | onRead (yarp::sig::LaserScan2D &v) override |
|
void | getLast (yarp::sig::LaserScan2D &data, yarp::os::Stamp &stmp) |
|
void | resetStat () |
|
| InputPortProcessor () |
|
void | onRead (yarp::sig::Vector &v) override |
|
int | getLast (yarp::sig::Vector &data, yarp::os::Stamp &stmp) |
|
int | getIterations () |
|
void | getEstFrequency (int &ite, double &av, double &min, double &max) |
|
int | getState () |
|
int | getChannels () |
|
| InputPortProcessor () |
|
void | onRead (yarp::sig::Sound &v) override |
|
bool | getLast (yarp::sig::Sound &data, yarp::os::Stamp &stmp) |
|
| InputPortProcessor (const InputPortProcessor &alt) |
|
| InputPortProcessor () |
|
virtual void | onRead (yarp::rosmsg::sensor_msgs::LaserScan &v) override |
|
void | getLast (yarp::dev::LaserScan2D &data, yarp::os::Stamp &stmp) |
|
| 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::sig::LaserScan2D & | 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::sig::LaserScan2D * | read (bool shouldWait=true) override |
| Read an available object from the port.
|
|
yarp::sig::LaserScan2D * | 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::sig::LaserScan2D &datum) override |
| Callback method.
|
|
void | useCallback (TypedReaderCallback< yarp::sig::LaserScan2D > &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.
|
|
| 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::sig::Vector & | 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::sig::Vector * | read (bool shouldWait=true) override |
| Read an available object from the port.
|
|
yarp::sig::Vector * | 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::sig::Vector &datum) override |
| Callback method.
|
|
void | useCallback (TypedReaderCallback< yarp::sig::Vector > &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.
|
|
| 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::sig::Sound & | 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::sig::Sound * | read (bool shouldWait=true) override |
| Read an available object from the port.
|
|
yarp::sig::Sound * | 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::sig::Sound &datum) override |
| Callback method.
|
|
void | useCallback (TypedReaderCallback< yarp::sig::Sound > &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.
|
|
| Subscriber (const std::string &name="") |
| Constructor.
|
|
virtual | ~Subscriber () |
| Destructor.
|
|
bool | topic (const std::string &name) |
| Set topic to subscribe to.
|
|
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.
|
|
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.
|
|
void | setReader (PortReader &reader) override |
| Set an external reader for port data.
|
|
yarp::rosmsg::sensor_msgs::LaserScan * | read (bool shouldWait=true) |
| Read a message from the port.
|
|
bool | read (PortReader &reader, bool willReply=false) override |
| Read an object from the port.
|
|
Port & | asPort () override |
| Get the concrete Port being used for communication.
|
|
const Port & | asPort () const override |
| Get the concrete Port being used for communication, const version.
|
|
void | onRead (yarp::rosmsg::sensor_msgs::LaserScan &datum) override |
| Callback method.
|
|
void | useCallback (TypedReaderCallback< yarp::rosmsg::sensor_msgs::LaserScan > &callback) |
|
void | useCallback () |
|
void | disableCallback () |
|
void | setStrict (bool strict=true) |
|
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.
|
|
Contact | where () const override |
| Returns information about how this port can be reached.
|
|
std::string | getName () const override |
| Get name of port.
|
|
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.
|
|
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.
|
|
bool | isWriting () override |
| Report whether the port is currently writing data.
|
|
void | setAdminReader (PortReader &reader) override |
| Set an external reader for unrecognized administrative port messages.
|
|
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.
|
|
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.
|
|
Property * | acquireProperties (bool readOnly) override |
| Access unstructured port properties.
|
|
void | releaseProperties (Property *prop) override |
| End access unstructured port properties.
|
|
bool | write (const PortWriter &writer, const PortWriter *callback=nullptr) const override |
| Write an object to the port.
|
|
bool | write (const PortWriter &writer, PortReader &reader, const PortWriter *callback=nullptr) const override |
| Write an object to the port, then expect one back.
|
|
bool | reply (PortWriter &writer) override |
| Send an object as a reply to an object read from the port.
|
|
bool | replyAndDrop (PortWriter &writer) override |
| Same as reply(), but closes connection after reply.
|
|
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=nullptr) 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.
|
|