data_agent.py 文件源码

def localJsonReport(self):
        import platform
        if platform.system() == 'Windows':
            rep_port = self.conf.get('report','local_json_port')
            server = StreamServer(('127.0.0.1', rep_port), self.processJsonRep)
            server.serve_forever()
        else:
            from libs.unixSocket import bind_unix_listener
            unix_sock_name = os.path.join(_agentBasePath,'localJsonReport.sock')
            server = StreamServer(bind_unix_listener(unix_sock_name), self.processJsonRep)
            os.chmod(unix_sock_name, 0o777)
            server.serve_forever()

    # ???????????
    #@profile