// $Id$
//
// Copyright (C) 2006 

// Definition of inline non-template functions

// Custom includes
#include "Utils/membind.hh"

#define prefix_ inline
///////////////////////////////cci.p///////////////////////////////////////

prefix_ unsigned g0dil::mediaserv::StreamConnection::bytesSent()
{
    return bytesWritten_;
}

prefix_ void g0dil::mediaserv::StreamConnection::registerCallback()
{
    senf::Scheduler::instance()
	.add(client_,senf::membind(&StreamConnection::callback,this),
	     senf::Scheduler::EV_WRITE);
}

prefix_ void g0dil::mediaserv::StreamConnection::unregisterCallback()
{
    senf::Scheduler::instance().remove(client_,senf::Scheduler::EV_WRITE);
}

prefix_ void g0dil::mediaserv::StreamConnection::registerTimeout(unsigned timeout)
{
    senf::Scheduler::instance()
	.timeout(timeout,senf::membind(&StreamConnection::timeout,this));
}

prefix_ unsigned g0dil::mediaserv::StreamConnection::targetBytes()
{
    return ((bufferMSecs_ + ((senf::now()-start_)/1000u))*bytesPerSecond_)/1000u;
}

///////////////////////////////cci.e///////////////////////////////////////
#undef prefix_


// Local Variables:
// mode: c++
// End: