#NEWLINE# def process_reply( self , message ) : #NEWLINE# #INDENT# result = super ( IperfGraphExecutor , self ) . process_reply ( message ) #NEWLINE# if ( not result [ 'stdout' ] ) : #NEWLINE# #INDENT# raise base . ExecutorException ( result , 'Empty result from iperf' ) #NEWLINE# #UNINDENT# samples = [ ] #NEWLINE# threads_count = ( self . test_definition . get ( 'threads' ) or 1 ) #NEWLINE# for row in csv . reader ( result [ 'stdout' ] . split ( '\n' ) ) : #NEWLINE# #INDENT# if ( row and ( len ( row ) > 8 ) ) : #NEWLINE# #INDENT# thread = row [ 5 ] #NEWLINE# if ( ( threads_count > 1 ) and ( thread != '-1' ) ) : #NEWLINE# #INDENT# continue #NEWLINE# #UNINDENT# ( start , end ) = row [ 6 ] . split ( '-' ) #NEWLINE# samples . append ( [ float ( end ) , int ( row [ 8 ] ) ] ) #NEWLINE# #UNINDENT# #UNINDENT# if start : #NEWLINE# #INDENT# samples . pop ( ) #NEWLINE# #UNINDENT# result [ 'samples' ] = samples #NEWLINE# result [ 'meta' ] = [ [ 'time' , 's' ] , [ 'bandwidth' , 'bit/s' ] ] #NEWLINE# return result