niryo_libraries.rospy.impl.tcpros_service.ServiceImpl

class documentation

class ServiceImpl(_Service):

Known subclasses: niryo_libraries.rospy.Service

Constructor: ServiceImpl(name, service_class, handler, buff_size, error_handler)

View In Hierarchy

Implementation of ROS Service. This intermediary class allows for more configuration of behavior than the Service class.

Method __init__ Undocumented
Method error_handler Undocumented
Method handle Process incoming request. This method should be run in its own thread. If header['persistent'] is set to 1, method will block until connection is broken. @param transport: transport instance @type transport: L{TCPROSTransport} @param header: headers from client @type header: dict...
Method shutdown Stop this service @param reason: human-readable shutdown reason @type reason: str
Method spin Let service run and take over thread until service or node shutdown. Use this method to keep your scripts from exiting execution.
Instance Variable buff_size Undocumented
Instance Variable done Undocumented
Instance Variable handler Undocumented
Instance Variable protocol Undocumented
Instance Variable registered Undocumented
Instance Variable seq Undocumented
Instance Variable uri Undocumented
Method _handle_request Process a single incoming request. @param transport: transport instance @type transport: L{TCPROSTransport} @param request: Message @type request: genpy.Message
Method _write_service_error Send error message to client @param transport: transport connection to client @type transport: Transport @param err_msg: error message to send to client @type err_msg: str
def __init__(self, name, service_class, handler, buff_size=DEFAULT_BUFF_SIZE, error_handler=None):
overridden in niryo_libraries.rospy.Service

Undocumented

def error_handler(self, e, exc_type, exc_value, tb):

Undocumented

def handle(self, transport, header):

Process incoming request. This method should be run in its own thread. If header['persistent'] is set to 1, method will block until connection is broken. @param transport: transport instance @type transport: L{TCPROSTransport} @param header: headers from client @type header: dict

def shutdown(self, reason=''):

Stop this service @param reason: human-readable shutdown reason @type reason: str

def spin(self):

Let service run and take over thread until service or node shutdown. Use this method to keep your scripts from exiting execution.

buff_size =

Undocumented

done: bool =

Undocumented

handler =

Undocumented

protocol =

Undocumented

registered: bool =

Undocumented

seq: int =

Undocumented

uri =

Undocumented

def _handle_request(self, transport, request):

Process a single incoming request. @param transport: transport instance @type transport: L{TCPROSTransport} @param request: Message @type request: genpy.Message

def _write_service_error(self, transport, err_msg):

Send error message to client @param transport: transport connection to client @type transport: Transport @param err_msg: error message to send to client @type err_msg: str