import of enigma2

1 files changed, 206 insertions, 0 deletions

diff --git a/lib/base/ebase.cpp b/lib/base/ebase.cpp
new file mode 100644
index 00000000..3babc2eb
--- /dev/null
+++ b/lib/base/ebase.cpp
@@ -0,0 +1,206 @@
+#include <lib/base/ebase.h>
+
+#include <fcntl.h>
+#include <unistd.h>
+
+#include <lib/base/eerror.h>
+
+eSocketNotifier::eSocketNotifier(eMainloop *context, int fd, int requested, bool startnow): context(*context), fd(fd), state(0), requested(requested)
+{
+	if (startnow)	
+		start();
+}
+
+eSocketNotifier::~eSocketNotifier()
+{
+	stop();
+}
+
+void eSocketNotifier::start()
+{
+	if (state)
+		stop();
+
+	context.addSocketNotifier(this);
+	state=1;
+}
+
+void eSocketNotifier::stop()
+{
+	if (state)
+		context.removeSocketNotifier(this);
+
+	state=0;
+}
+
+					// timer
+void eTimer::start(long msek, bool singleShot)
+{
+	if (bActive)
+		stop();
+
+	bActive = true;
+	bSingleShot = singleShot;
+	interval = msek;
+ 	gettimeofday(&nextActivation, 0);		
+//	eDebug("this = %p\nnow sec = %d, usec = %d\nadd %d msec", this, nextActivation.tv_sec, nextActivation.tv_usec, msek);
+	nextActivation += (msek<0 ? 0 : msek);
+//	eDebug("next Activation sec = %d, usec = %d", nextActivation.tv_sec, nextActivation.tv_usec );
+	context.addTimer(this);
+}
+
+void eTimer::stop()
+{
+	if (bActive)
+	{
+		bActive=false;
+		context.removeTimer(this);
+	}
+}
+
+void eTimer::changeInterval(long msek)
+{
+	if (bActive)  // Timer is running?
+	{
+		context.removeTimer(this);	 // then stop
+		nextActivation -= interval;  // sub old interval
+	}
+	else
+		bActive=true;	// then activate Timer
+
+	interval = msek;   			 			// set new Interval
+	nextActivation += interval;		// calc nextActivation
+
+	context.addTimer(this);				// add Timer to context TimerList
+}
+
+void eTimer::activate()   // Internal Funktion... called from eApplication
+{
+	timeval now;
+	gettimeofday(&now, 0);
+//	eDebug("this = %p\nnow sec = %d, usec = %d\nnextActivation sec = %d, usec = %d", this, now.tv_sec, now.tv_usec, nextActivation.tv_sec, nextActivation.tv_usec );
+//	eDebug("Timer emitted");
+	context.removeTimer(this);
+
+	if (!bSingleShot)
+	{
+		nextActivation += interval;
+		context.addTimer(this);
+	}
+	else
+		bActive=false;
+
+	/*emit*/ timeout();
+}
+
+// mainloop
+
+void eMainloop::addSocketNotifier(eSocketNotifier *sn)
+{
+	notifiers.insert(std::pair<int,eSocketNotifier*> (sn->getFD(), sn));
+}
+
+void eMainloop::removeSocketNotifier(eSocketNotifier *sn)
+{
+	notifiers.erase(sn->getFD());
+}
+
+void eMainloop::processOneEvent()
+{
+// process pending timers...
+	long usec=0;
+
+	while (TimerList && (usec = timeout_usec( TimerList.begin()->getNextActivation() ) ) <= 0 )
+		TimerList.begin()->activate();
+
+	int fdAnz = notifiers.size();
+	pollfd* pfd = new pollfd[fdAnz];  // make new pollfd array
+
+// fill pfd array
+	std::map<int,eSocketNotifier*>::iterator it(notifiers.begin());
+	for (int i=0; i < fdAnz; i++, it++)
+	{
+		pfd[i].fd = it->first;
+		pfd[i].events = it->second->getRequested();
+	}
+
+	int ret=poll(pfd, fdAnz, TimerList ? usec / 1000 : -1);  // milli .. not micro seks
+
+	if (ret>0)
+	{
+//		eDebug("bin aussem poll raus und da war was");
+		for (int i=0; i < fdAnz ; i++)
+		{
+			if( notifiers.find(pfd[i].fd) == notifiers.end())
+				continue;
+
+			int req = notifiers[pfd[i].fd]->getRequested();
+
+			if ( pfd[i].revents & req )
+			{
+				notifiers[pfd[i].fd]->activate(pfd[i].revents);
+
+				if (!--ret)
+					break;
+			} else if (pfd[i].revents & (POLLERR|POLLHUP|POLLNVAL))
+				eDebug("poll: unhandled POLLERR/HUP/NVAL for fd %d(%d)", pfd[i].fd,pfd[i].revents);
+		}
+	}
+	else if (ret<0)
+		eDebug("poll made error");
+
+		// check Timers...
+	while ( TimerList && timeout_usec( TimerList.begin()->getNextActivation() ) <= 0 )
+		TimerList.begin()->activate();
+
+	delete [] pfd;
+}
+
+
+int eMainloop::exec()
+{
+	if (!loop_level)
+	{
+		app_quit_now = false;
+		enter_loop();
+	}
+	return retval;
+}
+
+void eMainloop::enter_loop()
+{
+	loop_level++;
+
+	// Status der vorhandenen Loop merken
+	bool old_exit_loop = app_exit_loop;
+	
+	app_exit_loop = false;
+
+	while (!app_exit_loop && !app_quit_now)
+	{
+		processOneEvent();
+	}
+
+	// wiederherstellen der vorherigen app_exit_loop
+	app_exit_loop = old_exit_loop;
+
+	loop_level--;
+
+	if (!loop_level)
+	{
+			// do something here on exit the last loop
+	}
+}
+
+void eMainloop::exit_loop()  // call this to leave the current loop
+{
+	app_exit_loop = true;	
+}
+
+void eMainloop::quit( int ret )   // call this to leave all loops
+{
+	retval=ret;
+	app_quit_now = true;
+}
+
+eApplication* eApp = 0;