flowcraft/generator/inspect.py
def _update_barrier_status(self):
        """Checks whether the channels to each process have been closed.
        """

        with open(self.log_file) as fh:

            for line in fh:

                # Exit barrier update after session abort signal
                if "Session aborted" in line:
                    return

                if "<<< barrier arrive" in line:
                    # Retrieve process name from string
                    process_m = re.match(".*process: (.*)\)", line)
                    if process_m:
                        process = process_m.group(1)
                        # Updates process channel to complete
                        if process in self.processes:
                            self.processes[process]["barrier"] = "C"
def _update_barrier_status(self):
        with open(self.log_file) as fh:

            for line in fh:

                # Exit barrier update after session abort signal
                if "Session aborted" in line:
                    return

                if "<<< barrier arrive" in line:
                    # Retrieve process name from string
                    process_m = re.match(".*process: (.*)\)", line)
                    if process_m:
                        process = process_m.group(1)
                        # Updates process channel to complete
                        if process in self.processes:
                            self.processes[process]["barrier"] = "C"
def _update_barrier_status ( self ) : with open ( self . log_file ) as fh : for line in fh : # Exit barrier update after session abort signal if "Session aborted" in line : return if "<<< barrier arrive" in line : # Retrieve process name from string process_m = re . match ( ".*process: (.*)\)" , line ) if process_m : process = process_m . group ( 1 ) # Updates process channel to complete if process in self . processes : self . processes [ process ] [ "barrier" ] = "C"
Checks whether the channels to each process have been closed.
Checks whether the channels to each process have been closed .