| /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...] |
| /src/external/ibm-public/postfix/dist/src/qmgr/ |
| qmgr_job.c | 15 /* void qmgr_job_free(job)
16 /* QMGR_JOB *job;
18 /* void qmgr_job_move_limits(job)
19 /* QMGR_JOB *job;
28 /* Each job corresponds to a specific transport and message.
29 /* Each job has a peer list containing all pending delivery
32 /* qmgr_job_obtain() finds an existing job for named message and
33 /* transport combination. New empty job is created if no existing can
34 /* be found. In either case, the job is prepared for assignment of
37 /* qmgr_job_free() disposes of a per-transport job after al
104 QMGR_JOB *job; local
250 QMGR_JOB *job; local
489 QMGR_JOB *job, *best_job = 0; local
578 QMGR_JOB *job, *prev; local
833 QMGR_JOB *job, *next; local
[all...] |
| 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...] |
| /src/external/mpl/bind/dist/lib/isc/ |
| 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...] |
| 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...] |
| 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))
|
| /src/sys/external/bsd/drm2/dist/drm/amd/amdgpu/ |
| 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_job.h | 40 #define AMDGPU_JOB_GET_VMID(job) ((job) ? (job)->vmid : 0)
70 struct amdgpu_job **job, struct amdgpu_vm *vm);
72 struct amdgpu_job **job);
74 void amdgpu_job_free_resources(struct amdgpu_job *job);
75 void amdgpu_job_free(struct amdgpu_job *job);
76 int amdgpu_job_submit(struct amdgpu_job *job, struct drm_sched_entity *entity,
78 int amdgpu_job_submit_direct(struct amdgpu_job *job, struct amdgpu_ring *ring,
|
| amdgpu_ib.c | 128 struct amdgpu_ib *ibs, struct amdgpu_job *job,
148 /* ring tests don't use a job */
149 if (job) {
150 vm = job->vm;
151 fence_ctx = job->base.s_fence ?
152 job->base.s_fence->scheduled.context : 0;
163 if (vm && !job->vmid) {
178 if (ring->funcs->emit_pipeline_sync && job &&
179 ((tmp = amdgpu_sync_get_fence(&job->sched_sync, NULL)) ||
181 amdgpu_vm_need_pipeline_sync(ring, job))) {
[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/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/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.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/usr.bin/make/ |
| job.c | 1 /* $NetBSD: job.c,v 1.529 2026/04/06 17:13:54 rillig Exp $ */
93 * job table is empty.
119 #include "job.h"
126 /* "@(#)job.c 8.2 (Berkeley) 3/19/94" */
127 MAKE_RCSID("$NetBSD: job.c,v 1.529 2026/04/06 17:13:54 rillig Exp $");
155 JOB_ST_FREE, /* Job is available */
156 JOB_ST_SET_UP, /* Job is allocated but otherwise invalid */
157 JOB_ST_RUNNING, /* Job is running, pid valid */
158 JOB_ST_FINISHED /* Job is done (i.e. after SIGCHLD) */
169 * A Job manages the shell commands that are run to create a single target
575 const Job *job; local
680 Job *job; local
794 Job *job; local
1730 Job *job; local
1960 Job *job; local
2020 Job *job; local
2036 Job *job; local
2451 Job *job; local
2529 Job *job; local
[all...] |
| trace.c | 42 * Trace_Log Log an event about a particular make job.
48 #include "job.h"
61 "JOB",
84 Trace_Log(TrEvent event, Job *job)
104 if (job != NULL) {
105 GNode *gn = Job_Node(job);
108 Job_FlagsToString(job, flags, sizeof flags);
110 gn->name, Job_Pid(job), flags, type);
|
| /src/external/bsd/zstd/dist/programs/ |
| fileio_asyncio.c | 147 IOJob_t* const job = (IOJob_t*) malloc(sizeof(IOJob_t)); local
149 if(!job || !buffer)
151 job->buffer = buffer;
152 job->bufferSize = bufferSize;
153 job->usedBufferSize = 0;
154 job->file = NULL;
155 job->ctx = ctx;
156 job->offset = 0;
157 return job;
220 * Releases an acquired job back to the pool. Doesn't execute the job. *
262 IOJob_t* job = (IOJob_t*) ctx->availableJobs[i]; local
271 IOJob_t* job; local
374 IOJob_t* const job = (IOJob_t*) opaque; local
415 IOJob_t* job = (IOJob_t*) ctx->completedJobs[i]; local
437 IOJob_t *job = NULL; local
464 IOJob_t *job = NULL; local
489 IOJob_t* const job = (IOJob_t*) opaque; local
510 IOJob_t* const job = AIO_IOPool_acquireJob(&ctx->base); local
604 IOJob_t *job; local
[all...] |
| /src/usr.bin/make/unit-tests/ |
| job-output-long-lines.mk | 1 # $NetBSD: job-output-long-lines.mk,v 1.4 2020/11/01 17:29:13 rillig Exp $
10 # As of 2020-09-27, the default job buffer size is 1024. When a job produces
12 # not terminated by a newline. Because of this missing newline, the job
13 # markers "--- job-a ---" and "--- job-b ---" are not always written at the
22 all: job-a job-b
24 job-a:
29 job-b
[all...] |
| opt-tracefile.exp | 5 <timestamp> 1 JOB <make-pid> <curdir> dependency1 <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND|OP_MARK
6 <timestamp> 1 DON <make-pid> <curdir> dependency1 <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND|OP_MARK
7 <timestamp> 1 JOB <make-pid> <curdir> dependency2 <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND|OP_MARK
8 <timestamp> 1 DON <make-pid> <curdir> dependency2 <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND|OP_MARK
9 <timestamp> 1 JOB <make-pid> <curdir> trace <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND
10 <timestamp> 1 DON <make-pid> <curdir> trace <job-pid> --- OP_DEPENDS|OP_PHONY|OP_HAS_COMMANDS|OP_DEPS_FOUND
|
| sh-errctl.exp | 21 job started, job table:
22 job 0, status running, flags ---, pid <pid>
|
| /src/sys/kern/ |
| sys_aio.c | 38 * Workers sleep on service_cv until a job is assigned.
42 * Job distribution:
54 * Job tracking:
55 * A hash table (by userspace aiocb pointer) maps aiocb -> kernel job.
64 * Enables future enhancements like dynamic job appending during processing.
324 * Destroy job structure
327 aio_job_fini(struct aio_job *job)
329 mutex_enter(&job->mtx);
330 aiowaitgrouplk_fini(&job->lk);
331 mutex_exit(&job->mtx)
447 struct aio_job *job, *tmp; local
533 struct aio_job *job; local
843 struct aio_job *job = st->job; local
1136 struct aio_job *job; local
1171 struct aio_job *job; local
1197 struct aio_job *job = NULL; local
1260 struct aio_job *job = NULL; local
1293 struct aio_job *job = NULL; local
1741 struct aio_job *job; local
2175 struct aio_job *job; local
[all...] |
| kern_threadpool.c | 37 * can be given jobs to assign to a worker thread. Scheduling a job in
76 * touching remote CPUs' memory when scheduling a job, but that still
141 "struct threadpool *"/*pool*/, "struct threadpool_job *"/*job*/);
143 "struct threadpool *"/*pool*/, "struct threadpool_job *"/*job*/);
145 "struct threadpool *"/*pool*/, "struct threadpool_job *"/*job*/);
148 "struct threadpool_job *"/*job*/,
159 "struct threadpool_job *"/*job*/);
162 "struct threadpool_job *"/*job*/,
172 "struct threadpool *"/*pool*/, "struct threadpool_job *"/*job*/);
752 threadpool_job_init(struct threadpool_job *job, threadpool_job_fn_t fn
1043 struct threadpool_job *const job = TAILQ_FIRST(&pool->tp_jobs); local
1136 struct threadpool_job *const job = thread->tpt_job; 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/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/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...] |
