|
On 07/13/2016 02:28 AM, William Brown
wrote:
Can you please run the attached connection stress test script as well (for 24 hours)? I'm worried that you are introducing a lot of changes like might cause regressions.On Wed, 2016-07-13 at 14:47 +1000, William Brown wrote:https://fedorahosted.org/nunc-stans/ticket/57 https://fedorahosted.org/nunc-stans/attachment/ticket/57/0001-Ticket-57-Implement-a-strict-state-machine-for-nunc-.patch https://fedorahosted.org/nunc-stans/attachment/ticket/57/0002-Ticket-57-Update-the-configure-and-autotools-files.patch May not apply without #51, #54, #56Mentioned it in the ticket, but this builds and works with git master of DS with ldclt. So the code is "reliable" from that aspect. You need to already have a server instance setup with these entries and the idle timeout set to 10 seconds. You will also need to tweak the rootdn and password in the script. I know this script needs more polishing but it stresses the server in ways ldclt can not. uid=mark,dc=example,dc=com cn=group1,dc=example,dc=com ... cn=group10,dc=example,dc=com
Thanks, Mark
|
# --- BEGIN COPYRIGHT BLOCK ---
# Copyright (C) 2016 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
import signal
import threading
from ldap.ldapobject import SimpleLDAPObject
from lib389 import DirSrv
from lib389._constants import *
from lib389.properties import *
MAX_CONNS = 10000000
MAX_THREADS = 20
STOP = False
def signalHandler(signal, frame):
"""
handle control-C cleanly
"""
global STOP
STOP = True
sys.exit(0)
def openConnection(host, port, binddn="", passwd=""):
"""Open a new connection to an LDAP server"""
uri = "ldap://%s:%d/"; % (host, port)
server = ldap.initialize(uri)
server.simple_bind_s(binddn, passwd)
return server
class BindOnlyConn(threading.Thread):
"""This class opens and closes connections to a specified server
"""
def __init__(self, host='localhost', port=389, binddn=None, passwd=None):
"""Initialize the thread class withte server isntance info"""
threading.Thread.__init__(self)
self.daemon = True
self.host = host
self.port = port
self.binddn = binddn
self.passwd = passwd
def run(self):
"""Keep opening and closing connections"""
global STOP
idx = 0
while idx < MAX_CONNS and not STOP:
try:
conn = openConnection(self.host, self.port, self.binddn,
self.passwd)
conn.unbind_s()
time.sleep(.2)
except:
return
idx += 1
class IdleConn(threading.Thread):
"""This class opens and closes connections to a specified server
"""
def __init__(self, host='localhost', port=389, binddn=None, passwd=None):
"""Initialize the thread class withte server isntance info"""
threading.Thread.__init__(self)
self.daemon = True
self.host = host
self.port = port
self.binddn = binddn
self.passwd = passwd
def run(self):
"""Assume idleTimeout is set to less than 10 seconds
"""
global STOP
idx = 0
while idx < (MAX_CONNS / 10) and not STOP:
try:
conn = openConnection(self.host, self.port, self.binddn,
self.passwd)
conn.search_s('dc=example,dc=com', ldap.SCOPE_SUBTREE,
'uid=*')
time.sleep(10)
conn.search_s('dc=example,dc=com', ldap.SCOPE_SUBTREE,
'cn=*')
conn.unbind_s()
except:
return
idx += 1
class LongConn(threading.Thread):
"""This class opens and closes connections to a specified server
"""
def __init__(self, host='localhost', port=389, binddn=None, passwd=None):
"""Initialize the thread class with the server instance info"""
threading.Thread.__init__(self)
self.daemon = True
self.host = host
self.port = port
self.binddn = binddn
self.passwd = passwd
def run(self):
"""Assume idleTimeout is set to less than 10 seconds
"""
global STOP
idx = 0
while idx < MAX_CONNS and not STOP:
try:
conn = openConnection(self.host, self.port, self.binddn,
self.passwd)
conn.search_s('dc=example,dc=com', ldap.SCOPE_SUBTREE,
'objectclass=*')
conn.search_s('dc=example,dc=com', ldap.SCOPE_SUBTREE,
'uid=mark')
conn.search_s('dc=example,dc=com', ldap.SCOPE_SUBTREE,
'cn=*')
conn.search_s('', ldap.SCOPE_BASE, 'objectclass=*')
conn.unbind_s()
time.sleep(.2)
except:
return
idx += 1
def test_connection_load():
"""Start a bunch of threads that are going to open and close connections"""
# setup the control-C signal handler
signal.signal(signal.SIGINT, signalHandler)
#
# Bind/Unbind Conn Threads
#
threads = []
idx = 0
while idx < MAX_THREADS:
threads.append(BindOnlyConn(binddn='uid=mark,dc=example,dc=com',
passwd='password'))
idx += 1
for thread in threads:
thread.start()
#
# Idle Conn Threads
#
idx = 0
idle_threads = []
while idx < 10:
idle_threads.append(IdleConn(binddn='uid=mark,dc=example,dc=com',
passwd='password'))
idx += 1
for thread in idle_threads:
thread.start()
#
# Long Conn Threads
#
idx = 0
long_threads = []
while idx < 10:
long_threads.append(LongConn(binddn='cn=dm',
passwd='superman'))
idx += 1
for thread in long_threads:
thread.start()
#
# Now wait for all the threads to complete
#
while threading.active_count() > 0:
time.sleep(0.1)
print "Done"
if __name__ == '__main__':
# Run isolated
# -s for DEBUG mode
CURRENT_FILE = os.path.realpath(__file__)
pytest.main("-s %s" % CURRENT_FILE)-- 389-devel mailing list 389-devel@xxxxxxxxxxxxxxxxxxxxxxx https://lists.fedoraproject.org/admin/lists/389-devel@xxxxxxxxxxxxxxxxxxxxxxx
