diff --git a/scripts/capability_server b/scripts/capability_server index c5abd71..fb41d17 100755 --- a/scripts/capability_server +++ b/scripts/capability_server @@ -2,25 +2,6 @@ import sys -#### HACK until rospy uses the threading module rather than the thread module -import threading - -from rospy.impl import tcpros_service - - -class MyThread(object): - def __init__(self): - self.__threads_objs = [] - - def start_new_thread(self, func, args): - t = threading.Thread(target=func, args=args) - t.setDaemon(True) - t.start() - self.__threads_objs.append(t) - -tcpros_service._thread = MyThread() -#### END HACK - from capabilities.server import main if __name__ == '__main__': diff --git a/src/capabilities/server.py b/src/capabilities/server.py index 23c8309..05f8f5c 100644 --- a/src/capabilities/server.py +++ b/src/capabilities/server.py @@ -88,33 +88,6 @@ USER_SERVICE_REASON = 'user service call' -## Hack to squelch output from Service call failure ## - -from rospy.impl import tcpros_service - - -def custom__handle_request(self, transport, request): # pragma: no cover - import struct - from rospy.impl.tcpros_service import convert_return_to_response - from rospy.service import ServiceException - try: - # convert return type to response Message instance - response = convert_return_to_response(self.handler(request), self.response_class) - self.seq += 1 - # ok byte - transport.write_buff.write(struct.pack('