nodes.py 文件源码

def connect(self):
        if self._node["type"] == "tcp":
            reactor.connectTCP(self._node["host"], self._node["port"], self)
        elif self._node["type"] == "unix":
            reactor.connectUNIX(self._node["addr"], self)
        else:
            log.err("Unknown connect type")

        self.getRootObject().addCallback(self._proxy.insert, self._node["name"])