Mercurial > code > home > repos > light9

comparison bin/collector_loadtest.py @ 1858:7772cc48e016

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reformat all python Ignore-this: 1135b78893f8b3d31badddda7f45678f
author drewp@bigasterisk.com
date Tue, 21 May 2019 23:56:12 +0000
parents 8e0e5b3db301
children f066d6e874db
comparison
equal deleted inserted replaced
1857:3f1b9b9b0505 1858:7772cc48e016
5 from light9.namespaces import L9, DEV 5 from light9.namespaces import L9, DEV
6 from twisted.internet import reactor 6 from twisted.internet import reactor
7 import time 7 import time
8 import logging 8 import logging
9 log.setLevel(logging.DEBUG) 9 log.setLevel(logging.DEBUG)
10
11
10 def loadTest(): 12 def loadTest():
11 print "scheduling loadtest" 13 print "scheduling loadtest"
12 n = 2500 14 n = 2500
13 times = [None] * n 15 times = [None] * n
14 session = "loadtest%s" % time.time() 16 session = "loadtest%s" % time.time()
15 offset = 0 17 offset = 0
16 for i in range(n): 18 for i in range(n):
19
17 def send(i): 20 def send(i):
18 if i % 100 == 0: 21 if i % 100 == 0:
19 log.info('sendToCollector %s', i) 22 log.info('sendToCollector %s', i)
20 d = sendToCollector("http://localhost:999999/", session, 23 d = sendToCollector("http://localhost:999999/", session,
21 [[DEV["backlight1"], L9["color"], "#ffffff"], 24 [[DEV["backlight1"], L9["color"], "#ffffff"],
22 [DEV["backlight2"], L9["color"], "#ffffff"], 25 [DEV["backlight2"], L9["color"], "#ffffff"],
23 [DEV["backlight3"], L9["color"], "#ffffff"], 26 [DEV["backlight3"], L9["color"], "#ffffff"],
24 [DEV["backlight4"], L9["color"], "#ffffff"], 27 [DEV["backlight4"], L9["color"], "#ffffff"],
25 [DEV["backlight5"], L9["color"], "#ffffff"], 28 [DEV["backlight5"], L9["color"], "#ffffff"],
26 [DEV["down2"], L9["color"], "#ffffff"], 29 [DEV["down2"], L9["color"], "#ffffff"],
27 [DEV["down3"], L9["color"], "#ffffff"], 30 [DEV["down3"], L9["color"], "#ffffff"],
28 [DEV["down4"], L9["color"], "#ffffff"], 31 [DEV["down4"], L9["color"], "#ffffff"],
29 [DEV["houseSide"], L9["level"], .8], 32 [DEV["houseSide"], L9["level"], .8],
30 [DEV["backlight5"], L9["uv"], 0.011]]) 33 [DEV["backlight5"], L9["uv"], 0.011]])
34
31 def ontime(dt, i=i): 35 def ontime(dt, i=i):
32 times[i] = dt 36 times[i] = dt
37
33 d.addCallback(ontime) 38 d.addCallback(ontime)
39
34 reactor.callLater(offset, send, i) 40 reactor.callLater(offset, send, i)
35 offset += .002 41 offset += .002
36 42
37 def done(): 43 def done():
38 print "loadtest done" 44 print "loadtest done"
39 with open('/tmp/times', 'w') as f: 45 with open('/tmp/times', 'w') as f:
40 f.write(''.join('%s\n' % t for t in times)) 46 f.write(''.join('%s\n' % t for t in times))
41 reactor.stop() 47 reactor.stop()
42 reactor.callLater(offset+.5, done) 48
49 reactor.callLater(offset + .5, done)
43 reactor.run() 50 reactor.run()
51
44 52
45 if __name__ == '__main__': 53 if __name__ == '__main__':
46 loadTest() 54 loadTest()