Commit 7a36809c authored by Ferreira Da Silva, Rafael's avatar Ferreira Da Silva, Rafael
Browse files

Update train.py

parent 8fea82c0

train.py

+1 −7
Original line number Diff line number Diff line
@@ -252,13 +252,7 @@ if __name__ == "__main__": 
    subsocket.setsockopt_string(zmq.SUBSCRIBE, "metadata")

    subsocket.setsockopt_string(zmq.SUBSCRIBE, "data")

    subsocket.setsockopt_string(zmq.SUBSCRIBE, "END")

    subsocket.connect("tcp://REPLACE_HOST:5555")



    # let the publisher know we are established

    sigsocket = context.socket(zmq.REQ)

    sigsocket.connect("tcp://REPLACE_HOST:5556")

    sigsocket.send(b'')

    sigsocket.recv()

    subsocket.connect("tcp://REPLACE_HOST:5560")



    print("Synchronized; ready to receive data")

    def receive_byte_array(socket):