add more debugging

This commit is contained in:
Isaac Connor 2017-10-31 16:27:43 -04:00
parent b5491102ef
commit ab1c9f7c98
2 changed files with 4 additions and 0 deletions

View File

@ -693,6 +693,8 @@ Debug(2, "checking command Queue");
} // end if buffered playback } // end if buffered playback
frame_count++; frame_count++;
} }
unsigned long sleep_time = (unsigned long)((1000000 * ZM_RATE_BASE)/((base_fps?base_fps:1)*abs(replay_rate*2)));
Debug(2,"Sleep for (%d) microseconds");
usleep( (unsigned long)((1000000 * ZM_RATE_BASE)/((base_fps?base_fps:1)*abs(replay_rate*2))) ); usleep( (unsigned long)((1000000 * ZM_RATE_BASE)/((base_fps?base_fps:1)*abs(replay_rate*2))) );
if ( ttl ) { if ( ttl ) {
if ( (now.tv_sec - stream_start_time) > ttl ) { if ( (now.tv_sec - stream_start_time) > ttl ) {
@ -704,6 +706,7 @@ Debug(2, "checking command Queue");
break; break;
} }
} // end while } // end while
if ( buffered_playback ) { if ( buffered_playback ) {
Debug( 1, "Cleaning swap files from %s", swap_path ); Debug( 1, "Cleaning swap files from %s", swap_path );
struct stat stat_buf; struct stat stat_buf;

View File

@ -88,6 +88,7 @@ bool StreamBase::checkCommandQueue() {
//Error( "Partial message received, expected %d bytes, got %d", sizeof(msg), nbytes ); //Error( "Partial message received, expected %d bytes, got %d", sizeof(msg), nbytes );
//} //}
else { else {
Debug(2, "Message length is (%d)", nbytes );
processCommand( &msg ); processCommand( &msg );
return( true ); return( true );
} }