service.py 文件源码

def _init(cls,tid,initcode=True):
        try:
            tid=int(tid)
            result=yield  run_conn_fun("runQuery","select ip,svnpath,svnuser,svnpasswd,version      from   task_task WHERE  tid=%s",(tid,))
            ip,svnpath,svnuser,svnpasswd,svnversion =result[0]
            if  initcode==True:
                _defer =SubRpc().xmlrpc_init(tid,svnpath,svnversion,svnuser,svnpasswd,mode="task")
                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()
                else:
                    pass
                del cls.BUFF[tid]
            _task=task.LoopingCall(cls._check,tid)
            _task.start(60,now=False)  #??????
            yield  cls._check(tid)
            cls.BUFF[tid]=_task
            defer.returnValue(True)
        except Exception as e:
            defer.returnValue((False,str(e)))