burmatovan/openuds
1
0
Fork 0
forked from shaba/openuds
Code Issues Pull Requests Projects Releases Wiki Activity

* Added a "delay" before starting using IPC, so secondary thread is

Browse Source 
ensured to be running

Tests seems to work perfectly now.. Have to be tested intensibely in all
platforms, but seems to be almost finished (actor).
This commit is contained in:
Adolfo Gómez García 2014-12-08 13:11:07 +01:00
parent e9f38b044f
commit c9ec31f258
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
actors/src/UDSActorUser.py
View File

@ -36,6 +36,7 @@ import sys
from PyQt4 import QtGui from PyQt4 import QtGui
from PyQt4 import QtCore from PyQt4 import QtCore
import pickle import pickle
import time
from udsactor import ipc from udsactor import ipc
from udsactor import utils from udsactor import utils
from udsactor.log import logger from udsactor.log import logger
@ -98,6 +99,10 @@ class MessagesProcessor(QtCore.QThread):
if self.ipc is None: if self.ipc is None:
return return
self.running = True self.running = True
# Wait a bit so we ensure IPC thread is running...
time.sleep(2)
while self.running and self.ipc.running: while self.running and self.ipc.running:
try: try:
msg = self.ipc.getMessage() msg = self.ipc.getMessage()
@ -138,7 +143,6 @@ class UDSSystemTray(QtGui.QSystemTrayIcon):
exitAction.triggered.connect(self.about) exitAction.triggered.connect(self.about)
self.setContextMenu(self.menu) self.setContextMenu(self.menu)
self.ipc = MessagesProcessor() self.ipc = MessagesProcessor()
self.ipc.start()
self.maxIdleTime = None self.maxIdleTime = None
self.timer = QtCore.QTimer() self.timer = QtCore.QTimer()
self.timer.timeout.connect(self.checkIdle) self.timer.timeout.connect(self.checkIdle)
@ -163,6 +167,7 @@ class UDSSystemTray(QtGui.QSystemTrayIcon):
self.timer.start(5000) # Launch idle checking every 5 seconds self.timer.start(5000) # Launch idle checking every 5 seconds
self.ipc.start()
# If this is running, it's because he have logged in # If this is running, it's because he have logged in
self.ipc.sendLogin(operations.getCurrentUser()) self.ipc.sendLogin(operations.getCurrentUser())
@ -205,10 +210,11 @@ class UDSSystemTray(QtGui.QSystemTrayIcon):
if self.stopped is True: if self.stopped is True:
return return
self.stopped = True self.stopped = True
# If we close Client, send Loggof to Broker # If we close Client, send Logoff to Broker
self.ipc.sendLogout(operations.getCurrentUser()) self.ipc.sendLogout(operations.getCurrentUser())
self.timer.stop() self.timer.stop()
self.ipc.stop() self.ipc.stop()
operations.loggoff()
self.app.quit() self.app.quit()
if __name__ == '__main__': if __name__ == '__main__':