Deleted old tests
parent
8a50ccdab4
commit
157d3050bf
|
@ -1,42 +0,0 @@
|
||||||
#!/usr/bin/python
|
|
||||||
|
|
||||||
from config import hostname, port, username, password, testput_nbrdays
|
|
||||||
|
|
||||||
import ev_generator
|
|
||||||
import sogotests
|
|
||||||
import unittest
|
|
||||||
import webdavlib
|
|
||||||
|
|
||||||
class HTTPUnparsedURLTest(unittest.TestCase):
|
|
||||||
def __init__(self, arg):
|
|
||||||
unittest.TestCase.__init__(self, arg)
|
|
||||||
self.client = webdavlib.WebDAVClient(hostname, port,
|
|
||||||
username, password)
|
|
||||||
|
|
||||||
def setUp(self):
|
|
||||||
self.resource = '/SOGo/dav/%s/Calendar/test-dav-put/' % username
|
|
||||||
delete = webdavlib.WebDAVDELETE(self.resource)
|
|
||||||
self.client.execute(delete)
|
|
||||||
mkcol = webdavlib.WebDAVMKCOL(self.resource)
|
|
||||||
self.client.execute(mkcol)
|
|
||||||
self.assertEquals(mkcol.response["status"], 201,
|
|
||||||
"preparation: failure creating collection"
|
|
||||||
"(code = %d)" % mkcol.response["status"])
|
|
||||||
|
|
||||||
def testPUT(self):
|
|
||||||
gen = ev_generator.ev_generator(testput_nbrdays)
|
|
||||||
counter = 1
|
|
||||||
while gen.iter():
|
|
||||||
event = gen.event
|
|
||||||
url = self.resource + "event-%d.ics" % counter
|
|
||||||
put = webdavlib.HTTPPUT(url, event)
|
|
||||||
put.content_type = "text/calendar; charset=utf-8"
|
|
||||||
self.client.execute(put)
|
|
||||||
counter = counter + 1
|
|
||||||
|
|
||||||
def tearDown(self):
|
|
||||||
delete = webdavlib.WebDAVDELETE(self.resource)
|
|
||||||
self.client.execute(delete)
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
sogotests.runTests()
|
|
|
@ -1,80 +0,0 @@
|
||||||
#!/usr/bin/python
|
|
||||||
|
|
||||||
from config import hostname, port
|
|
||||||
|
|
||||||
import webdavlib
|
|
||||||
import random
|
|
||||||
import time
|
|
||||||
import threading
|
|
||||||
|
|
||||||
base=1127
|
|
||||||
userscount=100
|
|
||||||
password=""
|
|
||||||
batchcount=10
|
|
||||||
sleeptime=3
|
|
||||||
durationHeader="sogorequestduration"
|
|
||||||
#durationHeader="sogo-request-duration"
|
|
||||||
|
|
||||||
class StressIteration(threading.Thread):
|
|
||||||
def __init__(self, username):
|
|
||||||
threading.Thread.__init__(self)
|
|
||||||
self.username = username
|
|
||||||
self.time = 0.0
|
|
||||||
self.sogoTime = 0.0
|
|
||||||
|
|
||||||
def run(self):
|
|
||||||
client = webdavlib.WebDAVClient(hostname, port,
|
|
||||||
self.username, password)
|
|
||||||
resource = "/SOGo/dav/%s/Calendar/personal/" % self.username
|
|
||||||
startTime = time.time()
|
|
||||||
query = webdavlib.WebDAVSyncQuery(resource, None,
|
|
||||||
[ "getetag", "calendar-data" ])
|
|
||||||
client.execute(query)
|
|
||||||
if query.response["status"] != 207:
|
|
||||||
print "*** received unexpected code: %d (%s)" \
|
|
||||||
% (query.response["status"], resource)
|
|
||||||
endTime = time.time()
|
|
||||||
headers = query.response["headers"]
|
|
||||||
if headers.has_key(durationHeader):
|
|
||||||
self.sogoTime = float(headers[durationHeader])
|
|
||||||
self.time = endTime - startTime
|
|
||||||
# print "%f, %f" % (self.time, self.sogoTime)
|
|
||||||
|
|
||||||
class StressTest:
|
|
||||||
def __init__(self):
|
|
||||||
self.usernames = [ "invite%d" % (base + x)
|
|
||||||
for x in xrange(userscount) ]
|
|
||||||
self.random = random.Random()
|
|
||||||
|
|
||||||
def iteration(self):
|
|
||||||
usernames = self.random.sample(self.usernames, batchcount)
|
|
||||||
startTime = time.time()
|
|
||||||
threads = []
|
|
||||||
for username in usernames:
|
|
||||||
iteration = StressIteration(username)
|
|
||||||
iteration.start()
|
|
||||||
threads.append(iteration)
|
|
||||||
|
|
||||||
for thread in threads:
|
|
||||||
thread.join()
|
|
||||||
|
|
||||||
endTime = time.time()
|
|
||||||
|
|
||||||
programTime = endTime - startTime
|
|
||||||
requestsTime = 0.0
|
|
||||||
sogoTime = 0.0
|
|
||||||
for thread in threads:
|
|
||||||
requestsTime = requestsTime + thread.time
|
|
||||||
sogoTime = sogoTime + thread.sogoTime
|
|
||||||
|
|
||||||
print "Iteration time: %f, Total Requests Time: %f, Total SOGo Time: %f" \
|
|
||||||
% (programTime, requestsTime, sogoTime)
|
|
||||||
|
|
||||||
def start(self):
|
|
||||||
while True:
|
|
||||||
self.iteration()
|
|
||||||
time.sleep(sleeptime)
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
test = StressTest()
|
|
||||||
test.start()
|
|
Loading…
Reference in New Issue