import socket

#Se crea el socket del datanode escuchando en el puerto 5003 para que el Headnode se conecte
datanode3 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
datanode3.bind(('datanode3',5003))
datanode3.listen(1)
archivo= open("./data.txt","w")
#Se acepta la conexion del Headnode
while True:
    conn_h,addr_h = datanode3.accept()
    #Recibe el mensaje que el Headnode recibio del Cliente
    received=conn_h.recv(4096)
    string=received.decode('utf-8')
    if(string=='exit'):
        print("Cerrando conexion")
        break;
    #Escribe en el archivo el mensaje del cliente
    archivo.write(string+"\n")
    print(string)
    #Avisa al Headnode que el registro fue correcto
    mensaje="El registro fue correcto"
    conn_h.send(mensaje.encode('utf-8'))
datanode3.close()
archivo.close()
