source: roaraudio/roard/loop.c @ 71:6426d93defd0

//loop.c:

#include "roard.h"

int main_loop (int driver, DRIVER_USERDATA_T driver_inst, struct roar_audio_info * sa) {
 void ** streams_input = NULL;
 uint32_t pos = 0;
#ifdef MONITOR_LATENCY
 struct timeval         try, ans;
 long int ans_1last = 0, ans_2last = 0, ans_3last = 0;
 long int loopc = 0;

 printf("\n\e[s");
 fflush(stdout);
#endif

 ROAR_DBG("main_loop(*) = ?");
 alive = 1;

 while (alive) {
#ifdef MONITOR_LATENCY
 gettimeofday(&try, NULL);
#endif

  ROAR_DBG("main_loop(*): looping...");

  if ( g_listen_socket != -1 ) {
   ROAR_DBG("main_loop(*): check for new clients...");
   net_check_listen();
  }

  ROAR_DBG("main_loop(*): check for new data...");
  if ( clients_check_all() == 0 && g_terminate && g_listen_socket == -1 )
   alive = 0;

  ROAR_DBG("main_loop(*): mixing clients...");
  if ( g_standby ) {
   // while in standby we still neet to get the buffers to free input buffer space.
   streams_get_mixbuffers(&streams_input, sa, pos);
  } else {
   if ( streams_get_mixbuffers(&streams_input, sa, pos) == 0 ) {
    mix_clients(g_output_buffer, sa->bits, streams_input, ROAR_OUTPUT_BUFFER_SAMPLES * sa->channels);
   }
  }

/*
  // while in standby we still need to write out our buffer to not run in an endless loop without
  // a break
*/

  if ( g_standby ) {
   usleep((1000000 * ROAR_OUTPUT_BUFFER_SAMPLES) / sa->rate);
   printf("usleep(%u) = ?\n", (1000000 * ROAR_OUTPUT_BUFFER_SAMPLES) / sa->rate);
  } else {
   clients_send_filter(sa, pos);
   output_buffer_flush(driver_inst, driver);
   clients_send_mon(sa, pos);
  }
//  output_buffer_reinit();

  pos = ROAR_MATH_OVERFLOW_ADD(pos, ROAR_OUTPUT_BUFFER_SAMPLES);
  ROAR_DBG("main_loop(*): current pos: %u", pos);
#ifdef MONITOR_LATENCY
 gettimeofday(&ans, NULL);

 while (ans.tv_sec > try.tv_sec) {
  ans.tv_sec--;
  ans.tv_usec += 1000000;
 }
 ans.tv_usec -= try.tv_usec;

 if ( loopc % 128 ) {
  printf("\e[ucurrent latency: %.3fms  average: %.3fms   ",  ans.tv_usec                               / (double)1000,
                                                            (ans.tv_usec+ans_3last+ans_2last+ans_1last)/ (double)4000);
  fflush(stdout);
 }

 ans_3last = ans_2last;
 ans_2last = ans_1last;
 ans_1last = ans.tv_usec;
 loopc++;
#endif
 }

 return -1;
}

//ll