S15qkd/chopper2.py
def _t1logpipe_digest():
    '''
    Digest the t1log pipe written by chopper2.
    Chopper2 runs on the high-count side.
    Also counts the number of epochs recorded by chopper2.
    '''
    global t1logpipe_digest_thread_flag, t1_epoch_count, first_epoch
    t1_epoch_count = 0
    t1logpipe_digest_thread_flag = True

    while t1logpipe_digest_thread_flag is True:
        for message in _reader(PipesQKD.T1LOG):
            logger.debug(f'[read msg] {message}')
            if t1_epoch_count == 0:
                first_epoch = message.split()[0]
                logger.info(f'First_epoch: {first_epoch}')
            t1_epoch_count += 1
    logger.info(f'Thread finished.')

    Digest the t1log pipe written by chopper2.
    Chopper2 runs on the high-count side.
    Also counts the number of epochs recorded by chopper2.
    
Digest the t1log pipe written by chopper2.
Chopper2 runs on the high-count side.
Also counts the number of epochs recorded by chopper2.
Digest the t1log pipe written by chopper2 . Chopper2 runs on the high - count side . Also counts the number of epochs recorded by chopper2 .
def _t1logpipe_digest():
    global t1logpipe_digest_thread_flag, t1_epoch_count, first_epoch
    t1_epoch_count = 0
    t1logpipe_digest_thread_flag = True
    while t1logpipe_digest_thread_flag is True:
        for message in _reader(PipesQKD.T1LOG):
            logger.debug(f'[read msg] {message}')
            if t1_epoch_count == 0:
                first_epoch = message.split()[0]
                logger.info(f'First_epoch: {first_epoch}')
            t1_epoch_count += 1
    logger.info(f'Thread finished.')
def _t1logpipe_digest ( ) : global t1logpipe_digest_thread_flag , t1_epoch_count , first_epoch t1_epoch_count = 0 t1logpipe_digest_thread_flag = True while t1logpipe_digest_thread_flag is True : for message in _reader ( PipesQKD . T1LOG ) : logger . debug ( f'[read msg] {message}' ) if t1_epoch_count == 0 : first_epoch = message . split ( ) [ 0 ] logger . info ( f'First_epoch: {first_epoch}' ) t1_epoch_count += 1 logger . info ( f'Thread finished.' )
Digest the t1log pipe written by chopper2.
Digest the t1log pipe written by chopper2 .
'''
    Digest the t1log pipe written by chopper2.
    Chopper2 runs on the high-count side.
    Also counts the number of epochs recorded by chopper2.
    '''