This is an automated email from the git hooks/post-receive script.
spichugi pushed a commit to branch master
in repository 389-ds-base.
commit e1dca085cd1ba546c42baf394329f0f6ca491db6
Author: Sankar Ramalingam <sramling@redhat.com>
Date: Thu Jun 8 20:36:59 2017 +0530
Ticket #48944 - Add CI test case
Description: Added test cases to check if read only replica accumulates
invalid state info in DS error logs.
https://pagure.io/389-ds-base/issue/48944
Reviewed by: spichugi
Signed-off-by: Simon Pichugin <spichugi@redhat.com>
---
dirsrvtests/tests/tickets/ticket48944_test.py | 205 ++++++++++++++++++++++++++
1 file changed, 205 insertions(+)
diff --git a/dirsrvtests/tests/tickets/ticket48944_test.py b/dirsrvtests/tests/tickets/ticket48944_test.py
new file mode 100644
index 0000000..417508c
--- /dev/null
+++ b/dirsrvtests/tests/tickets/ticket48944_test.py
@@ -0,0 +1,205 @@
+# --- BEGIN COPYRIGHT BLOCK ---
+# Copyright (C) 2017 Red Hat, Inc.
+# All rights reserved.
+#
+# License: GPL (version 3 or any later version).
+# See LICENSE for details.
+# --- END COPYRIGHT BLOCK ---
+#
+import pytest
+from lib389.tasks import *
+from lib389.utils import *
+from lib389.topologies import topology_m2c2 as topo
+
+DEBUGGING = os.getenv("DEBUGGING", default=False)
+if DEBUGGING:
+ logging.getLogger(__name__).setLevel(logging.DEBUG)
+else:
+ logging.getLogger(__name__).setLevel(logging.INFO)
+log = logging.getLogger(__name__)
+
+ACCPOL_DN = "cn={},{}".format(PLUGIN_ACCT_POLICY, DN_PLUGIN)
+ACCP_CONF = "{},{}".format(DN_CONFIG, ACCPOL_DN)
+USER_PW = 'Secret123'
+
+
+def _last_login_time(topo, userdn, inst_name, last_login):
+ """Find lastLoginTime attribute value for a given master/consumer"""
+
+ if 'master' in inst_name:
+ if (last_login == 'bind_n_check'):
+ topo.ms[inst_name].simple_bind_s(userdn, USER_PW)
+ topo.ms[inst_name].simple_bind_s(DN_DM, PASSWORD)
+ entry = topo.ms[inst_name].search_s(userdn, ldap.SCOPE_BASE, 'objectClass=*', ['lastLoginTime'])
+ else:
+ if (last_login == 'bind_n_check'):
+ topo.cs[inst_name].simple_bind_s(userdn, USER_PW)
+ topo.cs[inst_name].simple_bind_s(DN_DM, PASSWORD)
+ entry = topo.cs[inst_name].search_s(userdn, ldap.SCOPE_BASE, 'objectClass=*', ['lastLoginTime'])
+ lastLogin = entry[0].lastLoginTime
+ return lastLogin
+
+
+def _enable_plugin(topo, inst_name):
+ """Enable account policy plugin and configure required attributes"""
+
+ log.info('Enable account policy plugin and configure required attributes')
+ if 'master' in inst_name:
+ log.info('Configure Account policy plugin on {}'.format(inst_name))
+ topo.ms[inst_name].simple_bind_s(DN_DM, PASSWORD)
+ try:
+ topo.ms[inst_name].plugins.enable(name=PLUGIN_ACCT_POLICY)
+ topo.ms[inst_name].modify_s(ACCPOL_DN, [(ldap.MOD_REPLACE, 'nsslapd-pluginarg0', ACCP_CONF)])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'alwaysrecordlogin', 'yes')])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'stateattrname', 'lastLoginTime')])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'altstateattrname', 'createTimestamp')])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'specattrname', 'acctPolicySubentry')])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'limitattrname', 'accountInactivityLimit')])
+ topo.ms[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'accountInactivityLimit', '3600')])
+ except ldap.LDAPError as e:
+ log.error('Failed to configure {} plugin for inst-{}'.format(PLUGIN_ACCT_POLICY, inst_name))
+ topo.ms[inst_name].restart(timeout=10)
+ else:
+ log.info('Configure Account policy plugin on {}'.format(inst_name))
+ topo.cs[inst_name].simple_bind_s(DN_DM, PASSWORD)
+ try:
+ topo.cs[inst_name].plugins.enable(name=PLUGIN_ACCT_POLICY)
+ topo.cs[inst_name].modify_s(ACCPOL_DN, [(ldap.MOD_REPLACE, 'nsslapd-pluginarg0', ACCP_CONF)])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'alwaysrecordlogin', 'yes')])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'stateattrname', 'lastLoginTime')])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'altstateattrname', 'createTimestamp')])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'specattrname', 'acctPolicySubentry')])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'limitattrname', 'accountInactivityLimit')])
+ topo.cs[inst_name].modify_s(ACCP_CONF, [(ldap.MOD_REPLACE, 'accountInactivityLimit', '3600')])
+ except ldap.LDAPError as e:
+ log.error('Failed to configure {} plugin for inst-{}'.format(PLUGIN_ACCT_POLICY, inst_name))
+ topo.cs[inst_name].restart(timeout=10)
+
+
+def test_ticket48944(topo):
+ """On a read only replica invalid state info can accumulate
+
+ :ID: 833be131-f3bf-493e-97c6-3121438a07b1
+ :feature: Account Policy Plugin
+ :setup: Two master and two consumer setup
+ :steps: 1. Configure Account policy plugin with alwaysrecordlogin set to yes
+ 2. Check if entries are synced across masters and consumers
+ 3. Stop all masters and consumers
+ 4. Start master1 and bind as user1 to create lastLoginTime attribute
+ 5. Start master2 and wait for the sync of lastLoginTime attribute
+ 6. Stop master1 and bind as user1 from master2
+ 7. Check if lastLoginTime attribute is updated and greater than master1
+ 8. Stop master2, start consumer1, consumer2 and then master2
+ 9. Check if lastLoginTime attribute is updated on both consumers
+ 10. Bind as user1 to both consumers and check the value is updated
+ 11. Check if lastLoginTime attribute is not updated from consumers
+ 12. Start master1 and make sure the lastLoginTime attribute is not updated on consumers
+ 13. Bind as user1 from master1 and check if all masters and consumers have the same value
+ 14. Check error logs of consumers for "deletedattribute;deleted" message
+ :expectedresults: No accumulation of replica invalid state info on consumers
+ """
+
+ log.info("Ticket 48944 - On a read only replica invalid state info can accumulate")
+ user_name = 'newbzusr'
+ tuserdn = 'uid={}1,ou=people,{}'.format(user_name, SUFFIX)
+ inst_list = ['master1', 'master2', 'consumer1', 'consumer2']
+ for inst_name in inst_list:
+ _enable_plugin(topo, inst_name)
+
+ log.info('Sleep for 10secs for the server to come up')
+ time.sleep(10)
+ log.info('Add few entries to server and check if entries are replicated')
+ for nos in range(10):
+ userdn = 'uid={}{},ou=people,{}'.format(user_name, nos, SUFFIX)
+ try:
+ topo.ms['master1'].add_s(Entry((userdn, {
+ 'objectclass': 'top person'.split(),
+ 'objectclass': 'inetorgperson',
+ 'cn': user_name,
+ 'sn': user_name,
+ 'userpassword': USER_PW,
+ 'mail': '{}@redhat.com'.format(user_name)})))
+ except ldap.LDAPError as e:
+ log.error('Failed to add {} user: error {}'.format(userdn, e.message['desc']))
+ raise e
+
+ log.info('Checking if entries are synced across masters and consumers')
+ entries_m1 = topo.ms['master1'].search_s(SUFFIX, ldap.SCOPE_SUBTREE, 'uid={}*'.format(user_name), ['uid=*'])
+ exp_entries = str(entries_m1).count('dn: uid={}*'.format(user_name))
+ entries_m2 = topo.ms['master2'].search_s(SUFFIX, ldap.SCOPE_SUBTREE, 'uid={}*'.format(user_name), ['uid=*'])
+ act_entries = str(entries_m2).count('dn: uid={}*'.format(user_name))
+ assert act_entries == exp_entries
+ inst_list = ['consumer1', 'consumer2']
+ for inst in inst_list:
+ entries_other = topo.cs[inst].search_s(SUFFIX, ldap.SCOPE_SUBTREE, 'uid={}*'.format(user_name), ['uid=*'])
+ act_entries = str(entries_other).count('dn: uid={}*'.format(user_name))
+ assert act_entries == exp_entries
+
+ topo.ms['master2'].stop(timeout=10)
+ topo.ms['master1'].stop(timeout=10)
+ topo.cs['consumer1'].stop(timeout=10)
+ topo.cs['consumer2'].stop(timeout=10)
+
+ topo.ms['master1'].start(timeout=10)
+ lastLogin_m1_1 = _last_login_time(topo, tuserdn, 'master1', 'bind_n_check')
+
+ log.info('Start master2 to sync lastLoginTime attribute from master1')
+ topo.ms['master2'].start(timeout=10)
+ time.sleep(5)
+ log.info('Stop master1')
+ topo.ms['master1'].stop(timeout=10)
+ log.info('Bind as user1 to master2 and check if lastLoginTime attribute is greater than master1')
+ lastLogin_m2_1 = _last_login_time(topo, tuserdn, 'master2', 'bind_n_check')
+ assert lastLogin_m2_1 > lastLogin_m1_1
+
+ log.info('Start all servers except master1')
+ topo.ms['master2'].stop(timeout=10)
+ topo.cs['consumer1'].start(timeout=10)
+ topo.cs['consumer2'].start(timeout=10)
+ topo.ms['master2'].start(timeout=10)
+ time.sleep(5)
+ log.info('Check if consumers are updated with lastLoginTime attribute value from master2')
+ lastLogin_c1_1 = _last_login_time(topo, tuserdn, 'consumer1', 'check')
+ assert lastLogin_c1_1 == lastLogin_m2_1
+
+ lastLogin_c2_1 = _last_login_time(topo, tuserdn, 'consumer2', 'check')
+ assert lastLogin_c2_1 == lastLogin_m2_1
+
+ log.info('Check if lastLoginTime update in consumers not synced to master2')
+ lastLogin_c1_2 = _last_login_time(topo, tuserdn, 'consumer1', 'bind_n_check')
+ assert lastLogin_c1_2 > lastLogin_m2_1
+
+ lastLogin_c2_2 = _last_login_time(topo, tuserdn, 'consumer2', 'bind_n_check')
+ assert lastLogin_c2_2 > lastLogin_m2_1
+
+ time.sleep(2)
+ lastLogin_m2_2 = _last_login_time(topo, tuserdn, 'master2', 'check')
+ assert lastLogin_m2_2 == lastLogin_m2_1
+
+ log.info('Start master1 and check if its updating its older lastLoginTime attribute to consumers')
+ topo.ms['master1'].start(timeout=10)
+ time.sleep(10)
+ lastLogin_c1_3 = _last_login_time(topo, tuserdn, 'consumer1', 'check')
+ assert lastLogin_c1_3 == lastLogin_c1_2
+
+ lastLogin_c2_3 = _last_login_time(topo, tuserdn, 'consumer2', 'check')
+ assert lastLogin_c2_3 == lastLogin_c2_2
+
+ log.info('Check if lastLoginTime update from master2 is synced to all masters and consumers')
+ lastLogin_m2_3 = _last_login_time(topo, tuserdn, 'master2', 'bind_n_check')
+ time.sleep(2)
+ lastLogin_m1_2 = _last_login_time(topo, tuserdn, 'master1', 'check')
+ lastLogin_c1_4 = _last_login_time(topo, tuserdn, 'consumer1', 'check')
+ lastLogin_c2_4 = _last_login_time(topo, tuserdn, 'consumer2', 'check')
+ assert lastLogin_m2_3 == lastLogin_m1_2 == lastLogin_c2_4 == lastLogin_c1_4
+
+ log.info('Checking consumer error logs for replica invalid state info')
+ assert not topo.cs['consumer2'].ds_error_log.match('.*deletedattribute;deleted.*')
+ assert not topo.cs['consumer1'].ds_error_log.match('.*deletedattribute;deleted.*')
+
+
+if __name__ == '__main__':
+ # Run isolated
+ # -s for DEBUG mode
+ CURRENT_FILE = os.path.realpath(__file__)
+ pytest.main("-s %s" % CURRENT_FILE)
--
To stop receiving notification emails like this one, please contact
the administrator of this repository.
_______________________________________________
389-commits mailing list -- 389-commits@lists.fedoraproject.org
To unsubscribe send an email to 389-commits-leave@lists.fedoraproject.org
No comments:
Post a Comment