server_JF.py 文件源码

def query_process_communication():
    global t2
    if os.path.exists('/tmp/process_com_' + login):
        os.remove('/tmp/process_com_' + login)
    sqp = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
    sqp.bind('/tmp/process_com_' + login)
    sqp.listen(1)
    while 1:
        conn_qp, _ = sqp.accept()
        while 1:
            data = conn_qp.recv(10)
            if data:
                if t2 and t2.is_alive():
                    t2.terminate()
                open_writing()
                conn_qp.close()
                break