Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 599) sorted by relevance

12345678910>>...24

/openbmc/qemu/io/
H A Dtask.c56 QIOTask *task; in qio_task_new() local
58 task = g_new0(QIOTask, 1); in qio_task_new()
60 task->source = source; in qio_task_new()
62 task->func = func; in qio_task_new()
63 task->opaque = opaque; in qio_task_new()
64 task->destroy = destroy; in qio_task_new()
65 qemu_mutex_init(&task->thread_lock); in qio_task_new()
66 qemu_cond_init(&task->thread_cond); in qio_task_new()
68 trace_qio_task_new(task, source, func, opaque); in qio_task_new()
70 return task; in qio_task_new()
[all …]
/openbmc/qemu/target/i386/kvm/
H A Dtdx-quote-generator.c74 static void tdx_generate_quote_cleanup(TdxGenerateQuoteTask *task) in tdx_generate_quote_cleanup() argument
76 timer_del(&task->timer); in tdx_generate_quote_cleanup()
78 if (task->watch) { in tdx_generate_quote_cleanup()
79 g_source_remove(task->watch); in tdx_generate_quote_cleanup()
81 qio_channel_close(QIO_CHANNEL(task->sioc), NULL); in tdx_generate_quote_cleanup()
82 object_unref(OBJECT(task->sioc)); in tdx_generate_quote_cleanup()
84 task->completion(task); in tdx_generate_quote_cleanup()
90 TdxGenerateQuoteTask *task = opaque; in tdx_get_quote_read() local
94 ret = qio_channel_read(ioc, task->receive_buf + task->receive_buf_received, in tdx_get_quote_read()
95 task->payload_len - task->receive_buf_received, &err); in tdx_get_quote_read()
[all …]
/openbmc/openbmc/poky/scripts/
H A Dtest-reexec62 task=$2
64 task=`echo $task | sed 's/_setscene//'`
66 if [ -f $LOGS/force.$target.$task ]; then
70 case $task in
75 echo "Attempting target $target, task $task"
77 bitbake $target -c cleansstate > $LOGS/initial.$target.$task
78 bitbake $target >> $LOGS/initial.$target.$task
79 clearsstate $target >> $LOGS/initial.$target.$task
81 bitbake $target -c $task -f > $LOGS/force.$target.$task
83 echo "FAILURE for $target $task"
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/mps/
H A Dmp5998.hpp16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> unlockPasswordProtection();
26 sdbusplus::async::task<bool> unlockWriteProtection();
27 sdbusplus::async::task<bool> storeMTP();
28 sdbusplus::async::task<bool> waitForMTPComplete();
29 sdbusplus::async::task<bool> sendRestoreMTPCommand();
[all …]
H A Dmp297x.hpp16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> isPasswordUnlock();
26 sdbusplus::async::task<bool> unlockWriteProtect();
27 sdbusplus::async::task<bool> storeDataIntoMTP();
28 sdbusplus::async::task<bool> enableMTPPageWriteRead();
29 sdbusplus::async::task<bool> enableMultiConfigCRC();
[all …]
H A Dmpx9xx.hpp26 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
28 sdbusplus::async::task<bool> updateFirmware(bool force) final;
29 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
30 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
34 sdbusplus::async::task<bool> checkId(MPX9XXCmd idCmd, uint32_t expected);
35 sdbusplus::async::task<bool> unlockWriteProtect();
36 sdbusplus::async::task<bool> disableStoreFaultTriggering();
37 sdbusplus::async::task<bool> setMultiConfigAddress(uint8_t config);
38 sdbusplus::async::task<bool> programConfigData(
40 sdbusplus::async::task<bool> programAllRegisters();
[all …]
H A Dmp2x6xx.hpp16 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
18 sdbusplus::async::task<bool> updateFirmware(bool force) final;
19 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
20 sdbusplus::async::task<bool> parseDeviceConfiguration() final;
24 sdbusplus::async::task<bool> checkId(PMBusCmd pmBusCmd, uint32_t expected);
25 sdbusplus::async::task<bool> unlockWriteProtect();
26 sdbusplus::async::task<bool> storeUserCode();
27 sdbusplus::async::task<bool> checkMTPCRC();
28 sdbusplus::async::task<bool> selectConfig(uint8_t config);
29 sdbusplus::async::task<bool> configAllRegisters();
[all …]
/openbmc/qemu/tests/unit/
H A Dtest-io-task.c55 static void task_callback(QIOTask *task, in task_callback() argument
60 data->source = qio_task_get_source(task); in task_callback()
61 qio_task_propagate_error(task, &data->err); in task_callback()
67 QIOTask *task; in test_task_complete() local
72 task = qio_task_new(obj, task_callback, &data, NULL); in test_task_complete()
73 src = qio_task_get_source(task); in test_task_complete()
75 qio_task_complete(task); in test_task_complete()
97 QIOTask *task; in test_task_data_free() local
101 task = qio_task_new(obj, task_callback, &data, task_data_free); in test_task_data_free()
103 qio_task_complete(task); in test_task_data_free()
[all …]
/openbmc/openbmc/poky/bitbake/lib/bb/
H A Dbuild.py83 def setTask(self, task): argument
84 self._task = task
89 task = property(getTask, setTask, None, "task property") variable in TaskBase
103 def __init__(self, task, fn, logfile, metadata, errprinted = False): argument
105 super(TaskFailed, self).__init__(task, fn, logfile, metadata)
115 def __init__(self, task, fn, metadata): argument
116 super(TaskInvalid, self).__init__(task, fn, None, metadata)
117 self._message = "No such task '%s'" % task
233 task = d.getVar('BB_RUNTASK') or func
234 if task == func:
[all …]
/openbmc/openbmc/poky/scripts/lib/checklayer/cases/
H A Dbsp.py87 for task in tasks:
88 tasks2tune[task] = tune
89 for task, sighash in curr_sigs.items():
90 …tunes.setdefault(tasks2tune[task], {}).setdefault(task, {}).setdefault(sighash, []).append(machine)
114 def visit(task): argument
115 color[task] = GRAY
116 for dep in depends.get(task, ()):
119 color[task] = BLACK
120 pn, taskname = task.rsplit('.', 1)
124 for task in depends.keys():
[all …]
/openbmc/qemu/include/io/
H A Dtask.h26 typedef void (*QIOTaskFunc)(QIOTask *task,
29 typedef void (*QIOTaskWorker)(QIOTask *task,
235 void qio_task_run_in_thread(QIOTask *task,
264 void qio_task_wait_thread(QIOTask *task);
274 void qio_task_complete(QIOTask *task);
291 void qio_task_set_error(QIOTask *task,
305 bool qio_task_propagate_error(QIOTask *task,
319 void qio_task_set_result_pointer(QIOTask *task,
333 gpointer qio_task_get_result_pointer(QIOTask *task);
348 Object *qio_task_get_source(QIOTask *task);
/openbmc/qemu/block/
H A Dblock-copy.c47 static coroutine_fn int block_copy_task_entry(AioTask *task);
84 AioTask task; member
110 static int64_t task_end(BlockCopyTask *task) in task_end() argument
112 return task->req.offset + task->req.bytes; in task_end()
192 BlockCopyTask *task; in block_copy_task_create() local
213 task = g_new(BlockCopyTask, 1); in block_copy_task_create()
214 *task = (BlockCopyTask) { in block_copy_task_create()
215 .task.func = block_copy_task_entry, in block_copy_task_create()
220 reqlist_init_req(&s->reqs, &task->req, offset, bytes); in block_copy_task_create()
222 return task; in block_copy_task_create()
[all …]
H A Daio_task.c39 AioTask *task = opaque; in aio_task_co() local
40 AioTaskPool *pool = task->pool; in aio_task_co()
45 task->ret = task->func(task); in aio_task_co()
49 if (task->ret < 0 && pool->status == 0) { in aio_task_co()
50 pool->status = task->ret; in aio_task_co()
53 g_free(task); in aio_task_co()
89 void coroutine_fn aio_task_pool_start_task(AioTaskPool *pool, AioTask *task) in aio_task_pool_start_task() argument
93 task->pool = pool; in aio_task_pool_start_task()
94 qemu_coroutine_enter(qemu_coroutine_create(aio_task_co, task)); in aio_task_pool_start_task()
H A Discsi.c113 struct scsi_task *task; member
125 struct scsi_task *task; member
163 if (acb->task != NULL) { in iscsi_bh_cb()
164 scsi_free_scsi_task(acb->task); in iscsi_bh_cb()
165 acb->task = NULL; in iscsi_bh_cb()
241 struct scsi_task *task = command_data; in iscsi_co_generic_cb() local
246 iTask->task = task; in iscsi_co_generic_cb()
274 int error = iscsi_translate_sense(&task->sense); in iscsi_co_generic_cb()
316 iscsi_scsi_cancel_task(iscsi, acb->task); in iscsi_abort_task_cb()
340 if (iscsi_task_mgmt_abort_task_async(iscsilun->iscsi, acb->task, in iscsi_aio_cancel()
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/tda38640a/
H A Dtda38640a.hpp19 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
22 sdbusplus::async::task<bool> updateFirmware(bool force) final;
23 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
44 sdbusplus::async::task<bool> getUserRemainingWrites(uint8_t* remain);
45 sdbusplus::async::task<bool> getDeviceId(uint32_t* deviceId);
46 sdbusplus::async::task<bool> program();
47 sdbusplus::async::task<bool> getProgStatus(uint8_t* status);
48 sdbusplus::async::task<bool> unlockDevice();
49 sdbusplus::async::task<bool> programmingCmd();
50 sdbusplus::async::task<bool> setPage(uint8_t page);
[all …]
/openbmc/phosphor-bmc-code-mgmt/cpld/lattice/
H A Dlattice_xo3_cpld.hpp21 sdbusplus::async::task<bool> prepareUpdate(const uint8_t* image,
23 sdbusplus::async::task<bool> doUpdate() override;
24 sdbusplus::async::task<bool> finishUpdate() override;
27 sdbusplus::async::task<bool> readUserCode(uint32_t& userCode) override;
28 sdbusplus::async::task<bool> readDeviceId();
29 sdbusplus::async::task<bool> eraseFlash();
30 sdbusplus::async::task<bool> writeProgramPage();
31 sdbusplus::async::task<bool> programUserCode();
32 sdbusplus::async::task<bool> programSinglePage(
34 sdbusplus::async::task<bool> verifySinglePage(
H A Dlattice_xo5_cpld.hpp21 sdbusplus::async::task<bool> prepareUpdate(const uint8_t* image,
23 sdbusplus::async::task<bool> doUpdate() override;
24 sdbusplus::async::task<bool> finishUpdate() override;
25 sdbusplus::async::task<bool> readUserCode(uint32_t& userCode) override;
28 sdbusplus::async::task<bool> waitUntilReady(
30 sdbusplus::async::task<bool> eraseCfg();
31 sdbusplus::async::task<bool> programCfg();
32 sdbusplus::async::task<bool> programPage(uint8_t block, uint8_t page,
34 sdbusplus::async::task<bool> verifyCfg();
35 sdbusplus::async::task<bool> readPage(uint8_t block, uint8_t page,
H A Dlattice_base_cpld.hpp135 sdbusplus::async::task<bool> updateFirmware(
139 sdbusplus::async::task<bool> getVersion(std::string& version);
151 virtual sdbusplus::async::task<bool> prepareUpdate(const uint8_t*,
153 virtual sdbusplus::async::task<bool> doUpdate() = 0;
154 virtual sdbusplus::async::task<bool> finishUpdate() = 0;
158 sdbusplus::async::task<bool> enableProgramMode();
159 sdbusplus::async::task<bool> resetConfigFlash();
160 sdbusplus::async::task<bool> programDone();
161 sdbusplus::async::task<bool> disableConfigInterface();
162 sdbusplus::async::task<bool> waitBusyAndVerify();
[all …]
/openbmc/phosphor-bmc-code-mgmt/i2c-vr/isl69269/
H A Disl69269.hpp26 sdbusplus::async::task<bool> verifyImage(const uint8_t* image,
29 sdbusplus::async::task<bool> updateFirmware(bool force) final;
30 sdbusplus::async::task<bool> getCRC(uint32_t* checksum) final;
55 sdbusplus::async::task<bool> dmaReadWrite(uint8_t* reg, uint8_t* resp);
56 sdbusplus::async::task<bool> getRemainingWrites(uint8_t* remain);
57 sdbusplus::async::task<bool> getHexMode(uint8_t* mode);
58 sdbusplus::async::task<bool> getDeviceId(uint32_t* deviceId);
59 sdbusplus::async::task<bool> getDeviceRevision(uint32_t* revision);
60 sdbusplus::async::task<bool> program();
61 sdbusplus::async::task<bool> getProgStatus();
[all …]
/openbmc/qemu/backends/
H A Dcryptodev-lkcf.c112 CryptoDevLKCFTask *task, *next; in cryptodev_lkcf_handle_response() local
122 QSIMPLEQ_FOREACH_SAFE(task, &responses, queue, next) { in cryptodev_lkcf_handle_response()
123 if (task->cb) { in cryptodev_lkcf_handle_response()
124 task->cb(task->opaque, task->status); in cryptodev_lkcf_handle_response()
126 g_free(task); in cryptodev_lkcf_handle_response()
257 CryptoDevLKCFTask *task, *next; in cryptodev_lkcf_cleanup() local
269 QSIMPLEQ_FOREACH_SAFE(task, &lkcf->requests, queue, next) { in cryptodev_lkcf_cleanup()
270 if (task->cb) { in cryptodev_lkcf_cleanup()
271 task->cb(task->opaque, task->status); in cryptodev_lkcf_cleanup()
273 g_free(task); in cryptodev_lkcf_cleanup()
[all …]
/openbmc/openbmc-test-automation/lib/
H A Djobs_processing.py51 task = Process(
54 process_list.append(task)
55 task.start()
58 for task in process_list:
59 task.join()
102 task = Process(
106 process_list.append(task)
107 task.start()
110 for task in process_list:
111 task.join()
/openbmc/openbmc/poky/meta/lib/oeqa/selftest/cases/
H A Dbblock.py36 for task in tasks:
38 'SIGGEN_LOCKEDSIGS_.+\s\+=\s"%s:%s:.*"' % (recipe, task),
44 % (recipe, task),
63 for task in tasks:
65 'SIGGEN_LOCKEDSIGS_.+\s\+=\s"%s:%s:.*"' % (recipe, task),
71 % (recipe, task, result.output),
86 for task in tasks:
87 task_append += "%s:append() {\n#modify task hash \n}\n" % task
163 task = line.split()[0]
164 if "setscene" in task:
[all …]
/openbmc/openbmc/poky/bitbake/lib/toaster/tests/builds/
H A Dtest_core_image_min.py59 for task in tasks:
61 if (task['order'] != cnt_tasks):
62 cnt_err.append(task['id'])
75 for task in tasks:
76 if (task['sstate_result'] != 3):
77 cnt_err.append(task['id'])
92 for task in tasks:
93 if (task['sstate_result'] != Task.SSTATE_NA and
94 task['sstate_result'] != Task.SSTATE_MISS):
95 cnt_err.append({'id': task['id'],
[all …]
/openbmc/pldm/platform-mc/
H A Dplatform_manager.hpp42 exec::task<int> initTerminus();
49 exec::task<int> configEventReceiver(pldm_tid_t tid);
57 exec::task<int> getPDRs(std::shared_ptr<Terminus> terminus);
75 exec::task<int> getPDR(
93 exec::task<int> getPDRRepositoryInfo(
110 exec::task<int> setEventReceiver(
121 exec::task<int> eventMessageBufferSize(pldm_tid_t tid,
137 exec::task<int> eventMessageSupported(
148 exec::task<int> getFRURecordTables(pldm_tid_t tid, const uint16_t& total,
163 exec::task<int> getFRURecordTable(
[all …]
/openbmc/phosphor-modbus/common/
H A Devents.hpp28 -> sdbusplus::async::task<>;
31 bool asserted) -> sdbusplus::async::task<>;
35 bool asserted) -> sdbusplus::async::task<>;
39 -> sdbusplus::async::task<>;
42 bool asserted) -> sdbusplus::async::task<>;
45 bool asserted) -> sdbusplus::async::task<>;
48 bool asserted) -> sdbusplus::async::task<>;
52 -> sdbusplus::async::task<>;

12345678910>>...24