Home
last modified time | relevance | path

Searched refs:qqueue_t (Results 1 – 8 of 8) sorted by relevance

/dports/sysutils/rsyslog8/rsyslog-8.2112.0/runtime/
H A Dqueue.h123 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 Dqueue.c309 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 Druleset.h34 qqueue_t *pQueue; /* "main" message queue, if the ruleset has its own (else NULL) */
54 qqueue_t* (*GetRulesetQueue)(ruleset_t*);
H A Dtypedefs.h70 typedef struct queue_s qqueue_t; typedef
H A Druleset.c736 static qqueue_t*
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/
H A Ddirty.h40 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 Daction.h73 qqueue_t *pQueue; /* action queue */
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/tools/
H A Drsyslogd.c199 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()