Home
last modified time | relevance | path

Searched refs:task (Results 1 - 19 of 19) sorted by relevance

/test/testfwk/xdevice/src/xdevice/_core/context/
H A Dimpl.py101 def _handler_repeat(cls, task) -> list:
103 for index in range(1, task.config.repeat + 1):
104 repeat_list = cls._construct_repeat_list(task, index)
110 def _construct_repeat_list(cls, task, index):
112 for driver_index, _ in enumerate(task.test_drivers):
113 cur_test_driver = copy.deepcopy(task.test_drivers[driver_index])
119 def __execute__(self, task):
124 self._channel.append((task_id, run_command, task.config.report_path))
131 unavailable, err_msg = self._check_task(task)
134 LOG.error("Exec task erro
[all...]
H A Dabs.py60 task = None
66 task = self.__discover__(options.__dict__)
67 self.__execute__(task)
71 self._on_task_error_(task, exception)
104 def _on_task_error_(self, task, exception: Exception):
107 def _on_execute_finished_(self, task, result: ExecuteFinished):
111 def _do_execute_(self, task):
125 def generate_task_report(self, task):
H A Dhandler.py68 def report_not_executed(report_path, test_drivers, error_message, task=None):
74 if task is not None:
75 repeat = task.config.repeat
85 if task and getattr(task.config, "testdict", ""):
H A Dupload.py55 def upload_task_result(cls, task, error_message=""):
63 summary_data_report = os.path.join(task.config.report_path,
67 task.config.report_path)
81 task.config.report_path, ReportConstant.summary_vision_report)
/test/testfwk/xdevice/src/xdevice/_core/executor/
H A Dscheduler.py88 def _do_execute_(self, task):
90 if task.config.exectype == TestExecType.device_test:
91 self._device_test_execute(task)
92 elif task.config.exectype == TestExecType.host_test:
93 self._host_test_execute(task)
95 LOG.info("Exec type %s is bypassed" % task.config.exectype)
98 """Discover task to execute"""
106 task = Task(drivers=[])
107 task.init(config)
112 root_descriptor = self._find_test_root_descriptor(task
[all...]
H A Dconcurrent.py92 def __init__(self, test_driver, task, environment, message_queue):
96 self.task = task
118 self.task.config.log_path, round_folder,
176 execute_result, self.task.config.report_path,
194 if getattr(self.task.config, "history_report_path", ""):
271 # do task setup for device
272 kits_copy = copy.deepcopy(self.task.config.kits)
290 # set product_info to self.task
292 getattr(self.task, ConfigCons
[all...]
H A Dsource.py75 if not config.testfile and not config.testlist and not config.task and \
185 config.task:
H A Drequest.py101 if getattr(config, "task", ""):
102 task_file = config.task + self.TASK_CONFIG_SUFFIX
/test/testfwk/arkxtest/jsunit/src/
H A Dservice.js513 this.coreContext.fireEvents('task', 'incorrectFormat');
517 this.coreContext.fireEvents('task', 'incorrectTestSuiteFormat');
529 await this.coreContext.fireEvents('task', 'taskStart');
533 await this.coreContext.fireEvents('task', 'taskDone');
537 this.coreContext.fireEvents('task', 'taskStart');
539 this.coreContext.fireEvents('task', 'taskDone');
H A Dcore.js45 task: {}
120 this.registerEvent('task', new TaskEvent({id: 'default', coreContext: this}));
125 this.subscribeEvent('task', this.getDefaultService('report'));
/test/xts/acts/resourceschedule/resourceschedule_standard/ffrt/entry/src/main/cpp/
H A Dffrtndk.cpp17 #include "ffrt/task.h"
721 ffrt_task_handle_t task = ffrt_submit_h_base(create_function_wrapper(OnePlusFunc), {}, {}, &task_attr); in DelayCTest001() local
722 const std::vector<ffrt_dependence_t> wait_deps = {{ffrt_dependence_task, task}}; in DelayCTest001()
740 ffrt_task_handle_destroy(task); in DelayCTest001()
773 ffrt_task_handle_t task = ffrt_submit_h_base(create_function_wrapper(func1), nullptr, nullptr, nullptr); in FfrtYieldC0001() local
778 const std::vector<ffrt_dependence_t> wait_deps = {{ffrt_dependence_task, task}}; in FfrtYieldC0001()
788 ffrt_task_handle_destroy(task); in FfrtYieldC0001()
1461 // cancel一个delay的未执行task in QueueCancelTest001()
1498 // cancel一个执行中task,ffrt的sleep in QueueCancelTest003()
1534 // cancel一个已执行的task in QueueCancelTest004()
1946 ffrt_task_handle_t task[maxNum][10]; QueueTest002() local
1992 ffrt_task_handle_t task[10][10]; QueueTest003() local
2503 ffrt_task_handle_t task = ffrt_submit_h_base(ffrt_header_t, &in, &out, nullptr); SubmitHBasicTest001() local
2523 ffrt_task_handle_t task = ffrt_submit_h_base( SubmitHBasicTest002() local
3440 ffrt_task_handle_t task; queue_parallel_0002() local
3657 ffrt_task_handle_t task = ffrt_submit_h_base(create_function_wrapper(OnePlusFunc), {}, {}, &task_attr); ffrt_attr_stack_size_0001() local
3686 ffrt_task_handle_t task = ffrt_submit_h_base(create_function_wrapper(OnePlusFunc), {}, {}, &task_attr); ffrt_task_handle_ref_0001() local
[all...]
/test/xts/device_attest/services/devattest_ability/src/
H A Ddevattest_service.cpp112 HILOGI("[DelayUnloadTask] Delay unload task begin"); in DelayUnloadTask()
121 auto task = []() { in DelayUnloadTask() local
142 unloadHandler_->PostTask(task, ATTEST_UNLOAD_TASK_ID, DELAY_TIME); in DelayUnloadTask()
/test/testfwk/xdevice/src/xdevice/_core/
H A Dconstants.py271 task = "task" variable in ConfigConst
/test/testfwk/xdevice/src/xdevice/_core/command/
H A Dconsole.py155 parser.add_argument("task",
158 help="Specify task name")
296 help="retry task by session id")
315 help="number of times that a task is executed"
414 if options.task == Task.EMPTY_TASK:
415 setattr(options, ConfigConst.task, "")
664 print("List task:")
903 action task
909 task Specify task nam
[all...]
/test/xts/acts/ability_lite/ability_posix/src/
H A DAbilityMgrTest.cpp946 auto task = [hapPath]{ in HWTEST_F() local
957 eventHandler1.PostTask(task); in HWTEST_F()
H A DAbilityMgrTest2.cpp978 auto task = [this, hapPath]{ in HWTEST_F() local
989 eventHandler1.PostTask(task); in HWTEST_F()
/test/xts/hats/hdf/camera/cameraHdi/buffer_manager/
H A Dbuffer_manager_utest.cpp252 std::thread task([&bufferPool, &bufferVector] { in HWTEST_F()
259 task.join(); in HWTEST_F()
/test/testfwk/developer_test/src/core/command/
H A Dconsole.py217 help="Not show task log in console."
468 task = "task" variable in ConfigConst
/test/testfwk/xdevice/plugins/ohos/src/ohos/testkit/
H A Dkit.py345 test_type = self.request.config.get(ConfigConst.task, "").upper()

Completed in 21 milliseconds