def process_bulk_vm_event(self, msg, phy_uplink):
LOG.info("<STR_LIT>", msg)<EOL>time.sleep(<NUM_LIT:3>)<EOL>if (not self.uplink_det_compl or<EOL>phy_uplink not in self.ovs_vdp_obj_dict):<EOL><INDENT>LOG.error("<STR_LIT>"<EOL>"<STR_LIT>")<EOL>return<EOL><DEDENT>ovs_vdp_obj = self.ovs_vdp_obj_dict[phy_uplink]<EOL>for vm_dict in msg.msg_dict.get('<STR_LIT>'):<EOL><INDENT>if vm_dict['<STR_LIT:status>'] == '<STR_LIT>':<EOL><INDENT>ovs_vdp_obj.pop_local_cache(vm_dict['<STR_LIT>'],<EOL>vm_dict['<STR_LIT>'],<EOL>vm_dict['<STR_LIT>'],<EOL>vm_dict['<STR_LIT>'],<EOL>vm_dict['<STR_LIT>'],<EOL>vm_dict['<STR_LIT>'])<EOL><DEDENT>vm_msg = VdpQueMsg(constants.VM_MSG_TYPE,<EOL>port_uuid=vm_dict['<STR_LIT>'],<EOL>vm_mac=vm_dict['<STR_LIT>'],<EOL>net_uuid=vm_dict['<STR_LIT>'],<EOL>segmentation_id=vm_dict['<STR_LIT>'],<EOL>status=vm_dict['<STR_LIT:status>'],<EOL>oui=vm_dict['<STR_LIT>'],<EOL>phy_uplink=phy_uplink)<EOL>self.process_vm_event(vm_msg, phy_uplink)<EOL><DEDENT>
Process the VM bulk event usually after a restart.