import gobject
import gtk
+import gtk_toolbox
+
try:
_
class ProgressDialog(gtk.Dialog):
- def __init__(self,title=_("Sync process"), parent=None):
- gtk.Dialog.__init__(self,title,parent,gtk.DIALOG_MODAL | gtk.DIALOG_DESTROY_WITH_PARENT,())
+ def __init__(self, title = _("Sync process"), parent = None):
+ gtk.Dialog.__init__(self, title, parent, gtk.DIALOG_MODAL | gtk.DIALOG_DESTROY_WITH_PARENT, ())
_moduleLogger.info("ProgressDialog, init")
- label=gtk.Label(_("Sync process running...please wait"))
+ label = gtk.Label(_("Sync process running...please wait"))
self.vbox.pack_start(label, True, True, 0)
- label=gtk.Label(_("(this can take some minutes)"))
+ label = gtk.Label(_("(this can take some minutes)"))
self.vbox.pack_start(label, True, True, 0)
- #self.progressbar=gtk.ProgressBar()
+ #self.progressbar = gtk.ProgressBar()
#self.vbox.pack_start(self.progressbar, True, True, 0)
#self.set_keep_above(True)
class Sync(gtk.VBox):
__gsignals__ = {
- 'syncFinished' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE,(gobject.TYPE_STRING,)),
- 'syncBeforeStart' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE,(gobject.TYPE_STRING,)),
+ 'syncFinished' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE, (gobject.TYPE_STRING, )),
+ 'syncBeforeStart' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE, (gobject.TYPE_STRING, )),
}
- def __init__(self,db,parentwindow,port):
- gtk.VBox.__init__(self,homogeneous=False, spacing=0)
+ def __init__(self, db, parentwindow, port):
+ gtk.VBox.__init__(self, homogeneous = False, spacing = 0)
_moduleLogger.info("Sync, init")
- self.db=db
- self.progress=None
- self.server=None
- self.port=int(port)
- self.parentwindow=parentwindow
- self.concernedRows=None
+ self.db = db
+ self.progress = None
+ self.server = None
+ self.port = int(port)
+ self.parentwindow = parentwindow
+ self.concernedRows = None
#print "Sync, 2"
#sql = "DROP TABLE sync"
- #self.db.speichereSQL(sql,log=False)
+ #self.db.speichereSQL(sql, log = False)
sql = "CREATE TABLE sync (id INTEGER PRIMARY KEY, syncpartner TEXT, uuid TEXT, pcdatum INTEGER)"
- self.db.speichereSQL(sql,log=False)
+ self.db.speichereSQL(sql, log = False)
#print "Sync, 3"
- sql="SELECT uuid,pcdatum FROM sync WHERE syncpartner=?"
- rows=self.db.ladeSQL(sql,("self",)) #Eigene Id feststellen
+ sql = "SELECT uuid, pcdatum FROM sync WHERE syncpartner = ?"
+ rows = self.db.ladeSQL(sql, ("self", )) #Eigene Id feststellen
#print "Sync, 3a"
- if (rows==None)or(len(rows)!=1):
- sql="DELETE FROM sync WHERE syncpartner=?"
- self.db.speichereSQL(sql,("self",),log=False)
+ if (rows == None)or(len(rows) != 1):
+ sql = "DELETE FROM sync WHERE syncpartner = ?"
+ self.db.speichereSQL(sql, ("self", ), log = False)
- #uuid1=uuid()
+ #uuid1 = uuid()
#print "Sync, 3b"
#print "Sync, 3bb"
- self.sync_uuid=str(uuid.uuid4())
- sql="INSERT INTO sync (syncpartner,uuid,pcdatum) VALUES (?,?,?)"
- self.db.speichereSQL(sql,("self",str(self.sync_uuid),int(time.time())),log=False)
+ self.sync_uuid = str(uuid.uuid4())
+ sql = "INSERT INTO sync (syncpartner, uuid, pcdatum) VALUES (?, ?, ?)"
+ self.db.speichereSQL(sql, ("self", str(self.sync_uuid), int(time.time())), log = False)
#print "Sync, 3c"
else:
- sync_uuid,pcdatum = rows[0]
- self.sync_uuid=sync_uuid
+ sync_uuid, pcdatum = rows[0]
+ self.sync_uuid = sync_uuid
#print "x1"
#print "Sync, 4"
- frame=gtk.Frame(_("Local SyncServer (port ")+str(self.port)+")")
- self.comboIP=gtk.combo_box_entry_new_text()
+ frame = gtk.Frame(_("Local SyncServer (port ")+str(self.port)+")")
+ self.comboIP = gtk.combo_box_entry_new_text()
self.comboIP.append_text("") #self.get_ip_address("eth0"))
#self.comboIP.append_text(self.get_ip_address("eth1")) #fixme
#self.comboIP.append_text(self.get_ip_address("eth2"))
#print "Sync, 4e"
frame.add(self.comboIP)
- serverbutton=gtk.ToggleButton(_("Start SyncServer"))
- serverbutton.connect("clicked",self.startServer,(None,))
- self.pack_start(frame, expand=False, fill=True, padding=1)
- self.pack_start(serverbutton, expand=False, fill=True, padding=1)
- self.syncServerStatusLabel=gtk.Label(_("Syncserver not running"))
- self.pack_start(self.syncServerStatusLabel, expand=False, fill=True, padding=1)
-
- frame=gtk.Frame(_("RemoteSync-Server (Port ")+str(self.port)+")")
- self.comboRemoteIP=gtk.combo_box_entry_new_text()
+ serverbutton = gtk.ToggleButton(_("Start SyncServer"))
+ serverbutton.connect("clicked", self.startServer, (None, ))
+ self.pack_start(frame, expand = False, fill = True, padding = 1)
+ self.pack_start(serverbutton, expand = False, fill = True, padding = 1)
+ self.syncServerStatusLabel = gtk.Label(_("Syncserver not running"))
+ self.pack_start(self.syncServerStatusLabel, expand = False, fill = True, padding = 1)
+
+ frame = gtk.Frame(_("RemoteSync-Server (Port ")+str(self.port)+")")
+ self.comboRemoteIP = gtk.combo_box_entry_new_text()
self.comboRemoteIP.append_text("192.168.0.?")
self.comboRemoteIP.append_text("192.168.1.?")
self.comboRemoteIP.append_text("192.168.176.?")
frame.add(self.comboRemoteIP)
- syncbutton=gtk.Button(_("Connect to remote SyncServer"))
- syncbutton.connect("clicked",self.syncButton,(None,))
- self.pack_start(frame, expand=False, fill=True, padding=1)
- self.pack_start(syncbutton, expand=False, fill=True, padding=1)
- self.syncStatusLabel=gtk.Label(_("no sync process (at the moment)"))
- self.pack_start(self.syncStatusLabel, expand=False, fill=True, padding=1)
+ syncbutton = gtk.Button(_("Connect to remote SyncServer"))
+ syncbutton.connect("clicked", self.syncButton, (None, ))
+ self.pack_start(frame, expand = False, fill = True, padding = 1)
+ self.pack_start(syncbutton, expand = False, fill = True, padding = 1)
+ self.syncStatusLabel = gtk.Label(_("no sync process (at the moment)"))
+ self.pack_start(self.syncStatusLabel, expand = False, fill = True, padding = 1)
#self.comboRemoteIP.set_text_column("Test")
self.comboRemoteIP.get_child().set_text(self.db.ladeDirekt("syncRemoteIP"))
self.comboIP.get_child().set_text(self.db.ladeDirekt("syncServerIP"))
#load
- if (self.db.ladeDirekt("startSyncServer",False)==True):
+ if (self.db.ladeDirekt("startSyncServer", False) == True):
serverbutton.set_active(True)
- def changeSyncStatus(self,active,title):
+ def changeSyncStatus(self, active, title):
self.syncStatusLabel.set_text(title)
- if active==True:
- if self.progress==None:
- self.progress=ProgressDialog(parent=self.parentwindow)
- self.emit("syncBeforeStart","syncBeforeStart")
+ if active == True:
+ if self.progress == None:
+ self.progress = ProgressDialog(parent = self.parentwindow)
+ self.emit("syncBeforeStart", "syncBeforeStart")
else:
- if self.progress!=None:
+ if self.progress is not None:
self.progress.hide()
self.progress.destroy()
- self.progress=None
- self.emit("syncFinished","syncFinished")
+ self.progress = None
+ self.emit("syncFinished", "syncFinished")
def pulse(self):
- if self.progress!=None:
+ if self.progress is not None:
self.progress.pulse()
- #if self.server!=None:
+ #if self.server is not None:
# self.server.pulse()
def getUeberblickBox(self):
- frame=gtk.Frame(_("Query"))
+ frame = gtk.Frame(_("Query"))
return frame
def handleRPC(self):
try:
- if (self.rpcserver==None): return False
+ if self.rpcserver is None:
+ return False
except:
return False
- while (len(self.poll.poll(0))>0):
- self.rpcserver.handle_request()
+ while 0 < len(self.poll.poll(0)):
+ self.rpcserver.hande_request()
return True
- def get_ip_address(self,ifname):
+ def get_ip_address(self, ifname):
return socket.gethostbyname(socket.gethostname())
#try:
# s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
- # ip=socket.inet_ntoa(fcntl.ioctl(s.fileno(),0x8915,struct.pack('256s', ifname[:15]))[20:24])
+ # ip = socket.inet_ntoa(fcntl.ioctl(s.fileno(), 0x8915, struct.pack('256s', ifname[:15]))[20:24])
# s.close()
#except:
- # ip=socket.gethostbyname(socket.gethostname())
+ # ip = socket.gethostbyname(socket.gethostname())
# s.close()
#return ip FixME
- def getLastSyncDate(self,sync_uuid):
- sql="SELECT syncpartner,pcdatum FROM sync WHERE uuid=?"
- rows=self.db.ladeSQL(sql,(sync_uuid,))
- if (rows!=None)and(len(rows)==1):
- syncpartner,pcdatum = rows[0]
+ def getLastSyncDate(self, sync_uuid):
+ sql = "SELECT syncpartner, pcdatum FROM sync WHERE uuid = ?"
+ rows = self.db.ladeSQL(sql, (sync_uuid, ))
+ if (rows is not None)and(len(rows) == 1):
+ syncpartner, pcdatum = rows[0]
else:
- pcdatum=-1
+ pcdatum = -1
_moduleLogger.info("LastSyncDatum: "+str(pcdatum)+" Jetzt "+str(int(time.time())))
return pcdatum
- def check4commit(self,newSQL,lastdate):
+ def check4commit(self, newSQL, lastdate):
_moduleLogger.info("check4commit 1")
- if self.concernedRows==None:
+ if self.concernedRows == None:
_moduleLogger.info("check4commit Updatung concernedRows")
- sql="SELECT pcdatum,rowid FROM logtable WHERE pcdatum>? ORDER BY pcdatum DESC"
- self.concernedRows=self.db.ladeSQL(sql,(lastdate,))
+ sql = "SELECT pcdatum, rowid FROM logtable WHERE pcdatum>? ORDER BY pcdatum DESC"
+ self.concernedRows = self.db.ladeSQL(sql, (lastdate, ))
- if (self.concernedRows!=None)and(len(self.concernedRows)>0):
+ if (self.concernedRows is not None)and(len(self.concernedRows)>0):
#_moduleLogger.info("check4commit 2")
- id1, pcdatum,sql, param, host, rowid = newSQL
+ id1, pcdatum, sql, param, host, rowid = newSQL
if len(rowid)>0:
for x in self.concernedRows:
#_moduleLogger.info("check4commit 3")
- if (x[1]==rowid):
+ if (x[1] == rowid):
if (x[0]>pcdatum):
_moduleLogger.info("newer sync entry, ignoring old one")
#_moduleLogger.info("check4commit 9.1")
#_moduleLogger.info("check4commit 9.3")
return True
- def writeSQLTupel(self,newSQLs,lastdate):
- if (newSQLs==None):
- return
+ def writeSQLTupel(self, newSQLs, lastdate):
+ if newSQLs is None:
+ return
- self.concernedRows=None
- pausenzaehler=0
+ self.concernedRows = None
+ pausenzaehler = 0
_moduleLogger.info("writeSQLTupel got "+str(len(newSQLs))+" sql tupels")
for newSQL in newSQLs:
#print ""
- #print "SQL1: ",newSQL[1]
- #print "SQL2: ",newSQL[2]
- #print "SQL3: ",newSQL[3]
- #print "Param:",string.split(newSQL[3]," <<Tren-ner>> ")
+ #print "SQL1: ", newSQL[1]
+ #print "SQL2: ", newSQL[2]
+ #print "SQL3: ", newSQL[3]
+ #print "Param:", string.split(newSQL[3], " <<Tren-ner>> ")
#print ""
- if (newSQL[3]!=""):
- param=string.split(newSQL[3]," <<Tren-ner>> ")
+ if (newSQL[3] != ""):
+ param = string.split(newSQL[3], " <<Tren-ner>> ")
else:
- param=None
+ param = None
if (len(newSQL)>2):
- commitSQL=True
+ commitSQL = True
- if (newSQL[5]!=None)and(len(newSQL[5])>0):
- commitSQL=self.check4commit(newSQL,lastdate)
+ if (newSQL[5] is not None)and(len(newSQL[5])>0):
+ commitSQL = self.check4commit(newSQL, lastdate)
- if (commitSQL==True):
- self.db.speichereSQL(newSQL[2],param,commit=False,pcdatum=newSQL[1],rowid=newSQL[5])
+ if commitSQL:
+ self.db.speichereSQL(newSQL[2], param, commit = False, pcdatum = newSQL[1], rowid = newSQL[5])
else:
_moduleLogger.error("writeSQLTupel: Error")
- pausenzaehler+=1
- if (pausenzaehler % 10)==0:
+ pausenzaehler += 1
+ if (pausenzaehler % 10) == 0:
self.pulse()
- while (gtk.events_pending()):
- gtk.main_iteration();
+ while gtk.events_pending():
+ gtk.main_iteration()
_moduleLogger.info("Alle SQLs an sqlite geschickt, commiting now")
self.db.commitSQL()
_moduleLogger.info("Alle SQLs commited")
- def doSync(self,sync_uuid,pcdatum,newSQLs,pcdatumjetzt):
- #print uuid,pcdatum,newSQLs
+ def doSync(self, sync_uuid, pcdatum, newSQLs, pcdatumjetzt):
+ #print uuid, pcdatum, newSQLs
#_moduleLogger.info("doSync 0")
- self.changeSyncStatus(True,_("sync process running"))
+ self.changeSyncStatus(True, _("sync process running"))
self.pulse()
#_moduleLogger.info("doSync 1")
- while (gtk.events_pending()):
+ while gtk.events_pending():
gtk.main_iteration();
- diff=time.time()-pcdatumjetzt
- if diff<0:
- diff=diff*(-1)
- if diff>30:
+ diff = abs(time.time() - pcdatumjetzt)
+ if 30 < diff:
return -1
_moduleLogger.info("doSync read sqls")
- sql="SELECT * FROM logtable WHERE pcdatum>?"
- rows=self.db.ladeSQL(sql,(pcdatum,))
+ sql = "SELECT * FROM logtable WHERE pcdatum>?"
+ rows = self.db.ladeSQL(sql, (pcdatum, ))
_moduleLogger.info("doSync read sqls")
- self.writeSQLTupel(newSQLs,pcdatum)
+ self.writeSQLTupel(newSQLs, pcdatum)
_moduleLogger.info("doSync wrote "+str(len(newSQLs))+" sqls")
_moduleLogger.info("doSync sending "+str(len(rows))+" sqls")
- i=0
return rows
def getRemoteSyncUUID(self):
return self.sync_uuid
- def startServer(self, widget, data=None):
+ @gtk_toolbox.log_exception(_moduleLogger)
+ def startServer(self, widget, data = None):
#Starte RPCServer
- self.db.speichereDirekt("syncServerIP",self.comboIP.get_child().get_text())
+ self.db.speichereDirekt("syncServerIP", self.comboIP.get_child().get_text())
- if (widget.get_active()==True):
+ if (widget.get_active() == True):
_moduleLogger.info("Starting Server")
try:
- ip=self.comboIP.get_child().get_text()
- self.rpcserver = SimpleXMLRPCServer((ip, self.port),allow_none=True)
+ ip = self.comboIP.get_child().get_text()
+ self.rpcserver = SimpleXMLRPCServer((ip, self.port), allow_none = True)
self.rpcserver.register_function(pow)
self.rpcserver.register_function(self.getLastSyncDate)
self.rpcserver.register_function(self.doSync)
self.rpcserver.register_function(self.getRemoteSyncUUID)
self.rpcserver.register_function(self.doSaveFinalTime)
self.rpcserver.register_function(self.pulse)
- self.poll=select.poll()
+ self.poll = select.poll()
self.poll.register(self.rpcserver.fileno())
gobject.timeout_add(1000, self.handleRPC)
self.syncServerStatusLabel.set_text(_("Syncserver running..."))
#save
- self.db.speichereDirekt("startSyncServer",True)
+ self.db.speichereDirekt("startSyncServer", True)
except:
- s=str(sys.exc_info())
+ s = str(sys.exc_info())
_moduleLogger.error("libsync: could not start server. Error: "+s)
- mbox=gtk.MessageDialog(None,gtk.DIALOG_MODAL,gtk.MESSAGE_ERROR,gtk.BUTTONS_OK,_("Sync server could not start. Please check IP and port.")) #gtk.DIALOG_MODAL
+ mbox = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_ERROR, gtk.BUTTONS_OK, _("Sync server could not start. Please check IP and port.")) #gtk.DIALOG_MODAL
mbox.set_modal(False)
- response=mbox.run()
+ response = mbox.run()
mbox.hide()
mbox.destroy()
widget.set_active(False)
pass
self.syncServerStatusLabel.set_text(_("Syncserver not running..."))
#save
- self.db.speichereDirekt("startSyncServer",False)
+ self.db.speichereDirekt("startSyncServer", False)
- def doSaveFinalTime(self,sync_uuid,pcdatum=None):
- if (pcdatum==None): pcdatum=int(time.time())
+ def doSaveFinalTime(self, sync_uuid, pcdatum = None):
+ if pcdatum is None:
+ pcdatum = int(time.time())
if (time.time()>pcdatum):
- pcdatum=int(time.time()) #größere Zeit nehmen
+ pcdatum = int(time.time()) #größere Zeit nehmen
self.pulse()
#fime save time+uuid
- sql="DELETE FROM sync WHERE uuid=?"
- self.db.speichereSQL(sql,(sync_uuid,),log=False)
- sql="INSERT INTO sync (syncpartner,uuid,pcdatum) VALUES (?,?,?)"
- self.db.speichereSQL(sql,("x",str(sync_uuid),pcdatum),log=False)
+ sql = "DELETE FROM sync WHERE uuid = ?"
+ self.db.speichereSQL(sql, (sync_uuid, ), log = False)
+ sql = "INSERT INTO sync (syncpartner, uuid, pcdatum) VALUES (?, ?, ?)"
+ self.db.speichereSQL(sql, ("x", str(sync_uuid), pcdatum), log = False)
self.pulse()
- self.changeSyncStatus(False,_("no sync process (at the moment)"))
- return (self.sync_uuid,pcdatum)
+ self.changeSyncStatus(False, _("no sync process (at the moment)"))
+ return (self.sync_uuid, pcdatum)
- def syncButton(self, widget, data=None):
+ @gtk_toolbox.log_exception(_moduleLogger)
+ def syncButton(self, widget, data = None):
_moduleLogger.info("Syncing")
- #sql="DELETE FROM logtable WHERE sql LIKE externeStundenplanung"
+ #sql = "DELETE FROM logtable WHERE sql LIKE externeStundenplanung"
#self.db.speichereSQL(sql)
- self.changeSyncStatus(True,_("sync process running"))
+ self.changeSyncStatus(True, _("sync process running"))
while (gtk.events_pending()):
- gtk.main_iteration();
+ gtk.main_iteration()
- self.db.speichereDirekt("syncRemoteIP",self.comboRemoteIP.get_child().get_text())
+ self.db.speichereDirekt("syncRemoteIP", self.comboRemoteIP.get_child().get_text())
try:
- self.server = xmlrpclib.ServerProxy("http://"+self.comboRemoteIP.get_child().get_text()+":"+str(self.port),allow_none=True)
- #lastDate=server.getLastSyncDate(str(self.sync_uuid))
- server_sync_uuid=self.server.getRemoteSyncUUID()
- lastDate=self.getLastSyncDate(str(server_sync_uuid))
+ self.server = xmlrpclib.ServerProxy("http://"+self.comboRemoteIP.get_child().get_text()+":"+str(self.port), allow_none = True)
+ #lastDate = server.getLastSyncDate(str(self.sync_uuid))
+ server_sync_uuid = self.server.getRemoteSyncUUID()
+ lastDate = self.getLastSyncDate(str(server_sync_uuid))
#print ("LastSyncDate: "+str(lastDate)+" Now: "+str(int(time.time())))
- sql="SELECT * FROM logtable WHERE pcdatum>?"
- rows=self.db.ladeSQL(sql,(lastDate,))
+ sql = "SELECT * FROM logtable WHERE pcdatum>?"
+ rows = self.db.ladeSQL(sql, (lastDate, ))
_moduleLogger.info("loaded concerned rows")
- newSQLs=self.server.doSync(self.sync_uuid,lastDate,rows,time.time())
+ newSQLs = self.server.doSync(self.sync_uuid, lastDate, rows, time.time())
_moduleLogger.info("did do sync, processing sqls now")
- if newSQLs!=-1:
- self.writeSQLTupel(newSQLs,lastDate)
+ if newSQLs != -1:
+ self.writeSQLTupel(newSQLs, lastDate)
- sync_uuid, finalpcdatum=self.server.doSaveFinalTime(self.sync_uuid)
+ sync_uuid, finalpcdatum = self.server.doSaveFinalTime(self.sync_uuid)
self.doSaveFinalTime(sync_uuid, finalpcdatum)
- self.changeSyncStatus(False,_("no sync process (at the moment)"))
+ self.changeSyncStatus(False, _("no sync process (at the moment)"))
- mbox = gtk.MessageDialog(None,gtk.DIALOG_MODAL,gtk.MESSAGE_INFO,gtk.BUTTONS_OK,_("Synchronization successfully completed"))
+ mbox = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_INFO, gtk.BUTTONS_OK, _("Synchronization successfully completed"))
response = mbox.run()
mbox.hide()
mbox.destroy()
else:
_moduleLogger.warning("Zeitdiff zu groß/oder anderer db-Fehler")
- self.changeSyncStatus(False,_("no sync process (at the moment)"))
- mbox = gtk.MessageDialog(None,gtk.DIALOG_MODAL,gtk.MESSAGE_INFO,gtk.BUTTONS_OK,_("The clocks are not synchronized between stations"))
+ self.changeSyncStatus(False, _("no sync process (at the moment)"))
+ mbox = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_INFO, gtk.BUTTONS_OK, _("The clocks are not synchronized between stations"))
response = mbox.run()
mbox.hide()
mbox.destroy()
except:
- _moduleLogger.warning("Sync connect failed")
- self.changeSyncStatus(False,_("no sync process (at the moment)"))
- mbox = gtk.MessageDialog(None,gtk.DIALOG_MODAL,gtk.MESSAGE_INFO,gtk.BUTTONS_OK,_("Sync failed, reason: ")+unicode(sys.exc_info()[1][1]))
- response = mbox.run()
- mbox.hide()
- mbox.destroy()
- self.server=None
- self.server=None
+ _moduleLogger.warning("Sync connect failed")
+ self.changeSyncStatus(False, _("no sync process (at the moment)"))
+ mbox = gtk.MessageDialog(None, gtk.DIALOG_MODAL, gtk.MESSAGE_INFO, gtk.BUTTONS_OK, _("Sync failed, reason: ")+unicode(sys.exc_info()[1][1]))
+ response = mbox.run()
+ mbox.hide()
+ mbox.destroy()
+ self.server = None
+ self.server = None
projects / multilist / blobdiff