| /src/external/mpl/bind/dist/lib/isc/ |
| helper.c | 24 #include <isc/job.h>
49 isc_job_t *job = isc_mem_get(helper->mctx, sizeof(*job)); local
50 *job = (isc_job_t){
55 cds_wfcq_node_init(&job->wfcq_node);
58 * cds_wfcq_enqueue() is non-blocking and enqueues the job to async
65 &helper->async_jobs.tail, &job->wfcq_node))
|
| async.c | 24 #include <isc/job.h>
47 isc_job_t *job = isc_mem_get(loop->mctx, sizeof(*job)); local
48 *job = (isc_job_t){
53 cds_wfcq_node_init(&job->wfcq_node);
56 * cds_wfcq_enqueue() is non-blocking and enqueues the job to async
63 &job->wfcq_node))
111 isc_job_t *job = caa_container_of(node, isc_job_t, wfcq_node); local
113 job->cb(job->cbarg)
[all...] |
| job.c | 1 /* $NetBSD: job.c,v 1.2 2025/01/26 16:25:37 christos Exp $ */
23 #include <isc/job.h>
43 * Public: #include <isc/job.h>
47 isc_job_run(isc_loop_t *loop, isc_job_t *job, isc_job_cb cb, void *cbarg) {
52 job->cb = cb;
53 job->cbarg = cbarg;
54 ISC_LINK_INIT(job, link);
56 ISC_LIST_APPEND(loop->run_jobs, job, link);
70 isc_job_t *job, *next; local
71 for (job = ISC_LIST_HEAD(jobs)
[all...] |
| quota.c | 84 * new job has appeared in the queue, then give it a chance
98 isc_job_t *job = caa_container_of(node, isc_job_t, wfcq_node); local
99 job->cb(job->cbarg);
103 isc_quota_acquire_cb(isc_quota_t *quota, isc_job_t *job, isc_job_cb cb,
106 REQUIRE(job == NULL || cb != NULL);
112 if (job != NULL) {
113 job->cb = cb;
114 job->cbarg = cbarg;
115 cds_wfcq_node_init(&job->wfcq_node)
[all...] |
| /src/external/ibm-public/postfix/dist/src/qmgr/ |
| qmgr_peer.c | 7 /* per-job peers
11 /* QMGR_PEER *qmgr_peer_create(job, queue)
12 /* QMGR_JOB *job;
15 /* QMGR_PEER *qmgr_peer_find(job, queue)
16 /* QMGR_JOB *job;
19 /* QMGR_PEER *qmgr_peer_obtain(job, queue)
20 /* QMGR_JOB *job;
26 /* QMGR_PEER *qmgr_peer_select(job)
27 /* QMGR_JOB *job;
30 /* These routines add/delete/manipulate per-job peers
99 QMGR_JOB *job = peer->job; local
[all...] |
| qmgr_entry.c | 125 peer->job->selected_entries++;
200 peer->job->selected_entries--;
212 QMGR_JOB *dst_job, *src_job = src_peer->job;
226 * adjusting the job counters accordingly, then dispose of the old entry.
230 * explicitly for the new job here.
257 QMGR_JOB *sponsor, *job = peer->job; local
258 QMGR_TRANSPORT *transport = job->transport;
270 job->selected_entries++;
281 job->rcpt_count -= entry->rcpt_list.len
[all...] |
| /src/external/bsd/cron/dist/ |
| job.c | 1 /* $NetBSD: job.c,v 1.3 2020/04/18 19:32:19 christos Exp $ */
27 static char rcsid[] = "Id: job.c,v 1.6 2004/01/23 18:56:43 vixie Exp";
29 __RCSID("$NetBSD: job.c,v 1.3 2020/04/18 19:32:19 christos Exp $");
41 } job; typedef in typeref:struct:_job
45 static int okay_to_go(job *);
49 job *j;
59 /* build a job queue element */
74 job *j, *prev = NULL;
92 job *j, *prev = NULL;
111 job *j
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/amd/amdgpu/ |
| amdgpu_jpeg.c | 146 struct amdgpu_job *job; local
152 r = amdgpu_job_alloc_with_ib(ring->adev, ib_size_dw * 4, &job);
156 ib = &job->ibs[0];
166 r = amdgpu_job_submit_direct(job, ring, &f);
177 amdgpu_job_free(job);
|
| amdgpu_job.c | 39 struct amdgpu_job *job = to_amdgpu_job(s_job); local
44 if (amdgpu_ring_soft_recovery(ring, job->vmid, s_job->s_fence->parent)) {
50 amdgpu_vm_get_task_info(ring->adev, job->pasid, &ti);
52 job->base.sched->name, atomic_read(&ring->fence_drv.last_seq),
58 amdgpu_device_gpu_recover(ring->adev, job);
64 struct amdgpu_job **job, struct amdgpu_vm *vm)
73 *job = kzalloc(size, GFP_KERNEL);
74 if (!*job)
81 (*job)->base.sched = &adev->rings[0]->sched;
82 (*job)->vm = vm
126 struct amdgpu_job *job = to_amdgpu_job(s_job); local
191 struct amdgpu_job *job = to_amdgpu_job(sched_job); local
223 struct amdgpu_job *job; local
[all...] |
| amdgpu_vcn.c | 393 struct amdgpu_job *job; local
398 r = amdgpu_job_alloc_with_ib(adev, 64, &job);
402 ib = &job->ibs[0];
416 r = amdgpu_job_submit_direct(job, ring, &f);
431 amdgpu_job_free(job);
561 struct amdgpu_job *job; local
567 r = amdgpu_job_alloc_with_ib(ring->adev, ib_size_dw * 4, &job);
571 ib = &job->ibs[0];
594 r = amdgpu_job_submit_direct(job, ring, &f);
605 amdgpu_job_free(job);
614 struct amdgpu_job *job; local
[all...] |
| /src/tests/rump/kernspace/ |
| threadpool.c | 99 struct threadpool_job job; member in struct:test_job_data
105 test_job_func_schedule(struct threadpool_job *job)
108 container_of(job, struct test_job_data, job);
114 threadpool_job_done(job);
119 test_job_func_cancel(struct threadpool_job *job)
122 container_of(job, struct test_job_data, job);
133 threadpool_job_done(job);
142 threadpool_job_init(&data->job, fn, &data->mutex, "testjob")
[all...] |
| /src/crypto/external/bsd/openssl.old/dist/test/ |
| asynctest.c | 49 ASYNC_JOB *job; local
51 job = ASYNC_get_current_job();
52 if (job == NULL)
54 waitctx = ASYNC_get_wait_ctx(job);
128 ASYNC_JOB *job = NULL; local
136 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
139 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
156 ASYNC_JOB *job = NULL; local
164 || ASYNC_start_job(&job, waitctx, &funcret, save_current, NULL, 0)
166 || currjob != job
183 ASYNC_JOB *job = NULL; local
250 ASYNC_JOB *job = NULL; local
[all...] |
| /src/external/mpl/bind/dist/tests/isc/ |
| job_test.c | 30 #include <isc/job.h>
44 isc_job_t job; member in struct:test_arg
67 isc_job_run(isc_loop(), &ta->job, job_cb, ta);
69 isc_job_run(isc_loop(), &ta->job, shutdown_cb, ta);
80 *ta = (struct test_arg){ .job = ISC_JOB_INITIALIZER };
83 isc_job_run(isc_loop(), &ta->job, job_cb, ta);
98 struct test_arg n1 = { .job = ISC_JOB_INITIALIZER, .arg.n = 1 };
99 struct test_arg n2 = { .job = ISC_JOB_INITIALIZER, .arg.n = 2 };
100 struct test_arg n3 = { .job = ISC_JOB_INITIALIZER, .arg.n = 3 };
101 struct test_arg n4 = { .job = ISC_JOB_INITIALIZER, .arg.n = 4 }
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/scheduler/ |
| sched_entity.c | 50 * @guilty: atomic_t set to 1 when a job on this queue
114 * Return true if entity could provide a job.
240 struct drm_sched_job *job = container_of(cb, struct drm_sched_job, local
243 drm_sched_fence_finished(job->s_fence);
244 WARN_ON(job->s_fence->parent);
245 job->sched->ops->free_job(job);
258 struct drm_sched_job *job; local
261 while ((job = to_drm_sched_job(spsc_queue_pop(&entity->job_queue)))) {
262 struct drm_sched_fence *s_fence = job->s_fence
[all...] |
| sched_main.c | 34 * backend operations to the scheduler like submitting a job to hardware run queue,
35 * returning the dependencies of a job etc.
127 * drm_sched_rq_select_entity - Select an entity which could provide a job to run
224 * drm_sched_suspend_timeout - Suspend scheduler job timeout
261 * drm_sched_resume_timeout - Resume scheduler job timeout
299 struct drm_sched_job *job; local
306 job = list_first_entry_or_null(&sched->ring_mirror_list,
309 if (job) {
311 * Remove the bad job so it cannot be freed by concurrent
315 list_del_init(&job->node)
694 struct drm_sched_job *job; local
[all...] |
| /src/crypto/external/apache2/openssl/dist/crypto/async/ |
| async.c | 80 ASYNC_JOB *job = NULL; local
82 job = OPENSSL_zalloc(sizeof(*job));
83 if (job == NULL)
86 job->status = ASYNC_JOB_RUNNING;
88 return job;
91 static void async_job_free(ASYNC_JOB *job)
93 if (job != NULL) {
94 OPENSSL_free(job->funcargs);
95 async_fibre_free(&job->fibrectx)
102 ASYNC_JOB *job; local
150 ASYNC_JOB *job; local
291 ASYNC_JOB *job; local
320 ASYNC_JOB *job; local
382 ASYNC_JOB *job; local
[all...] |
| /src/crypto/external/bsd/openssl/dist/crypto/async/ |
| async.c | 82 ASYNC_JOB *job = NULL; local
84 job = OPENSSL_zalloc(sizeof(*job));
85 if (job == NULL) {
90 job->status = ASYNC_JOB_RUNNING;
92 return job;
95 static void async_job_free(ASYNC_JOB *job)
97 if (job != NULL) {
98 OPENSSL_free(job->funcargs);
99 async_fibre_free(&job->fibrectx)
105 ASYNC_JOB *job; local
152 ASYNC_JOB *job; local
293 ASYNC_JOB *job; local
322 ASYNC_JOB *job; local
385 ASYNC_JOB *job; local
[all...] |
| /src/crypto/external/bsd/openssl/dist/test/ |
| asynctest.c | 82 ASYNC_JOB *job; local
84 job = ASYNC_get_current_job();
85 if (job == NULL)
87 waitctx = ASYNC_get_wait_ctx(job);
198 ASYNC_JOB *job = NULL; local
206 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
209 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
226 ASYNC_JOB *job = NULL; local
234 || ASYNC_start_job(&job, waitctx, &funcret, save_current, NULL, 0)
236 || currjob != job
253 ASYNC_JOB *job = NULL; local
320 ASYNC_JOB *job = NULL; local
344 ASYNC_JOB *job = NULL; local
[all...] |
| /src/crypto/external/bsd/openssl.old/dist/crypto/async/ |
| async.c | 80 ASYNC_JOB *job = NULL; local
82 job = OPENSSL_zalloc(sizeof(*job));
83 if (job == NULL) {
88 job->status = ASYNC_JOB_RUNNING;
90 return job;
93 static void async_job_free(ASYNC_JOB *job)
95 if (job != NULL) {
96 OPENSSL_free(job->funcargs);
97 async_fibre_free(&job->fibrectx)
103 ASYNC_JOB *job; local
146 ASYNC_JOB *job; local
257 ASYNC_JOB *job; local
286 ASYNC_JOB *job; local
349 ASYNC_JOB *job; local
[all...] |
| /src/external/bsd/zstd/dist/contrib/seekable_format/examples/ |
| parallel_processing.c | 108 struct sum_job* job = (struct sum_job*)opaque; local
109 job->done = 0;
111 FILE* const fin = fopen_orDie(job->fname, "rb");
119 size_t const frameSize = ZSTD_seekable_getFrameDecompressedSize(seekable, job->frameNb);
122 size_t result = ZSTD_seekable_decompressFrame(seekable, data, frameSize, job->frameNb);
130 job->sum = sum;
131 job->done = 1;
|
| /src/external/cddl/osnet/lib/libzfs/ |
| thread_pool.c | 40 tpool_job_t *job; local
45 for (job = tpool->tp_head; job != NULL; job = tpool->tp_head) {
46 tpool->tp_head = job->tpj_next;
47 free(job);
84 * Called by a worker thread on return from a tpool_dispatch()d job.
112 tpool_job_t *job; local
161 if ((job = tpool->tp_head) != NULL &&
164 func = job->tpj_func
265 tpool_job_t *job; local
[all...] |
| /src/bin/sh/ |
| jobs.h | 50 #define SHOW_ISSIG 0x20 /* job was signalled */
51 #define SHOW_NO_FREE 0x40 /* do not free job */
56 * A job structure contains information about a job. A job is either a
69 struct job { struct
74 pid_t pgrp; /* process group of this job */
82 #define JOBWANTED 2 /* set if this is a job being sought */
83 #define JPIPEFAIL 4 /* set if -o pipefail when job created */
85 char jobctl; /* job running under job control *
[all...] |
| /src/sys/arch/mips/atheros/dev/ |
| arspi.c | 93 #define JOB_WAIT 0x8 /* job must wait for WIP bits */
260 struct arspi_job *job = st->st_busprivate; local
262 kmem_free(job, sizeof(*job));
283 struct arspi_job *job; local
297 job = st->st_busprivate;
306 if (job->job_flags & JOB_WAIT) {
312 } else if (job->job_flags & JOB_WREN) {
319 PUTREG(sc, ARSPI_REG_DATA, job->job_data);
322 PUTREG(sc, ARSPI_REG_OPCODE, job->job_opcode
347 struct arspi_job *job; local
466 struct arspi_job *job; local
579 struct arspi_job *job = st->st_busprivate; local
609 struct arspi_job *job = st->st_busprivate; local
[all...] |
| /src/crypto/external/apache2/openssl/dist/test/ |
| asynctest.c | 83 ASYNC_JOB *job; local
85 job = ASYNC_get_current_job();
86 if (job == NULL)
88 waitctx = ASYNC_get_wait_ctx(job);
198 ASYNC_JOB *job = NULL; local
206 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
209 || ASYNC_start_job(&job, waitctx, &funcret, add_two, NULL, 0)
226 ASYNC_JOB *job = NULL; local
234 || ASYNC_start_job(&job, waitctx, &funcret, save_current, NULL, 0)
236 || currjob != job
253 ASYNC_JOB *job = NULL; local
320 ASYNC_JOB *job = NULL; local
344 ASYNC_JOB *job = NULL; local
[all...] |
| /src/external/bsd/tmux/dist/ |
| job.c | 33 * Job scheduling. Run queued commands in the background and record their
41 /* A single job. */
42 struct job { struct
64 LIST_ENTRY(job) entry;
68 static LIST_HEAD(joblist, job) all_jobs = LIST_HEAD_INITIALIZER(all_jobs);
70 /* Start a job running. */
71 struct job *
77 struct job *job; local
198 job = xcalloc(1, sizeof *job)
311 struct job *job = data; local
325 struct job *job = data; local
342 struct job *job = data; local
360 struct job *job; local
413 struct job *job; local
425 struct job *job; local
438 struct job *job; local
[all...] |
