diff --git a/lib/ansible/modules/network/cloudengine/ce_bfd_global.py b/lib/ansible/modules/network/cloudengine/ce_bfd_global.py
new file mode 100644
index 00000000000..fdb705b6fb5
--- /dev/null
+++ b/lib/ansible/modules/network/cloudengine/ce_bfd_global.py
@@ -0,0 +1,584 @@
+#!/usr/bin/python
+#
+# This file is part of Ansible
+#
+# Ansible is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# Ansible is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with Ansible.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+ANSIBLE_METADATA = {'metadata_version': '1.0',
+                    'status': ['preview'],
+                    'supported_by': 'community'}
+
+DOCUMENTATION = """
+---
+module: ce_bfd_global
+version_added: "2.4"
+short_description: Manages BFD global configuration on HUAWEI CloudEngine devices.
+description:
+    - Manages BFD global configuration on HUAWEI CloudEngine devices.
+author: QijunPan (@CloudEngine-Ansible)
+options:
+    bfd_enable:
+        description:
+            - Enables the global Bidirectional Forwarding Detection (BFD) function.
+        required: false
+        default: null
+        choices: ['enable', 'disable']
+    default_ip:
+        description:
+            - Specifies the default multicast IP address.
+              The value ranges from 224.0.0.107 to 224.0.0.250.
+        required: false
+        default: null
+    tos_exp_dynamic:
+        description:
+            - Indicates the priority of BFD control packets for dynamic BFD sessions.
+              The value is an integer ranging from 0 to 7.
+              The default priority is 7, which is the highest priority of BFD control packets.
+        required: false
+        default: null
+    tos_exp_static:
+        description:
+            - Indicates the priority of BFD control packets for static BFD sessions.
+              The value is an integer ranging from 0 to 7.
+              The default priority is 7, which is the highest priority of BFD control packets.
+        required: false
+        default: null
+    damp_init_wait_time:
+        description:
+            - Specifies an initial flapping suppression time for a BFD session.
+              The value is an integer ranging from 1 to 3600000, in milliseconds.
+              The default value is 2000.
+        required: false
+        default: null
+    damp_max_wait_time:
+        description:
+            - Specifies a maximum flapping suppression time for a BFD session.
+              The value is an integer ranging from 1 to 3600000, in milliseconds.
+              The default value is 15000.
+        required: false
+        default: null
+    damp_second_wait_time:
+        description:
+            - Specifies a secondary flapping suppression time for a BFD session.
+              The value is an integer ranging from 1 to 3600000, in milliseconds.
+              The default value is 5000.
+        required: false
+        default: null
+    delay_up_time:
+        description:
+            - Specifies the delay before a BFD session becomes Up.
+              The value is an integer ranging from 1 to 600, in seconds.
+              The default value is 0, indicating that a BFD session immediately becomes Up.
+        required: false
+        default: null
+    state:
+        description:
+            - Determines whether the config should be present or not on the device.
+        required: false
+        default: present
+        choices: ['present', 'absent']
+"""
+
+EXAMPLES = '''
+- name: bfd global module test
+  hosts: cloudengine
+  connection: local
+  gather_facts: no
+  vars:
+    cli:
+      host: "{{ inventory_hostname }}"
+      port: "{{ ansible_ssh_port }}"
+      username: "{{ username }}"
+      password: "{{ password }}"
+      transport: cli
+
+  tasks:
+  - name: Enable the global BFD function
+    ce_bfd_global:
+      bfd_enable: enable
+      provider: '{{ cli }}'
+
+  - name: Set the default multicast IP address to 224.0.0.150
+    ce_bfd_global:
+      bfd_enable: enable
+      default_ip: 224.0.0.150
+      state: present
+      provider: '{{ cli }}'
+
+  - name: Set the priority of BFD control packets for dynamic and static BFD sessions
+    ce_bfd_global:
+      bfd_enable: enable
+      tos_exp_dynamic: 5
+      tos_exp_static: 6
+      state: present
+      provider: '{{ cli }}'
+
+  - name: Disable the global BFD function
+    ce_bfd_global:
+      bfd_enable: disable
+      provider: '{{ cli }}'
+'''
+
+RETURN = '''
+proposed:
+    description: k/v pairs of parameters passed into module
+    returned: verbose mode
+    type: dict
+    sample: {
+        "bfd_enalbe": "enable",
+        "damp_init_wait_time": null,
+        "damp_max_wait_time": null,
+        "damp_second_wait_time": null,
+        "default_ip": null,
+        "delayUpTimer": null,
+        "state": "present",
+        "tos_exp_dynamic": null,
+        "tos_exp_static": null
+    }
+existing:
+    description: k/v pairs of existing configuration
+    returned: verbose mode
+    type: dict
+    sample: {
+        "global": {
+            "bfdEnable": "false",
+            "dampInitWaitTime": "2000",
+            "dampMaxWaitTime": "12000",
+            "dampSecondWaitTime": "5000",
+            "defaultIp": "224.0.0.184",
+            "delayUpTimer": null,
+            "tosExp": "7",
+            "tosExpStatic": "7"
+        }
+    }
+end_state:
+    description: k/v pairs of configuration after module execution
+    returned: verbose mode
+    type: dict
+    sample: {
+        "global": {
+            "bfdEnable": "true",
+            "dampInitWaitTime": "2000",
+            "dampMaxWaitTime": "12000",
+            "dampSecondWaitTime": "5000",
+            "defaultIp": "224.0.0.184",
+            "delayUpTimer": null,
+            "tosExp": "7",
+            "tosExpStatic": "7"
+        }
+    }
+updates:
+    description: commands sent to the device
+    returned: always
+    type: list
+    sample: [ "bfd" ]
+changed:
+    description: check to see if a change was made on the device
+    returned: always
+    type: boolean
+    sample: true
+'''
+
+import sys
+import socket
+from xml.etree import ElementTree
+from ansible.module_utils.basic import AnsibleModule
+from ansible.module_utils.ce import get_nc_config, set_nc_config, ce_argument_spec
+
+CE_NC_GET_BFD = """
+    <filter type="subtree">
+      <bfd xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
+      %s
+      </bfd>
+    </filter>
+"""
+
+CE_NC_GET_BFD_GLB = """
+        <bfdSchGlobal>
+          <bfdEnable></bfdEnable>
+          <defaultIp></defaultIp>
+          <tosExp></tosExp>
+          <tosExpStatic></tosExpStatic>
+          <dampInitWaitTime></dampInitWaitTime>
+          <dampMaxWaitTime></dampMaxWaitTime>
+          <dampSecondWaitTime></dampSecondWaitTime>
+          <delayUpTimer></delayUpTimer>
+        </bfdSchGlobal>
+"""
+
+
+def check_ip_addr(ipaddr):
+    """check ip address, Supports IPv4 and IPv6"""
+
+    if not ipaddr or '\x00' in ipaddr:
+        return False
+
+    try:
+        res = socket.getaddrinfo(ipaddr, 0, socket.AF_UNSPEC,
+                                 socket.SOCK_STREAM,
+                                 0, socket.AI_NUMERICHOST)
+        return bool(res)
+    except socket.gaierror:
+        err = sys.exc_info()[1]
+        if err.args[0] == socket.EAI_NONAME:
+            return False
+        raise
+
+
+def check_default_ip(ipaddr):
+    """check the default multicast IP address"""
+
+    # The value ranges from 224.0.0.107 to 224.0.0.250
+    if not check_ip_addr(ipaddr):
+        return False
+
+    if ipaddr.count(".") != 3:
+        return False
+
+    ips = ipaddr.split(".")
+    if ips[0] != "224" or ips[1] != "0" or ips[2] != "0":
+        return False
+
+    if not ips[3].isdigit() or int(ips[3]) < 107 or int(ips[3]) > 250:
+        return False
+
+    return True
+
+
+class BfdGlobal(object):
+    """Manages BFD Global"""
+
+    def __init__(self, argument_spec):
+        self.spec = argument_spec
+        self.module = None
+        self.__init_module__()
+
+        # module input info
+        self.bfd_enable = self.module.params['bfd_enable']
+        self.default_ip = self.module.params['default_ip']
+        self.tos_exp_dynamic = self.module.params['tos_exp_dynamic']
+        self.tos_exp_static = self.module.params['tos_exp_static']
+        self.damp_init_wait_time = self.module.params['damp_init_wait_time']
+        self.damp_max_wait_time = self.module.params['damp_max_wait_time']
+        self.damp_second_wait_time = self.module.params['damp_second_wait_time']
+        self.delay_up_time = self.module.params['delay_up_time']
+        self.state = self.module.params['state']
+
+        # host info
+        self.host = self.module.params['host']
+        self.username = self.module.params['username']
+        self.port = self.module.params['port']
+
+        # state
+        self.changed = False
+        self.bfd_dict = dict()
+        self.updates_cmd = list()
+        self.commands = list()
+        self.results = dict()
+        self.proposed = dict()
+        self.existing = dict()
+        self.end_state = dict()
+
+    def __init_module__(self):
+        """init module"""
+
+        required_together = [('damp_init_wait_time', 'damp_max_wait_time', 'damp_second_wait_time')]
+        self.module = AnsibleModule(argument_spec=self.spec,
+                                    required_together=required_together,
+                                    supports_check_mode=True)
+
+    def get_bfd_dict(self):
+        """bfd config dict"""
+
+        bfd_dict = dict()
+        bfd_dict["global"] = dict()
+        conf_str = CE_NC_GET_BFD % CE_NC_GET_BFD_GLB
+
+        xml_str = get_nc_config(self.module, conf_str)
+        if "<data/>" in xml_str:
+            return bfd_dict
+
+        xml_str = xml_str.replace('\r', '').replace('\n', '').\
+            replace('xmlns="urn:ietf:params:xml:ns:netconf:base:1.0"', "").\
+            replace('xmlns="http://www.huawei.com/netconf/vrp"', "")
+        root = ElementTree.fromstring(xml_str)
+
+        # get bfd global info
+        glb = root.find("data/bfd/bfdSchGlobal")
+        if glb:
+            for attr in glb:
+                bfd_dict["global"][attr.tag] = attr.text
+
+        return bfd_dict
+
+    def config_global(self):
+        """configures bfd global params"""
+
+        xml_str = ""
+        damp_chg = False
+
+        # bfd_enable
+        if self.bfd_enable:
+            if bool(self.bfd_dict["global"].get("bfdEnable", "false") == "true") != bool(self.bfd_enable == "enable"):
+                if self.bfd_enable == "enable":
+                    xml_str = "<bfdEnable>true</bfdEnable>"
+                    self.updates_cmd.append("bfd")
+                else:
+                    xml_str = "<bfdEnable>false</bfdEnable>"
+                    self.updates_cmd.append("undo bfd")
+
+        # get bfd end state
+        bfd_state = "disable"
+        if self.bfd_enable:
+            bfd_state = self.bfd_enable
+        elif self.bfd_dict["global"].get("bfdEnable", "false") == "true":
+            bfd_state = "enable"
+
+        # default_ip
+        if self.default_ip:
+            if bfd_state == "enable":
+                if self.state == "present" and self.default_ip != self.bfd_dict["global"].get("defaultIp"):
+                    xml_str += "<defaultIp>%s</defaultIp>" % self.default_ip
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("default-ip-address %s" % self.default_ip)
+                elif self.state == "absent" and self.default_ip == self.bfd_dict["global"].get("defaultIp"):
+                    xml_str += "<defaultIp/>"
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("undo default-ip-address")
+
+        # tos_exp_dynamic
+        if self.tos_exp_dynamic is not None:
+            if bfd_state == "enable":
+                if self.state == "present" and self.tos_exp_dynamic != int(self.bfd_dict["global"].get("tosExp", "7")):
+                    xml_str += "<tosExp>%s</tosExp>" % self.tos_exp_dynamic
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("tos-exp %s dynamic" % self.tos_exp_dynamic)
+                elif self.state == "absent" and self.tos_exp_dynamic == int(self.bfd_dict["global"].get("tosExp", "7")):
+                    xml_str += "<tosExp/>"
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("undo tos-exp dynamic")
+
+        # tos_exp_static
+        if self.tos_exp_static is not None:
+            if bfd_state == "enable":
+                if self.state == "present" \
+                        and self.tos_exp_static != int(self.bfd_dict["global"].get("tosExpStatic", "7")):
+                    xml_str += "<tosExpStatic>%s</tosExpStatic>" % self.tos_exp_static
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("tos-exp %s static" % self.tos_exp_static)
+                elif self.state == "absent" \
+                        and self.tos_exp_static == int(self.bfd_dict["global"].get("tosExpStatic", "7")):
+                    xml_str += "<tosExpStatic/>"
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("undo tos-exp static")
+
+        # delay_up_time
+        if self.delay_up_time is not None:
+            if bfd_state == "enable":
+                delay_time = self.bfd_dict["global"].get("delayUpTimer", "0")
+                if not delay_time or not delay_time.isdigit():
+                    delay_time = "0"
+                if self.state == "present" \
+                        and self.delay_up_time != int(delay_time):
+                    xml_str += "<delayUpTimer>%s</delayUpTimer>" % self.delay_up_time
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("delay-up %s" % self.delay_up_time)
+                elif self.state == "absent" \
+                        and self.delay_up_time == int(delay_time):
+                    xml_str += "<delayUpTimer/>"
+                    if "bfd" not in self.updates_cmd:
+                        self.updates_cmd.append("bfd")
+                    self.updates_cmd.append("undo delay-up")
+
+        # damp_init_wait_time damp_max_wait_time damp_second_wait_time
+        if self.damp_init_wait_time is not None and self.damp_second_wait_time is not None \
+                and self.damp_second_wait_time is not None:
+            if bfd_state == "enable":
+                if self.state == "present":
+                    if self.damp_max_wait_time != int(self.bfd_dict["global"].get("dampMaxWaitTime", "2000")):
+                        xml_str += "<dampMaxWaitTime>%s</dampMaxWaitTime>" % self.damp_max_wait_time
+                        damp_chg = True
+                    if self.damp_init_wait_time != int(self.bfd_dict["global"].get("dampInitWaitTime", "12000")):
+                        xml_str += "<dampInitWaitTime>%s</dampInitWaitTime>" % self.damp_init_wait_time
+                        damp_chg = True
+                    if self.damp_second_wait_time != int(self.bfd_dict["global"].get("dampSecondWaitTime", "5000")):
+                        xml_str += "<dampSecondWaitTime>%s</dampSecondWaitTime>" % self.damp_second_wait_time
+                        damp_chg = True
+                    if damp_chg:
+                        if "bfd" not in self.updates_cmd:
+                            self.updates_cmd.append("bfd")
+                        self.updates_cmd.append("dampening timer-interval maximum %s initial %s secondary %s" % (
+                            self.damp_max_wait_time, self.damp_init_wait_time, self.damp_second_wait_time))
+                else:
+                    damp_chg = True
+                    if self.damp_max_wait_time != int(self.bfd_dict["global"].get("dampMaxWaitTime", "2000")):
+                        damp_chg = False
+                    if self.damp_init_wait_time != int(self.bfd_dict["global"].get("dampInitWaitTime", "12000")):
+                        damp_chg = False
+                    if self.damp_second_wait_time != int(self.bfd_dict["global"].get("dampSecondWaitTime", "5000")):
+                        damp_chg = False
+
+                    if damp_chg:
+                        xml_str += "<dampMaxWaitTime/><dampInitWaitTime/><dampSecondWaitTime/>"
+                        if "bfd" not in self.updates_cmd:
+                            self.updates_cmd.append("bfd")
+                        self.updates_cmd.append("undo dampening timer-interval maximum %s initial %s secondary %s" % (
+                            self.damp_max_wait_time, self.damp_init_wait_time, self.damp_second_wait_time))
+        if xml_str:
+            return '<bfdSchGlobal operation="merge">' + xml_str + '</bfdSchGlobal>'
+        else:
+            return ""
+
+    def netconf_load_config(self, xml_str):
+        """load bfd config by netconf"""
+
+        if not xml_str:
+            return
+
+        xml_cfg = """
+            <config>
+            <bfd xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
+            %s
+            </bfd>
+            </config>""" % xml_str
+        set_nc_config(self.module, xml_cfg)
+        self.changed = True
+
+    def check_params(self):
+        """Check all input params"""
+
+        # check default_ip
+        if self.default_ip:
+            if not check_default_ip(self.default_ip):
+                self.module.fail_json(msg="Error: Default ip is invalid.")
+
+        # check tos_exp_dynamic
+        if self.tos_exp_dynamic is not None:
+            if self.tos_exp_dynamic < 0 or self.tos_exp_dynamic > 7:
+                self.module.fail_json(msg="Error: Session tos_exp_dynamic is not ranges from 0 to 7.")
+
+        # check tos_exp_static
+        if self.tos_exp_static is not None:
+            if self.tos_exp_static < 0 or self.tos_exp_static > 7:
+                self.module.fail_json(msg="Error: Session tos_exp_static is not ranges from 0 to 7.")
+
+        # check damp_init_wait_time
+        if self.damp_init_wait_time is not None:
+            if self.damp_init_wait_time < 1 or self.damp_init_wait_time > 3600000:
+                self.module.fail_json(msg="Error: Session damp_init_wait_time is not ranges from 1 to 3600000.")
+
+        # check damp_max_wait_time
+        if self.damp_max_wait_time is not None:
+            if self.damp_max_wait_time < 1 or self.damp_max_wait_time > 3600000:
+                self.module.fail_json(msg="Error: Session damp_max_wait_time is not ranges from 1 to 3600000.")
+
+        # check damp_second_wait_time
+        if self.damp_second_wait_time is not None:
+            if self.damp_second_wait_time < 1 or self.damp_second_wait_time > 3600000:
+                self.module.fail_json(msg="Error: Session damp_second_wait_time is not ranges from 1 to 3600000.")
+
+        # check delay_up_time
+        if self.delay_up_time is not None:
+            if self.delay_up_time < 1 or self.delay_up_time > 600:
+                self.module.fail_json(msg="Error: Session delay_up_time is not ranges from 1 to 600.")
+
+    def get_proposed(self):
+        """get proposed info"""
+
+        self.proposed["bfd_enalbe"] = self.bfd_enable
+        self.proposed["default_ip"] = self.default_ip
+        self.proposed["tos_exp_dynamic"] = self.tos_exp_dynamic
+        self.proposed["tos_exp_static"] = self.tos_exp_static
+        self.proposed["damp_init_wait_time"] = self.damp_init_wait_time
+        self.proposed["damp_max_wait_time"] = self.damp_max_wait_time
+        self.proposed["damp_second_wait_time"] = self.damp_second_wait_time
+        self.proposed["delay_up_time"] = self.delay_up_time
+        self.proposed["state"] = self.state
+
+    def get_existing(self):
+        """get existing info"""
+
+        if not self.bfd_dict:
+            return
+
+        self.existing["global"] = self.bfd_dict.get("global")
+
+    def get_end_state(self):
+        """get end state info"""
+
+        bfd_dict = self.get_bfd_dict()
+        if not bfd_dict:
+            return
+
+        self.end_state["global"] = bfd_dict.get("global")
+
+    def work(self):
+        """worker"""
+
+        self.check_params()
+        self.bfd_dict = self.get_bfd_dict()
+        self.get_existing()
+        self.get_proposed()
+
+        # deal present or absent
+        xml_str = self.config_global()
+
+        # update to device
+        if xml_str:
+            self.netconf_load_config(xml_str)
+            self.changed = True
+
+        self.get_end_state()
+        self.results['changed'] = self.changed
+        self.results['proposed'] = self.proposed
+        self.results['existing'] = self.existing
+        self.results['end_state'] = self.end_state
+        if self.changed:
+            self.results['updates'] = self.updates_cmd
+        else:
+            self.results['updates'] = list()
+
+        self.module.exit_json(**self.results)
+
+
+def main():
+    """Module main"""
+
+    argument_spec = dict(
+        bfd_enable=dict(required=False, type='str', choices=['enable', 'disable']),
+        default_ip=dict(required=False, type='str'),
+        tos_exp_dynamic=dict(required=False, type='int'),
+        tos_exp_static=dict(required=False, type='int'),
+        damp_init_wait_time=dict(required=False, type='int'),
+        damp_max_wait_time=dict(required=False, type='int'),
+        damp_second_wait_time=dict(required=False, type='int'),
+        delay_up_time=dict(required=False, type='int'),
+        state=dict(required=False, default='present', choices=['present', 'absent'])
+    )
+
+    argument_spec.update(ce_argument_spec)
+    module = BfdGlobal(argument_spec)
+    module.work()
+
+
+if __name__ == '__main__':
+    main()