#!/usr/bin/env python
import subprocess
from threading import Thread
import signal
import sys
import os

KEEP_RUNNING = True

def signalHandler(signal, frame):
	global KEEP_RUNNING
	KEEP_RUNNING = False
	print("Closing")
	sys.exit(0)

def spawnRenderer():
	while KEEP_RUNNING:
		proc = subprocess.Popen(["/root/renderer.py"], shell=True, stdout=subprocess.PIPE)
		print("Process RENDERER PID: " + str(proc.pid))
		try:
			stdoutdata, stderrdata = proc.communicate()
		except:
			print "An error occured, running again..."
	return None

def spawnMixer():
	while KEEP_RUNNING:
		proc = subprocess.Popen(["/root/mixer.py"], shell=True, stdout=subprocess.PIPE)
		print("Process MIXER PID: " + str(proc.pid))
		try:
			stdoutdata, stderrdata = proc.communicate()
		except:
			print "An error occured, running again..."
	return None

def spawnTranslator():
	while KEEP_RUNNING:
		proc = subprocess.Popen(["/root/translator.py"], shell=True, stdout=subprocess.PIPE)
		print("Process TRANSLATOR PID: " + str(proc.pid))
		try:
			stdoutdata, stderrdata = proc.communicate()
		except:
			print "An error occured, running again..."
	return None

def spawnExtractor():
	while KEEP_RUNNING:
		proc = subprocess.Popen(["/root/extractor.py"], shell=True, stdout=subprocess.PIPE)
		print("Process EXTRACTOR PID: " + str(proc.pid))
		try:
			stdoutdata, stderrdata = proc.communicate()
		except:
			print "An error occured, running again..."
	return None

if __name__ == "__main__":
	signal.signal(signal.SIGINT, signalHandler)

	t = Thread(target=spawnExtractor, args=())
	t.start()

	t2 = Thread(target=spawnTranslator, args=())
	t2.start()

	t3 = Thread(target=spawnRenderer, args=())
	t3.start()

	t4 = Thread(target=spawnMixer, args=())
	t4.start()
		#thread.start_new_thread(spawnWorker, (worker,))