src/app/http-streamer/inudp.cpp
void InUDPThread::doLoop()
{
    initReader();

    while (!isStopped())
    {
        // do something only if we have a connectons for this input
        if (m_sem.isLocked())
        {
            // just log
            klk_log(KLKLOG_DEBUG,
                    "No any output connection "
                    "for input HTTP thread on %s:%d. "
                    "Stop receiving info",
                    getRoute()->getHost().c_str(),
                    getRoute()->getPort());
            break;
        }

        doLoopAction();
    }
}
// Main loop (data processing) for UDP connections
Main loop (data processing) for UDP connections
Main loop ( data processing ) for UDP connections
void InUDPThread::doLoop()
{
    initReader();
    while (!isStopped())
    {
        if (m_sem.isLocked())
        {
            klk_log(KLKLOG_DEBUG,
                    "No any output connection "
                    "for input HTTP thread on %s:%d. "
                    "Stop receiving info",
                    getRoute()->getHost().c_str(),
                    getRoute()->getPort());
            break;
        }
        doLoopAction();
    }
}
void InUDPThread :: doLoop ( ) { initReader ( ) ; while ( ! isStopped ( ) ) { if ( m_sem . isLocked ( ) ) { klk_log ( KLKLOG_DEBUG , " " " " " " , getRoute ( ) -> getHost ( ) . c_str ( ) , getRoute ( ) -> getPort ( ) ) ; break ; } doLoopAction ( ) ; } }
Main loop (data processing) for UDP connections
Main loop ( data processing ) for UDP connections
// do something only if we have a connectons for this input // just log