summaryrefslogtreecommitdiffstats
path: root/For Weekly Test/30-07-2011/Controller.py
diff options
context:
space:
mode:
authorRefik Hadzialic2011-08-02 16:47:17 +0200
committerRefik Hadzialic2011-08-02 16:47:17 +0200
commit24414ec73f840f3f9050b4724bdeae6fd9731870 (patch)
treef931677f26ab4f7d18d34dc6175316dd125dd030 /For Weekly Test/30-07-2011/Controller.py
parentModiefied the code to work with ssh tunneling (diff)
parentrename device name on database. (diff)
downloadgsm-selftest-24414ec73f840f3f9050b4724bdeae6fd9731870.tar.gz
gsm-selftest-24414ec73f840f3f9050b4724bdeae6fd9731870.tar.xz
gsm-selftest-24414ec73f840f3f9050b4724bdeae6fd9731870.zip
Merge branch 'master' of lab.ks.uni-freiburg.de:lsfks/projekte/gsm-selftest
Diffstat (limited to 'For Weekly Test/30-07-2011/Controller.py')
-rw-r--r--For Weekly Test/30-07-2011/Controller.py76
1 files changed, 59 insertions, 17 deletions
diff --git a/For Weekly Test/30-07-2011/Controller.py b/For Weekly Test/30-07-2011/Controller.py
index c0c102d..e4a4566 100644
--- a/For Weekly Test/30-07-2011/Controller.py
+++ b/For Weekly Test/30-07-2011/Controller.py
@@ -2,53 +2,95 @@ import sys
import ClientClass
import DbClass
import ControllerClass
-import classCheck
+import PingClass
+from time import sleep
+
+
+def ping(handler):
+
+ global serverStatus
+
+ if handler == 'landline':
+ server = PingClass.Ping('sipgate.de')
+ serverStatus = server.ping(3)
+
+ elif handler == 'sip':
+ server = PingClass.Ping('132.230.4.8')
+ serverStatus = server.ping(3)
+
+ elif handler == 'unisip':
+ server = PingClass.Ping('132.230.252.228')
+ serverStatus = server.ping(3)
+
+ elif handler == 'gsmr1':
+ server = PingClass.Ping('localhost')
+ serverStatus = server.ping(3)
+
+ elif handler == 'gsmr2':
+ server = PingClass.Ping('132.230.4.64')
+ serverStatus = server.ping(3)
db = DbClass.DBMySQLConnection('root', 'randompasswordSQL', 'localhost', 'gsmselftesting')
db.connectDB()
dbStatus = db.connectDB()
-
if dbStatus == 1:
if db.anyTasksToDo() == 1:
-
+ i=0
for item in db.tasksList:
-
taskID = item[0]
taskNo = item[1]
callFrom = item[2]
callTo = item[3]
- print "Test ID : " , taskID
- print "Caller : " , callFrom
- print "Receiver : " , callTo
+ destination = db.deviceAddress(str(callTo))
- call = classCheck.checking(callFrom)
- rec = classCheck.checking(callTo)
+ caller = db.deviceAddress(str(callFrom))
- if call.serverStatus <> 0:
+ callAdd = caller[0]
+ recAdd = destination[0]
+ destNo = destination[1]
+
+ if callFrom == 'unisip':
+ destNo = destNo[7:]
+
+
+ print '\n'
+ print "Task ID: ", taskID
+ print "Calling From: ", callFrom
+ print "To: ", callTo
+ print "number: ", destNo
+
+ ping(callFrom)
+
+ if serverStatus <> 0:
- if rec.serverStatus <> 0:
+ ping(callTo)
+ if serverStatus <> 0:
- makeTest = ControllerClass.test(callFrom, callTo,rec.destNumber)
+ makeTest = ControllerClass.test(callFrom, callAdd, callTo, recAdd, destNo)
makeTest.FuncTest()
db.addResult(taskID, makeTest.testResult)
if makeTest.repeatTest == True:
db.insertTaskIn2(callTo,callFrom,taskNo)
+
+ print "Result :", makeTest.testResult
+
+ db.deleteTempTask(taskID)
+ db.tasksList.remove(item)
+ db.tasksList.insert(i,'')
+ i = i+1
+
+ sleep(3)
else:
print "[failed] 500 "+callTo+ " Server Internal Error"
else:
print "[failed] 500 "+callFrom+ " Server Internal Error"
-
- call = None
- rec = None
- db.deleteTempTask(taskID)
db.cleanTasksList()
-
else:
print "No job at all"
else: