Home
last modified time | relevance | path

Searched refs:job (Results 1 – 25 of 83) sorted by relevance

1234

/f-stack/dpdk/lib/librte_jobstats/
H A Drte_jobstats.c61 if (job->period + JOB_UPDATE_STEP_UP < job->max_period) in default_update_function()
64 if (job->min_period + JOB_UPDATE_STEP_DOWN < job->period) in default_update_function()
131 if (unlikely(ctx == NULL || job == NULL || job->context != NULL)) in rte_jobstats_start()
135 job->context = ctx; in rte_jobstats_start()
151 if (unlikely(job == NULL || job->context == NULL)) in rte_jobstats_abort()
172 if (unlikely(job == NULL || job->context == NULL)) in rte_jobstats_finish()
178 (*job->update_period_cb)(job, job_value); in rte_jobstats_finish()
194 job->exec_cnt++; in rte_jobstats_finish()
235 if (job == NULL) in rte_jobstats_init()
244 strlcpy(job->name, name == NULL ? "" : name, RTE_DIM(job->name)); in rte_jobstats_init()
[all …]
H A Drte_jobstats.h33 typedef void (*rte_job_update_period_cb_t)(struct rte_jobstats *job,
179 rte_jobstats_init(struct rte_jobstats *job, const char *name,
193 rte_jobstats_set_target(struct rte_jobstats *job, int64_t target);
208 rte_jobstats_start(struct rte_jobstats_context *ctx, struct rte_jobstats *job);
222 rte_jobstats_abort(struct rte_jobstats *job);
241 rte_jobstats_finish(struct rte_jobstats *job, int64_t job_value);
254 rte_jobstats_set_period(struct rte_jobstats *job, uint64_t period,
266 rte_jobstats_set_min(struct rte_jobstats *job, uint64_t period);
277 rte_jobstats_set_max(struct rte_jobstats *job, uint64_t period);
291 rte_jobstats_set_update_period_function(struct rte_jobstats *job,
[all …]
/f-stack/freebsd/kern/
H A Dvfs_aio.c563 if (job->uiop != &job->uio) in aio_free_entry()
868 error = kern_mlock(job->userproc, job->cred, in aio_process_mlock()
1118 job->handle_fn(job); in aio_daemon()
1637 MPASS(job->uiop == &job->uio || job->uiop == NULL); in aio_aqueue()
1671 MPASS(job->uiop != &job->uio && job->uiop != NULL); in aio_aqueue()
1676 job->uio.uio_iov = job->iov; in aio_aqueue()
1678 job->uio.uio_resid = job->uaiocb.aio_nbytes; in aio_aqueue()
1680 job->uiop = &job->uio; in aio_aqueue()
1727 if (job->uiop != &job->uio) in aio_aqueue()
1786 error = aio_qbio(job->userproc, job); in aio_queue_file()
[all …]
H A Dsys_socket.c615 fp = job->fd_file; in soaio_process_job()
620 job_total_nbytes = job->uiop->uio_resid + job->aio_done; in soaio_process_job()
621 done = job->aio_done; in soaio_process_job()
624 job->uiop->uio_td = td; in soaio_process_job()
643 job->msgrcv = 1; in soaio_process_job()
655 job->msgsnd = 1; in soaio_process_job()
664 job->aio_done = done; in soaio_process_job()
692 aio_cancel(job); in soaio_process_job()
714 struct kaiocb *job; in soaio_process_sb() local
797 done = job->aio_done; in soo_aio_cancel()
[all …]
/f-stack/dpdk/drivers/crypto/aesni_mb/
H A Drte_aesni_mb_pmd.c1125 job->iv = iv->va; in set_cpu_mb_job_params()
1146 job->iv++; in set_cpu_mb_job_params()
1213 job->src = buf; in set_cpu_mb_job_params()
1268 const int aead = is_aead_algo(job->hash_alg, job->cipher_mode); in set_mb_job_params()
1751 for (i = 0; job != NULL; i++, job = IMB_GET_COMPLETED_JOB(mb_mgr)) in handle_completed_sync_jobs()
1760 JOB_AES_HMAC *job; in flush_mb_sync_mgr() local
1775 if (job) in flush_mb_mgr()
1793 return job; in set_job_null_op()
1803 JOB_AES_HMAC *job; in aesni_mb_pmd_dequeue_burst() local
1859 if (job) in aesni_mb_pmd_dequeue_burst()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dbio.c132 struct bio_job *job = zmalloc(sizeof(*job)); in bioCreateBackgroundJob() local
134 job->time = time(NULL); in bioCreateBackgroundJob()
135 job->arg1 = arg1; in bioCreateBackgroundJob()
136 job->arg2 = arg2; in bioCreateBackgroundJob()
137 job->arg3 = arg3; in bioCreateBackgroundJob()
146 struct bio_job *job; in bioProcessBackgroundJobs() local
181 job = ln->value; in bioProcessBackgroundJobs()
196 if (job->arg1) in bioProcessBackgroundJobs()
198 else if (job->arg2 && job->arg3) in bioProcessBackgroundJobs()
199 lazyfreeFreeDatabaseFromBioThread(job->arg2,job->arg3); in bioProcessBackgroundJobs()
[all …]
/f-stack/freebsd/contrib/device-tree/Bindings/powerpc/fsl/
H A Draideng.txt30 There must be a sub-node for each job queue present in RAID Engine
34 This identifies the job queue interface
35 - reg: offset and length of the register set for job queue
42 compatible = "fsl,raideng-v1.0-job-queue";
48 There must be a sub-node for each job ring present in RAID Engine
49 This node must be a sub-node of job queue node
51 - compatible: Must contain "fsl,raideng-v1.0-job-ring" as the value
52 This identifies job ring. Should contain either
55 - reg: offset and length of the register set for job ring
56 - interrupts: interrupt mapping for job ring IRQ
[all …]
/f-stack/freebsd/contrib/openzfs/lib/libtpool/
H A Dthread_pool.c39 tpool_job_t *job; in delete_pool() local
60 for (job = tpool->tp_head; job != NULL; job = tpool->tp_head) { in delete_pool()
62 free(job); in delete_pool()
128 tpool_job_t *job; in tpool_worker() local
182 arg = job->tpj_arg; in tpool_worker()
191 free(job); in tpool_worker()
414 tpool_job_t *job; in tpool_dispatch() local
418 if ((job = calloc(1, sizeof (*job))) == NULL) in tpool_dispatch()
420 job->tpj_next = NULL; in tpool_dispatch()
421 job->tpj_func = func; in tpool_dispatch()
[all …]
/f-stack/freebsd/contrib/device-tree/src/powerpc/fsl/
H A Dqoriq-sec6.0-0.dtsi42 compatible = "fsl,sec-v6.0-job-ring",
43 "fsl,sec-v5.2-job-ring",
44 "fsl,sec-v5.0-job-ring",
45 "fsl,sec-v4.4-job-ring",
46 "fsl,sec-v4.0-job-ring";
51 compatible = "fsl,sec-v6.0-job-ring",
52 "fsl,sec-v5.2-job-ring",
53 "fsl,sec-v5.0-job-ring",
54 "fsl,sec-v4.4-job-ring",
55 "fsl,sec-v4.0-job-ring";
H A Dqoriq-sec5.3-0.dtsi45 compatible = "fsl,sec-v5.3-job-ring",
46 "fsl,sec-v5.0-job-ring",
47 "fsl,sec-v4.0-job-ring";
53 compatible = "fsl,sec-v5.3-job-ring",
54 "fsl,sec-v5.0-job-ring",
55 "fsl,sec-v4.0-job-ring";
61 compatible = "fsl,sec-v5.3-job-ring",
62 "fsl,sec-v5.0-job-ring",
63 "fsl,sec-v4.0-job-ring";
70 "fsl,sec-v5.0-job-ring",
[all …]
H A Dqoriq-sec5.2-0.dtsi45 compatible = "fsl,sec-v5.2-job-ring",
46 "fsl,sec-v5.0-job-ring",
47 "fsl,sec-v4.0-job-ring";
53 compatible = "fsl,sec-v5.2-job-ring",
54 "fsl,sec-v5.0-job-ring",
55 "fsl,sec-v4.0-job-ring";
61 compatible = "fsl,sec-v5.2-job-ring",
62 "fsl,sec-v5.0-job-ring",
63 "fsl,sec-v4.0-job-ring";
70 "fsl,sec-v5.0-job-ring",
[all …]
H A Dpq3-sec4.4-0.dtsi45 compatible = "fsl,sec-v4.4-job-ring", "fsl,sec-v4.0-job-ring";
51 compatible = "fsl,sec-v4.4-job-ring", "fsl,sec-v4.0-job-ring";
57 compatible = "fsl,sec-v4.4-job-ring", "fsl,sec-v4.0-job-ring";
63 compatible = "fsl,sec-v4.4-job-ring", "fsl,sec-v4.0-job-ring";
H A Dqoriq-sec4.2-0.dtsi45 compatible = "fsl,sec-v4.2-job-ring",
46 "fsl,sec-v4.0-job-ring";
52 compatible = "fsl,sec-v4.2-job-ring",
53 "fsl,sec-v4.0-job-ring";
59 compatible = "fsl,sec-v4.2-job-ring",
60 "fsl,sec-v4.0-job-ring";
66 compatible = "fsl,sec-v4.2-job-ring",
67 "fsl,sec-v4.0-job-ring";
H A Dqoriq-sec5.0-0.dtsi45 compatible = "fsl,sec-v5.0-job-ring",
46 "fsl,sec-v4.0-job-ring";
52 compatible = "fsl,sec-v5.0-job-ring",
53 "fsl,sec-v4.0-job-ring";
59 compatible = "fsl,sec-v5.0-job-ring",
60 "fsl,sec-v4.0-job-ring";
66 compatible = "fsl,sec-v5.0-job-ring",
67 "fsl,sec-v4.0-job-ring";
H A Dqoriq-raid1.0-0.dtsi43 compatible = "fsl,raideng-v1.0-job-queue";
50 compatible = "fsl,raideng-v1.0-job-ring", "fsl,raideng-v1.0-hp-ring";
57 compatible = "fsl,raideng-v1.0-job-ring", "fsl,raideng-v1.0-lp-ring";
65 compatible = "fsl,raideng-v1.0-job-queue";
72 compatible = "fsl,raideng-v1.0-job-ring", "fsl,raideng-v1.0-hp-ring";
79 compatible = "fsl,raideng-v1.0-job-ring", "fsl,raideng-v1.0-lp-ring";
/f-stack/freebsd/sys/
H A Daio.h204 bool aio_cancel_cleared(struct kaiocb *job);
205 void aio_cancel(struct kaiocb *job);
206 bool aio_clear_cancel_function(struct kaiocb *job);
207 void aio_complete(struct kaiocb *job, long status, int error);
208 void aio_schedule(struct kaiocb *job, aio_handle_fn_t *func);
209 bool aio_set_cancel_function(struct kaiocb *job, aio_cancel_fn_t *func);
210 void aio_switch_vmspace(struct kaiocb *job);
/f-stack/dpdk/drivers/raw/dpaa2_qdma/
H A Ddpaa2_qdma.c219 *ppjob = job[loop]; in dpdmai_dev_set_fd_us()
319 *ppjob = job[i]; in dpdmai_dev_set_multi_fd_lf_no_rsp()
334 job[i]->src, job[i]->dest, job[i]->len, in dpdmai_dev_set_multi_fd_lf_no_rsp()
371 *ppjob = job[i]; in dpdmai_dev_set_multi_fd_lf()
387 job[i]->src, job[i]->dest, job[i]->len, in dpdmai_dev_set_multi_fd_lf()
436 ppjob[i] = job[i]; in dpdmai_dev_set_sg_fd_lf()
461 src = job[0]->src; in dpdmai_dev_set_sg_fd_lf()
462 dst = job[0]->dest; in dpdmai_dev_set_sg_fd_lf()
463 len = job[0]->len; in dpdmai_dev_set_sg_fd_lf()
526 *job = *ppjob; in dpdmai_dev_get_single_job_lf()
[all …]
H A Ddpaa2_qdma.h120 struct rte_qdma_job **job,
124 struct rte_qdma_job **job,
130 struct rte_qdma_job **job,
135 struct rte_qdma_job **job,
/f-stack/dpdk/examples/l2fwd-jobstats/
H A Dmain.c133 struct rte_jobstats *job; in show_lcore_stats() local
175 job = &qconf->port_fwd_jobs[i]; in show_lcore_stats()
178 jobs_period[i] = job->period; in show_lcore_stats()
180 jobs_exec[i] = job->exec_time; in show_lcore_stats()
184 rte_jobstats_reset(job); in show_lcore_stats()
247 job = &qconf->port_fwd_jobs[i]; in show_lcore_stats()
252 i, job->name, in show_lcore_stats()
264 job = &qconf->flush_job; in show_lcore_stats()
269 i, job->name, in show_lcore_stats()
370 if (job->min_period + UPDATE_STEP_DOWN < job->period) in l2fwd_job_update_cb()
[all …]
/f-stack/freebsd/contrib/zstd/lib/compress/
H A Dzstdmt_compress.c689 if (job->cdict) { in ZSTDMT_compressionJob()
694 U64 const pledgedSrcSize = job->firstJob ? job->fullFrameSize : job->src.size; in ZSTDMT_compressionJob()
707 ZSTDMT_serialState_update(job->serial, cctx, rawSeqStore, job->src, job->jobID); in ZSTDMT_compressionJob()
726 assert(job->cSize == 0); in ZSTDMT_compressionJob()
755 ZSTDMT_serialState_ensureFinished(job->serial, job->jobID, job->cSize); in ZSTDMT_compressionJob()
756 if (job->prefix.size > 0) in ZSTDMT_compressionJob()
1305 assert(job->lastJob == 1); in ZSTDMT_writeLastEmptyBlock()
1309 job->dstBuff = ZSTDMT_getBuffer(job->bufPool); in ZSTDMT_writeLastEmptyBlock()
1315 job->src = kNullRange; in ZSTDMT_writeLastEmptyBlock()
1316 job->cSize = ZSTD_writeLastEmptyBlock(job->dstBuff.start, job->dstBuff.capacity); in ZSTDMT_writeLastEmptyBlock()
[all …]
/f-stack/freebsd/contrib/device-tree/Bindings/crypto/
H A Dfsl-sec6.txt103 compatible = "fsl,sec-v6.0-job-ring";
123 compatible = "fsl,sec-v6.0-job-ring",
124 "fsl,sec-v5.2-job-ring",
125 "fsl,sec-v5.0-job-ring",
126 "fsl,sec-v4.4-job-ring",
127 "fsl,sec-v4.0-job-ring";
132 compatible = "fsl,sec-v6.0-job-ring",
133 "fsl,sec-v5.2-job-ring",
134 "fsl,sec-v5.0-job-ring",
135 "fsl,sec-v4.4-job-ring",
[all …]
/f-stack/dpdk/drivers/regex/mlx5/
H A Dmlx5_regex_fastpath.c104 struct mlx5_regex_job *job) in prep_one() argument
130 job->user_id = op->user_id; in prep_one()
195 extract_result(struct rte_regex_ops *op, struct mlx5_regex_job *job) in extract_result() argument
198 op->user_id = job->user_id; in extract_result()
203 job->metadata + in extract_result()
210 (job->output + offset), rule_id); in extract_result()
213 (job->output + offset), start_ptr); in extract_result()
216 (job->output + offset), length); in extract_result()
307 struct mlx5_regex_job *job = &queue->jobs[job_id]; in setup_sqs() local
312 (uintptr_t)job->metadata); in setup_sqs()
[all …]
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Dzvol.c977 minors_job_t *job = arg; in zvol_prefetch_minors_impl() local
978 char *dsname = job->name; in zvol_prefetch_minors_impl()
983 if (job->error == 0) { in zvol_prefetch_minors_impl()
1010 minors_job_t *job; in zvol_create_snap_minor_cb() local
1016 job->name = n; in zvol_create_snap_minor_cb()
1018 job->error = 0; in zvol_create_snap_minor_cb()
1052 minors_job_t *job; in zvol_create_minors_cb() local
1058 job->name = n; in zvol_create_minors_cb()
1060 job->error = 0; in zvol_create_minors_cb()
1104 minors_job_t *job; in zvol_create_minors_recursive() local
[all …]
/f-stack/freebsd/contrib/device-tree/src/arm64/freescale/
H A Dfsl-ls1012a.dtsi196 compatible = "fsl,sec-v5.4-job-ring",
197 "fsl,sec-v5.0-job-ring",
198 "fsl,sec-v4.0-job-ring";
204 compatible = "fsl,sec-v5.4-job-ring",
205 "fsl,sec-v5.0-job-ring",
206 "fsl,sec-v4.0-job-ring";
212 compatible = "fsl,sec-v5.4-job-ring",
213 "fsl,sec-v5.0-job-ring",
214 "fsl,sec-v4.0-job-ring";
221 "fsl,sec-v5.0-job-ring",
[all …]
/f-stack/dpdk/doc/guides/sample_app_ug/
H A Dl2_forward_job_stats.rst272 * stats_read_pending and lock are used during job stats read phase.
295 * Flush job statistics
307 rte_exit(1, "Failed to reset flush job timer for lcore %u: %s",
315 rte_jobstats_init(job, name, 0, drain_tsc, 0, MAX_PKT_BURST);
316 rte_jobstats_set_update_period_function(job, l2fwd_job_update_cb);
323 rte_exit(1, "Failed to reset lcore %u port %u job timer: %s",
349 /* Do the Idle job:
351 * - check if some real job need to be executed
381 …loop do the whole jobs management. When any job is ready, the use rte_timer_manage() is used to ca…
386 Third do-while loop is the idle job (idle stats counter). Its only purpose is monitoring if any job…
[all …]

1234