prefix_ void g0dil::mediaserv::StreamConnection::registerCallback()
{
- satcom::lib::Scheduler::instance()
- .add(client_,satcom::lib::membind(&StreamConnection::callback,this),
- satcom::lib::Scheduler::EV_WRITE);
+ senf::Scheduler::instance()
+ .add(client_,senf::membind(&StreamConnection::callback,this),
+ senf::Scheduler::EV_WRITE);
}
prefix_ void g0dil::mediaserv::StreamConnection::unregisterCallback()
{
- satcom::lib::Scheduler::instance().remove(client_,satcom::lib::Scheduler::EV_WRITE);
+ senf::Scheduler::instance().remove(client_,senf::Scheduler::EV_WRITE);
}
prefix_ void g0dil::mediaserv::StreamConnection::registerTimeout(unsigned timeout)
{
- satcom::lib::Scheduler::instance()
- .timeout(timeout,satcom::lib::membind(&StreamConnection::timeout,this));
+ senf::Scheduler::instance()
+ .timeout(timeout,senf::membind(&StreamConnection::timeout,this));
}
prefix_ unsigned g0dil::mediaserv::StreamConnection::targetBytes()
{
- return ((bufferMSecs_ + ((satcom::lib::now()-start_)/1000u))*bytesPerSecond_)/1000u;
+ return ((bufferMSecs_ + ((senf::now()-start_)/1000u))*bytesPerSecond_)/1000u;
}
///////////////////////////////cci.e///////////////////////////////////////