service.py 文件源码

def _init(cls,tid,initcode=True):
        try:
            tid=int(tid)
            result=yield  run_conn_fun("runQuery","select ip,svnpath,svnuser,svnpasswd,version,rule    from   cron_task WHERE  tid=%s",(tid,))
            ip,svnpath,svnuser,svnpasswd,svnversion,rule=result[0]
            if  initcode==True:
                _defer =SubRpc().xmlrpc_init(int(tid),svnpath,int(svnversion),svnuser,svnpasswd)
                set_time_out(2,_defer)
                try:
                    yield  _defer
                except defer.CancelledError :
                    pass
            else:
                pass
            if not  cls.BUFF.has_key(tid):
                pass
            else:
                if cls.BUFF[tid].running:
                    cls.BUFF[tid].stop()
            schedule=CronSchedule(rule)
            sc=ScheduledCall(cls._run,tid)
            sc.start(schedule)
            cls.BUFF[tid]=sc
            defer.returnValue(True)
        except Exception as e:
            defer.returnValue((False,str(e)))