Searched refs:qqueue_t (Results 1 – 8 of 8) sorted by relevance
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/runtime/ |
H A D | queue.h | 123 rsRetVal (*MultiEnq)(qqueue_t *pThis, multi_submit_t *pMultiSub); 202 rsRetVal qqueueDestruct(qqueue_t **ppThis); 203 rsRetVal qqueueEnqMsg(qqueue_t *pThis, flowControl_t flwCtlType, smsg_t *pMsg); 204 rsRetVal qqueueStart(qqueue_t *pThis); 205 rsRetVal qqueueSetMaxFileSize(qqueue_t *pThis, size_t iMaxFileSize); 207 rsRetVal qqueueConstruct(qqueue_t **ppThis, queueType_t qType, int iWorkerThreads, 210 rsRetVal qqueueApplyCnfParam(qqueue_t *pThis, struct nvlst *lst); 211 void qqueueSetDefaultsRulesetQueue(qqueue_t *pThis); 212 void qqueueSetDefaultsActionQueue(qqueue_t *pThis); 213 void qqueueDbgPrint(qqueue_t *pThis); [all …]
|
H A D | queue.c | 309 qqueueDbgPrint(qqueue_t *pThis) in qqueueDbgPrint() 348 getPhysicalQueueSize(qqueue_t *pThis) in getPhysicalQueueSize() 359 getLogicalQueueSize(qqueue_t *pThis) in getLogicalQueueSize() 436 qqueueChkIsDA(qqueue_t *pThis) in qqueueChkIsDA() 456 StartDA(qqueue_t *pThis) in StartDA() 1377 cancelWorkers(qqueue_t *pThis) in cancelWorkers() 1484 qqueue_t *pThis; in qqueueConstruct() 1491 CHKmalloc(pThis = (qqueue_t *)calloc(1, sizeof(qqueue_t))); in qqueueConstruct() 2006 RateLimiter(qqueue_t *pThis) in RateLimiter() 2304 ChkStopWrkrReg(qqueue_t *pThis) in ChkStopWrkrReg() [all …]
|
H A D | ruleset.h | 34 qqueue_t *pQueue; /* "main" message queue, if the ruleset has its own (else NULL) */ 54 qqueue_t* (*GetRulesetQueue)(ruleset_t*);
|
H A D | typedefs.h | 70 typedef struct queue_s qqueue_t; typedef
|
H A D | ruleset.c | 736 static qqueue_t*
|
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/ |
H A D | dirty.h | 40 rsRetVal createMainQueue(qqueue_t **ppQueue, uchar *pszQueueName, struct nvlst *lst); 41 rsRetVal startMainQueue(qqueue_t *pQueue); 44 extern qqueue_t *pMsgQueue; /* the main message queue */
|
H A D | action.h | 73 qqueue_t *pQueue; /* action queue */
|
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/tools/ |
H A D | rsyslogd.c | 199 qqueue_t *pMsgQueue = NULL; /* default main message queue */ 710 rsRetVal createMainQueue(qqueue_t **ppQueue, uchar *pszQueueName, struct nvlst *lst) in createMainQueue() 811 startMainQueue(qqueue_t *const pQueue) in startMainQueue() 1045 qqueue_t *pQueue; in submitMsg2() 1102 qqueue_t *pQueue; in ATTR_NONNULL()
|