vservice.py 文件源码

def __init__(self, task_id, cid, vservice):
        """Constructor"""
        self._task_id = task_id
        self._cid = cid
        self._vservice = vservice
        assert isinstance(self._vservice, VService)
        self._conn = vservice.get_conn_by_cid(cid)

        # pri attrs
        self._result = None
        self._ack_flag = False
        self._STATE = client.TASK_STATE_PENDING
        self._retry_times = 0
        self._waitingack = False

        #
        # looping call to ack
        #
        self._loopingcall_ack = LoopingCall(self._checking_ack)

    #----------------------------------------------------------------------