#NEWLINE# def _test_get_throughput( self ) : #NEWLINE# #INDENT# xid = self . tester_sw . send_flow_stats ( ) #NEWLINE# self . send_msg_xids . append ( xid ) #NEWLINE# self . _wait ( ) #NEWLINE# assert ( len ( self . rcv_msgs ) == 1 ) #NEWLINE# flow_stats = self . rcv_msgs [ 0 ] . body #NEWLINE# self . logger . debug ( flow_stats ) #NEWLINE# result = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# for stat in flow_stats : #NEWLINE# #INDENT# if ( stat . cookie != THROUGHPUT_COOKIE ) : #NEWLINE# #INDENT# continue #NEWLINE# #UNINDENT# result [ str ( stat . match ) ] = ( stat . byte_count , stat . packet_count ) #NEWLINE# #UNINDENT# return ( time . time ( ) , result )