server_JF.py 文件源码

def finish_query(devices, data_layer, son):
    res = {}
    for x in devices.keys():
        for item in devices[x]:
            try:
                res[repr((x[0], x[1], x[2], x[3]))].append(repr(data_layer.get_address(item[1], item[7])))
            except KeyError:
                res[repr((x[0], x[1], x[2], x[3]))] = [repr(data_layer.get_address(item[1], item[7]))]
    s_qp = socket.socket(family=socket.AF_UNIX, type=socket.SOCK_STREAM)
    son.send(json.dumps(res))
    for x in devices.keys():
        devices[x].close()
    data_layer.close()
    try:
        s_qp.connect('/tmp/process_com_' + login)
    except FileNotFoundError:
        print('FileNotFoundError')
    except ConnectionRefusedError:
        print('ConnectionRefusedError')
    s_qp.send(b'True')
    s_qp.close()