ofApp.cpp

#include "ofApp.h"
#define PORT_GST 5000

//This app is a demo of the ability to play multiple files with the Non-Texture Player
//It requires multiple video files to be in /home/pi/videos/current
//There is a bit of glitching while the files switch

//This also demonstrates the ofxOMXPlayerListener pattern available

//If your app extends ofxOMXPlayerListener you will receive an event when the video ends





bool doLoadNextMovie = false;
void ofApp::onVideoEnd(ofxOMXPlayerListenerEventData& e)
{
	ofLogVerbose(__func__) << " RECEIVED";
	doLoadNextMovie = true;
}


void ofApp::onCharacterReceived(KeyListenerEventData& e)
{
	keyPressed((int)e.character);
}

unsigned long long skipTimeStart=0;
unsigned long long skipTimeEnd=0;
unsigned long long amountSkipped =0;
unsigned long long totalAmountSkipped =0;
//--------------------------------------------------------------
void ofApp::setup()
{
    ofSetLogLevel(OF_LOG_VERBOSE);

	ofBackground(ofColor::black);
	consoleListener.setup(this);

	//this will let us just grab a video without recompiling
	ofDirectory currentVideoDirectory(ofToDataPath("/home/pi/openFrameworks/apps/myApps/video", true));
	if (currentVideoDirectory.exists())
	{
		currentVideoDirectory.listDir();
		currentVideoDirectory.sort();
		files = currentVideoDirectory.getFiles();
		if (files.size()>0)
		{
			videoCounter = 0;
			settings.videoPath = files[videoCounter].path();
			settings.useHDMIForAudio = true;	//default true
			settings.enableLooping = false;		//default true
			settings.enableTexture = true;		//default true
			settings.listener = this;			//this app extends ofxOMXPlayerListener so it will receive events ;
			omxPlayer.setup(settings);
		}
	}

//from gstreamTest: //////////

	w=1280,h=720;
	ip="10.254.32.151";
	gst.setPipeline("tcpclientsrc host="+ip+" port="+ofToString(PORT_GST)+" ! gdpdepay ! rtph264depay ! avdec_h264 ! videoconvert", OF_PIXELS_RGB, true, w, h);
	gst.startPipeline();
	tex.allocate(w,h,GL_RGB);
	gst.play();

/////////////////////////////
}


void ofApp::loadNextMovie()
{
	if(videoCounter+1<files.size())
	{
		videoCounter++;
	}else
	{
		videoCounter = 0;
	}
	skipTimeStart = ofGetElapsedTimeMillis();
	omxPlayer.loadMovie(files[videoCounter].path());
	skipTimeEnd = ofGetElapsedTimeMillis();
	amountSkipped = skipTimeEnd-skipTimeStart;
	totalAmountSkipped+=amountSkipped;
	doLoadNextMovie = false;
}

//--------------------------------------------------------------
void ofApp::update()
{
	if (doLoadNextMovie)
	{
		ofLogVerbose(__func__) << "doing reload";

		if(omxPlayer.isTextureEnabled())
		{
			//clear the texture if you want
			//omxPlayer.getTextureReference().clear();
		}
		//with the texture based player this must be done here - especially if the videos are different resolutions
		loadNextMovie();
	}

//from gstreamTest///////////////////////////////

	gst.update();
	if(gst.isFrameNew()) {
		tex.loadData(gst.getPixels());
	}

/////////////////////////////////////////////////



}


//--------------------------------------------------------------
void ofApp::draw(){

	//ofBackgroundGradient(ofColor::red, ofColor::black, OF_GRADIENT_CIRCULAR);

	if(!omxPlayer.isTextureEnabled()) return;

	omxPlayer.draw(0, 0, ofGetWidth(), ofGetHeight());

//from gstreamTest///////////

	tex.draw(x,y,w,h);

/////////////////////////////

}

//--------------------------------------------------------------
void ofApp::keyPressed  (int key){

	ofLogVerbose(__func__) << "key: " << key;
	switch (key)
	{
		case 'n':
		{
			doLoadNextMovie = true;
			break;
		}
	}
}