#NEWLINE# @ set_ev_cls ( ofp_event . EventOFPBarrierReply , handler . MAIN_DISPATCHER ) #NEWLINE# def barrier_reply_handler( self , ev ) : #NEWLINE# #INDENT# state_list = [ STATE_INIT_FLOW , STATE_INIT_THROUGHPUT_FLOW , STATE_INIT_METER , STATE_INIT_GROUP , STATE_FLOW_INSTALL , STATE_THROUGHPUT_FLOW_INSTALL , STATE_METER_INSTALL , STATE_GROUP_INSTALL , STATE_SEND_BARRIER ] #NEWLINE# if ( self . state in state_list ) : #NEWLINE# #INDENT# if ( self . waiter and ( ev . msg . xid in self . send_msg_xids ) ) : #NEWLINE# #INDENT# self . rcv_msgs . append ( ev . msg ) #NEWLINE# self . waiter . set ( ) #NEWLINE# hub . sleep ( 0 )