S15qkd/splicer.py
def start_splicer(qkd_protocol: int = QKDProtocol.BBM92):
    '''
    Starts the splicer process and attaches a thread digesting 
    the splice pipe and the genlog.
    '''
    global data_root, cwd, proc_splicer
    initialize()
    args = f'-d {FoldersQKD.T3FILES} \
             -D {FoldersQKD.RECEIVEFILES} \
             -f {FoldersQKD.RAWKEYS} \
             -E {PipesQKD.SPLICER} \
             {kill_option} \
             -p {qkd_protocol} \
             -m {PipesQKD.GENLOG}'
    with open(f'{FoldersQKD.DATAROOT}/splicer_stderr', 'a+') as f_err:
        with open(f'{FoldersQKD.DATAROOT}/splicer_stdout', 'a+') as f_stdout:
            proc_splicer = subprocess.Popen([prog_splicer, *args.split()],
                                            stdout=f_stdout,
                                            stderr=f_err)
    time.sleep(0.1)
    logger.info(f'Started splicer process.')
    thread_splicepipe_digest = threading.Thread(target=_splice_pipe_digest,
                                                args=([qkd_protocol]))
    thread_splicepipe_digest.start()

    Starts the splicer process and attaches a thread digesting 
    the splice pipe and the genlog.
    
Starts the splicer process and attaches a thread digesting
the splice pipe and the genlog.
Starts the splicer process and attaches a thread digesting the splice pipe and the genlog .
def start_splicer(qkd_protocol: int = QKDProtocol.BBM92):
    global data_root, cwd, proc_splicer
    initialize()
    args = f'-d {FoldersQKD.T3FILES} \
             -D {FoldersQKD.RECEIVEFILES} \
             -f {FoldersQKD.RAWKEYS} \
             -E {PipesQKD.SPLICER} \
             {kill_option} \
             -p {qkd_protocol} \
             -m {PipesQKD.GENLOG}'
    with open(f'{FoldersQKD.DATAROOT}/splicer_stderr', 'a+') as f_err:
        with open(f'{FoldersQKD.DATAROOT}/splicer_stdout', 'a+') as f_stdout:
            proc_splicer = subprocess.Popen([prog_splicer, *args.split()],
                                            stdout=f_stdout,
                                            stderr=f_err)
    time.sleep(0.1)
    logger.info(f'Started splicer process.')
    thread_splicepipe_digest = threading.Thread(target=_splice_pipe_digest,
                                                args=([qkd_protocol]))
    thread_splicepipe_digest.start()
def start_splicer ( qkd_protocol : int = QKDProtocol . BBM92 ) : global data_root , cwd , proc_splicer initialize ( ) args = f'-d {FoldersQKD.T3FILES} \
             -D {FoldersQKD.RECEIVEFILES} \
             -f {FoldersQKD.RAWKEYS} \
             -E {PipesQKD.SPLICER} \
             {kill_option} \
             -p {qkd_protocol} \
             -m {PipesQKD.GENLOG}' with open ( f'{FoldersQKD.DATAROOT}/splicer_stderr' , 'a+' ) as f_err : with open ( f'{FoldersQKD.DATAROOT}/splicer_stdout' , 'a+' ) as f_stdout : proc_splicer = subprocess . Popen ( [ prog_splicer , * args . split ( ) ] , stdout = f_stdout , stderr = f_err ) time . sleep ( 0.1 ) logger . info ( f'Started splicer process.' ) thread_splicepipe_digest = threading . Thread ( target = _splice_pipe_digest , args = ( [ qkd_protocol ] ) ) thread_splicepipe_digest . start ( )
Starts the splicer process and attaches a thread digesting
the splice pipe and the genlog.
Starts the splicer process and attaches a thread digesting the splice pipe and the genlog .
'''
    Starts the splicer process and attaches a thread digesting 
    the splice pipe and the genlog.
    '''
qkd_protocol
int