#NEWLINE# def __get_time_offset_concurrency( self ) : #NEWLINE# #INDENT# if ( ( not self . load . ramp_up ) or ( self . count >= self . concurrency ) ) : #NEWLINE# #INDENT# if ( self . need_start_loop is None ) : #NEWLINE# #INDENT# self . need_start_loop = True #NEWLINE# #UNINDENT# return ( - 1 ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if self . load . steps : #NEWLINE# #INDENT# step = math . floor ( ( self . count / self . step_size ) ) #NEWLINE# return ( step * self . step_len ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# return ( ( self . count * self . load . ramp_up ) / self . concurrency )