|
 |
be9751 |
From 1fef5649ce05a17a741789cafb65269c099b396b Mon Sep 17 00:00:00 2001
|
|
|
be9751 |
From: progier389 <72748589+progier389@users.noreply.github.com>
|
|
|
be9751 |
Date: Wed, 16 Dec 2020 16:21:35 +0100
|
|
|
be9751 |
Subject: [PATCH 2/3] Issue #4504 - Fix pytest test_dsconf_replication_monitor
|
|
|
be9751 |
(#4505)
|
|
|
be9751 |
|
|
|
be9751 |
(cherry picked from commit 0b08e6f35b000d1383580be59f902ac813e940f2)
|
|
|
be9751 |
---
|
|
|
be9751 |
.../tests/suites/clu/repl_monitor_test.py | 50 +++++++++++++------
|
|
|
be9751 |
1 file changed, 36 insertions(+), 14 deletions(-)
|
|
|
be9751 |
|
|
|
be9751 |
diff --git a/dirsrvtests/tests/suites/clu/repl_monitor_test.py b/dirsrvtests/tests/suites/clu/repl_monitor_test.py
|
|
|
be9751 |
index b03d170c8..eb18d2da2 100644
|
|
|
be9751 |
--- a/dirsrvtests/tests/suites/clu/repl_monitor_test.py
|
|
|
be9751 |
+++ b/dirsrvtests/tests/suites/clu/repl_monitor_test.py
|
|
|
be9751 |
@@ -9,6 +9,7 @@
|
|
|
be9751 |
import time
|
|
|
be9751 |
import subprocess
|
|
|
be9751 |
import pytest
|
|
|
be9751 |
+import re
|
|
|
be9751 |
|
|
|
be9751 |
from lib389.cli_conf.replication import get_repl_monitor_info
|
|
|
be9751 |
from lib389.tasks import *
|
|
|
be9751 |
@@ -67,6 +68,25 @@ def check_value_in_log_and_reset(content_list, second_list=None, single_value=No
|
|
|
be9751 |
log.info('Reset log file')
|
|
|
be9751 |
f.truncate(0)
|
|
|
be9751 |
|
|
|
be9751 |
+def get_hostnames_from_log(port1, port2):
|
|
|
be9751 |
+ # Get the supplier host names as displayed in replication monitor output
|
|
|
be9751 |
+ with open(LOG_FILE, 'r') as logfile:
|
|
|
be9751 |
+ logtext = logfile.read()
|
|
|
be9751 |
+ # search for Supplier :hostname:port
|
|
|
be9751 |
+ # and use \D to insure there is no more number is after
|
|
|
be9751 |
+ # the matched port (i.e that 10 is not matching 101)
|
|
|
be9751 |
+ regexp = '(Supplier: )([^:]*)(:' + str(port1) + '\D)'
|
|
|
be9751 |
+ match=re.search(regexp, logtext)
|
|
|
be9751 |
+ host_m1 = 'localhost.localdomain'
|
|
|
be9751 |
+ if (match is not None):
|
|
|
be9751 |
+ host_m1 = match.group(2)
|
|
|
be9751 |
+ # Same for master 2
|
|
|
be9751 |
+ regexp = '(Supplier: )([^:]*)(:' + str(port2) + '\D)'
|
|
|
be9751 |
+ match=re.search(regexp, logtext)
|
|
|
be9751 |
+ host_m2 = 'localhost.localdomain'
|
|
|
be9751 |
+ if (match is not None):
|
|
|
be9751 |
+ host_m2 = match.group(2)
|
|
|
be9751 |
+ return (host_m1, host_m2)
|
|
|
be9751 |
|
|
|
be9751 |
@pytest.mark.ds50545
|
|
|
be9751 |
@pytest.mark.bz1739718
|
|
|
be9751 |
@@ -95,9 +115,6 @@ def test_dsconf_replication_monitor(topology_m2, set_log_file):
|
|
|
be9751 |
m1 = topology_m2.ms["master1"]
|
|
|
be9751 |
m2 = topology_m2.ms["master2"]
|
|
|
be9751 |
|
|
|
be9751 |
- alias_content = ['Supplier: M1 (' + m1.host + ':' + str(m1.port) + ')',
|
|
|
be9751 |
- 'Supplier: M2 (' + m2.host + ':' + str(m2.port) + ')']
|
|
|
be9751 |
-
|
|
|
be9751 |
connection_content = 'Supplier: '+ m1.host + ':' + str(m1.port)
|
|
|
be9751 |
content_list = ['Replica Root: dc=example,dc=com',
|
|
|
be9751 |
'Replica ID: 1',
|
|
|
be9751 |
@@ -160,20 +177,9 @@ def test_dsconf_replication_monitor(topology_m2, set_log_file):
|
|
|
be9751 |
'001',
|
|
|
be9751 |
m1.host + ':' + str(m1.port)]
|
|
|
be9751 |
|
|
|
be9751 |
- dsrc_content = '[repl-monitor-connections]\n' \
|
|
|
be9751 |
- 'connection1 = ' + m1.host + ':' + str(m1.port) + ':' + DN_DM + ':' + PW_DM + '\n' \
|
|
|
be9751 |
- 'connection2 = ' + m2.host + ':' + str(m2.port) + ':' + DN_DM + ':' + PW_DM + '\n' \
|
|
|
be9751 |
- '\n' \
|
|
|
be9751 |
- '[repl-monitor-aliases]\n' \
|
|
|
be9751 |
- 'M1 = ' + m1.host + ':' + str(m1.port) + '\n' \
|
|
|
be9751 |
- 'M2 = ' + m2.host + ':' + str(m2.port)
|
|
|
be9751 |
-
|
|
|
be9751 |
connections = [m1.host + ':' + str(m1.port) + ':' + DN_DM + ':' + PW_DM,
|
|
|
be9751 |
m2.host + ':' + str(m2.port) + ':' + DN_DM + ':' + PW_DM]
|
|
|
be9751 |
|
|
|
be9751 |
- aliases = ['M1=' + m1.host + ':' + str(m1.port),
|
|
|
be9751 |
- 'M2=' + m2.host + ':' + str(m2.port)]
|
|
|
be9751 |
-
|
|
|
be9751 |
args = FakeArgs()
|
|
|
be9751 |
args.connections = connections
|
|
|
be9751 |
args.aliases = None
|
|
|
be9751 |
@@ -181,8 +187,24 @@ def test_dsconf_replication_monitor(topology_m2, set_log_file):
|
|
|
be9751 |
|
|
|
be9751 |
log.info('Run replication monitor with connections option')
|
|
|
be9751 |
get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)
|
|
|
be9751 |
+ (host_m1, host_m2) = get_hostnames_from_log(m1.port, m2.port)
|
|
|
be9751 |
check_value_in_log_and_reset(content_list, connection_content, error_list=error_list)
|
|
|
be9751 |
|
|
|
be9751 |
+ # Prepare the data for next tests
|
|
|
be9751 |
+ aliases = ['M1=' + host_m1 + ':' + str(m1.port),
|
|
|
be9751 |
+ 'M2=' + host_m2 + ':' + str(m2.port)]
|
|
|
be9751 |
+
|
|
|
be9751 |
+ alias_content = ['Supplier: M1 (' + host_m1 + ':' + str(m1.port) + ')',
|
|
|
be9751 |
+ 'Supplier: M2 (' + host_m2 + ':' + str(m2.port) + ')']
|
|
|
be9751 |
+
|
|
|
be9751 |
+ dsrc_content = '[repl-monitor-connections]\n' \
|
|
|
be9751 |
+ 'connection1 = ' + m1.host + ':' + str(m1.port) + ':' + DN_DM + ':' + PW_DM + '\n' \
|
|
|
be9751 |
+ 'connection2 = ' + m2.host + ':' + str(m2.port) + ':' + DN_DM + ':' + PW_DM + '\n' \
|
|
|
be9751 |
+ '\n' \
|
|
|
be9751 |
+ '[repl-monitor-aliases]\n' \
|
|
|
be9751 |
+ 'M1 = ' + host_m1 + ':' + str(m1.port) + '\n' \
|
|
|
be9751 |
+ 'M2 = ' + host_m2 + ':' + str(m2.port)
|
|
|
be9751 |
+
|
|
|
be9751 |
log.info('Run replication monitor with aliases option')
|
|
|
be9751 |
args.aliases = aliases
|
|
|
be9751 |
get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)
|
|
|
be9751 |
--
|
|
|
be9751 |
2.26.2
|
|
|
be9751 |
|