aboutsummaryrefslogtreecommitdiff
path: root/tools/test-integration.py
diff options
context:
space:
mode:
Diffstat (limited to 'tools/test-integration.py')
-rwxr-xr-xtools/test-integration.py57
1 files changed, 30 insertions, 27 deletions
diff --git a/tools/test-integration.py b/tools/test-integration.py
index 55bbf389f..6251b0d97 100755
--- a/tools/test-integration.py
+++ b/tools/test-integration.py
@@ -8,6 +8,7 @@ import urllib2
import json
import socket
import time
+import threading
messages = {
'gps103' : 'imei:123456789012345,help me,1201011201,,F,120100.000,A,6000.0000,N,13000.0000,E,0.00,;',
@@ -141,6 +142,7 @@ def send_message(port, message):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1', port))
s.send(message)
+ time.sleep(5)
s.close()
def get_protocols(cookie, device_id):
@@ -155,40 +157,41 @@ def get_protocols(cookie, device_id):
protocols.append(position['protocol'])
return protocols
-ports = load_ports()
+if __name__ == "__main__":
+ ports = load_ports()
-cookie = login()
-remove_devices(cookie)
-
-devices = {
- '123456789012345' : add_device(cookie, '123456789012345'),
- '123456789012' : add_device(cookie, '123456789012'),
- '1234567890' : add_device(cookie, '1234567890'),
- '123456' : add_device(cookie, '123456'),
- '1234' : add_device(cookie, '1234')
-}
+ cookie = login()
+ remove_devices(cookie)
+ devices = {
+ '123456789012345' : add_device(cookie, '123456789012345'),
+ '123456789012' : add_device(cookie, '123456789012'),
+ '1234567890' : add_device(cookie, '1234567890'),
+ '123456' : add_device(cookie, '123456'),
+ '1234' : add_device(cookie, '1234')
+ }
-all = set(ports.keys())
-protocols = set(messages.keys())
+ all = set(ports.keys())
+ protocols = set(messages.keys())
-print 'Total: %d' % len(all)
-print 'Missing: %d' % len(all - protocols)
-print 'Covered: %d' % len(protocols)
+ print 'Total: %d' % len(all)
+ print 'Missing: %d' % len(all - protocols)
+ print 'Covered: %d' % len(protocols)
-#if all - protocols:
-# print '\nMissing: %s\n' % repr(list((all - protocols)))
+ #if all - protocols:
+ # print '\nMissing: %s\n' % repr(list((all - protocols)))
-for protocol in messages:
- send_message(ports[protocol], messages[protocol])
+ for protocol in messages:
+ thread = threading.Thread(target = send_message, args = (ports[protocol], messages[protocol]))
+ thread.start()
-time.sleep(10)
+ time.sleep(10)
-for device in devices:
- protocols -= set(get_protocols(cookie, devices[device]))
+ for device in devices:
+ protocols -= set(get_protocols(cookie, devices[device]))
-print 'Success: %d' % (len(messages) - len(protocols))
-print 'Failed: %d' % len(protocols)
+ print 'Success: %d' % (len(messages) - len(protocols))
+ print 'Failed: %d' % len(protocols)
-if protocols:
- print '\nFailed: %s' % repr(list(protocols))
+ if protocols:
+ print '\nFailed: %s' % repr(list(protocols))