Add batch event processing in lime/sdl

project/src/backend/sdl/SDLApplication.cpp

@@ -46,6 +46,11 @@ namespace lime {
 		lastUpdate = 0;
 		nextUpdate = 0;
 
+		eventQueue = NULL;
+		queueLength = 0;
+		queueMaxLength = 0;
+		isGCBlocking = false;
+
 		ApplicationEvent applicationEvent;
 		ClipboardEvent clipboardEvent;
 		DropEvent dropEvent;
@@ -80,7 +85,12 @@ namespace lime {
 
 	SDLApplication::~SDLApplication () {
 
-
+		if (NULL != eventQueue) {
+			SDL_free (eventQueue);
+			eventQueue = NULL;
+			queueMaxLength = 0;
+			queueLength = 0;
+		}
 
 	}
 
@@ -332,6 +342,8 @@ namespace lime {
 		lastUpdate = SDL_GetTicks ();
 		nextUpdate = lastUpdate;
 
+		while (20 == BatchUpdate(20));
+
 	}
 
 
@@ -827,7 +839,6 @@ namespace lime {
 
 	static SDL_TimerID timerID = 0;
 	bool timerActive = false;
-	bool firstTime = true;
 
 	Uint32 OnTimer (Uint32 interval, void *) {
 
@@ -857,9 +868,7 @@ namespace lime {
 
 		#if (!defined (IPHONE) && !defined (EMSCRIPTEN))
 
-		if (active && (firstTime || WaitEvent (&event))) {
-
-			firstTime = false;
+		if (active && WaitEvent (&event)) {
 
 			HandleEvent (&event);
 			event.type = -1;
@@ -912,6 +921,83 @@ namespace lime {
 	}
 
 
+	int SDLApplication::BatchUpdate (int numEvents) {
+
+		SDL_Event* mouseMoved = NULL;
+
+		if (!active) {
+			return -1;
+		}
+
+		queueLength = numEvents;
+
+		if (queueLength > queueMaxLength) {
+
+			if (NULL != eventQueue) {
+				SDL_free (eventQueue);
+			}
+
+			eventQueue = reinterpret_cast<SDL_Event*> (SDL_malloc (queueLength * sizeof (SDL_Event)));
+			if (NULL == eventQueue) {
+				queueLength = 0;
+				queueMaxLength = 0;
+			} else {
+				queueMaxLength = queueLength;
+			}
+		}
+
+		int numPending = GetPendingEvents (eventQueue, queueLength);
+
+		// only allow GC free objects while we're handling events
+		if (isGCBlocking) System::GCExitBlocking ();
+		isGCBlocking = false;
+
+		int nextEvent;
+		for (nextEvent = 0; nextEvent < numPending; ++nextEvent) {
+
+			if (SDL_MOUSEMOTION == eventQueue[nextEvent].type) {
+				// we'll only handle the last motion event in the batch
+				mouseMoved = &eventQueue[nextEvent];
+			} else {
+				HandleEvent (&eventQueue[nextEvent]);
+				eventQueue[nextEvent].type = -1;
+				if (!active) {
+					return -1;
+				}
+			}
+		}
+
+		// handle the mouse motion event if there is one this batch
+		if (NULL != mouseMoved) {
+			HandleEvent (mouseMoved);
+			mouseMoved->type = -1;
+		}
+
+		currentUpdate = SDL_GetTicks ();
+
+		#if (!defined (IPHONE) && !defined (EMSCRIPTEN))
+
+		if (currentUpdate >= nextUpdate) {
+
+			SDL_RemoveTimer (timerID);
+			OnTimer (0, 0);
+
+		} else if (!timerActive) {
+
+			timerActive = true;
+			timerID = SDL_AddTimer (nextUpdate - currentUpdate, OnTimer, 0);
+
+		}
+
+		if (!isGCBlocking) System::GCEnterBlocking ();
+		isGCBlocking = true;
+
+		#endif
+
+		return nextEvent;
+	}
+
+
 	void SDLApplication::UpdateFrame () {
 
 		#ifdef EMSCRIPTEN
@@ -978,6 +1064,16 @@ namespace lime {
 
 	}
 
+
+	int SDLApplication::GetPendingEvents (SDL_Event* events, int maxEvents)
+	{
+		SDL_PumpEvents ();
+
+		int numEvents = SDL_PeepEvents (events, maxEvents, SDL_GETEVENT, SDL_FIRSTEVENT, SDL_LASTEVENT);
+
+		return numEvents;
+	}
+
 
 	Application* CreateApplication () {
 

project/src/backend/sdl/SDLApplication.h

@@ -34,6 +34,7 @@ namespace lime {
 			virtual int Quit ();
 			virtual void SetFrameRate (double frameRate);
 			virtual bool Update ();
+			virtual int BatchUpdate(int numEvents);
 
 			void RegisterWindow (SDLWindow *window);
 
@@ -51,13 +52,18 @@ namespace lime {
 			void ProcessTouchEvent (SDL_Event* event);
 			void ProcessWindowEvent (SDL_Event* event);
 			int WaitEvent (SDL_Event* event);
+			int GetPendingEvents (SDL_Event* event, int NumEvents);
 
 			static void UpdateFrame ();
 			static void UpdateFrame (void*);
 
 			static SDLApplication* currentApplication;
 
 			bool active;
+			SDL_Event* eventQueue;
+			int queueLength;
+			int queueMaxLength;
+			bool isGCBlocking;
 			ApplicationEvent applicationEvent;
 			ClipboardEvent clipboardEvent;
 			Uint32 currentUpdate;