| /dports/finance/aqbanking/aqbanking-6.2.10/src/libs/plugins/backends/aqhbci/joblayer/ |
| H A D | jobqueue.c | 40 AH_JOBQUEUE *jq; in AH_JobQueue_new() local
56 void AH_JobQueue_free(AH_JOBQUEUE *jq) in AH_JobQueue_free()
74 void AH_JobQueue_Attach(AH_JOBQUEUE *jq) in AH_JobQueue_Attach()
82 uint32_t AH_JobQueue_GetFlags(const AH_JOBQUEUE *jq) in AH_JobQueue_GetFlags()
91 void AH_JobQueue_SetFlags(AH_JOBQUEUE *jq, uint32_t f) in AH_JobQueue_SetFlags()
100 void AH_JobQueue_AddFlags(AH_JOBQUEUE *jq, uint32_t f) in AH_JobQueue_AddFlags()
118 AB_USER *AH_JobQueue_GetUser(const AH_JOBQUEUE *jq) in AH_JobQueue_GetUser()
127 int AH_JobQueue_GetSecProfile(const AH_JOBQUEUE *jq) in AH_JobQueue_GetSecProfile()
145 int AH_JobQueue_GetSecClass(const AH_JOBQUEUE *jq) in AH_JobQueue_GetSecClass()
154 void AH_JobQueue_SetSecClass(AH_JOBQUEUE *jq, int i) in AH_JobQueue_SetSecClass()
[all …]
|
| H A D | jobqueue_addjob.c | 49 AH_JOBQUEUE_ADDRESULT AH_JobQueue_AddJob(AH_JOBQUEUE *jq, AH_JOB *j) in AH_JobQueue_AddJob()
134 AH_JOBQUEUE_ADDRESULT _checkJobTypes(AH_JOBQUEUE *jq, AH_JOB *jobToAdd) in _checkJobTypes()
169 int _countJobTypes(const AH_JOBQUEUE *jq, const AH_JOB *jobToAdd) in _countJobTypes()
196 int _countJobsOfType(const AH_JOBQUEUE *jq, const char *jobTypeName) in _countJobsOfType()
213 int _countJobsOtherThanTan(const AH_JOBQUEUE *jq) in _countJobsOtherThanTan()
230 AH_JOBQUEUE_ADDRESULT _checkJobFlags(AH_JOBQUEUE *jq, AH_JOB *jobToAdd) in _checkJobFlags()
271 AH_JOBQUEUE_ADDRESULT _checkSigners(AH_JOBQUEUE *jq, AH_JOB *jobToAdd) in _checkSigners()
|
| H A D | jobqueue_dispatch.c | 51 int AH_JobQueue_DispatchMessage(AH_JOBQUEUE *jq, AH_MSG *msg, GWEN_DB_NODE *db) in AH_JobQueue_DispatchMessage()
104 void _scanAllResultSegments(AH_JOBQUEUE *jq, GWEN_DB_NODE *db, uint32_t guiid) in _scanAllResultSegments()
200 GWEN_DB_NODE *_sampleSecuritySegments(AH_JOBQUEUE *jq, AH_MSG *msg, GWEN_DB_NODE *db) in _sampleSecuritySegments()
244 void _removeAttachPoints(const AH_JOBQUEUE *jq) in _removeAttachPoints()
274 void _setUsedTanStatusInJobs(const AH_JOBQUEUE *jq) in _setUsedTanStatusInJobs()
303 void _adjustSystemTanStatus(AH_JOBQUEUE *jq, uint32_t guiid) in _adjustSystemTanStatus()
343 AH_JOB *_findReferencedJob(AH_JOBQUEUE *jq, int refMsgNum, int refSegNum) in _findReferencedJob()
414 void _handleSegmentResultForAllJobs(AH_JOBQUEUE *jq, GWEN_DB_NODE *dbSegment) in _handleSegmentResultForAllJobs()
427 void _handleSegmentResult(AH_JOBQUEUE *jq, AH_JOB *j, GWEN_DB_NODE *dbSegment) in _handleSegmentResult()
464 void _addResponseToAllJobs(AH_JOBQUEUE *jq, GWEN_DB_NODE *dbPreparedJobResponse) in _addResponseToAllJobs()
[all …]
|
| H A D | jobqueue_tomsg.c | 44 AH_MSG *AH_JobQueue_ToMessage(AH_JOBQUEUE *jq, AH_DIALOG *dlg) in AH_JobQueue_ToMessage()
51 AH_MSG *AH_JobQueue_ToMessageWithTan(AH_JOBQUEUE *jq, AH_DIALOG *dlg, const char *sTan) in AH_JobQueue_ToMessageWithTan()
95 int _messageSetupWithCryptoAndTan(AH_JOBQUEUE *jq, AH_DIALOG *dlg, AH_MSG *msg, const char *sTan) in _messageSetupWithCryptoAndTan()
151 int _encodeJobs(AH_JOBQUEUE *jq, AH_MSG *msg) in _encodeJobs()
218 void _updateJobsAfterEncodingMessage(AH_JOBQUEUE *jq, AH_DIALOG *dlg, AH_MSG *msg) in _updateJobsAfterEncodingMessage()
|
| /dports/textproc/jq/jq-jq-1.6/src/ |
| H A D | builtin.c | 166 static jv f_frexp(jq_state *jq, jv input) { in f_frexp()
178 static jv f_modf(jq_state *jq, jv input) { in f_modf()
405 static jv f_dump(jq_state *jq, jv input) { in f_dump()
990 static jv f_min(jq_state *jq, jv x) { in f_min()
994 static jv f_max(jq_state *jq, jv x) { in f_max()
1384 static jv f_mktime(jq_state *jq, jv a) { in f_mktime()
1401 static jv f_gmtime(jq_state *jq, jv a) { in f_gmtime()
1416 static jv f_gmtime(jq_state *jq, jv a) { in f_gmtime()
1431 static jv f_gmtime(jq_state *jq, jv a) { in f_gmtime()
1536 static jv f_now(jq_state *jq, jv a) { in f_now()
[all …]
|
| H A D | execute.c | 163 void stack_push(jq_state *jq, jv val) { in stack_push()
170 jv stack_pop(jq_state *jq) { in stack_pop()
183 jv stack_popn(jq_state *jq) { in stack_popn()
304 static void jq_reset(jq_state *jq) { in jq_reset()
339 jv jq_next(jq_state *jq) { in jq_next()
989 jq_state *jq; in jq_init() local
1053 void jq_teardown(jq_state **jq) { in jq_teardown()
1185 jv jq_get_jq_origin(jq_state *jq) { in jq_get_jq_origin()
1193 jv jq_get_lib_dirs(jq_state *jq) { in jq_get_lib_dirs()
1245 jq_halted(jq_state *jq) in jq_halted()
[all …]
|
| /dports/finance/aqbanking/aqbanking-6.2.10/src/libs/plugins/backends/aqhbci/applayer/ |
| H A D | cbox_queue.c | 122 int _performQueue(AH_OUTBOX_CBOX *cbox, AH_DIALOG *dlg, AH_JOBQUEUE *jq) in _performQueue()
255 AH_JOBQUEUE *jq; in _performNonDialogQueues() local
347 int _performDialogQueue(AH_OUTBOX_CBOX *cbox, AH_JOBQUEUE *jq) in _performDialogQueue()
462 AH_JOBQUEUE *jq; in _extractMatchingQueues() local
482 AH_JOBQUEUE *jq; in _handleQueueListError() local
511 AH_JOBQUEUE *jq; in _sendAndRecvDialogQueues() local
565 int AH_OutboxCBox_SendAndRecvQueueNoTan(AH_OUTBOX_CBOX *cbox, AH_DIALOG *dlg, AH_JOBQUEUE *jq) in AH_OutboxCBox_SendAndRecvQueueNoTan()
588 int AH_OutboxCBox_SendAndRecvQueue(AH_OUTBOX_CBOX *cbox, AH_DIALOG *dlg, AH_JOBQUEUE *jq) in AH_OutboxCBox_SendAndRecvQueue()
615 void _handleQueueError(AH_OUTBOX_CBOX *cbox, AH_JOBQUEUE *jq, const char *logStr) in _handleQueueError()
647 AH_JOBQUEUE *jq; in AH_OutboxCBox_Finish() local
|
| /dports/biology/exonerate/exonerate-2.4.0/src/general/ |
| H A D | jobqueue.c | 35 register JobQueue *jq = data; in JobQueue_thread_func() local
65 register JobQueue *jq = g_new(JobQueue, 1); in JobQueue_create() local
87 void JobQueue_destroy(JobQueue *jq){ in JobQueue_destroy()
99 void JobQueue_submit(JobQueue *jq, JobQueue_Func job_func, in JobQueue_submit()
116 void JobQueue_complete(JobQueue *jq){ in JobQueue_complete()
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
313 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
354 static int StartServer(jobq_t* jq) in StartServer()
381 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
649 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/sysutils/bareos19-traymonitor/bareos-Release-19.2.11/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
314 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
355 static int StartServer(jobq_t* jq) in StartServer()
383 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
651 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/sysutils/bareos19-client/bareos-Release-19.2.11/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
314 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
355 static int StartServer(jobq_t* jq) in StartServer()
383 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
651 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/sysutils/bareos19-server/bareos-Release-19.2.11/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
314 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
355 static int StartServer(jobq_t* jq) in StartServer()
383 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
651 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/dird/ |
| H A D | jobq.c | 58 int jobq_init(jobq_t *jq, int threads, void *(*engine)(void *arg)) in jobq_init()
104 int jobq_destroy(jobq_t *jq) in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
222 int jobq_add(jobq_t *jq, JCR *jcr) in jobq_add()
313 int jobq_remove(jobq_t *jq, JCR *jcr) in jobq_remove()
353 static int start_server(jobq_t *jq) in start_server()
395 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
629 static bool reschedule_job(JCR *jcr, jobq_t *jq, jobq_item_t *je) in reschedule_job()
|
| /dports/sysutils/bacula11-server/bacula-11.0.5/src/dird/ |
| H A D | jobq.c | 58 int jobq_init(jobq_t *jq, int threads, void *(*engine)(void *arg)) in jobq_init()
104 int jobq_destroy(jobq_t *jq) in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
222 int jobq_add(jobq_t *jq, JCR *jcr) in jobq_add()
313 int jobq_remove(jobq_t *jq, JCR *jcr) in jobq_remove()
353 static int start_server(jobq_t *jq) in start_server()
395 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
629 static bool reschedule_job(JCR *jcr, jobq_t *jq, jobq_item_t *je) in reschedule_job()
|
| /dports/sysutils/bacula11-client-static/bacula-11.0.5/src/dird/ |
| H A D | jobq.c | 58 int jobq_init(jobq_t *jq, int threads, void *(*engine)(void *arg)) in jobq_init()
104 int jobq_destroy(jobq_t *jq) in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
222 int jobq_add(jobq_t *jq, JCR *jcr) in jobq_add()
313 int jobq_remove(jobq_t *jq, JCR *jcr) in jobq_remove()
353 static int start_server(jobq_t *jq) in start_server()
395 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
629 static bool reschedule_job(JCR *jcr, jobq_t *jq, jobq_item_t *je) in reschedule_job()
|
| /dports/sysutils/bacula11-client/bacula-11.0.5/src/dird/ |
| H A D | jobq.c | 58 int jobq_init(jobq_t *jq, int threads, void *(*engine)(void *arg)) in jobq_init()
104 int jobq_destroy(jobq_t *jq) in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
222 int jobq_add(jobq_t *jq, JCR *jcr) in jobq_add()
313 int jobq_remove(jobq_t *jq, JCR *jcr) in jobq_remove()
353 static int start_server(jobq_t *jq) in start_server()
395 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
629 static bool reschedule_job(JCR *jcr, jobq_t *jq, jobq_item_t *je) in reschedule_job()
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
313 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
354 static int StartServer(jobq_t* jq) in StartServer()
381 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
649 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/sysutils/bareos18-traymonitor/bareos-Release-18.2.12/core/src/dird/ |
| H A D | jobq.cc | 72 int JobqInit(jobq_t *jq, int max_workers, void *(*engine)(void *arg)) in JobqInit()
121 int JobqDestroy(jobq_t *jq) in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
213 int JobqAdd(jobq_t *jq, JobControlRecord *jcr) in JobqAdd()
317 int JobqRemove(jobq_t *jq, JobControlRecord *jcr) in JobqRemove()
358 static int StartServer(jobq_t *jq) in StartServer()
384 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
650 static bool RescheduleJob(JobControlRecord *jcr, jobq_t *jq, jobq_item_t *je) in RescheduleJob()
|
| /dports/sysutils/bareos18-client/bareos-Release-18.2.12/core/src/dird/ |
| H A D | jobq.cc | 72 int JobqInit(jobq_t *jq, int max_workers, void *(*engine)(void *arg)) in JobqInit()
121 int JobqDestroy(jobq_t *jq) in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
213 int JobqAdd(jobq_t *jq, JobControlRecord *jcr) in JobqAdd()
317 int JobqRemove(jobq_t *jq, JobControlRecord *jcr) in JobqRemove()
358 static int StartServer(jobq_t *jq) in StartServer()
384 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
650 static bool RescheduleJob(JobControlRecord *jcr, jobq_t *jq, jobq_item_t *je) in RescheduleJob()
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
313 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
354 static int StartServer(jobq_t* jq) in StartServer()
381 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
649 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/sysutils/bareos18-server/bareos-Release-18.2.12/core/src/dird/ |
| H A D | jobq.cc | 72 int JobqInit(jobq_t *jq, int max_workers, void *(*engine)(void *arg)) in JobqInit()
121 int JobqDestroy(jobq_t *jq) in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
213 int JobqAdd(jobq_t *jq, JobControlRecord *jcr) in JobqAdd()
317 int JobqRemove(jobq_t *jq, JobControlRecord *jcr) in JobqRemove()
358 static int StartServer(jobq_t *jq) in StartServer()
384 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
650 static bool RescheduleJob(JobControlRecord *jcr, jobq_t *jq, jobq_item_t *je) in RescheduleJob()
|
| /dports/www/bareos-webui/bareos-Release-20.0.3/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
313 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
354 static int StartServer(jobq_t* jq) in StartServer()
381 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
649 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/www/bareos19-webui/bareos-Release-19.2.11/core/src/dird/ |
| H A D | jobq.cc | 67 int JobqInit(jobq_t* jq, int max_workers, void* (*engine)(void* arg)) in JobqInit()
120 int JobqDestroy(jobq_t* jq) in JobqDestroy()
155 jobq_t* jq; member
168 jobq_t* jq = ((wait_pkt*)arg)->jq; in sched_wait() local
208 int JobqAdd(jobq_t* jq, JobControlRecord* jcr) in JobqAdd()
314 int JobqRemove(jobq_t* jq, JobControlRecord* jcr) in JobqRemove()
355 static int StartServer(jobq_t* jq) in StartServer()
383 jobq_t* jq = (jobq_t*)arg; in jobq_server() local
651 static bool RescheduleJob(JobControlRecord* jcr, jobq_t* jq, jobq_item_t* je) in RescheduleJob()
|
| /dports/www/bareos18-webui/bareos-Release-18.2.12/core/src/dird/ |
| H A D | jobq.cc | 72 int JobqInit(jobq_t *jq, int max_workers, void *(*engine)(void *arg)) in JobqInit()
121 int JobqDestroy(jobq_t *jq) in JobqDestroy()
157 jobq_t *jq; member
170 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
213 int JobqAdd(jobq_t *jq, JobControlRecord *jcr) in JobqAdd()
317 int JobqRemove(jobq_t *jq, JobControlRecord *jcr) in JobqRemove()
358 static int StartServer(jobq_t *jq) in StartServer()
384 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
650 static bool RescheduleJob(JobControlRecord *jcr, jobq_t *jq, jobq_item_t *je) in RescheduleJob()
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/dird/ |
| H A D | jobq.c | 58 int jobq_init(jobq_t *jq, int threads, void *(*engine)(void *arg)) in jobq_init()
104 int jobq_destroy(jobq_t *jq) in jobq_destroy()
148 jobq_t *jq; member
162 jobq_t *jq = ((wait_pkt *)arg)->jq; in sched_wait() local
224 int jobq_add(jobq_t *jq, JCR *jcr) in jobq_add()
315 int jobq_remove(jobq_t *jq, JCR *jcr) in jobq_remove()
355 static int start_server(jobq_t *jq) in start_server()
397 jobq_t *jq = (jobq_t *)arg; in jobq_server() local
633 static bool reschedule_job(JCR *jcr, jobq_t *jq, jobq_item_t *je) in reschedule_job()
|