mirror of
https://github.com/linux-system-roles/network.git
synced 2026-07-19 01:17:00 +00:00
19139286ed
Refactor the volatilize action of nm provider: * Move code to `module_utils/network_lsr/nm` * The `module_utils/network_lsr/nm` only volatilize profile by given UUID instead of guess. The `library/network_connections.py` is responsible on choosing UUID. Signed-off-by: Gris Ge <fge@redhat.com>
113 lines
3.4 KiB
Python
113 lines
3.4 KiB
Python
# SPDX-License-Identifier: BSD-3-Clause
|
|
|
|
# Handle NM.RemoteConnection
|
|
|
|
import logging
|
|
|
|
# Relative import is not support by ansible 2.8 yet
|
|
# pylint: disable=import-error, no-name-in-module
|
|
from ansible.module_utils.network_lsr.nm import client # noqa:E501
|
|
from ansible.module_utils.network_lsr.nm import error # noqa:E501
|
|
|
|
# pylint: enable=import-error, no-name-in-module
|
|
|
|
|
|
def delete_remote_connection(nm_profile, timeout, check_mode):
|
|
if not nm_profile:
|
|
logging.info("NULL NM.RemoteConnection, no need to delete")
|
|
return False
|
|
|
|
if not check_mode:
|
|
main_loop = client.get_mainloop(timeout)
|
|
user_data = main_loop
|
|
nm_profile.delete_async(
|
|
main_loop.cancellable,
|
|
_nm_profile_delete_call_back,
|
|
user_data,
|
|
)
|
|
logging.debug(
|
|
"Deleting profile {id}/{uuid} with timeout {timeout}".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid(), timeout=timeout
|
|
)
|
|
)
|
|
main_loop.run()
|
|
return True
|
|
|
|
|
|
def _nm_profile_delete_call_back(nm_profile, result, user_data):
|
|
main_loop = user_data
|
|
if main_loop.is_cancelled:
|
|
return
|
|
|
|
try:
|
|
success = nm_profile.delete_finish(result)
|
|
except Exception as e:
|
|
main_loop.fail(
|
|
error.LsrNetworkNmError(
|
|
"Connection deletion aborted on {id}/{uuid}: error={error}".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid(), error=e
|
|
)
|
|
)
|
|
)
|
|
if success:
|
|
main_loop.quit()
|
|
else:
|
|
main_loop.fail(
|
|
error.LsrNetworkNmError(
|
|
"Connection deletion aborted on {id}/{uuid}: error=unknown".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid()
|
|
)
|
|
)
|
|
)
|
|
|
|
|
|
def volatilize_remote_connection(nm_profile, timeout, check_mode):
|
|
if not nm_profile:
|
|
logging.info("NULL NM.RemoteConnection, no need to volatilize")
|
|
return False
|
|
if not check_mode:
|
|
main_loop = client.get_mainloop(timeout)
|
|
user_data = main_loop
|
|
nm_profile.update2(
|
|
None, # settings
|
|
client.NM.SettingsUpdate2Flags.IN_MEMORY_ONLY
|
|
| client.NM.SettingsUpdate2Flags.VOLATILE,
|
|
None, # args
|
|
main_loop.cancellable,
|
|
_nm_profile_volatile_update2_call_back,
|
|
user_data,
|
|
)
|
|
logging.debug(
|
|
"Volatilizing profile {id}/{uuid} with timeout {timeout}".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid(), timeout=timeout
|
|
)
|
|
)
|
|
main_loop.run()
|
|
return True
|
|
|
|
|
|
def _nm_profile_volatile_update2_call_back(nm_profile, result, user_data):
|
|
main_loop = user_data
|
|
if main_loop.is_cancelled:
|
|
return
|
|
|
|
try:
|
|
success = nm_profile.update2_finish(result)
|
|
except Exception as e:
|
|
main_loop.fail(
|
|
error.LsrNetworkNmError(
|
|
"Connection volatilize aborted on {id}/{uuid}: error={error}".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid(), error=e
|
|
)
|
|
)
|
|
)
|
|
if success:
|
|
main_loop.quit()
|
|
else:
|
|
main_loop.fail(
|
|
error.LsrNetworkNmError(
|
|
"Connection volatilize aborted on {id}/{uuid}: error=unknown".format(
|
|
id=nm_profile.get_id(), uuid=nm_profile.get_uuid()
|
|
)
|
|
)
|
|
)
|