Home
last modified time | relevance | path

Searched refs:jq (Results 1 – 25 of 2268) sorted by relevance

12345678910>>...91

/dports/finance/aqbanking/aqbanking-6.2.10/src/libs/plugins/backends/aqhbci/joblayer/
H A Djobqueue.c47 jq->user=u; in AH_JobQueue_new()
50 jq->usage=1; in AH_JobQueue_new()
51 return jq; in AH_JobQueue_new()
58 if (jq) { in AH_JobQueue_free()
76 assert(jq); in AH_JobQueue_Attach()
84 assert(jq); in AH_JobQueue_GetFlags()
93 assert(jq); in AH_JobQueue_SetFlags()
102 assert(jq); in AH_JobQueue_AddFlags()
111 assert(jq); in AH_JobQueue_SubFlags()
120 assert(jq); in AH_JobQueue_GetUser()
[all …]
H A Djobqueue_addjob.c52 assert(jq); in AH_JobQueue_AddJob()
60 if (AH_JobQueue_GetCount(jq)<1) { in AH_JobQueue_AddJob()
73 jobQueueResult=_checkJobFlags(jq, j); in AH_JobQueue_AddJob()
79 jobQueueResult=_checkJobTypes(jq, j); in AH_JobQueue_AddJob()
85 jobQueueResult=_checkSigners(jq, j); in AH_JobQueue_AddJob()
91 if (AH_JobQueue_GetSecClass(jq)==0) in AH_JobQueue_AddJob()
144 user=AH_JobQueue_GetUser(jq); in _checkJobTypes()
176 j=AH_JobQueue_GetFirstJob(jq); in _countJobTypes()
201 j=AH_JobQueue_GetFirstJob(jq); in _countJobsOfType()
218 j=AH_JobQueue_GetFirstJob(jq); in _countJobsOtherThanTan()
[all …]
/dports/textproc/jq/jq-jq-1.6/src/
H A Dexecute.c160 jq->curr_frame = stack_pop_block(&jq->stk, jq->curr_frame, frame_size(fp->bc)); in frame_pop()
165 jq->stk_top = stack_push_block(&jq->stk, jq->stk_top, sizeof(jv)); in stack_push()
176 jq->stk_top = stack_pop_block(&jq->stk, jq->stk_top, sizeof(jv)); in stack_pop()
189 jq->stk_top = stack_pop_block(&jq->stk, jq->stk_top, sizeof(jv)); in stack_popn()
328 jq->err_cb(jq->err_cb_data, value); in jq_report_error()
613 stack_push(jq, jq->path); in jq_next()
618 stack_push(jq, jq->value_at_path); in jq_next()
644 jq->path = stack_pop(jq); in jq_next()
660 jq->path = stack_pop(jq); in jq_next()
1048 stack_save(jq, jq->bc->code, stack_get_pos(jq)); in jq_start()
[all …]
/dports/databases/p5-Redis-JobQueue/Redis-JobQueue-1.19/t/01_JobQueue/
H A D01_new.t66 my ( $jq, $next_jq );
88 isa_ok( $jq, 'Redis::JobQueue' );
126 $jq = Redis::JobQueue->new(
141 $jq = Redis::JobQueue->new(
158 $jq = Redis::JobQueue->new(
166 $jq = Redis::JobQueue->new(
175 $jq = Redis::JobQueue->new(
184 $jq = Redis::JobQueue->new(
189 $jq,
196 $jq = Redis::JobQueue->new(
[all …]
H A D11_last_errorcode.t104 $jq->_call_redis( "DEL", $_ ) foreach $jq->_call_redis( "KEYS", "JobQueue:*" );
112 $jq->_call_redis( "DEL", $_ ) foreach $jq->_call_redis( "KEYS", "JobQueue:*" );
117 @jobs = $jq->get_job_ids;
151 $jq->_redis->quit;
167 $jq->_redis->quit;
194 $jq->_call_redis( "DEL", $_ ) foreach $jq->_call_redis( "KEYS", "JobQueue:*" );
213 $jq->timeout( 1 );
235 $jq->_call_redis( "DEL", $_ ) foreach $jq->_call_redis( "KEYS", "JobQueue:*" );
258 $jq->timeout( 1 );
301 $jq->_call_redis( "DEL", $_ ) foreach $jq->_call_redis( "KEYS", "JobQueue:*" );
[all …]
/dports/textproc/jq/jq-jq-1.6/docs/content/2.download/
H A Ddefault.yml35 [64-bit](https://github.com/stedolan/jq/releases/download/jq-1.6/jq-linux64)
37 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.6/jq-linux32).
40 [64-bit](https://github.com/stedolan/jq/releases/download/jq-1.5/jq-linux64)
42 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.5/jq-linux32).
47 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.4/jq-linux-x86).
52 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.3/jq-linux-x86).
60 [64-bit](https://github.com/stedolan/jq/releases/download/jq-1.6/jq-osx-amd64).
68 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.4/jq-osx-x86).
73 [32-bit](https://github.com/stedolan/jq/releases/download/jq-1.3/jq-osx-x86).
143 …* [Source tarball for jq 1.6](https://github.com/stedolan/jq/releases/download/jq-1.6/jq-1.6.tar.g…
[all …]
/dports/biology/exonerate/exonerate-2.4.0/src/general/
H A Djobqueue.c52 } while(!jq->is_complete); in JobQueue_thread_func()
68 jq->is_complete = FALSE; in JobQueue_create()
70 jq->running_count = 0; in JobQueue_create()
74 jq->pq = PQueue_create(jq->pq_set, JobQueue_Task_compare, NULL); in JobQueue_create()
76 pthread_create(&jq->thread[i], NULL, JobQueue_thread_func, jq); in JobQueue_create()
78 return jq; in JobQueue_create()
93 g_free(jq->thread); in JobQueue_destroy()
95 g_free(jq); in JobQueue_destroy()
103 g_assert(jq); in JobQueue_submit()
121 job_total = PQueue_total(jq->pq) + jq->running_count; in JobQueue_complete()
[all …]
/dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
255 sched_pkt->jq = jq; in jobq_add()
264 P(jq->mutex); in jobq_add()
301 V(jq->mutex); in jobq_add()
372 } else if (jq->num_workers < jq->max_workers) { in start_server()
441 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
253 sched_pkt->jq = jq; in jobq_add()
262 P(jq->mutex); in jobq_add()
299 V(jq->mutex); in jobq_add()
370 } else if (jq->num_workers < jq->max_workers) { in start_server()
439 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
509 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula11-server/bacula-11.0.5/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
253 sched_pkt->jq = jq; in jobq_add()
262 P(jq->mutex); in jobq_add()
299 V(jq->mutex); in jobq_add()
370 } else if (jq->num_workers < jq->max_workers) { in start_server()
439 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
509 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula9-client-static/bacula-9.6.7/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
255 sched_pkt->jq = jq; in jobq_add()
264 P(jq->mutex); in jobq_add()
301 V(jq->mutex); in jobq_add()
372 } else if (jq->num_workers < jq->max_workers) { in start_server()
441 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula11-client-static/bacula-11.0.5/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
253 sched_pkt->jq = jq; in jobq_add()
262 P(jq->mutex); in jobq_add()
299 V(jq->mutex); in jobq_add()
370 } else if (jq->num_workers < jq->max_workers) { in start_server()
439 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
509 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula11-client/bacula-11.0.5/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
253 sched_pkt->jq = jq; in jobq_add()
262 P(jq->mutex); in jobq_add()
299 V(jq->mutex); in jobq_add()
370 } else if (jq->num_workers < jq->max_workers) { in start_server()
439 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
509 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula9-client/bacula-9.6.7/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
255 sched_pkt->jq = jq; in jobq_add()
264 P(jq->mutex); in jobq_add()
301 V(jq->mutex); in jobq_add()
372 } else if (jq->num_workers < jq->max_workers) { in start_server()
441 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bacula9-server/bacula-9.6.7/src/dird/
H A Djobq.c111 P(jq->mutex); in jobq_destroy()
136 V(jq->mutex); in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
255 sched_pkt->jq = jq; in jobq_add()
264 P(jq->mutex); in jobq_add()
301 V(jq->mutex); in jobq_add()
372 } else if (jq->num_workers < jq->max_workers) { in start_server()
441 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/databases/p5-Redis-JobQueue/Redis-JobQueue-1.19/ex/
H A Dexample.pl32 my $jq = shift;
77 my $jq;
85 exception( $jq, $@ ) if $@;
93 $job = $jq->add_job(
101 exception( $jq, $@ ) if $@;
105 $job = $jq->add_job(
113 exception( $jq, $@ ) if $@;
174 exception( $jq, $@ ) if $@;
192 exception( $jq, $@ ) if $@;
222 exception( $jq, $@ ) if $@;
[all …]
/dports/sysutils/bareos19-traymonitor/bareos-Release-19.2.11/core/src/dird/
H A Djobq.cc125 P(jq->mutex); in JobqDestroy()
143 V(jq->mutex); in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
244 sched_pkt->jq = jq; in JobqAdd()
254 P(jq->mutex); in JobqAdd()
302 V(jq->mutex); in JobqAdd()
360 if (jq->num_workers < jq->max_workers) { in StartServer()
430 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
512 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos19-client/bareos-Release-19.2.11/core/src/dird/
H A Djobq.cc125 P(jq->mutex); in JobqDestroy()
143 V(jq->mutex); in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
244 sched_pkt->jq = jq; in JobqAdd()
254 P(jq->mutex); in JobqAdd()
302 V(jq->mutex); in JobqAdd()
360 if (jq->num_workers < jq->max_workers) { in StartServer()
430 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
512 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos19-server/bareos-Release-19.2.11/core/src/dird/
H A Djobq.cc125 P(jq->mutex); in JobqDestroy()
143 V(jq->mutex); in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
244 sched_pkt->jq = jq; in JobqAdd()
254 P(jq->mutex); in JobqAdd()
302 V(jq->mutex); in JobqAdd()
360 if (jq->num_workers < jq->max_workers) { in StartServer()
430 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
512 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos18-traymonitor/bareos-Release-18.2.12/core/src/dird/
H A Djobq.cc128 P(jq->mutex); in JobqDestroy()
145 V(jq->mutex); in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
246 sched_pkt->jq = jq; in JobqAdd()
255 P(jq->mutex); in JobqAdd()
303 V(jq->mutex); in JobqAdd()
363 if (jq->num_workers < jq->max_workers) { in StartServer()
431 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos18-client/bareos-Release-18.2.12/core/src/dird/
H A Djobq.cc128 P(jq->mutex); in JobqDestroy()
145 V(jq->mutex); in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
246 sched_pkt->jq = jq; in JobqAdd()
255 P(jq->mutex); in JobqAdd()
303 V(jq->mutex); in JobqAdd()
363 if (jq->num_workers < jq->max_workers) { in StartServer()
431 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos18-server/bareos-Release-18.2.12/core/src/dird/
H A Djobq.cc128 P(jq->mutex); in JobqDestroy()
145 V(jq->mutex); in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
246 sched_pkt->jq = jq; in JobqAdd()
255 P(jq->mutex); in JobqAdd()
303 V(jq->mutex); in JobqAdd()
363 if (jq->num_workers < jq->max_workers) { in StartServer()
431 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/www/bareos19-webui/bareos-Release-19.2.11/core/src/dird/
H A Djobq.cc125 P(jq->mutex); in JobqDestroy()
143 V(jq->mutex); in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
244 sched_pkt->jq = jq; in JobqAdd()
254 P(jq->mutex); in JobqAdd()
302 V(jq->mutex); in JobqAdd()
360 if (jq->num_workers < jq->max_workers) { in StartServer()
430 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
512 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/www/bareos18-webui/bareos-Release-18.2.12/core/src/dird/
H A Djobq.cc128 P(jq->mutex); in JobqDestroy()
145 V(jq->mutex); in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
246 sched_pkt->jq = jq; in JobqAdd()
255 P(jq->mutex); in JobqAdd()
303 V(jq->mutex); in JobqAdd()
363 if (jq->num_workers < jq->max_workers) { in StartServer()
431 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
513 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]
/dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/dird/
H A Djobq.cc125 P(jq->mutex); in JobqDestroy()
143 V(jq->mutex); in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
243 sched_pkt->jq = jq; in JobqAdd()
253 P(jq->mutex); in JobqAdd()
301 V(jq->mutex); in JobqAdd()
359 if (jq->num_workers < jq->max_workers) { in StartServer()
428 while (!jq->ready_jobs->empty() && !jq->quit) { in jobq_server()
510 if (!jq->waiting_jobs->empty() && !jq->quit) { in jobq_server()
[all …]

12345678910>>...91