work_manager.py 文件源码

def _cb_add_work(self, request):
        with self.lock_experiment:
            experiment = rospy.get_param('/work')
            task = {
                    "num_iterations": request.num_iterations,
                    "num_trials": request.num_trials,
                    "method": request.method
                }
            experiment.append(task)
            rospy.set_param('/work', self.check(experiment))
            return AddWorkResponse(task=len(experiment)-1)