[ShareDaemon-CVS] sharedaemon-ui-web/src/test TestSemaphore.h,NONE,1.1 TestSemaphore.cpp,NONE,1.1

[<mik...@us...>]

Update of /cvsroot/sharedaemon/sharedaemon-ui-web/src/test
In directory sc8-pr-cvs1:/tmp/cvs-serv9609/src/test

Added Files:
	TestSemaphore.h TestSemaphore.cpp 
Log Message:
24/12/2003	Barbeaux
	* Added simple test program for Semaphores.

--- NEW FILE: TestSemaphore.h ---
/*
 *  This file is part of webInterface.
 *  Copyright (C) 2003 Mikael Barbeaux <mik...@us...>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

 
#ifndef _TEST_SEMAPHORE_H_
#define _TEST_SEMAPHORE_H_

#include "TestHandler.h"
#include "../thread/Semaphore.h"
#include "../thread/Thread.h"
#include "../exceptions/ThreadException.h"
#include <iostream>
using namespace std;

/**
 * Defines a thread class that will be handled by the semaphore.
 */ 
class MyThread : public Thread {
	
	private:
	
		// the semaphore
		Semaphore *semaphore;
		// thread id
		int id;
	
	public:
		
		/**
		 * Creates a test thread for the semaphore
		 */ 
		MyThread(Semaphore *sem, int nb) : Thread() {
			semaphore = sem;
			id = nb;
		}
		
		/**
		 * Destructor for MyThread
		 */ 
		~MyThread() throw (ThreadException) {}
		
		/**
		 * Runs the Thread
		 */ 
		virtual void run() {
			/* The thread will wait to be signaled by the tester by the semaphore
			 * that it can enters its processing mode. */
			cout << "Thread n" << id << " says : I am waiting for the semaphore" << endl;
			semaphore->wait();
			cout << "Thread n" << id << "says : Thanks, Tester !";
			cout << " I can process now" << endl;
			for(int i=0;i<9;i++)  {
				cout << "Thread n" << id << " says : I am processing" << endl;
				Thread::sleep(1); 
			}
			cout << "Thread n" << id << " has finished !" << endl;
		}
	
};

/**
 * Defines a tester for threads synchronized with semaphores.
 */ 
class TestSemaphore : public TestHandler {

	private:
	
		// semaphore for synchronizing threads.
		Semaphore *sync;

	public:

		/**
		 * Creates a TestSemaphore object.
		 */ 
		TestSemaphore();
		
		/**
		 * Destructor for TestSemaphore
		 */ 
		~TestSemaphore();
		
		/**
		 * Runs the tester.
		 */ 
		virtual void test();

};

#endif


--- NEW FILE: TestSemaphore.cpp ---
/*
 *  This file is part of webInterface.
 *  Copyright (C) 2003 Mikael Barbeaux <mik...@us...>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
 
 #include "TestSemaphore.h"

/**
 * Creates a TestSemaphore object.
 */ 
TestSemaphore::TestSemaphore() : TestHandler() {
	// initialize the semaphore
	sync = new Semaphore(0);
}

/**
 * Destructor for TestSemaphore
 */ 
TestSemaphore::~TestSemaphore() {
	// delete the semaphore
	delete sync;
}

/**
 * Runs the tester.
 */ 
void TestSemaphore::test() {
		/** This test tries to launch two threads and to
		 * synchronize them with the semaphore. */
	cout << endl;
	cout << "ShareDaemon Web Interface - Test" << endl << endl;
	cout << "Test for semaphores and threads... " << endl;
	cout << "Two threads wanting to process their work wants to get " << endl;
	cout << "the semaphore before continuing. The program will " <<endl;
	cout << "will test synchronization between threads thanks to the" << endl;
	cout << "semaphore." << endl;
	cout << "Press enter to continue" << endl;
	getchar();
	cout << endl << endl;
	try {
		// Creates the threads
		MyThread t1(sync, 1);
		MyThread t2(sync, 2);
		// Launches the threads
		t1.start();
		t2.start();
		// Goes on working
		for(int i=1;i<15;i++) {
			cout << "Tester is working..." << endl;
			if((i %5) == 0) {
				cout << "I need help, releasing a thread !" << endl;
				sync->post();
			}
			Thread::sleep(1);
		}
		cout << "Tester has finished !" <<  endl;
		cout << "Tester says : Waiting for threads to end" << endl;
		t1.wait();
		t2.wait();
		cout << "Tester says : Threads ended, thanks for the help !" << endl << endl;
		
	}
	catch(Exception& e) {
		// display the exception message
		cout << e.getMessage() << endl;
	}
	cout << "Did you see the threads being synchronized by the semaphore ?" << endl;
	cout << "  If no => VERY BAD :(" << endl;
	cout << "  If yes => Test worked !! :D" << endl << endl;
	cout << "Press enter to continue" << endl;
	getchar();
}