Kino: DvEncoder Class Reference

00760                                                             : active( false ), audio( "/dev/dsp" )
00761 {
00762     this->width = width;
00763     this->height = height;
00764 
00765     this->filename = filename;
00766     for ( int i = 0; i < Preferences::getInstance().dvCaptureBuffers; ++i )
00767     {
00768         available.push_back( NULL );
00769     }
00770 
00771     pthread_mutex_init( &mutex, NULL );
00772     pthread_create( &thread, NULL, startThread, this );
00773 }

00776 {
00777     active = false;
00778     pthread_join( thread, NULL );
00779 
00780     for ( int i = available.size(); i > 0; --i )
00781     {
00782         EncoderFrame *frame = available[ 0 ];
00783         available.pop_front();
00784         delete frame;
00785     }
00786 
00787     for ( int i = used.size(); i > 0; --i )
00788     {
00789         EncoderFrame *frame = used[ 0 ];
00790         used.pop_front();
00791         delete frame;
00792     }
00793 }

00814 {
00815     pthread_mutex_lock( &mutex );
00816     used.push_back( frame );
00817     pthread_mutex_unlock( &mutex );
00818 }

00796 {
00797     EncoderFrame * frame = NULL;
00798 
00799     pthread_mutex_lock( &mutex );
00800     if ( available.size() > 0 )
00801     {
00802         frame = available[ 0 ];
00803         if ( frame == NULL )
00804             frame = new EncoderFrame;
00805 
00806         available.pop_front();
00807     }
00808     pthread_mutex_unlock( &mutex );
00809 
00810     return frame;
00811 }

00821 {
00822     DvEncoder * encoder = ( DvEncoder * ) ptr;
00823     cout << "starting encoder thread..." << endl;
00824     encoder->writeThread( );
00825     return NULL;
00826 }

00829 {
00830     struct timespec tm =
00831         {
00832             0, 0
00833         };
00834     char command[ 10240 ];
00835     int counter = 0;
00836     struct stat stats;
00837     string thisfile;
00838 
00839     active = true;
00840 
00841     do
00842     {
00843         ostringstream sb;
00844         sb << filename << setfill( '0' ) << setw( 3 ) << ++ counter << ".dv";
00845         thisfile = sb.str();
00846         cout << ">>> Trying " << thisfile << endl;
00847     }
00848     while ( stat( thisfile.c_str(), &stats ) == 0 );
00849 
00850     KinoVideoPipe *encode = NULL;
00851 
00852     if ( ENCODE_YUV )
00853     {
00854         encode = KinoVideoFactory::CreateVideoPipe( PIPE_VIDEO_DV_YUV );
00855         sprintf( command, "ffmpeg -threads 2 -f yuv4mpegpipe -i pipe: -f audio_device -ac 2 -ar 48000 -i %s -y %s", audio, thisfile.c_str() );
00856 //      sprintf( command, "ffmpeg -f yuv4mpegpipe -i pipe: -f audio_device -ac 2 -ar 48000 -i %s -vcodec mpeg4 -qscale 1 -aspect 4:3 -acodec pcm_s16le -y %s.avi", audio, thisfile.c_str() );
00857     }
00858     else
00859     {
00860         encode = KinoVideoFactory::CreateVideoPipe( PIPE_VIDEO_DV_PGM );
00861         sprintf( command, "encodedv -a dsp -i pgm -p 2 -q 2 - %s > %s", audio, thisfile.c_str() );
00862     }
00863 
00864     encode->OpenVideoPipe( command, width, height );
00865 
00866     while ( active || used.size() > 0 )
00867     {
00868         if ( used.size() > 0 )
00869         {
00870             pthread_mutex_lock( &mutex );
00871             EncoderFrame *frame = used.front();
00872             used.pop_front();
00873             pthread_mutex_unlock( &mutex );
00874 
00875             if ( frame != NULL )
00876             {
00877                 if ( ENCODE_YUV )
00878                     encode->OutputVideoFrame( frame->image, width * height * 2 );
00879                 else
00880                     encode->OutputVideoFrame( frame->image, width * height * 3 / 2 );
00881 
00882                 pthread_mutex_lock( &mutex );
00883                 available.push_back( frame );
00884                 pthread_mutex_unlock( &mutex );
00885             }
00886         }
00887 
00888         nanosleep( &tm, NULL );
00889     }
00890 
00891     encode->CloseVideo();
00892 
00893     delete encode;
00894 
00895     FileTracker::GetInstance().Add( thisfile.c_str() );
00896 }


Public Member Functions
	DvEncoder (char *, int, int)
	~DvEncoder ()
EncoderFrame *	getFrame ()
void	doneWithFrame (EncoderFrame *)
void	writeThread ()
Static Public Member Functions
static void *	startThread (void *)
Public Attributes
char *	audio
Private Attributes
unsigned char	data [144000]
dv_encoder_t *	encoder
FILE *	p
bool	active
pthread_t	thread
pthread_mutex_t	mutex
char *	filename
int	width
int	height
Static Private Attributes
static deque< EncoderFrame * >	used
	Rudimentary encoding class for raw dv stream.
static deque< EncoderFrame * >	available

DvEncoder Class Reference

Public Member Functions

Static Public Member Functions

Public Attributes

Private Attributes

Static Private Attributes

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation