PEATSA/Core/Environment.py
def wait(self, error=False):
	
		'''This method will not return until all process in the environment have called it.
		
		This is a wrapper around MPI_Barrier which handles the case where MPI is not available'''

		from inspect import stack
	
		if self.verbose is True:
			string = '(%s) Waiting at line %d of %s' % (datetime.datetime.now().strftime('%H:%M:%S'),
					 stack()[1][0].f_lineno, stack()[1][0].f_code.co_filename)
			self.log(string)
			
		if Environment.isParallel:
			import pypar
			pypar.barrier()	
			#Because MPI_ABORT doesn't work in pypar if called from one process
			#we need a way for process to communicate to each other if an error occurred
			#during the code they executed before this barrier. We do a scatter/gather of
			#the error parameter - This isn't very efficient but it's all we can do now
			errors = self.combineArray([error])
			if True in errors:
				self.exit(1)
				
		if self.verbose is True:
			string = '(%s) Finished waiting' % (datetime.datetime.now().strftime('%H:%M:%S'))
			self.log(string)
This method will not return until all process in the environment have called it.
		
		This is a wrapper around MPI_Barrier which handles the case where MPI is not available
This method will not return until all process in the environment have called it.
This is a wrapper around MPI_Barrier which handles the case where MPI is not available
This method will not return until all process in the environment have called it . This is a wrapper around MPI_Barrier which handles the case where MPI is not available
def wait(self, error=False):
		from inspect import stack
		if self.verbose is True:
			string = '(%s) Waiting at line %d of %s' % (datetime.datetime.now().strftime('%H:%M:%S'),
					 stack()[1][0].f_lineno, stack()[1][0].f_code.co_filename)
			self.log(string)
		if Environment.isParallel:
			import pypar
			pypar.barrier()	
			errors = self.combineArray([error])
			if True in errors:
				self.exit(1)
		if self.verbose is True:
			string = '(%s) Finished waiting' % (datetime.datetime.now().strftime('%H:%M:%S'))
			self.log(string)
def wait ( self , error = False ) : from inspect import stack if self . verbose is True : string = '(%s) Waiting at line %d of %s' % ( datetime . datetime . now ( ) . strftime ( '%H:%M:%S' ) , stack ( ) [ 1 ] [ 0 ] . f_lineno , stack ( ) [ 1 ] [ 0 ] . f_code . co_filename ) self . log ( string ) if Environment . isParallel : import pypar pypar . barrier ( ) errors = self . combineArray ( [ error ] ) if True in errors : self . exit ( 1 ) if self . verbose is True : string = '(%s) Finished waiting' % ( datetime . datetime . now ( ) . strftime ( '%H:%M:%S' ) ) self . log ( string )
This method will not return until all process in the environment have called it.
This method will not return until all process in the environment have called it .
'''This method will not return until all process in the environment have called it.
		
		This is a wrapper around MPI_Barrier which handles the case where MPI is not available''' #Because MPI_ABORT doesn't work in pypar if called from one process #we need a way for process to communicate to each other if an error occurred #during the code they executed before this barrier. We do a scatter/gather of #the error parameter - This isn't very efficient but it's all we can do now
self
error