src/app/http-streamer/inthread.cpp
void InThreadContainer::setInfo(const InputInfoList& list)
{
    if (m_stop.isStopped())
    {
        return;
    }

    InThreadList old = m_list;

    // process all gotten data
    std::for_each(list.begin(), list.end(),
                  boost::bind(&InThreadContainer::addInfo, this,
                              _1, boost::ref(old)));

    // remove missing
    std::for_each(old.begin(), old.end(),
                  boost::bind(&InThreadContainer::delInfo,
                              this, _1));
}
// Sets input threds accordingly with the info at the list
// Only threads that apply the route info will be keep and new threads
// will be start
Sets input threds accordingly with the info at the list
Only threads that apply the route info will be keep and new threads
will be start
Sets input threds accordingly with the info at the list Only threads that apply the route info will be keep and new threads will be start
void InThreadContainer::setInfo(const InputInfoList& list)
{
    if (m_stop.isStopped())
    {
        return;
    }
    InThreadList old = m_list;
    std::for_each(list.begin(), list.end(),
                  boost::bind(&InThreadContainer::addInfo, this,
                              _1, boost::ref(old)));
    std::for_each(old.begin(), old.end(),
                  boost::bind(&InThreadContainer::delInfo,
                              this, _1));
}
void InThreadContainer :: setInfo ( const InputInfoList & list ) { if ( m_stop . isStopped ( ) ) { return ; } InThreadList old = m_list ; std :: for_each ( list . begin ( ) , list . end ( ) , boost :: bind ( & InThreadContainer :: addInfo , this , _1 , boost :: ref ( old ) ) ) ; std :: for_each ( old . begin ( ) , old . end ( ) , boost :: bind ( & InThreadContainer :: delInfo , this , _1 ) ) ; }
Sets input threds accordingly with the info at the list
Only threads that apply the route info will be keep and new threads
will be start
Sets input threds accordingly with the info at the list Only threads that apply the route info will be keep and new threads will be start
// process all gotten data // remove missing