Server/StreamConnection.cci

   1 // $Id$
   2 //
   3 // Copyright (C) 2006
   4
   5 // Definition of inline non-template functions
   6
   7 // Custom includes
   8 #include "Utils/membind.hh"
   9
  10 #define prefix_ inline
  11 ///////////////////////////////cci.p///////////////////////////////////////
  12
  13 prefix_ unsigned g0dil::mediaserv::StreamConnection::bytesSent()
  14 {
  15     return bytesWritten_;
  16 }
  17
  18 prefix_ void g0dil::mediaserv::StreamConnection::registerCallback()
  19 {
  20     senf::Scheduler::instance()
  21         .add(client_,senf::membind(&StreamConnection::callback,this),
  22              senf::Scheduler::EV_WRITE);
  23 }
  24
  25 prefix_ void g0dil::mediaserv::StreamConnection::unregisterCallback()
  26 {
  27     senf::Scheduler::instance().remove(client_,senf::Scheduler::EV_WRITE);
  28 }
  29
  30 prefix_ void g0dil::mediaserv::StreamConnection::registerTimeout(unsigned timeout)
  31 {
  32     senf::Scheduler::instance()
  33         .timeout(timeout,senf::membind(&StreamConnection::timeout,this));
  34 }
  35
  36 prefix_ unsigned g0dil::mediaserv::StreamConnection::targetBytes()
  37 {
  38     return ((bufferMSecs_ + ((senf::now()-start_)/1000u))*bytesPerSecond_)/1000u;
  39 }
  40
  41 ///////////////////////////////cci.e///////////////////////////////////////
  42 #undef prefix_
  43
  44 \f
  45 // Local Variables:
  46 // mode: c++
  47 // End: