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
void processImInternal(void)
{
    smsg_t* pMsg;
    smsg_t* repMsg;

    while (iminternalRemoveMsg(&pMsg) == RS_RET_OK)
    {
        rsRetVal localRet =
            ratelimitMsg(internalMsg_ratelimiter, pMsg, &repMsg);
        if (repMsg != NULL)
        {
            logmsgInternal_doWrite(repMsg);
        }
        if (localRet == RS_RET_OK)
        {
            logmsgInternal_doWrite(pMsg);
        }
    }
}
/* this function pulls all internal messages from the buffer
 * and puts them into the processing engine.
 * We can only do limited error handling, as this would not
 * really help us. TODO: add error messages?
 * rgerhards, 2007-08-03
 */
this function pulls all internal messages from the buffer
and puts them into the processing engine.
We can only do limited error handling, as this would not
really help us. TODO: add error messages.
this function pulls all internal messages from the buffer and puts them into the processing engine . We can only do limited error handling as this would not really help us . TODO : add error messages .
void processImInternal(void)
{
    smsg_t* pMsg;
    smsg_t* repMsg;
    while (iminternalRemoveMsg(&pMsg) == RS_RET_OK)
    {
        rsRetVal localRet =
            ratelimitMsg(internalMsg_ratelimiter, pMsg, &repMsg);
        if (repMsg != NULL)
        {
            logmsgInternal_doWrite(repMsg);
        }
        if (localRet == RS_RET_OK)
        {
            logmsgInternal_doWrite(pMsg);
        }
    }
}
void processImInternal ( void ) { smsg_t * pMsg ; smsg_t * repMsg ; while ( iminternalRemoveMsg ( & pMsg ) == RS_RET_OK ) { rsRetVal localRet = ratelimitMsg ( internalMsg_ratelimiter , pMsg , & repMsg ) ; if ( repMsg != NULL ) { logmsgInternal_doWrite ( repMsg ) ; } if ( localRet == RS_RET_OK ) { logmsgInternal_doWrite ( pMsg ) ; } } }
this function pulls all internal messages from the buffer
 and puts them into the processing engine.
this function pulls all internal messages from the buffer and puts them into the processing engine .