src/app/http-streamer/inthread.cpp
void InThread::doLoopAction()
{
    while (getReader()->checkData() == ERROR)
    {
        if (isStopped())
            return;
        // just log and try again
        klk_log(KLKLOG_DEBUG,
                "No income connection from %s within %d sec. "
                "for input HTTP thread on %s:%d",
                getReader()->getPeerName().c_str(),
                WAITINTERVAL,
                getRoute()->getHost().c_str(),
                getRoute()->getPort());
    }
    if (isStopped())
        return;


    BinaryData buff;
    getReader()->getData(buff);
    BOOST_ASSERT(buff.empty() == false);

#if 0
    klk_log(KLKLOG_DEBUG,
            "Got %d bytes for HTTP streamer at inthread", buff.size());
#endif

    // send the data to recived connection from end-users
    getFactory()->getConnectThreadContainer()->sendConnectionData(
        m_info->getPath(), buff);
}
// Do the main loop action
// wait for a data portion and send it to connection threads
Do the main loop action
wait for a data portion and send it to connection threads
Do the main loop action wait for a data portion and send it to connection threads
void InThread::doLoopAction()
{
    while (getReader()->checkData() == ERROR)
    {
        if (isStopped())
            return;
        klk_log(KLKLOG_DEBUG,
                "No income connection from %s within %d sec. "
                "for input HTTP thread on %s:%d",
                getReader()->getPeerName().c_str(),
                WAITINTERVAL,
                getRoute()->getHost().c_str(),
                getRoute()->getPort());
    }
    if (isStopped())
        return;
    BinaryData buff;
    getReader()->getData(buff);
    BOOST_ASSERT(buff.empty() == false);
#if 0
    klk_log(KLKLOG_DEBUG,
            "Got %d bytes for HTTP streamer at inthread", buff.size());
#endif
    getFactory()->getConnectThreadContainer()->sendConnectionData(
        m_info->getPath(), buff);
}
void InThread :: doLoopAction ( ) { while ( getReader ( ) -> checkData ( ) == ERROR ) { if ( isStopped ( ) ) return ; klk_log ( KLKLOG_DEBUG , " " " " , getReader ( ) -> getPeerName ( ) . c_str ( ) , WAITINTERVAL , getRoute ( ) -> getHost ( ) . c_str ( ) , getRoute ( ) -> getPort ( ) ) ; } if ( isStopped ( ) ) return ; BinaryData buff ; getReader ( ) -> getData ( buff ) ; BOOST_ASSERT ( buff . empty ( ) == false ) ; #if 0 klk_log ( KLKLOG_DEBUG , " " , buff . size ( ) ) ; #endif getFactory ( ) -> getConnectThreadContainer ( ) -> sendConnectionData ( m_info -> getPath ( ) , buff ) ; }
Do the main loop action
wait for a data portion and send it to connection threads
Do the main loop action wait for a data portion and send it to connection threads
// just log and try again // send the data to recived connection from end-users