#NEWLINE# def _test_msg_install( self , datapath , message ) : #NEWLINE# #INDENT# xid = datapath . send_msg ( message ) #NEWLINE# self . send_msg_xids . append ( xid ) #NEWLINE# xid = datapath . send_barrier_request ( ) #NEWLINE# self . send_msg_xids . append ( xid ) #NEWLINE# self . _wait ( ) #NEWLINE# assert ( len ( message . rcv_msgs ) == 1 ) #NEWLINE# msg = self . rcv_msgs [ 0 ] #NEWLINE# assert isinstance ( msg , datapath . dp . ofproto_parser . OFPBarrierReply )