Package node_manager_fkie :: Module packages_thread
[frames] | no frames]

Source Code for Module node_manager_fkie.packages_thread

 1  # Software License Agreement (BSD License) 
 2  # 
 3  # Copyright (c) 2012, Fraunhofer FKIE/US, Alexander Tiderko 
 4  # All rights reserved. 
 5  # 
 6  # Redistribution and use in source and binary forms, with or without 
 7  # modification, are permitted provided that the following conditions 
 8  # are met: 
 9  # 
10  #  * Redistributions of source code must retain the above copyright 
11  #    notice, this list of conditions and the following disclaimer. 
12  #  * Redistributions in binary form must reproduce the above 
13  #    copyright notice, this list of conditions and the following 
14  #    disclaimer in the documentation and/or other materials provided 
15  #    with the distribution. 
16  #  * Neither the name of Fraunhofer nor the names of its 
17  #    contributors may be used to endorse or promote products derived 
18  #    from this software without specific prior written permission. 
19  # 
20  # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
21  # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 
22  # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 
23  # FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE 
24  # COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
25  # INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 
26  # BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 
27  # LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 
28  # CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
29  # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN 
30  # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
31  # POSSIBILITY OF SUCH DAMAGE. 
32   
33  from python_qt_binding.QtCore import QObject, Signal 
34  import os 
35  import threading 
36   
37  import rospy 
38   
39  from .common import get_packages 
40   
41   
42 -class PackagesThread(QObject, threading.Thread):
43 ''' 44 A thread to list all available ROS packages and 45 publish there be sending a QT signal. 46 ''' 47 packages = Signal(dict) 48 ''' 49 @ivar: packages is a signal, which is emitted, if a list with ROS packages was 50 created {package : path}. 51 ''' 52
53 - def __init__(self):
54 ''' 55 ''' 56 QObject.__init__(self) 57 threading.Thread.__init__(self) 58 self.setDaemon(True)
59
60 - def run(self):
61 ''' 62 ''' 63 try: 64 # fill the input fields 65 root_paths = [os.path.normpath(p) for p in os.getenv("ROS_PACKAGE_PATH").split(':')] 66 packages = {} 67 for p in root_paths: 68 ret = get_packages(p) 69 packages = dict(ret.items() + packages.items()) 70 self.packages.emit(packages) 71 except: 72 import traceback 73 formatted_lines = traceback.format_exc(1).splitlines() 74 print "Error while list packages:\n\t%s" % traceback.format_exc() 75 try: 76 rospy.logwarn("Error while list packages:\n\t%s", formatted_lines[-1]) 77 except: 78 pass
79