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  import os 
34  import threading 
35  from python_qt_binding import QtCore 
36   
37  import rospy 
38  from common import get_packages 
39   
40   
41 -class PackagesThread(QtCore.QObject, threading.Thread): 
42    ''' 
43    A thread to list all available ROS packages and 
44    publish there be sending a QT signal. 
45    ''' 
46    packages = QtCore.Signal(dict) 
47    ''' 
48    @ivar: packages is a signal, which is emitted, if a list with ROS packages was 
49    created {package : path}. 
50    ''' 
51   
52 -  def __init__(self): 
53      ''' 
54      ''' 
55      QtCore.QObject.__init__(self) 
56      threading.Thread.__init__(self) 
57      self.setDaemon(True) 
58   
59 -  def run(self): 
60      ''' 
61      ''' 
62      try: 
63        # fill the input fields 
64        root_paths = [os.path.normpath(p) for p in os.getenv("ROS_PACKAGE_PATH").split(':')] 
65        packages = {} 
66        for p in root_paths: 
67          ret = get_packages(p) 
68          packages = dict(ret.items() + packages.items()) 
69        self.packages.emit(packages) 
70      except: 
71        import traceback 
72        formatted_lines = traceback.format_exc().splitlines() 
73        rospy.logwarn("Error while list packages:\n\t%s", formatted_lines[-1]) 
74