import Sensor_merge_lineal
import random
import time
import numpy
import sys
from multiprocessing import Process, Manager, Lock
from multiprocessing.managers import BaseManager


def alarmas(object, num_process, tiempo_limite):
    tiempo_inicio = time.time()
    while (1):
        lista = object.get_obj()
        for i in range (0,num_process):
            if(lista[i] > 0):
                tiempo = time.time() - lista[i]
                object.set_value(i, -1)
                object.set_value_tiempos(tiempo)

class ListObj(object):
        def __init__(self, lista, lista_tiempos_promedios):
                self.lista = lista
                self.lista_tiempos_promedios = lista_tiempos_promedios

        def set_value(self, indice_lista, tiempo_atencion):
                self.lista[indice_lista] = tiempo_atencion

        def set_value_tiempos(self, tiempo_atencion):  #para estadistica
                self.lista_tiempos_promedios.append(tiempo_atencion)

        def get_obj(self):
                return self.lista

        def get_value_tiempos(self): #para estadistica
                return self.lista_tiempos_promedios

if __name__=="__main__":
        num_process = 1
        tamano_de_matriz = 10
        if len(sys.argv) >2:
            temp1=int(sys.argv[2])
            if sys.argv[2].isdigit() and temp1 > 10 and temp1 < 100000:
                tamano_de_matriz=temp1#cantidad de valores
        if len(sys.argv) >1:
            temp2=int(sys.argv[1])
            if sys.argv[1].isdigit() and temp2 > 1 and temp2 < 100:
                num_process = temp2 #cantidad de sensores

        BaseManager.register('ListObj', ListObj)
        manager = BaseManager()
        manager.start()

        tiempo_limite = 5 #tiempo que corre alarmas
        lista=list(range(num_process))
        lista = [-1 for i in range(num_process)] #inicializamos con -1
        lista_tiempos_promedios = []
        listObl = manager.ListObj(lista,lista_tiempos_promedios)

        process_list = []
        for p in range(num_process):
                proc = Sensor_merge_lineal.Sensor(listObl, p, tamano_de_matriz)
                process_list.append(proc)

        for x in range(num_process):
                process_list[x].start()

        alarmas= Process(target=alarmas, args=(listObl,num_process, tiempo_limite))
        alarmas.start()

        time.sleep(tiempo_limite)

        for x in range(num_process):
                process_list[x].terminate()

        alarmas.terminate()

        media = numpy.mean(listObl.get_value_tiempos() ) #promedio de ti
        print(media)