openbmc/build/tmp/deploy/sdk/witherspoon-2019-08-08/sysroots/armv6-openbmc-linux-gnueabi/usr/src/debug/rsyslog/8.1903.0-r0/rsyslog-8.1903.0/tools/rsyslogd.c
static rsRetVal msgConsumer(void __attribute__((unused)) * notNeeded,
                            batch_t* pBatch, wti_t* pWti)
{
    DEFiRet;
    assert(pBatch != NULL);
    preprocessBatch(pBatch, pWti->pbShutdownImmediate);
    ruleset.ProcessBatch(pBatch, pWti);
    // TODO: the BATCH_STATE_COMM must be set somewhere down the road, but we
    // do not have this yet and so we emulate -- 2010-06-10
    int i;
    for (i = 0; i < pBatch->nElem && !*pWti->pbShutdownImmediate; i++)
    {
        pBatch->eltState[i] = BATCH_STATE_COMM;
    }
    RETiRet;
}
/* The consumer of dequeued messages. This function is called by the
 * queue engine on dequeueing of a message. It runs on a SEPARATE
 * THREAD. It receives an array of pointers, which it must iterate
 * over. We do not do any further batching, as this is of no benefit
 * for the main queue.
 */
The consumer of dequeued messages. This function is called by the
queue engine on dequeueing of a message. It runs on a SEPARATE
THREAD. It receives an array of pointers, which it must iterate
over. We do not do any further batching, as this is of no benefit
for the main queue.
The consumer of dequeued messages . This function is called by the queue engine on dequeueing of a message . It runs on a SEPARATE THREAD . It receives an array of pointers which it must iterate over . We do not do any further batching as this is of no benefit for the main queue .
static rsRetVal msgConsumer(void __attribute__((unused)) * notNeeded,
                            batch_t* pBatch, wti_t* pWti)
{
    DEFiRet;
    assert(pBatch != NULL);
    preprocessBatch(pBatch, pWti->pbShutdownImmediate);
    ruleset.ProcessBatch(pBatch, pWti);
    int i;
    for (i = 0; i < pBatch->nElem && !*pWti->pbShutdownImmediate; i++)
    {
        pBatch->eltState[i] = BATCH_STATE_COMM;
    }
    RETiRet;
}
static rsRetVal msgConsumer ( void __attribute__ ( ( unused ) ) * notNeeded , batch_t * pBatch , wti_t * pWti ) { DEFiRet ; assert ( pBatch != NULL ) ; preprocessBatch ( pBatch , pWti -> pbShutdownImmediate ) ; ruleset . ProcessBatch ( pBatch , pWti ) ; int i ; for ( i = 0 ; i < pBatch -> nElem && ! * pWti -> pbShutdownImmediate ; i ++ ) { pBatch -> eltState [ i ] = BATCH_STATE_COMM ; } RETiRet ; }
The consumer of dequeued messages.
The consumer of dequeued messages .
// TODO: the BATCH_STATE_COMM must be set somewhere down the road, but we // do not have this yet and so we emulate -- 2010-06-10