pysilcam/__main__.py
def collector(inputQueue, outputQueue, datafilename, proc_list, testInputQueue,
              settings, rts=None):
    '''
    collects all the results and write them into the stats.csv file

    Args:
        inputQueue  ()              : queue where the images are added for processing
                                      initilised using defineQueues()
        outputQueue ()              : queue where information is retrieved from processing
                                      initilised using defineQueues()
        datafilename (str)          : filename where processed data are written to csv
        proc_list   (list)          : list of multiprocessing objects
        testInputQueue (Bool)       : if True function will keep collecting until inputQueue is empty
        settings (PySilcamSettings) : Settings read from a .ini file
        rts (Class):                : Class for realtime stats
    '''

    countProcessFinished = 0

    while ((outputQueue.qsize() > 0) or (testInputQueue and inputQueue.qsize() > 0)):

        task = outputQueue.get()

        if (task is None):
            countProcessFinished = countProcessFinished + 1
            if (len(proc_list) == 0):  # no multiprocessing
                break
            # The collector can be stopped only after all loop processes are finished
            elif (countProcessFinished == len(proc_list)):
                break
            continue

        writeCSV(datafilename, task)
        collect_rts(settings, rts, task)

    collects all the results and write them into the stats.csv file

    Args:
        inputQueue  ()              : queue where the images are added for processing
                                      initilised using defineQueues()
        outputQueue ()              : queue where information is retrieved from processing
                                      initilised using defineQueues()
        datafilename (str)          : filename where processed data are written to csv
        proc_list   (list)          : list of multiprocessing objects
        testInputQueue (Bool)       : if True function will keep collecting until inputQueue is empty
        settings (PySilcamSettings) : Settings read from a .ini file
        rts (Class):                : Class for realtime stats
    
collects all the results and write them into the stats.csv file
collects all the results and write them into the stats . csv file
def collector(inputQueue, outputQueue, datafilename, proc_list, testInputQueue,
              settings, rts=None):
    countProcessFinished = 0
    while ((outputQueue.qsize() > 0) or (testInputQueue and inputQueue.qsize() > 0)):
        task = outputQueue.get()
        if (task is None):
            countProcessFinished = countProcessFinished + 1
            if (len(proc_list) == 0):  
                break
            elif (countProcessFinished == len(proc_list)):
                break
            continue
        writeCSV(datafilename, task)
        collect_rts(settings, rts, task)
def collector ( inputQueue , outputQueue , datafilename , proc_list , testInputQueue , settings , rts = None ) : countProcessFinished = 0 while ( ( outputQueue . qsize ( ) > 0 ) or ( testInputQueue and inputQueue . qsize ( ) > 0 ) ) : task = outputQueue . get ( ) if ( task is None ) : countProcessFinished = countProcessFinished + 1 if ( len ( proc_list ) == 0 ) : break elif ( countProcessFinished == len ( proc_list ) ) : break continue writeCSV ( datafilename , task ) collect_rts ( settings , rts , task )
collects all the results and write them into the stats.csv file
collects all the results and write them into the stats . csv file
'''
    collects all the results and write them into the stats.csv file

    Args:
        inputQueue  ()              : queue where the images are added for processing
                                      initilised using defineQueues()
        outputQueue ()              : queue where information is retrieved from processing
                                      initilised using defineQueues()
        datafilename (str)          : filename where processed data are written to csv
        proc_list   (list)          : list of multiprocessing objects
        testInputQueue (Bool)       : if True function will keep collecting until inputQueue is empty
        settings (PySilcamSettings) : Settings read from a .ini file
        rts (Class):                : Class for realtime stats
    ''' # no multiprocessing # The collector can be stopped only after all loop processes are finished
inputQueue
outputQueue
datafilename
filename where processed data are written to csv
filename where processed data are written to csv
proc_list
list of multiprocessing objects
list of multiprocessing objects
testInputQueue
if True function will keep collecting until inputQueue is empty
if True function will keep collecting until inputQueue is empty
settings
Settings read from a .ini file
Settings read from a . ini file
rts
: Class for realtime stats
: Class for realtime stats
inputQueue  ()              
queue where the images are added for processing
initilised using defineQueues()
queue where the images are added for processing initilised using defineQueues ()
outputQueue ()              
queue where information is retrieved from processing
initilised using defineQueues()
queue where information is retrieved from processing initilised using defineQueues ()