Public Member Functions | |
void | addListener (NodeListener listener) |
DefaultNode (NodeConfiguration nodeConfiguration, Collection< NodeListener > nodeListeners, ScheduledExecutorService scheduledExecutorService) | |
void | executeCancellableLoop (final CancellableLoop cancellableLoop) |
Time | getCurrentTime () |
Log | getLog () |
URI | getMasterUri () |
MessageSerializationFactory | getMessageSerializationFactory () |
GraphName | getName () |
ParameterTree | getParameterTree () |
NodeNameResolver | getResolver () |
ScheduledExecutorService | getScheduledExecutorService () |
MessageFactory | getServiceRequestMessageFactory () |
MessageFactory | getServiceResponseMessageFactory () |
MessageFactory | getTopicMessageFactory () |
URI | getUri () |
URI | lookupServiceUri (GraphName serviceName) |
URI | lookupServiceUri (String serviceName) |
GraphName | resolveName (GraphName name) |
GraphName | resolveName (String name) |
void | shutdown () |
Package Functions | |
InetSocketAddress | getAddress () |
Registrar | getRegistrar () |
public< T, S > ServiceServer < T, S > | getServiceServer (GraphName serviceName) |
public< T, S > ServiceServer < T, S > | getServiceServer (String serviceName) |
private< T > MessageDeserializer< T > | newMessageDeserializer (String messageType) |
private< T > org.ros.message.MessageSerializer < T > | newMessageSerializer (String messageType) |
public< T > Publisher< T > | newPublisher (GraphName topicName, String messageType) |
public< T > Publisher< T > | newPublisher (String topicName, String messageType) |
public< T, S > ServiceClient < T, S > | newServiceClient (GraphName serviceName, String serviceType) throws ServiceNotFoundException |
public< T, S > ServiceClient < T, S > | newServiceClient (String serviceName, String serviceType) throws ServiceNotFoundException |
private< T > MessageDeserializer< T > | newServiceRequestDeserializer (String serviceType) |
private< T > MessageSerializer< T > | newServiceRequestSerializer (String serviceType) |
private< T > MessageDeserializer< T > | newServiceResponseDeserializer (String serviceType) |
private< T > MessageSerializer< T > | newServiceResponseSerializer (String serviceType) |
public< T, S > ServiceServer < T, S > | newServiceServer (GraphName serviceName, String serviceType, ServiceResponseBuilder< T, S > responseBuilder) |
public< T, S > ServiceServer < T, S > | newServiceServer (String serviceName, String serviceType, ServiceResponseBuilder< T, S > responseBuilder) |
public< T > Subscriber< T > | newSubscriber (GraphName topicName, String messageType) |
public< T > Subscriber< T > | newSubscriber (String topicName, String messageType) |
Private Member Functions | |
void | signalOnError (final Throwable throwable) |
void | signalOnShutdown () |
void | signalOnShutdownComplete () |
void | signalOnStart () |
void | start () |
Private Attributes | |
RosoutLogger | log |
final MasterClient | masterClient |
final URI | masterUri |
final NodeConfiguration | nodeConfiguration |
final ListenerGroup< NodeListener > | nodeListeners |
final GraphName | nodeName |
final ParameterManager | parameterManager |
final ParameterTree | parameterTree |
final PublisherFactory | publisherFactory |
final Registrar | registrar |
final NodeNameResolver | resolver |
final ScheduledExecutorService | scheduledExecutorService |
final ServiceFactory | serviceFactory |
final ServiceManager | serviceManager |
final SlaveServer | slaveServer |
final SubscriberFactory | subscriberFactory |
TimeProvider | timeProvider |
final TopicParticipantManager | topicParticipantManager |
Static Private Attributes | |
static final boolean | DEBUG = false |
static final int | MAX_SHUTDOWN_DELAY_DURATION = 5 |
static final TimeUnit | MAX_SHUTDOWN_DELAY_UNITS = TimeUnit.SECONDS |
The default implementation of a Node.
Definition at line 85 of file DefaultNode.java.
org.ros.internal.node.DefaultNode.DefaultNode | ( | NodeConfiguration | nodeConfiguration, |
Collection< NodeListener > | nodeListeners, | ||
ScheduledExecutorService | scheduledExecutorService | ||
) | [inline] |
DefaultNodes should only be constructed using the DefaultNodeFactory.
nodeConfiguration | the NodeConfiguration for this Node |
nodeListeners | a Collection of NodeListeners that will be added to this Node before it starts |
Definition at line 128 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.addListener | ( | NodeListener | listener | ) | [inline] |
Add a new NodeListener to the Node.
listener | the NodeListener to add |
Implements org.ros.node.Node.
Definition at line 476 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.executeCancellableLoop | ( | final CancellableLoop | cancellableLoop | ) | [inline] |
Definition at line 564 of file DefaultNode.java.
InetSocketAddress org.ros.internal.node.DefaultNode.getAddress | ( | ) | [inline, package] |
Definition at line 554 of file DefaultNode.java.
Time org.ros.internal.node.DefaultNode.getCurrentTime | ( | ) | [inline] |
In ROS, time can be wallclock (actual) or simulated, so it is important to use ConnectedNode#getCurrentTime() instead of using the standard Java routines for determining the current time.
Implements org.ros.node.ConnectedNode.
Definition at line 376 of file DefaultNode.java.
Log org.ros.internal.node.DefaultNode.getLog | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 386 of file DefaultNode.java.
URI org.ros.internal.node.DefaultNode.getMasterUri | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 436 of file DefaultNode.java.
MessageSerializationFactory org.ros.internal.node.DefaultNode.getMessageSerializationFactory | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 456 of file DefaultNode.java.
GraphName org.ros.internal.node.DefaultNode.getName | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 381 of file DefaultNode.java.
Create a ParameterTree to query and set parameters on the ROS parameter server.
Implements org.ros.node.ConnectedNode.
Definition at line 446 of file DefaultNode.java.
Registrar org.ros.internal.node.DefaultNode.getRegistrar | ( | ) | [inline, package] |
Definition at line 229 of file DefaultNode.java.
Implements org.ros.node.Node.
Definition at line 441 of file DefaultNode.java.
ScheduledExecutorService org.ros.internal.node.DefaultNode.getScheduledExecutorService | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 559 of file DefaultNode.java.
Implements org.ros.node.Node.
Definition at line 466 of file DefaultNode.java.
Implements org.ros.node.Node.
Definition at line 471 of file DefaultNode.java.
public<T, S> ServiceServer<T, S> org.ros.internal.node.DefaultNode.getServiceServer | ( | GraphName | serviceName | ) | [inline, package] |
serviceName | the GraphName of the ServiceServer |
null
Implements org.ros.node.ConnectedNode.
Definition at line 324 of file DefaultNode.java.
public<T, S> ServiceServer<T, S> org.ros.internal.node.DefaultNode.getServiceServer | ( | String | serviceName | ) | [inline, package] |
Implements org.ros.node.ConnectedNode.
Definition at line 329 of file DefaultNode.java.
Implements org.ros.node.Node.
Definition at line 461 of file DefaultNode.java.
URI org.ros.internal.node.DefaultNode.getUri | ( | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 451 of file DefaultNode.java.
URI org.ros.internal.node.DefaultNode.lookupServiceUri | ( | GraphName | serviceName | ) | [inline] |
null
Implements org.ros.node.ConnectedNode.
Definition at line 334 of file DefaultNode.java.
URI org.ros.internal.node.DefaultNode.lookupServiceUri | ( | String | serviceName | ) | [inline] |
Implements org.ros.node.ConnectedNode.
Definition at line 346 of file DefaultNode.java.
private<T> MessageDeserializer<T> org.ros.internal.node.DefaultNode.newMessageDeserializer | ( | String | messageType | ) | [inline, package] |
Definition at line 238 of file DefaultNode.java.
private<T> org.ros.message.MessageSerializer<T> org.ros.internal.node.DefaultNode.newMessageSerializer | ( | String | messageType | ) | [inline, package] |
Definition at line 233 of file DefaultNode.java.
public<T> Publisher<T> org.ros.internal.node.DefaultNode.newPublisher | ( | GraphName | topicName, |
String | messageType | ||
) | [inline, package] |
<T> | the message type to create the publisher for |
topicName | the topic name, will be pushed down under this namespace unless '/' is prepended. |
messageType | the message data type (e.g. "std_msgs/String") |
Implements org.ros.node.ConnectedNode.
Definition at line 268 of file DefaultNode.java.
public<T> Publisher<T> org.ros.internal.node.DefaultNode.newPublisher | ( | String | topicName, |
String | messageType | ||
) | [inline, package] |
Implements org.ros.node.ConnectedNode.
Definition at line 279 of file DefaultNode.java.
public<T, S> ServiceClient<T, S> org.ros.internal.node.DefaultNode.newServiceClient | ( | GraphName | serviceName, |
String | serviceType | ||
) | throws ServiceNotFoundException [inline, package] |
Create a ServiceClient.
serviceName | the name of the service |
serviceType | the type of the service (e.g. "rosjava_test_msgs/AddTwoInts") |
ServiceNotFoundException | thrown if no matching service could be found |
Implements org.ros.node.ConnectedNode.
Definition at line 351 of file DefaultNode.java.
public<T, S> ServiceClient<T, S> org.ros.internal.node.DefaultNode.newServiceClient | ( | String | serviceName, |
String | serviceType | ||
) | throws ServiceNotFoundException [inline, package] |
Implements org.ros.node.ConnectedNode.
Definition at line 370 of file DefaultNode.java.
private<T> MessageDeserializer<T> org.ros.internal.node.DefaultNode.newServiceRequestDeserializer | ( | String | serviceType | ) | [inline, package] |
Definition at line 262 of file DefaultNode.java.
private<T> MessageSerializer<T> org.ros.internal.node.DefaultNode.newServiceRequestSerializer | ( | String | serviceType | ) | [inline, package] |
Definition at line 256 of file DefaultNode.java.
private<T> MessageDeserializer<T> org.ros.internal.node.DefaultNode.newServiceResponseDeserializer | ( | String | serviceType | ) | [inline, package] |
Definition at line 250 of file DefaultNode.java.
private<T> MessageSerializer<T> org.ros.internal.node.DefaultNode.newServiceResponseSerializer | ( | String | serviceType | ) | [inline, package] |
Definition at line 244 of file DefaultNode.java.
public<T, S> ServiceServer<T, S> org.ros.internal.node.DefaultNode.newServiceServer | ( | GraphName | serviceName, |
String | serviceType, | ||
ServiceResponseBuilder< T, S > | serviceResponseBuilder | ||
) | [inline, package] |
Create a new ServiceServer.
serviceName | the name of the service |
serviceType | the type of the service (e.g. "rosjava_test_msgs/AddTwoInts") |
serviceResponseBuilder | called for every request to build a response |
Implements org.ros.node.ConnectedNode.
Definition at line 301 of file DefaultNode.java.
public<T, S> ServiceServer<T, S> org.ros.internal.node.DefaultNode.newServiceServer | ( | String | serviceName, |
String | serviceType, | ||
ServiceResponseBuilder< T, S > | serviceResponseBuilder | ||
) | [inline, package] |
Implements org.ros.node.ConnectedNode.
Definition at line 317 of file DefaultNode.java.
public<T> Subscriber<T> org.ros.internal.node.DefaultNode.newSubscriber | ( | GraphName | topicName, |
String | messageType | ||
) | [inline, package] |
<T> | the message type to create the Subscriber for |
topicName | the topic name to be subscribed to, this will be auto resolved |
messageType | the message data type (e.g. "std_msgs/String") |
Implements org.ros.node.ConnectedNode.
Definition at line 284 of file DefaultNode.java.
public<T> Subscriber<T> org.ros.internal.node.DefaultNode.newSubscriber | ( | String | topicName, |
String | messageType | ||
) | [inline, package] |
Implements org.ros.node.ConnectedNode.
Definition at line 296 of file DefaultNode.java.
GraphName org.ros.internal.node.DefaultNode.resolveName | ( | GraphName | name | ) | [inline] |
Resolve the given name, using ROS conventions, into a full ROS namespace name. Will be relative to the current namespace unless the name is global.
name | the name to resolve |
Implements org.ros.node.Node.
Definition at line 391 of file DefaultNode.java.
GraphName org.ros.internal.node.DefaultNode.resolveName | ( | String | name | ) | [inline] |
Implements org.ros.node.Node.
Definition at line 396 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.shutdown | ( | ) | [inline] |
void org.ros.internal.node.DefaultNode.signalOnError | ( | final Throwable | throwable | ) | [inline, private] |
SignalRunnable all NodeListeners that the Node has experienced an error.
Each listener is called in a separate thread.
Definition at line 486 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.signalOnShutdown | ( | ) | [inline, private] |
SignalRunnable all NodeListeners that the Node has started shutting down.
Each listener is called in a separate thread.
Definition at line 517 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.signalOnShutdownComplete | ( | ) | [inline, private] |
SignalRunnable all NodeListeners that the Node has shut down.
Each listener is called in a separate thread.
Definition at line 539 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.signalOnStart | ( | ) | [inline, private] |
SignalRunnable all NodeListeners that the Node has started.
Each listener is called in a separate thread.
Definition at line 501 of file DefaultNode.java.
void org.ros.internal.node.DefaultNode.start | ( | ) | [inline, private] |
Definition at line 178 of file DefaultNode.java.
final boolean org.ros.internal.node.DefaultNode.DEBUG = false [static, private] |
Definition at line 87 of file DefaultNode.java.
Definition at line 115 of file DefaultNode.java.
final MasterClient org.ros.internal.node.DefaultNode.masterClient [private] |
Definition at line 102 of file DefaultNode.java.
final URI org.ros.internal.node.DefaultNode.masterUri [private] |
Definition at line 101 of file DefaultNode.java.
final int org.ros.internal.node.DefaultNode.MAX_SHUTDOWN_DELAY_DURATION = 5 [static, private] |
The maximum delay before shutdown will begin even if all NodeListeners have not yet returned from their NodeListener#onShutdown(Node) callback.
Definition at line 95 of file DefaultNode.java.
final TimeUnit org.ros.internal.node.DefaultNode.MAX_SHUTDOWN_DELAY_UNITS = TimeUnit.SECONDS [static, private] |
Definition at line 96 of file DefaultNode.java.
final NodeConfiguration org.ros.internal.node.DefaultNode.nodeConfiguration [private] |
Definition at line 98 of file DefaultNode.java.
final ListenerGroup<NodeListener> org.ros.internal.node.DefaultNode.nodeListeners [private] |
Definition at line 99 of file DefaultNode.java.
final GraphName org.ros.internal.node.DefaultNode.nodeName [private] |
Definition at line 106 of file DefaultNode.java.
final ParameterManager org.ros.internal.node.DefaultNode.parameterManager [private] |
Definition at line 105 of file DefaultNode.java.
final ParameterTree org.ros.internal.node.DefaultNode.parameterTree [private] |
Definition at line 109 of file DefaultNode.java.
final PublisherFactory org.ros.internal.node.DefaultNode.publisherFactory [private] |
Definition at line 110 of file DefaultNode.java.
final Registrar org.ros.internal.node.DefaultNode.registrar [private] |
Definition at line 113 of file DefaultNode.java.
final NodeNameResolver org.ros.internal.node.DefaultNode.resolver [private] |
Definition at line 107 of file DefaultNode.java.
final ScheduledExecutorService org.ros.internal.node.DefaultNode.scheduledExecutorService [private] |
Definition at line 100 of file DefaultNode.java.
final ServiceFactory org.ros.internal.node.DefaultNode.serviceFactory [private] |
Definition at line 112 of file DefaultNode.java.
final ServiceManager org.ros.internal.node.DefaultNode.serviceManager [private] |
Definition at line 104 of file DefaultNode.java.
final SlaveServer org.ros.internal.node.DefaultNode.slaveServer [private] |
Definition at line 108 of file DefaultNode.java.
final SubscriberFactory org.ros.internal.node.DefaultNode.subscriberFactory [private] |
Definition at line 111 of file DefaultNode.java.
Definition at line 116 of file DefaultNode.java.
Definition at line 103 of file DefaultNode.java.