From e6b20ffcc995b2ac190b96850073c0569bc6d294 Mon Sep 17 00:00:00 2001

From: Noriko Hosoi <nhosoi@redhat.com>

Date: Thu, 16 Jul 2015 10:41:53 -0700

Subject: [PATCH 25/30] Ticket #48226 - CI test: added test cases for ticket

 48226

Description: In MMR, double free coould occur under some special condition

This test script was written by thierry bordaz <tbordaz@redhat.com>.

A small modification to check the memory leak was added.

(cherry picked from commit f5d24450477f8341261c3e5cb5c54ec1ab83328f)

(cherry picked from commit 8600a5eabc78848ad1bf0a9c2014823d0cd6cedc)

---

 dirsrvtests/tickets/ticket48226_test.py | 239 ++++++++++++++++++++++++++++++++

 1 file changed, 239 insertions(+)

 create mode 100644 dirsrvtests/tickets/ticket48226_test.py

diff --git a/dirsrvtests/tickets/ticket48226_test.py b/dirsrvtests/tickets/ticket48226_test.py

new file mode 100644

index 0000000..87814e7

--- /dev/null

+++ b/dirsrvtests/tickets/ticket48226_test.py

@@ -0,0 +1,239 @@

+# --- BEGIN COPYRIGHT BLOCK ---

+# Copyright (C) 2015 Red Hat, Inc.

+# All rights reserved.

+#

+# License: GPL (version 3 or any later version).

+# See LICENSE for details. 

+# --- END COPYRIGHT BLOCK ---

+#

+import os

+import sys

+import time

+import ldap

+import logging

+import pytest

+from lib389 import DirSrv, Entry, tools, tasks

+from lib389.tools import DirSrvTools

+from lib389._constants import *

+from lib389.properties import *

+from lib389.tasks import *

+from lib389.utils import *

+

+logging.getLogger(__name__).setLevel(logging.DEBUG)

+log = logging.getLogger(__name__)

+

+installation1_prefix = None

+

+

+class TopologyReplication(object):

+    def __init__(self, master1, master2):

+        master1.open()

+        self.master1 = master1

+        master2.open()

+        self.master2 = master2

+

+

+@pytest.fixture(scope="module")

+def topology(request):

+    global installation1_prefix

+    os.environ['USE_VALGRIND'] = '1'

+    if installation1_prefix:

+        args_instance[SER_DEPLOYED_DIR] = installation1_prefix

+

+    # Creating master 1...

+    master1 = DirSrv(verbose=False)

+    if installation1_prefix:

+        args_instance[SER_DEPLOYED_DIR] = installation1_prefix

+    args_instance[SER_HOST] = HOST_MASTER_1

+    args_instance[SER_PORT] = PORT_MASTER_1

+    args_instance[SER_SERVERID_PROP] = SERVERID_MASTER_1

+    args_instance[SER_CREATION_SUFFIX] = DEFAULT_SUFFIX

+    args_master = args_instance.copy()

+    master1.allocate(args_master)

+    instance_master1 = master1.exists()

+    if instance_master1:

+        master1.delete()

+    master1.create()

+    master1.open()

+    master1.replica.enableReplication(suffix=SUFFIX, role=REPLICAROLE_MASTER, replicaId=REPLICAID_MASTER_1)

+

+    # Creating master 2...

+    master2 = DirSrv(verbose=False)

+    if installation1_prefix:

+        args_instance[SER_DEPLOYED_DIR] = installation1_prefix

+    args_instance[SER_HOST] = HOST_MASTER_2

+    args_instance[SER_PORT] = PORT_MASTER_2

+    args_instance[SER_SERVERID_PROP] = SERVERID_MASTER_2

+    args_instance[SER_CREATION_SUFFIX] = DEFAULT_SUFFIX

+    args_master = args_instance.copy()

+    master2.allocate(args_master)

+    instance_master2 = master2.exists()

+    if instance_master2:

+        master2.delete()

+    master2.create()

+    master2.open()

+    master2.replica.enableReplication(suffix=SUFFIX, role=REPLICAROLE_MASTER, replicaId=REPLICAID_MASTER_2)

+

+    #

+    # Create all the agreements

+    #

+    # Creating agreement from master 1 to master 2

+    properties = {RA_NAME:      r'meTo_$host:$port',

+                  RA_BINDDN:    defaultProperties[REPLICATION_BIND_DN],

+                  RA_BINDPW:    defaultProperties[REPLICATION_BIND_PW],

+                  RA_METHOD:    defaultProperties[REPLICATION_BIND_METHOD],

+                  RA_TRANSPORT_PROT: defaultProperties[REPLICATION_TRANSPORT]}

+    m1_m2_agmt = master1.agreement.create(suffix=SUFFIX, host=master2.host, port=master2.port, properties=properties)

+    if not m1_m2_agmt:

+        log.fatal("Fail to create a master -> master replica agreement")

+        sys.exit(1)

+    log.debug("%s created" % m1_m2_agmt)

+

+    # Creating agreement from master 2 to master 1

+    properties = {RA_NAME:      r'meTo_$host:$port',

+                  RA_BINDDN:    defaultProperties[REPLICATION_BIND_DN],

+                  RA_BINDPW:    defaultProperties[REPLICATION_BIND_PW],

+                  RA_METHOD:    defaultProperties[REPLICATION_BIND_METHOD],

+                  RA_TRANSPORT_PROT: defaultProperties[REPLICATION_TRANSPORT]}

+    m2_m1_agmt = master2.agreement.create(suffix=SUFFIX, host=master1.host, port=master1.port, properties=properties)

+    if not m2_m1_agmt:

+        log.fatal("Fail to create a master -> master replica agreement")

+        sys.exit(1)

+    log.debug("%s created" % m2_m1_agmt)

+

+    # Allow the replicas to get situated with the new agreements...

+    time.sleep(5)

+

+    #

+    # Initialize all the agreements

+    #

+    master1.agreement.init(SUFFIX, HOST_MASTER_2, PORT_MASTER_2)

+    master1.waitForReplInit(m1_m2_agmt)

+

+    # Check replication is working...

+    if master1.testReplication(DEFAULT_SUFFIX, master2):

+        log.info('Replication is working.')

+    else:

+        log.fatal('Replication is not working.')

+        assert False

+

+    # Clear out the tmp dir

+    master1.clearTmpDir(__file__)

+

+    return TopologyReplication(master1, master2)

+

+def test_ticket11111_set_purgedelay(topology):

+    args = {REPLICA_PURGE_DELAY: '5',

+            REPLICA_PURGE_INTERVAL: '5'}

+    try:

+        topology.master1.replica.setProperties(DEFAULT_SUFFIX, None, None, args)

+    except:

+        log.fatal('Failed to configure replica')

+        assert False

+    try:

+        topology.master2.replica.setProperties(DEFAULT_SUFFIX, None, None, args)

+    except:

+        log.fatal('Failed to configure replica')

+        assert False

+    topology.master1.modify_s(DN_CONFIG, [(ldap.MOD_REPLACE, 'nsslapd-auditlog-logging-enabled', 'on')])

+    topology.master2.modify_s(DN_CONFIG, [(ldap.MOD_REPLACE, 'nsslapd-auditlog-logging-enabled', 'on')])

+    topology.master1.restart(10)

+    topology.master2.restart(10)

+    

+

+def test_ticket11111_1(topology):

+    name = 'test_entry'

+    dn = "cn=%s,%s" % (name, SUFFIX)

+    

+    topology.master1.add_s(Entry((dn , {

+                                            'objectclass': "top person".split(),

+                                            'sn': name,

+                                            'cn': name})))

+                                            

+    # First do an update that is replicated

+    mods = [(ldap.MOD_ADD, 'description', '5')]

+    topology.master1.modify_s(dn, mods)

+    

+    nbtry = 0

+    while (nbtry <= 10):

+        try:

+            ent = topology.master2.getEntry(dn, ldap.SCOPE_BASE, "(objectclass=*)", ['description'])

+            if ent.hasAttr('description') and ent.getValue('description') == '5':

+                break

+        except ldap.NO_SUCH_OBJECT:

+            pass

+        nbtry = nbtry + 1

+        time.sleep(1)

+    assert nbtry <= 10

+    

+    # Stop M2 so that it will not receive the next update

+    topology.master2.stop(10)

+    

+    # ADD a new value that is not replicated

+    mods = [(ldap.MOD_DELETE, 'description', '5')]

+    topology.master1.modify_s(dn, mods)

+    

+    # Stop M1 so that it will keep del '5' that is unknown from master2

+    topology.master1.stop(10)

+    

+    # Get the sbin directory so we know where to replace 'ns-slapd'

+    sbin_dir = get_sbin_dir(prefix=topology.master2.prefix)

+

+    # Enable valgrind

+    valgrind_enable(sbin_dir)

+

+    # start M2 to do the next updates

+    topology.master2.start(10)

+    

+    # ADD 'description' by '5' 

+    mods = [(ldap.MOD_DELETE, 'description', '5')]

+    topology.master2.modify_s(dn, mods)

+    

+    # DEL 'description' by '5'

+    mods = [(ldap.MOD_ADD, 'description', '5')]

+    topology.master2.modify_s(dn, mods)

+    

+    # sleep of purgedelay so that the next update will purge the CSN_7

+    time.sleep(6)

+    

+    # ADD 'description' by '8' that purge the state info

+    mods = [(ldap.MOD_ADD, 'description', '6')]

+    topology.master2.modify_s(dn, mods)

+

+    if valgrind_check_leak(topology.master2, 'csnset_dup'):

+        log.error('test_csnset_dup: Memory leak is present!')

+    else:

+        log.info('test_csnset_dup: No leak is present!')

+    

+    if valgrind_check_leak(topology.master2, 'Invalid'):

+        log.info('Valgrind reported invalid!')

+    else:

+        log.info('Valgrind is happy!')

+    

+    #log.info("You can attach yourself")

+    #time.sleep(60)

+    

+    # Enable valgrind

+    valgrind_disable(sbin_dir)

+

+    topology.master1.start(10)

+

+    

+def test_ticket11111_final(topology):

+    topology.master1.delete()

+    topology.master2.delete()

+    log.info('Testcase PASSED')

+

+

+def run_isolated():

+    global installation1_prefix

+    installation1_prefix = None

+

+    topo = topology(True)

+    test_ticket11111_set_purgedelay(topo)

+    test_ticket11111_1(topo)

+    

+

+if __name__ == '__main__':

+    run_isolated()

+

-- 

1.9.3