/dports/finance/aqbanking/aqbanking-6.2.10/src/libs/plugins/backends/aqhbci/joblayer/ |
H A D | jobqueue.c | 47 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 D | jobqueue_addjob.c | 52 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 D | execute.c | 160 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 D | 01_new.t | 66 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 D | 11_last_errorcode.t | 104 $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 D | default.yml | 35 [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 D | jobqueue.c | 52 } 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | jobq.c | 111 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 D | example.pl | 32 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 D | jobq.cc | 125 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 D | jobq.cc | 125 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 D | jobq.cc | 125 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 D | jobq.cc | 128 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 D | jobq.cc | 128 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 D | jobq.cc | 128 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 D | jobq.cc | 125 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 D | jobq.cc | 128 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 D | jobq.cc | 125 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 …]
|