fucked up- no workie.. back out

1 files changed, 177 insertions, 175 deletions

diff --git a/core/multimedia/opieplayer/loopcontrol.cpp b/core/multimedia/opieplayer/loopcontrol.cpp
index 1ae0059..dd466ed 100644
--- a/core/multimedia/opieplayer/loopcontrol.cpp
+++ b/core/multimedia/opieplayer/loopcontrol.cpp
@@ -1,7 +1,7 @@
 /**********************************************************************
-** Copyright (C) 2000 Trolltech AS.  All rights reserved.
+** Copyright (C) 2000-2002 Trolltech AS.  All rights reserved.
 **
-** This file is part of Qtopia Environment.
+** This file is part of the Qtopia Environment.
 **
 ** This file may be distributed and/or modified under the terms of the
 ** GNU General Public License version 2 as published by the Free Software
@@ -17,13 +17,12 @@
 ** not clear to you.
 **
 **********************************************************************/
-// L.J.Potter added changes Fri 02-15-2002
-
 #include <qpe/qpeapplication.h>
-
 #ifdef Q_WS_QWS
+
 #include <qpe/qcopenvelope_qws.h>
 #endif
+#include <qpe/mediaplayerplugininterface.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
@@ -33,7 +32,6 @@
 #include "loopcontrol.h"
 #include "videowidget.h"
 #include "audiodevice.h"
-#include "mediaplayerplugininterface.h"
 #include "mediaplayerstate.h"
 
 
@@ -45,13 +43,13 @@ extern MediaPlayerState *mediaPlayerState;
 #define DecodeLoopDebug(x)
 
 
-static char     *audioBuffer = NULL;
+static char	    *audioBuffer = NULL;
 static AudioDevice  *audioDevice = NULL;
-static bool     disabledSuspendScreenSaver = FALSE;
-static bool     previousSuspendMode = FALSE;
+static bool	    disabledSuspendScreenSaver = FALSE;
+static bool	    previousSuspendMode = FALSE;
 
 
-pthread_t audio_tid;
+pthread_t	audio_tid;
 pthread_attr_t  audio_attr;
 bool threadOkToGo = FALSE;
 
@@ -59,22 +57,22 @@ bool threadOkToGo = FALSE;
 class Mutex {
 public:
     Mutex() {
-  pthread_mutexattr_t attr;
-  pthread_mutexattr_init( &attr );
-  pthread_mutex_init( &mutex, &attr );
-  pthread_mutexattr_destroy( &attr );
+	pthread_mutexattr_t attr;
+	pthread_mutexattr_init( &attr );
+	pthread_mutex_init( &mutex, &attr );
+	pthread_mutexattr_destroy( &attr );
     }
 
     ~Mutex() {
-  pthread_mutex_destroy( &mutex );
+	pthread_mutex_destroy( &mutex );
     }
 
     void lock() {
-  pthread_mutex_lock( &mutex );
+	pthread_mutex_lock( &mutex );
     }
 
     void unlock() {
-  pthread_mutex_unlock( &mutex );
+	pthread_mutex_unlock( &mutex );
     }
 private:
     pthread_mutex_t mutex;
@@ -84,10 +82,10 @@ private:
 void *startAudioThread( void *ptr ) {
     LoopControl *mpegView = (LoopControl *)ptr;
     while ( TRUE ) {
-  if ( threadOkToGo && mpegView->moreAudio )
-      mpegView->startAudio();
-  else
-      usleep( 10000 ); // Semi-buzy-wait till we are playing again
+	if ( threadOkToGo && mpegView->moreAudio )
+	    mpegView->startAudio();
+	else
+	    usleep( 10000 ); // Semi-buzy-wait till we are playing again
     }
     return 0;
 }
@@ -104,19 +102,24 @@ LoopControl::LoopControl( QObject *parent, const char *name )
     audioMutex = new Mutex;
 
     pthread_attr_init(&audio_attr);
-#define USE_REALTIME_AUDIO_THREAD
-#ifdef USE_REALTIME_AUDIO_THREAD
-    // Attempt to set it to real-time round robin
-    if ( pthread_attr_setschedpolicy( &audio_attr, SCHED_RR ) == 0 ) {
-  sched_param params;
-  params.sched_priority = 50;
-  pthread_attr_setschedparam(&audio_attr,&params);
-    } else {
-  qDebug( "Error setting up a realtime thread, reverting to using a normal thread." );
-  pthread_attr_destroy(&audio_attr);
-  pthread_attr_init(&audio_attr);
+
+    if ( getuid() == 0 ) {
+        printf("true, guid = %i\n", getuid());
+
+	// Attempt to set it to real-time round robin
+	if ( pthread_attr_setschedpolicy( &audio_attr, SCHED_RR ) == 0 ) {
+	    sched_param params;
+	    params.sched_priority = 50;
+	    pthread_attr_setschedparam(&audio_attr,&params);
+	} else {
+	    qDebug( "Error setting up a realtime thread, reverting to using a normal thread." );
+	    pthread_attr_destroy(&audio_attr);
+	    pthread_attr_init(&audio_attr);
+	}
     }
-#endif
+//    printf("false, guid = %i\n", getuid());
+    usleep( 100 );
+
     pthread_create(&audio_tid, &audio_attr, (void * (*)(void *))startAudioThread, this);
 }
 
@@ -133,14 +136,14 @@ static int currentSample = 0;
 void LoopControl::timerEvent( QTimerEvent *te ) {
 
     if ( te->timerId() == videoId )
-  startVideo();
+	startVideo();
 
     if ( te->timerId() == sliderId ) {
-  if ( hasAudioChannel && !hasVideoChannel && moreAudio ) {
-      mediaPlayerState->updatePosition( audioSampleCounter );
-  } else if ( hasVideoChannel && moreVideo ) {
-      mediaPlayerState->updatePosition( current_frame );
-  }
+	if ( hasAudioChannel && !hasVideoChannel && moreAudio ) {
+	    mediaPlayerState->updatePosition( audioSampleCounter );
+	} else if ( hasVideoChannel && moreVideo ) {
+	    mediaPlayerState->updatePosition( current_frame );
+	}
     }
 
     if ( !moreVideo && !moreAudio ) { 
@@ -154,26 +157,26 @@ void LoopControl::setPosition( long pos ) {
     audioMutex->lock();
 
     if ( hasVideoChannel && hasAudioChannel ) {
-  playtime.restart();
-  playtime = playtime.addMSecs( long((double)-pos * 1000.0 / framerate) );
-  current_frame = pos + 1;
-  mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
-  prev_frame = current_frame - 1;
-  currentSample = (int)( (double)current_frame * freq / framerate );
-  mediaPlayerState->curDecoder()->audioSetSample( currentSample, stream );
-  audioSampleCounter = currentSample - 1;
+	playtime.restart();
+	playtime = playtime.addMSecs( long((double)-pos * 1000.0 / framerate) );
+	current_frame = pos + 1;
+	mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
+	prev_frame = current_frame - 1;
+	currentSample = (int)( (double)current_frame * freq / framerate );
+	mediaPlayerState->curDecoder()->audioSetSample( currentSample, stream );
+	audioSampleCounter = currentSample - 1;
     } else if ( hasVideoChannel ) {
-  playtime.restart();
-  playtime = playtime.addMSecs( long((double)-pos * 1000.0 / framerate) );
-  current_frame = pos + 1;
-  mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
-  prev_frame = current_frame - 1;
+	playtime.restart();
+	playtime = playtime.addMSecs( long((double)-pos * 1000.0 / framerate) );
+	current_frame = pos + 1;
+	mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
+	prev_frame = current_frame - 1;
     } else if ( hasAudioChannel ) {
-  playtime.restart();
-  playtime = playtime.addMSecs( long((double)-pos * 1000.0 / freq) );
-  currentSample = pos + 1;
-  mediaPlayerState->curDecoder()->audioSetSample( currentSample, stream );
-  audioSampleCounter = currentSample - 1;
+	playtime.restart();
+	playtime = playtime.addMSecs( long((double)-pos * 1000.0 / freq) );
+	currentSample = pos + 1;
+	mediaPlayerState->curDecoder()->audioSetSample( currentSample, stream );
+	audioSampleCounter = currentSample - 1;
     }
 
     audioMutex->unlock();
@@ -186,32 +189,32 @@ void LoopControl::startVideo() {
 
         if ( mediaPlayerState->curDecoder() ) {
 
-      if ( hasAudioChannel && !isMuted ) {
+	    if ( hasAudioChannel && !isMuted ) {
 
-    current_frame = long( playtime.elapsed() * framerate / 1000 );
+		current_frame = long( playtime.elapsed() * framerate / 1000 );
 
-    if ( prev_frame != -1 && current_frame <= prev_frame )
-        return;
+		if ( prev_frame != -1 && current_frame <= prev_frame )
+		    return;
 
-      } else {
-    // Don't skip
-    current_frame++;
-      }
+	    } else {
+		// Don't skip
+		current_frame++;
+	    }
 
-      if ( prev_frame == -1 || current_frame > prev_frame ) {
-    if ( current_frame > prev_frame + 1 ) {
-        mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
-    }
-    moreVideo = videoUI->playVideo();
-    prev_frame = current_frame;
-      }
+	    if ( prev_frame == -1 || current_frame > prev_frame ) {
+		if ( current_frame > prev_frame + 1 ) {
+		    mediaPlayerState->curDecoder()->videoSetFrame( current_frame, stream );
+		}
+		moreVideo = videoUI->playVideo();
+		prev_frame = current_frame;
+	    }
 
-  } else {
+	} else {
 
-      moreVideo = FALSE;
-      killTimer( videoId );
+	    moreVideo = FALSE;
+	    killTimer( videoId );
 
-  }
+	}
 
     }
 }
@@ -223,37 +226,36 @@ void LoopControl::startAudio() {
 
     if ( moreAudio ) {
 
-  if ( !isMuted && mediaPlayerState->curDecoder() ) {
+	if ( !isMuted && mediaPlayerState->curDecoder() ) {
 
-      currentSample = audioSampleCounter + 1;
+	    currentSample = audioSampleCounter + 1;
 
-      if ( currentSample != audioSampleCounter + 1 )
-    qDebug("out of sync with decoder %i %i", currentSample, audioSampleCounter);
+	    if ( currentSample != audioSampleCounter + 1 )
+		qDebug("out of sync with decoder %i %i", currentSample, audioSampleCounter);
 
-      long samplesRead = 0;
-      bool readOk=mediaPlayerState->curDecoder()->audioReadSamples( (short*)audioBuffer, channels, 1024, samplesRead, stream );
-      long sampleWeShouldBeAt = long( playtime.elapsed() ) * freq / 1000;
-      long sampleWaitTime = currentSample - sampleWeShouldBeAt;
+	    long samplesRead = 0;
+	    mediaPlayerState->curDecoder()->audioReadSamples( (short*)audioBuffer, channels, 1024, samplesRead, stream );
+	    long sampleWeShouldBeAt = long( playtime.elapsed() ) * freq / 1000;
+	    long sampleWaitTime = currentSample - sampleWeShouldBeAt;
 
-        if ( ( sampleWaitTime > 2000 ) && ( sampleWaitTime < 20000 ) ) {
-      usleep( (long)((double)sampleWaitTime * 1000000.0 / freq) );
-        }
-      else if ( sampleWaitTime <= -5000 ) {
-     qDebug("need to catch up by: %li (%i,%li)", -sampleWaitTime, currentSample, sampleWeShouldBeAt );
-     //mediaPlayerState->curDecoder()->audioSetSample( sampleWeShouldBeAt, stream );
-     currentSample = sampleWeShouldBeAt;
-       }
+	    if ( ( sampleWaitTime > 2000 ) && ( sampleWaitTime < 20000 ) ) {
+		usleep( (long)((double)sampleWaitTime * 1000000.0 / freq) );
+	    } else if ( sampleWaitTime <= -5000 ) {
+		qDebug("need to catch up by: %li (%i,%li)", -sampleWaitTime, currentSample, sampleWeShouldBeAt );
+		//mediaPlayerState->curDecoder()->audioSetSample( sampleWeShouldBeAt, stream );
+		currentSample = sampleWeShouldBeAt;
+	    }
 
-      audioDevice->write( audioBuffer, samplesRead * 2 * channels );
-      audioSampleCounter = currentSample + samplesRead - 1;
+	    audioDevice->write( audioBuffer, samplesRead * 2 * channels );
+	    audioSampleCounter = currentSample + samplesRead - 1;
 
-      moreAudio = readOk && (audioSampleCounter <= total_audio_samples);
+	    moreAudio = audioSampleCounter <= total_audio_samples;
 
-  } else {
+	} else {
 
-      moreAudio = FALSE;
+	    moreAudio = FALSE;
 
-  }
+	}
 
     }
 
@@ -266,7 +268,7 @@ void LoopControl::killTimers() {
     audioMutex->lock();
 
     if ( hasVideoChannel ) 
-  killTimer( videoId );
+	killTimer( videoId );
     killTimer( sliderId );
     threadOkToGo = FALSE;
 
@@ -282,14 +284,14 @@ void LoopControl::startTimers() {
     moreAudio = FALSE;
 
     if ( hasVideoChannel ) {
-  moreVideo = TRUE;
-  int mSecsBetweenFrames = (int)(100 / framerate); // 10% of the real value
-  videoId = startTimer( mSecsBetweenFrames );
+	moreVideo = TRUE;
+	int mSecsBetweenFrames = (int)(100 / framerate); // 10% of the real value
+	videoId = startTimer( mSecsBetweenFrames );
     }
 
     if ( hasAudioChannel ) {
-  moreAudio = TRUE;
-  threadOkToGo = TRUE;
+	moreAudio = TRUE;
+	threadOkToGo = TRUE;
     }
 
     sliderId = startTimer( 300 ); // update slider every 1/3 second
@@ -301,16 +303,16 @@ void LoopControl::startTimers() {
 void LoopControl::setPaused( bool pause ) {
 
     if ( !mediaPlayerState->curDecoder() || !mediaPlayerState->curDecoder()->isOpen() )
-  return;
+	return;
 
     if ( pause ) {
-  killTimers();
+	killTimers();
     } else {
-  // Force an update of the position
-  mediaPlayerState->setPosition( mediaPlayerState->position() + 1 );
-  mediaPlayerState->setPosition( mediaPlayerState->position() - 1 );
-  // Just like we never stopped
-  startTimers();
+	// Force an update of the position
+	mediaPlayerState->setPosition( mediaPlayerState->position() + 1 );
+	mediaPlayerState->setPosition( mediaPlayerState->position() - 1 );
+	// Just like we never stopped
+	startTimers();
     }
 }
 
@@ -319,28 +321,28 @@ void LoopControl::stop( bool willPlayAgainShortly ) {
 
 #if defined(Q_WS_QWS) && !defined(QT_NO_COP)
     if ( !willPlayAgainShortly && disabledSuspendScreenSaver ) {
-  disabledSuspendScreenSaver = FALSE; 
-  // Re-enable the suspend mode
-  QCopEnvelope("QPE/System", "setScreenSaverMode(int)" ) << QPEApplication::Enable;
+	disabledSuspendScreenSaver = FALSE; 
+	// Re-enable the suspend mode
+	QCopEnvelope("QPE/System", "setScreenSaverMode(int)" ) << QPEApplication::Enable;
     }
 #endif
 
     if ( mediaPlayerState->curDecoder() && mediaPlayerState->curDecoder()->isOpen() ) {
 
-  killTimers();
+	killTimers();
 
-  audioMutex->lock();
+	audioMutex->lock();
 
-  mediaPlayerState->curDecoder()->close();
+	mediaPlayerState->curDecoder()->close();
 
-  if ( audioDevice ) {
-      delete audioDevice;
-      delete audioBuffer;
-      audioDevice = 0;
-      audioBuffer = 0;
-  }
+	if ( audioDevice ) {
+	    delete audioDevice;
+	    delete audioBuffer;
+	    audioDevice = 0;
+	    audioBuffer = 0;
+	}
 
-  audioMutex->unlock();
+	audioMutex->unlock();
 
     }
 }
@@ -359,67 +361,67 @@ bool LoopControl::init( const QString& filename ) {
    
     // ### Hack to use libmpeg3plugin to get the number of audio samples if we are using the libmad plugin
     if ( mediaPlayerState->curDecoder()->pluginName() == QString("LibMadPlugin") ) {
-  if ( mediaPlayerState->libMpeg3Decoder() && mediaPlayerState->libMpeg3Decoder()->open( filename ) ) {
-      total_audio_samples = mediaPlayerState->libMpeg3Decoder()->audioSamples( 0 );
-      mediaPlayerState->libMpeg3Decoder()->close();
-  }
+	if ( mediaPlayerState->libMpeg3Decoder() && mediaPlayerState->libMpeg3Decoder()->open( filename ) ) {
+	    total_audio_samples = mediaPlayerState->libMpeg3Decoder()->audioSamples( 0 );
+	    mediaPlayerState->libMpeg3Decoder()->close();
+	}
     }
-    
+
     if ( !mediaPlayerState->curDecoder()|| !mediaPlayerState->curDecoder()->open( filename ) ) {
-  audioMutex->unlock();
-  return FALSE;
+	audioMutex->unlock();
+	return FALSE;
     }
 
     hasAudioChannel = mediaPlayerState->curDecoder()->audioStreams() > 0;
     hasVideoChannel = mediaPlayerState->curDecoder()->videoStreams() > 0;
 
     if ( hasAudioChannel ) {
-  int astream = 0;
+	int astream = 0;
 
-  channels = mediaPlayerState->curDecoder()->audioChannels( astream );
-  qDebug( "LC- channels = %d", channels );
-  
-  if ( !total_audio_samples )
-      total_audio_samples = mediaPlayerState->curDecoder()->audioSamples( astream );
+	channels = mediaPlayerState->curDecoder()->audioChannels( astream );
+	DecodeLoopDebug(( "channels = %d\n", channels ));
+	
+	if ( !total_audio_samples )
+	    total_audio_samples = mediaPlayerState->curDecoder()->audioSamples( astream );
 
-//  total_audio_samples += 1000;
+	total_audio_samples += 1000;
 
-  mediaPlayerState->setLength( total_audio_samples );
-  
-  freq = mediaPlayerState->curDecoder()->audioFrequency( astream );
-  qDebug( "LC- frequency = %d", freq );
+	mediaPlayerState->setLength( total_audio_samples );
+	
+	freq = mediaPlayerState->curDecoder()->audioFrequency( astream );
+	DecodeLoopDebug(( "frequency = %d\n", freq ));
 
-  audioSampleCounter = 0;
+	audioSampleCounter = 0;
 
-   int bits_per_sample = mediaPlayerState->curDecoder()->audioBitsPerSample( astream);
+	static const int bytes_per_sample = 2; //16 bit
 
-  audioDevice = new AudioDevice( freq, channels, bits_per_sample);
-  audioBuffer = new char[ audioDevice->bufferSize() ];
-  channels = audioDevice->channels();
+	audioDevice = new AudioDevice( freq, channels, bytes_per_sample );
+	audioBuffer = new char[ audioDevice->bufferSize() ];
+	channels = audioDevice->channels();
 
-  //### must check which frequency is actually used.
-  static const int size = 1;
-  short int buf[size];
-  long samplesRead = 0;
-  mediaPlayerState->curDecoder()->audioReadSamples( buf, channels, size, samplesRead, stream );
+	//### must check which frequency is actually used.
+	static const int size = 1;
+	short int buf[size];
+	long samplesRead = 0;
+	mediaPlayerState->curDecoder()->audioReadSamples( buf, channels, size, samplesRead, stream );
     }
 
     if ( hasVideoChannel ) {
-  total_video_frames = mediaPlayerState->curDecoder()->videoFrames( stream );
+	total_video_frames = mediaPlayerState->curDecoder()->videoFrames( stream );
 
-  mediaPlayerState->setLength( total_video_frames );
+	mediaPlayerState->setLength( total_video_frames );
 
-  framerate = mediaPlayerState->curDecoder()->videoFrameRate( stream );
-  DecodeLoopDebug(( "Frame rate %g total %ld", framerate, total_video_frames ));
+	framerate = mediaPlayerState->curDecoder()->videoFrameRate( stream );
+	DecodeLoopDebug(( "Frame rate %g total %ld", framerate, total_video_frames ));
 
-  if ( framerate <= 1.0 ) {
-      DecodeLoopDebug(( "Crazy frame rate, resetting to sensible" ));
-      framerate = 25;
-  }
+	if ( framerate <= 1.0 ) {
+	    DecodeLoopDebug(( "Crazy frame rate, resetting to sensible" ));
+	    framerate = 25;
+	}
 
-  if ( total_video_frames == 1 ) {
-      DecodeLoopDebug(( "Cannot seek to frame" ));
-  }
+	if ( total_video_frames == 1 ) {
+	    DecodeLoopDebug(( "Cannot seek to frame" ));
+	}
 
     }
 
@@ -439,11 +441,11 @@ void LoopControl::play() {
 
 #if defined(Q_WS_QWS) && !defined(QT_NO_COP)
     if ( !disabledSuspendScreenSaver || previousSuspendMode != hasVideoChannel ) {
-  disabledSuspendScreenSaver = TRUE; 
-  previousSuspendMode = hasVideoChannel;
+	disabledSuspendScreenSaver = TRUE; 
+	previousSuspendMode = hasVideoChannel;
         // Stop the screen from blanking and power saving state
-  QCopEnvelope("QPE/System", "setScreenSaverMode(int)" ) 
-      << ( hasVideoChannel ? QPEApplication::Disable : QPEApplication::DisableSuspend );
+	QCopEnvelope("QPE/System", "setScreenSaverMode(int)" ) 
+	    << ( hasVideoChannel ? QPEApplication::Disable : QPEApplication::DisableSuspend );
     }
 #endif
 
@@ -454,14 +456,14 @@ void LoopControl::play() {
 
 void LoopControl::setMute( bool on ) {
     if ( on != isMuted ) {
-  isMuted = on;
-  if ( !on ) {
-      // Force an update of the position
-      mediaPlayerState->setPosition( mediaPlayerState->position() + 1 );
-      mediaPlayerState->setPosition( mediaPlayerState->position() - 1 );
-      // Resume playing audio
-      moreAudio = TRUE;
-  }
+	isMuted = on;
+	if ( !on ) {
+	    // Force an update of the position
+	    mediaPlayerState->setPosition( mediaPlayerState->position() + 1 );
+	    mediaPlayerState->setPosition( mediaPlayerState->position() - 1 );
+	    // Resume playing audio
+	    moreAudio = TRUE;
+	}
     }
 }