add background file eraser class for asynchronous file deletion

3 files changed, 125 insertions, 1 deletions

diff --git a/lib/components/Makefile.am b/lib/components/Makefile.am
index c25791a7..70bd8b6b 100644
--- a/lib/components/Makefile.am
+++ b/lib/components/Makefile.am
@@ -3,5 +3,5 @@ INCLUDES = \
 
 noinst_LIBRARIES = libenigma_components.a
 
-libenigma_components_a_SOURCES = scan.cpp listboxepg.cpp
+libenigma_components_a_SOURCES = scan.cpp listboxepg.cpp file_eraser.cpp
 	
\ No newline at end of file
diff --git a/lib/components/file_eraser.cpp b/lib/components/file_eraser.cpp
new file mode 100644
index 00000000..bc26bf7c
--- /dev/null
+++ b/lib/components/file_eraser.cpp
@@ -0,0 +1,83 @@
+#include <lib/components/file_eraser.h>
+#include <lib/base/eerror.h>
+#include <lib/base/init.h>
+#include <lib/base/init_num.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <unistd.h>
+#include <errno.h>
+
+eBackgroundFileEraser *eBackgroundFileEraser::instance;
+
+eBackgroundFileEraser::eBackgroundFileEraser()
+	:messages(this,1), stop_thread_timer(this)
+{
+	if (!instance)
+		instance=this;
+	CONNECT(messages.recv_msg, eBackgroundFileEraser::gotMessage);
+	CONNECT(stop_thread_timer.timeout, eBackgroundFileEraser::idle);
+}
+
+void eBackgroundFileEraser::idle()
+{
+	quit(0);
+}
+
+eBackgroundFileEraser::~eBackgroundFileEraser()
+{
+	messages.send(Message::quit);
+	if ( thread_running() )
+		kill();
+	if (instance==this)
+		instance=0;
+}
+
+void eBackgroundFileEraser::thread()
+{
+	nice(5);
+	reset();
+	runLoop();
+	stop_thread_timer.stop();
+}
+
+void eBackgroundFileEraser::erase(const char *filename)
+{
+	if (filename)
+	{
+		char buf[255];
+		snprintf(buf, 255, "%s.$$$", filename);
+		if (rename(filename, buf)<0)
+			;/*perror("rename file failed !!!");*/
+		else
+		{
+			messages.send(Message(Message::erase, strdup(buf)));
+			if (!thread_running())
+				run();
+		}
+	}
+}
+
+void eBackgroundFileEraser::gotMessage(const Message &msg )
+{
+	switch (msg.type)
+	{
+		case Message::erase:
+			if ( msg.filename )
+			{
+				if ( ::unlink(msg.filename) < 0 )
+					eDebug("remove file %s failed (%m)", msg.filename);
+				else
+					eDebug("file %s erased", msg.filename);
+				free((char*)msg.filename);
+			}
+			stop_thread_timer.start(2000, true); // stop thread in two seconds
+			break;
+		case Message::quit:
+			quit(0);
+			break;
+		default:
+			eDebug("unhandled thread message");
+	}
+}
+
+eAutoInitP0<eBackgroundFileEraser> init_eBackgroundFilEraser(eAutoInitNumbers::configuration+1, "Background File Eraser");
diff --git a/lib/components/file_eraser.h b/lib/components/file_eraser.h
new file mode 100644
index 00000000..6cb13dda
--- /dev/null
+++ b/lib/components/file_eraser.h
@@ -0,0 +1,41 @@
+#ifndef __lib_components_file_eraser_h
+#define __lib_components_file_eraser_h
+
+#include <lib/base/thread.h>
+#include <lib/base/message.h>
+#include <lib/base/ebase.h>
+
+class eBackgroundFileEraser: public eMainloop, private eThread, public Object
+{
+	struct Message
+	{
+		int type;
+		const char *filename;
+		enum
+		{
+			erase,
+			quit
+		};
+		Message(int type=0, const char *filename=0)
+			:type(type), filename(filename)
+		{}
+	};
+	eFixedMessagePump<Message> messages;
+	static eBackgroundFileEraser *instance;
+	void gotMessage(const Message &message);
+	void thread();
+	void idle();
+	eTimer stop_thread_timer;
+#ifndef SWIG
+public:
+#endif
+	eBackgroundFileEraser();
+	~eBackgroundFileEraser();
+#ifdef SWIG
+public:
+#endif
+	void erase(const char * filename);
+	static eBackgroundFileEraser *getInstance() { return instance; }
+};
+
+#endif