diff options
Diffstat (limited to 'Testcases/cfgm_common/uve/cfgm_cpuinfo')
42 files changed, 3367 insertions, 0 deletions
diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.py diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.pyc Binary files differnew file mode 100644 index 0000000..8d74650 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/__init__.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.html new file mode 100644 index 0000000..166887a --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.html @@ -0,0 +1,14 @@ +<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" + "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> +<html xmlns="http://www.w3.org/1999/xhtml"> +<head> +<meta http-equiv="Content-Type" content="text/html;charset=utf-8" /> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>Module: cfgm_cpuinfo</title></head><body> +<h1>Module: cfgm_cpuinfo</h1> +<table><tr><th>Module</th><th>Sandeshs</th></tr> +<tr> +<td>cfgm_cpuinfo</td><td></td></tr> +</table> +<hr/><h2 id="Sandeshs"></h2> +</body></html>
diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.xml b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.xml new file mode 100644 index 0000000..da831a3 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cfgm_cpuinfo.xml @@ -0,0 +1,3 @@ +<?xml-stylesheet type="text/xsl" href="/universal_parse.xsl"?> +<cfgm_cpuinfo type="rlist"> +</cfgm_cpuinfo> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.py new file mode 100644 index 0000000..aadd78e --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException +from ttypes import * + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.pyc Binary files differnew file mode 100644 index 0000000..9d1a5e5 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/constants.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.pyc Binary files differnew file mode 100644 index 0000000..1446e7d --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/__init__.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.py new file mode 100644 index 0000000..aadd78e --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.py @@ -0,0 +1,12 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException +from ttypes import * + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.pyc Binary files differnew file mode 100644 index 0000000..453ec8d --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/constants.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.html new file mode 100644 index 0000000..f2fb672 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.html @@ -0,0 +1,18 @@ +<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" + "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> +<html xmlns="http://www.w3.org/1999/xhtml"> +<head> +<meta http-equiv="Content-Type" content="text/html;charset=utf-8" /> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>Module: cpuinfo</title></head><body> +<h1>Module: cpuinfo</h1> +<table><tr><th>Module</th><th>Sandeshs</th></tr> +<tr> +<td>cpuinfo</td><td><a href="cpuinfo.html#Snh_CpuLoadInfoReq">CpuLoadInfoReq</a><br/> +</td></tr> +</table> +<hr/><h2 id="Sandeshs"></h2> +<div class="definition"><h3 id="Snh_CpuLoadInfoReq">CpuLoadInfoReq</h3> +<form action="Snh_CpuLoadInfoReq" method="get"> +<table><tr><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Value</th></tr> +</table><button type="submit">Send</button></form><br/></div></body></html>
diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.xml b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.xml new file mode 100644 index 0000000..d3a129b --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/cpuinfo.xml @@ -0,0 +1,5 @@ +<?xml-stylesheet type="text/xsl" href="/universal_parse.xsl"?> +<cpuinfo type="rlist"> +<CpuLoadInfoReq type="sandesh"> +</CpuLoadInfoReq> +</cpuinfo> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.py new file mode 100644 index 0000000..e48bba8 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.py @@ -0,0 +1,15 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +import ttypes + +_HTTP_REQUEST_LIST = [ +{ 'uri':'/Snh_CpuLoadInfoReq', 'method':ttypes.CpuLoadInfoReq.handle_http_request }, +] + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.pyc Binary files differnew file mode 100644 index 0000000..c013398 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/http_request.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/index.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/index.html new file mode 100644 index 0000000..a338214 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/index.html @@ -0,0 +1,10 @@ +<html><head> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>All Thrift declarations</title></head><body> +<h1>All Thrift declarations</h1> +<table><tr><th>Module</th><th>Services</th><th>Sandeshs</th><th>Data types</th><th>Constants</th></tr> +<tr> +<td>cpuinfo</td><td><a href="cpuinfo.html#Snh_CpuLoadInfoReq">CpuLoadInfoReq</a><br/> +</td></tr> +</table> +</body></html> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.py new file mode 100644 index 0000000..22463de --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.py @@ -0,0 +1,25 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + + +# This autogenerated skeleton file illustrates the implementation of +# derived class to handle the sandesh request. + + +# Create a derived class from "CpuLoadInfoReq" to handle +# the sandesh request. Add this derived class "CpuLoadInfoReq_derived" +# in module CpuLoadInfoReq_derived.py and add it in your package + +class CpuLoadInfoReq_derived(CpuLoadInfoReq): + + + def handle_request(self): + # Add your code to handle the "CpuLoadInfoReq" request + pass + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.pyc Binary files differnew file mode 100644 index 0000000..d8eb2c1 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/request_skeleton.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/style.css b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/style.css new file mode 100644 index 0000000..6dc2f22 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/style.css @@ -0,0 +1,10 @@ +/* Auto-generated CSS for generated Thrift docs */ +body { font-family: Tahoma, sans-serif; } +pre { background-color: #dddddd; padding: 6px; } +h3,h4 { padding-top: 0px; margin-top: 0px; } +div.definition { border: 1px solid gray; margin: 10px; padding: 10px; } +div.extends { margin: -0.5em 0 1em 5em } +table { border: 1px solid grey; border-collapse: collapse; } +td { border: 1px solid grey; padding: 1px 6px; vertical-align: top; } +th { border: 1px solid black; background-color: #bbbbbb; + text-align: left; padding: 1px 6px; } diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.py new file mode 100644 index 0000000..fa6ed17 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.py @@ -0,0 +1,960 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException + +from pysandesh.transport import TTransport +from pysandesh.protocol import TBinaryProtocol, TProtocol +try: + from pysandesh.protocol import fastbinary +except: + fastbinary = None + +import cStringIO +import uuid +import bottle +from pysandesh import sandesh_base +from pysandesh.sandesh_http import SandeshHttp +from pysandesh.sandesh_uve import SandeshUVETypeMaps +from pysandesh.util import UTCTimestampUsec, UTCTimestampUsecToString +from pysandesh.gen_py.sandesh.constants import * + + + +class CpuLoadAvg(object): + """ + Attributes: + - one_min_avg + - five_min_avg + - fifteen_min_avg + """ + + thrift_spec = ( + None, # 0 + (1, TType.DOUBLE, 'one_min_avg', None, None, ), # 1 + (2, TType.DOUBLE, 'five_min_avg', None, None, ), # 2 + (3, TType.DOUBLE, 'fifteen_min_avg', None, None, ), # 3 + ) + + def __init__(self, one_min_avg=None, five_min_avg=None, fifteen_min_avg=None,): + self.one_min_avg = one_min_avg + self.five_min_avg = five_min_avg + self.fifteen_min_avg = fifteen_min_avg + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.DOUBLE: + (length, self.one_min_avg) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.DOUBLE: + (length, self.five_min_avg) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.DOUBLE: + (length, self.fifteen_min_avg) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('CpuLoadAvg') < 0: return -1 + if self.one_min_avg is not None: + annotations = {} + if oprot.writeFieldBegin('one_min_avg', TType.DOUBLE, 1, annotations) < 0: return -1 + if oprot.writeDouble(self.one_min_avg) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.five_min_avg is not None: + annotations = {} + if oprot.writeFieldBegin('five_min_avg', TType.DOUBLE, 2, annotations) < 0: return -1 + if oprot.writeDouble(self.five_min_avg) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.fifteen_min_avg is not None: + annotations = {} + if oprot.writeFieldBegin('fifteen_min_avg', TType.DOUBLE, 3, annotations) < 0: return -1 + if oprot.writeDouble(self.fifteen_min_avg) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.one_min_avg is not None: + log_str.write('one_min_avg = ') + log_str.write(str(self.one_min_avg)) + log_str.write(' ') + if self.five_min_avg is not None: + log_str.write('five_min_avg = ') + log_str.write(str(self.five_min_avg)) + log_str.write(' ') + if self.fifteen_min_avg is not None: + log_str.write('fifteen_min_avg = ') + log_str.write(str(self.fifteen_min_avg)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class MemInfo(object): + """ + Attributes: + - virt + - peakvirt + - res + """ + + thrift_spec = ( + None, # 0 + (1, TType.U32, 'virt', None, None, ), # 1 + (2, TType.U32, 'peakvirt', None, None, ), # 2 + (3, TType.U32, 'res', None, None, ), # 3 + ) + + def __init__(self, virt=None, peakvirt=None, res=None,): + self.virt = virt + self.peakvirt = peakvirt + self.res = res + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.U32: + (length, self.virt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.U32: + (length, self.peakvirt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.U32: + (length, self.res) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('MemInfo') < 0: return -1 + if self.virt is not None: + annotations = {} + if oprot.writeFieldBegin('virt', TType.U32, 1, annotations) < 0: return -1 + if oprot.writeU32(self.virt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.peakvirt is not None: + annotations = {} + if oprot.writeFieldBegin('peakvirt', TType.U32, 2, annotations) < 0: return -1 + if oprot.writeU32(self.peakvirt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.res is not None: + annotations = {} + if oprot.writeFieldBegin('res', TType.U32, 3, annotations) < 0: return -1 + if oprot.writeU32(self.res) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.virt is not None: + log_str.write('virt = ') + log_str.write(str(self.virt)) + log_str.write(' ') + if self.peakvirt is not None: + log_str.write('peakvirt = ') + log_str.write(str(self.peakvirt)) + log_str.write(' ') + if self.res is not None: + log_str.write('res = ') + log_str.write(str(self.res)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class SysMemInfo(object): + """ + Attributes: + - total + - used + - free + - buffers + """ + + thrift_spec = ( + None, # 0 + (1, TType.U32, 'total', None, None, ), # 1 + (2, TType.U32, 'used', None, None, ), # 2 + (3, TType.U32, 'free', None, None, ), # 3 + (4, TType.U32, 'buffers', None, None, ), # 4 + ) + + def __init__(self, total=None, used=None, free=None, buffers=None,): + self.total = total + self.used = used + self.free = free + self.buffers = buffers + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.U32: + (length, self.total) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.U32: + (length, self.used) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.U32: + (length, self.free) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.U32: + (length, self.buffers) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('SysMemInfo') < 0: return -1 + if self.total is not None: + annotations = {} + if oprot.writeFieldBegin('total', TType.U32, 1, annotations) < 0: return -1 + if oprot.writeU32(self.total) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.used is not None: + annotations = {} + if oprot.writeFieldBegin('used', TType.U32, 2, annotations) < 0: return -1 + if oprot.writeU32(self.used) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.free is not None: + annotations = {} + if oprot.writeFieldBegin('free', TType.U32, 3, annotations) < 0: return -1 + if oprot.writeU32(self.free) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.buffers is not None: + annotations = {} + if oprot.writeFieldBegin('buffers', TType.U32, 4, annotations) < 0: return -1 + if oprot.writeU32(self.buffers) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.total is not None: + log_str.write('total = ') + log_str.write(str(self.total)) + log_str.write(' ') + if self.used is not None: + log_str.write('used = ') + log_str.write(str(self.used)) + log_str.write(' ') + if self.free is not None: + log_str.write('free = ') + log_str.write(str(self.free)) + log_str.write(' ') + if self.buffers is not None: + log_str.write('buffers = ') + log_str.write(str(self.buffers)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class CpuLoadInfo(object): + """ + Attributes: + - num_cpu + - sys_mem_info + - meminfo + - cpuload + - cpu_share + """ + + thrift_spec = ( + None, # 0 + (1, TType.U32, 'num_cpu', None, None, ), # 1 + (2, TType.STRUCT, 'meminfo', (MemInfo, MemInfo.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'cpuload', (CpuLoadAvg, CpuLoadAvg.thrift_spec), None, ), # 3 + (4, TType.DOUBLE, 'cpu_share', None, None, ), # 4 + (5, TType.STRUCT, 'sys_mem_info', (SysMemInfo, SysMemInfo.thrift_spec), None, ), # 5 + ) + + def __init__(self, num_cpu=None, sys_mem_info=None, meminfo=None, cpuload=None, cpu_share=None,): + self.num_cpu = num_cpu + self.sys_mem_info = sys_mem_info + self.meminfo = meminfo + self.cpuload = cpuload + self.cpu_share = cpu_share + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.U32: + (length, self.num_cpu) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRUCT: + self.sys_mem_info = SysMemInfo() + read_cnt += self.sys_mem_info.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.meminfo = MemInfo() + read_cnt += self.meminfo.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.cpuload = CpuLoadAvg() + read_cnt += self.cpuload.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.DOUBLE: + (length, self.cpu_share) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('CpuLoadInfo') < 0: return -1 + if self.num_cpu is not None: + annotations = {} + if oprot.writeFieldBegin('num_cpu', TType.U32, 1, annotations) < 0: return -1 + if oprot.writeU32(self.num_cpu) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.meminfo is not None: + annotations = {} + if oprot.writeFieldBegin('meminfo', TType.STRUCT, 2, annotations) < 0: return -1 + if self.meminfo.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpuload is not None: + annotations = {} + if oprot.writeFieldBegin('cpuload', TType.STRUCT, 3, annotations) < 0: return -1 + if self.cpuload.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpu_share is not None: + annotations = {} + if oprot.writeFieldBegin('cpu_share', TType.DOUBLE, 4, annotations) < 0: return -1 + if oprot.writeDouble(self.cpu_share) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.sys_mem_info is not None: + annotations = {} + if oprot.writeFieldBegin('sys_mem_info', TType.STRUCT, 5, annotations) < 0: return -1 + if self.sys_mem_info.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.num_cpu is not None: + log_str.write('num_cpu = ') + log_str.write(str(self.num_cpu)) + log_str.write(' ') + if self.sys_mem_info is not None: + log_str.write('sys_mem_info = ') + log_str.write('<< ') + log_str.write(self.sys_mem_info.log()) + log_str.write('>>') + log_str.write(' ') + if self.meminfo is not None: + log_str.write('meminfo = ') + log_str.write('<< ') + log_str.write(self.meminfo.log()) + log_str.write('>>') + log_str.write(' ') + if self.cpuload is not None: + log_str.write('cpuload = ') + log_str.write('<< ') + log_str.write(self.cpuload.log()) + log_str.write('>>') + log_str.write(' ') + if self.cpu_share is not None: + log_str.write('cpu_share = ') + log_str.write(str(self.cpu_share)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ProcessCpuInfo(object): + """ + Attributes: + - module_id + - inst_id + - mem_virt + - cpu_share + - mem_res + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'module_id', None, None, ), # 1 + (2, TType.STRING, 'inst_id', None, None, ), # 2 + (3, TType.U32, 'mem_virt', None, None, ), # 3 + (4, TType.DOUBLE, 'cpu_share', None, None, ), # 4 + (5, TType.U32, 'mem_res', None, None, ), # 5 + ) + + def __init__(self, module_id=None, inst_id=None, mem_virt=None, cpu_share=None, mem_res=None,): + self.module_id = module_id + self.inst_id = inst_id + self.mem_virt = mem_virt + self.cpu_share = cpu_share + self.mem_res = mem_res + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.module_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.inst_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.U32: + (length, self.mem_virt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.DOUBLE: + (length, self.cpu_share) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.U32: + (length, self.mem_res) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ProcessCpuInfo') < 0: return -1 + if self.module_id is not None: + annotations = {} + if oprot.writeFieldBegin('module_id', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.module_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.inst_id is not None: + annotations = {} + if oprot.writeFieldBegin('inst_id', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.inst_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.mem_virt is not None: + annotations = {} + if oprot.writeFieldBegin('mem_virt', TType.U32, 3, annotations) < 0: return -1 + if oprot.writeU32(self.mem_virt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpu_share is not None: + annotations = {} + if oprot.writeFieldBegin('cpu_share', TType.DOUBLE, 4, annotations) < 0: return -1 + if oprot.writeDouble(self.cpu_share) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.mem_res is not None: + annotations = {} + if oprot.writeFieldBegin('mem_res', TType.U32, 5, annotations) < 0: return -1 + if oprot.writeU32(self.mem_res) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.module_id is not None: + log_str.write('module_id = ') + log_str.write(self.module_id) + log_str.write(' ') + if self.inst_id is not None: + log_str.write('inst_id = ') + log_str.write(self.inst_id) + log_str.write(' ') + if self.mem_virt is not None: + log_str.write('mem_virt = ') + log_str.write(str(self.mem_virt)) + log_str.write(' ') + if self.cpu_share is not None: + log_str.write('cpu_share = ') + log_str.write(str(self.cpu_share)) + log_str.write(' ') + if self.mem_res is not None: + log_str.write('mem_res = ') + log_str.write(str(self.mem_res)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class CpuLoadInfoReq(sandesh_base.SandeshRequest): + + thrift_spec = ( + ) + + def __init__(self, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshRequest.__init__(self) + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 2471203225 + self._hints = 0 + + @staticmethod + def handle_http_request(sandesh=sandesh_base.sandesh_global): + sandesh_req = CpuLoadInfoReq() + if not sandesh_req: + return SandeshHttp.http_error('Sandesh Request "CpuLoadInfoReq" not implemented') + sandesh_req._context = bottle.request.url + handle_req_fn = getattr(sandesh_req, "handle_request", None) + if callable(handle_req_fn): + handle_req_fn(sandesh_req) + else: + return SandeshHttp.http_error('Sandesh Request "CpuLoadInfoReq" not implemented') + resp = SandeshHttp.get_http_response() + if resp: + return resp + else: + return SandeshHttp.http_error('No Response for Sandesh Request "CpuLoadInfoReq"') + + def log(self, trace=False): + log_str = cStringIO.StringIO() + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('CpuLoadInfoReq') < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class CpuLoadInfoResp(sandesh_base.SandeshResponse): + + thrift_spec = ( + (0, TType.BOOL, 'more', None, None, ), # 0 + (1, TType.STRUCT, 'cpu_info', (CpuLoadInfo, CpuLoadInfo.thrift_spec), None, ), # 1 + ) + + def __init__(self, cpu_info=None, more=None, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshResponse.__init__(self) + self.cpu_info = cpu_info + self.more = more + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 4227955829 + self._hints = 0 + + def log(self, trace=False): + log_str = cStringIO.StringIO() + if trace: + log_str.write(str(self._timestamp)) + log_str.write(' ') + log_str.write('CpuLoadInfoResp: ') + if self.cpu_info is not None: + log_str.write('cpu_info = ') + log_str.write('<< ') + log_str.write(self.cpu_info.log()) + log_str.write('>>') + log_str.write(' ') + if self.more is not None: + log_str.write('more = ') + if self.more: + log_str.write('True') + else: + log_str.write('False') + log_str.write(' ') + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.cpu_info = CpuLoadInfo() + read_cnt += self.cpu_info.read(iprot) + else: + iprot.skip(ftype) + elif fid == 0: + if ftype == TType.BOOL: + (length, self.more) = iprot.readBool(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('CpuLoadInfoResp') < 0: return -1 + if self.more is not None: + annotations = {} + if oprot.writeFieldBegin('more', TType.BOOL, 0, annotations) < 0: return -1 + if oprot.writeBool(self.more) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpu_info is not None: + annotations = {} + if oprot.writeFieldBegin('cpu_info', TType.STRUCT, 1, annotations) < 0: return -1 + if self.cpu_info.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + if self.more != other.more: + return False + if self.cpu_info != other.cpu_info: + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + + +_SANDESH_REQUEST_LIST = [ +'CpuLoadInfoReq', +] + + +_SANDESH_UVE_LIST = [ +] + + +_SANDESH_UVE_DATA_LIST = [ +] + + +_SANDESH_ALARM_LIST = [ +] + + +_SANDESH_ALARM_DATA_LIST = [ +] diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.pyc Binary files differnew file mode 100644 index 0000000..5cffc67 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/cpuinfo/ttypes.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.py new file mode 100644 index 0000000..8baea4f --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.py @@ -0,0 +1,14 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +import ttypes + +_HTTP_REQUEST_LIST = [ +] + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.pyc Binary files differnew file mode 100644 index 0000000..8dec371 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/http_request.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/index.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/index.html new file mode 100644 index 0000000..d9836a6 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/index.html @@ -0,0 +1,14 @@ +<html><head> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>All Thrift declarations</title></head><body> +<h1>All Thrift declarations</h1> +<table><tr><th>Module</th><th>Services</th><th>Sandeshs</th><th>Data types</th><th>Constants</th></tr> +<tr> +<td>cfgm_cpuinfo</td><td></td></tr> +<tr> +<td>cpuinfo</td><td><a href="cpuinfo.html#Snh_CpuLoadInfoReq">CpuLoadInfoReq</a><br/> +</td></tr> +<tr> +<td>process_info</td><td></td></tr> +</table> +</body></html> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.pyc Binary files differnew file mode 100644 index 0000000..34a8d06 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/__init__.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.py new file mode 100644 index 0000000..561413e --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.py @@ -0,0 +1,33 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException +from ttypes import * + +ConnectionTypeNames = { + 0 : "Test", + 1 : "IFMap", + 2 : "XMPP", + 3 : "Collector", + 4 : "Database", + 5 : "Redis", + 6 : "Zookeeper", + 7 : "Discovery", + 8 : "ApiServer", + 9 : "ToR", +} +ConnectionStatusNames = { + 0 : "Initializing", + 1 : "Down", + 2 : "Up", +} +ProcessStateNames = { + 0 : "Functional", + 1 : "Non-Functional", +} diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.pyc Binary files differnew file mode 100644 index 0000000..a13a91f --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/constants.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.py new file mode 100644 index 0000000..8baea4f --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.py @@ -0,0 +1,14 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +import ttypes + +_HTTP_REQUEST_LIST = [ +] + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.pyc Binary files differnew file mode 100644 index 0000000..4348a49 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/http_request.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/index.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/index.html new file mode 100644 index 0000000..9550828 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/index.html @@ -0,0 +1,9 @@ +<html><head> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>All Thrift declarations</title></head><body> +<h1>All Thrift declarations</h1> +<table><tr><th>Module</th><th>Services</th><th>Sandeshs</th><th>Data types</th><th>Constants</th></tr> +<tr> +<td>process_info</td><td></td></tr> +</table> +</body></html> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.html b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.html new file mode 100644 index 0000000..2a1230f --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.html @@ -0,0 +1,13 @@ +<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" + "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> +<html xmlns="http://www.w3.org/1999/xhtml"> +<head> +<meta http-equiv="Content-Type" content="text/html;charset=utf-8" /> +<link href="style.css" rel="stylesheet" type="text/css"/> +<title>Module: process_info</title></head><body> +<h1>Module: process_info</h1> +<table><tr><th>Module</th><th>Sandeshs</th></tr> +<tr> +<td>process_info</td><td></td></tr> +</table> +</body></html>
diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.xml b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.xml new file mode 100644 index 0000000..ed715d3 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/process_info.xml @@ -0,0 +1,3 @@ +<?xml-stylesheet type="text/xsl" href="/universal_parse.xsl"?> +<process_info type="rlist"> +</process_info> diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.py new file mode 100644 index 0000000..99c1196 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.py @@ -0,0 +1,13 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + + +# This autogenerated skeleton file illustrates the implementation of +# derived class to handle the sandesh request. + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.pyc Binary files differnew file mode 100644 index 0000000..11f0c97 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/request_skeleton.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/style.css b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/style.css new file mode 100644 index 0000000..6dc2f22 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/style.css @@ -0,0 +1,10 @@ +/* Auto-generated CSS for generated Thrift docs */ +body { font-family: Tahoma, sans-serif; } +pre { background-color: #dddddd; padding: 6px; } +h3,h4 { padding-top: 0px; margin-top: 0px; } +div.definition { border: 1px solid gray; margin: 10px; padding: 10px; } +div.extends { margin: -0.5em 0 1em 5em } +table { border: 1px solid grey; border-collapse: collapse; } +td { border: 1px solid grey; padding: 1px 6px; vertical-align: top; } +th { border: 1px solid black; background-color: #bbbbbb; + text-align: left; padding: 1px 6px; } diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py new file mode 100644 index 0000000..5c12c29 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py @@ -0,0 +1,854 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException + +from pysandesh.transport import TTransport +from pysandesh.protocol import TBinaryProtocol, TProtocol +try: + from pysandesh.protocol import fastbinary +except: + fastbinary = None + +import cStringIO +import uuid +import bottle +from pysandesh import sandesh_base +from pysandesh.sandesh_http import SandeshHttp +from pysandesh.sandesh_uve import SandeshUVETypeMaps +from pysandesh.util import UTCTimestampUsec, UTCTimestampUsecToString +from pysandesh.gen_py.sandesh.constants import * + + +class ConnectionType(object): + TEST = 0 + IFMAP = 1 + XMPP = 2 + COLLECTOR = 3 + DATABASE = 4 + REDIS = 5 + ZOOKEEPER = 6 + DISCOVERY = 7 + APISERVER = 8 + TOR = 9 + + _VALUES_TO_NAMES = { + 0: "TEST", + 1: "IFMAP", + 2: "XMPP", + 3: "COLLECTOR", + 4: "DATABASE", + 5: "REDIS", + 6: "ZOOKEEPER", + 7: "DISCOVERY", + 8: "APISERVER", + 9: "TOR", + } + + _NAMES_TO_VALUES = { + "TEST": 0, + "IFMAP": 1, + "XMPP": 2, + "COLLECTOR": 3, + "DATABASE": 4, + "REDIS": 5, + "ZOOKEEPER": 6, + "DISCOVERY": 7, + "APISERVER": 8, + "TOR": 9, + } + +class ConnectionStatus(object): + INIT = 0 + DOWN = 1 + UP = 2 + + _VALUES_TO_NAMES = { + 0: "INIT", + 1: "DOWN", + 2: "UP", + } + + _NAMES_TO_VALUES = { + "INIT": 0, + "DOWN": 1, + "UP": 2, + } + +class ProcessState(object): + FUNCTIONAL = 0 + NON_FUNCTIONAL = 1 + + _VALUES_TO_NAMES = { + 0: "FUNCTIONAL", + 1: "NON_FUNCTIONAL", + } + + _NAMES_TO_VALUES = { + "FUNCTIONAL": 0, + "NON_FUNCTIONAL": 1, + } + + +class ConnectionInfo(object): + """ + Attributes: + - type + - name + - server_addrs + - status + - description + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'type', None, None, ), # 1 + (2, TType.STRING, 'name', None, None, ), # 2 + (3, TType.LIST, 'server_addrs', (TType.STRING,None), None, ), # 3 + (4, TType.STRING, 'status', None, None, ), # 4 + (5, TType.STRING, 'description', None, None, ), # 5 + ) + + def __init__(self, type=None, name=None, server_addrs=None, status=None, description=None,): + self.type = type + self.name = name + self.server_addrs = server_addrs + self.status = status + self.description = description + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.type) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.server_addrs = [] + (length, _etype3, _size0) = iprot.readListBegin() + read_cnt += length + for _i4 in xrange(_size0): + read_cnt += iprot.readContainerElementBegin() + (length, _elem5) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.server_addrs.append(_elem5) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + (length, self.status) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + (length, self.description) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ConnectionInfo') < 0: return -1 + if self.type is not None: + annotations = {} + if oprot.writeFieldBegin('type', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.type) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.name is not None: + annotations = {} + if oprot.writeFieldBegin('name', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.server_addrs is not None: + annotations = {} + if oprot.writeFieldBegin('server_addrs', TType.LIST, 3, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.server_addrs)) < 0: return -1 + for iter6 in self.server_addrs: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter6) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.status is not None: + annotations = {} + if oprot.writeFieldBegin('status', TType.STRING, 4, annotations) < 0: return -1 + if oprot.writeString(self.status) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.description is not None: + annotations = {} + if oprot.writeFieldBegin('description', TType.STRING, 5, annotations) < 0: return -1 + if oprot.writeString(self.description) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.type is not None: + log_str.write('type = ') + log_str.write(self.type) + log_str.write(' ') + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.server_addrs is not None: + log_str.write('server_addrs = ') + log_str.write('[ ') + for iter7 in self.server_addrs: + log_str.write(iter7) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.status is not None: + log_str.write('status = ') + log_str.write(self.status) + log_str.write(' ') + if self.description is not None: + log_str.write('description = ') + log_str.write(self.description) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ProcessStatus(object): + """ + Attributes: + - module_id + - instance_id + - state + - connection_infos + - description + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'module_id', None, None, ), # 1 + (2, TType.STRING, 'instance_id', None, None, ), # 2 + (3, TType.STRING, 'state', None, None, ), # 3 + (4, TType.LIST, 'connection_infos', (TType.STRUCT,(ConnectionInfo, ConnectionInfo.thrift_spec)), None, ), # 4 + (5, TType.STRING, 'description', None, None, ), # 5 + ) + + def __init__(self, module_id=None, instance_id=None, state=None, connection_infos=None, description=None,): + self.module_id = module_id + self.instance_id = instance_id + self.state = state + self.connection_infos = connection_infos + self.description = description + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.module_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.instance_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + (length, self.state) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.connection_infos = [] + (length, _etype11, _size8) = iprot.readListBegin() + read_cnt += length + for _i12 in xrange(_size8): + _elem13 = ConnectionInfo() + read_cnt += _elem13.read(iprot) + self.connection_infos.append(_elem13) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + (length, self.description) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ProcessStatus') < 0: return -1 + if self.module_id is not None: + annotations = {} + if oprot.writeFieldBegin('module_id', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.module_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.instance_id is not None: + annotations = {} + if oprot.writeFieldBegin('instance_id', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.instance_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.state is not None: + annotations = {} + if oprot.writeFieldBegin('state', TType.STRING, 3, annotations) < 0: return -1 + if oprot.writeString(self.state) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.connection_infos is not None: + annotations = {} + if oprot.writeFieldBegin('connection_infos', TType.LIST, 4, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.connection_infos)) < 0: return -1 + for iter14 in self.connection_infos: + if iter14.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.description is not None: + annotations = {} + if oprot.writeFieldBegin('description', TType.STRING, 5, annotations) < 0: return -1 + if oprot.writeString(self.description) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.module_id is not None: + log_str.write('module_id = ') + log_str.write(self.module_id) + log_str.write(' ') + if self.instance_id is not None: + log_str.write('instance_id = ') + log_str.write(self.instance_id) + log_str.write(' ') + if self.state is not None: + log_str.write('state = ') + log_str.write(self.state) + log_str.write(' ') + if self.connection_infos is not None: + log_str.write('connection_infos = ') + log_str.write('[ ') + for iter15 in self.connection_infos: + log_str.write('<< ') + log_str.write(iter15.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.description is not None: + log_str.write('description = ') + log_str.write(self.description) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class DiskPartitionUsageStats(object): + """ + Attributes: + - partition_type + - partition_name + - partition_space_used_1k + - partition_space_available_1k + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'partition_type', None, None, ), # 1 + (2, TType.STRING, 'partition_name', None, None, ), # 2 + (3, TType.U64, 'partition_space_used_1k', None, None, ), # 3 + (4, TType.U64, 'partition_space_available_1k', None, None, ), # 4 + ) + + def __init__(self, partition_type=None, partition_name=None, partition_space_used_1k=None, partition_space_available_1k=None,): + self.partition_type = partition_type + self.partition_name = partition_name + self.partition_space_used_1k = partition_space_used_1k + self.partition_space_available_1k = partition_space_available_1k + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.partition_type) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.partition_name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.U64: + (length, self.partition_space_used_1k) = iprot.readU64(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.U64: + (length, self.partition_space_available_1k) = iprot.readU64(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('DiskPartitionUsageStats') < 0: return -1 + if self.partition_type is not None: + annotations = {} + if oprot.writeFieldBegin('partition_type', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.partition_type) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.partition_name is not None: + annotations = {} + if oprot.writeFieldBegin('partition_name', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.partition_name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.partition_space_used_1k is not None: + annotations = {} + if oprot.writeFieldBegin('partition_space_used_1k', TType.U64, 3, annotations) < 0: return -1 + if oprot.writeU64(self.partition_space_used_1k) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.partition_space_available_1k is not None: + annotations = {} + if oprot.writeFieldBegin('partition_space_available_1k', TType.U64, 4, annotations) < 0: return -1 + if oprot.writeU64(self.partition_space_available_1k) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.partition_type is not None: + log_str.write('partition_type = ') + log_str.write(self.partition_type) + log_str.write(' ') + if self.partition_name is not None: + log_str.write('partition_name = ') + log_str.write(self.partition_name) + log_str.write(' ') + if self.partition_space_used_1k is not None: + log_str.write('partition_space_used_1k = ') + log_str.write(str(self.partition_space_used_1k)) + log_str.write(' ') + if self.partition_space_available_1k is not None: + log_str.write('partition_space_available_1k = ') + log_str.write(str(self.partition_space_available_1k)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ProcessInfo(object): + """ + Attributes: + - process_name + - process_state + - start_count + - stop_count + - exit_count + - last_start_time + - last_stop_time + - last_exit_time + - core_file_list + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'process_name', None, None, ), # 1 + (2, TType.STRING, 'process_state', None, None, ), # 2 + (3, TType.U32, 'start_count', None, None, ), # 3 + (4, TType.U32, 'stop_count', None, None, ), # 4 + (5, TType.U32, 'exit_count', None, None, ), # 5 + (6, TType.STRING, 'last_start_time', None, None, ), # 6 + (7, TType.STRING, 'last_stop_time', None, None, ), # 7 + (8, TType.STRING, 'last_exit_time', None, None, ), # 8 + (9, TType.LIST, 'core_file_list', (TType.STRING,None), None, ), # 9 + ) + + def __init__(self, process_name=None, process_state=None, start_count=None, stop_count=None, exit_count=None, last_start_time=None, last_stop_time=None, last_exit_time=None, core_file_list=None,): + self.process_name = process_name + self.process_state = process_state + self.start_count = start_count + self.stop_count = stop_count + self.exit_count = exit_count + self.last_start_time = last_start_time + self.last_stop_time = last_stop_time + self.last_exit_time = last_exit_time + self.core_file_list = core_file_list + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.process_name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + (length, self.process_state) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.U32: + (length, self.start_count) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.U32: + (length, self.stop_count) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.U32: + (length, self.exit_count) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + (length, self.last_start_time) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + (length, self.last_stop_time) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.STRING: + (length, self.last_exit_time) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.LIST: + self.core_file_list = [] + (length, _etype19, _size16) = iprot.readListBegin() + read_cnt += length + for _i20 in xrange(_size16): + read_cnt += iprot.readContainerElementBegin() + (length, _elem21) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.core_file_list.append(_elem21) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ProcessInfo') < 0: return -1 + if self.process_name is not None: + annotations = {} + if oprot.writeFieldBegin('process_name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.process_name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.process_state is not None: + annotations = {} + if oprot.writeFieldBegin('process_state', TType.STRING, 2, annotations) < 0: return -1 + if oprot.writeString(self.process_state) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.start_count is not None: + annotations = {} + if oprot.writeFieldBegin('start_count', TType.U32, 3, annotations) < 0: return -1 + if oprot.writeU32(self.start_count) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.stop_count is not None: + annotations = {} + if oprot.writeFieldBegin('stop_count', TType.U32, 4, annotations) < 0: return -1 + if oprot.writeU32(self.stop_count) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.exit_count is not None: + annotations = {} + if oprot.writeFieldBegin('exit_count', TType.U32, 5, annotations) < 0: return -1 + if oprot.writeU32(self.exit_count) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.last_start_time is not None: + annotations = {} + if oprot.writeFieldBegin('last_start_time', TType.STRING, 6, annotations) < 0: return -1 + if oprot.writeString(self.last_start_time) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.last_stop_time is not None: + annotations = {} + if oprot.writeFieldBegin('last_stop_time', TType.STRING, 7, annotations) < 0: return -1 + if oprot.writeString(self.last_stop_time) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.last_exit_time is not None: + annotations = {} + if oprot.writeFieldBegin('last_exit_time', TType.STRING, 8, annotations) < 0: return -1 + if oprot.writeString(self.last_exit_time) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.core_file_list is not None: + annotations = {} + if oprot.writeFieldBegin('core_file_list', TType.LIST, 9, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.core_file_list)) < 0: return -1 + for iter22 in self.core_file_list: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter22) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.process_name is not None: + log_str.write('process_name = ') + log_str.write(self.process_name) + log_str.write(' ') + if self.process_state is not None: + log_str.write('process_state = ') + log_str.write(self.process_state) + log_str.write(' ') + if self.start_count is not None: + log_str.write('start_count = ') + log_str.write(str(self.start_count)) + log_str.write(' ') + if self.stop_count is not None: + log_str.write('stop_count = ') + log_str.write(str(self.stop_count)) + log_str.write(' ') + if self.exit_count is not None: + log_str.write('exit_count = ') + log_str.write(str(self.exit_count)) + log_str.write(' ') + if self.last_start_time is not None: + log_str.write('last_start_time = ') + log_str.write(self.last_start_time) + log_str.write(' ') + if self.last_stop_time is not None: + log_str.write('last_stop_time = ') + log_str.write(self.last_stop_time) + log_str.write(' ') + if self.last_exit_time is not None: + log_str.write('last_exit_time = ') + log_str.write(self.last_exit_time) + log_str.write(' ') + if self.core_file_list is not None: + log_str.write('core_file_list = ') + log_str.write('[ ') + for iter23 in self.core_file_list: + log_str.write(iter23) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + + +_SANDESH_REQUEST_LIST = [ +] + + +_SANDESH_UVE_LIST = [ +] + + +_SANDESH_UVE_DATA_LIST = [ +] + + +_SANDESH_ALARM_LIST = [ +] + + +_SANDESH_ALARM_DATA_LIST = [ +] diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.pyc Binary files differnew file mode 100644 index 0000000..a07afd4 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.py new file mode 100644 index 0000000..99c1196 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.py @@ -0,0 +1,13 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + + +# This autogenerated skeleton file illustrates the implementation of +# derived class to handle the sandesh request. + diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.pyc Binary files differnew file mode 100644 index 0000000..0ba81c0 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/request_skeleton.pyc diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/style.css b/Testcases/cfgm_common/uve/cfgm_cpuinfo/style.css new file mode 100644 index 0000000..6dc2f22 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/style.css @@ -0,0 +1,10 @@ +/* Auto-generated CSS for generated Thrift docs */ +body { font-family: Tahoma, sans-serif; } +pre { background-color: #dddddd; padding: 6px; } +h3,h4 { padding-top: 0px; margin-top: 0px; } +div.definition { border: 1px solid gray; margin: 10px; padding: 10px; } +div.extends { margin: -0.5em 0 1em 5em } +table { border: 1px solid grey; border-collapse: collapse; } +td { border: 1px solid grey; padding: 1px 6px; vertical-align: top; } +th { border: 1px solid black; background-color: #bbbbbb; + text-align: left; padding: 1px 6px; } diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.py new file mode 100644 index 0000000..ce6e3ae --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.py @@ -0,0 +1,1281 @@ +# +# Autogenerated by Sandesh Compiler (1.0) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py:new_style +# Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. +# + +from pysandesh.Thrift import TType, TMessageType, TException +import cpuinfo.ttypes +import process_info.ttypes + + +from pysandesh.transport import TTransport +from pysandesh.protocol import TBinaryProtocol, TProtocol +try: + from pysandesh.protocol import fastbinary +except: + fastbinary = None + +import cStringIO +import uuid +import bottle +from pysandesh import sandesh_base +from pysandesh.sandesh_http import SandeshHttp +from pysandesh.sandesh_uve import SandeshUVETypeMaps +from pysandesh.util import UTCTimestampUsec, UTCTimestampUsecToString +from pysandesh.gen_py.sandesh.constants import * + + + +class ModuleCpuInfo(object): + """ + Attributes: + - module_id + - cpu_info + - instance_id + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'module_id', None, None, ), # 1 + (2, TType.STRUCT, 'cpu_info', (cpuinfo.ttypes.CpuLoadInfo, cpuinfo.ttypes.CpuLoadInfo.thrift_spec), None, ), # 2 + (3, TType.STRING, 'instance_id', None, None, ), # 3 + ) + + def __init__(self, module_id=None, cpu_info=None, instance_id=None,): + self.module_id = module_id + self.cpu_info = cpu_info + self.instance_id = instance_id + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.module_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.cpu_info = cpuinfo.ttypes.CpuLoadInfo() + read_cnt += self.cpu_info.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + (length, self.instance_id) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ModuleCpuInfo') < 0: return -1 + if self.module_id is not None: + annotations = {} + if oprot.writeFieldBegin('module_id', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.module_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpu_info is not None: + annotations = {} + if oprot.writeFieldBegin('cpu_info', TType.STRUCT, 2, annotations) < 0: return -1 + if self.cpu_info.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.instance_id is not None: + annotations = {} + if oprot.writeFieldBegin('instance_id', TType.STRING, 3, annotations) < 0: return -1 + if oprot.writeString(self.instance_id) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.module_id is not None: + log_str.write('module_id = ') + log_str.write(self.module_id) + log_str.write(' ') + if self.cpu_info is not None: + log_str.write('cpu_info = ') + log_str.write('<< ') + log_str.write(self.cpu_info.log()) + log_str.write('>>') + log_str.write(' ') + if self.instance_id is not None: + log_str.write('instance_id = ') + log_str.write(self.instance_id) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ModuleCpuState(object): + """ + Attributes: + - name + - deleted + - module_cpu_info + - build_info + - config_node_ip + - api_server_cpu_share + - schema_xmer_cpu_share + - service_monitor_cpu_share + - api_server_mem_virt + - schema_xmer_mem_virt + - service_monitor_mem_virt + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'deleted', None, None, ), # 2 + (3, TType.LIST, 'module_cpu_info', (TType.STRUCT,(ModuleCpuInfo, ModuleCpuInfo.thrift_spec)), None, ), # 3 + (4, TType.STRING, 'build_info', None, None, ), # 4 + (5, TType.LIST, 'config_node_ip', (TType.STRING,None), None, ), # 5 + (6, TType.DOUBLE, 'api_server_cpu_share', None, None, ), # 6 + (7, TType.DOUBLE, 'schema_xmer_cpu_share', None, None, ), # 7 + (8, TType.DOUBLE, 'service_monitor_cpu_share', None, None, ), # 8 + (9, TType.U32, 'api_server_mem_virt', None, None, ), # 9 + (10, TType.U32, 'schema_xmer_mem_virt', None, None, ), # 10 + (11, TType.U32, 'service_monitor_mem_virt', None, None, ), # 11 + ) + + def __init__(self, name=None, deleted=None, module_cpu_info=None, build_info=None, config_node_ip=None, api_server_cpu_share=None, schema_xmer_cpu_share=None, service_monitor_cpu_share=None, api_server_mem_virt=None, schema_xmer_mem_virt=None, service_monitor_mem_virt=None,): + self.name = name + self.deleted = deleted + self.module_cpu_info = module_cpu_info + self.build_info = build_info + self.config_node_ip = config_node_ip + self.api_server_cpu_share = api_server_cpu_share + self.schema_xmer_cpu_share = schema_xmer_cpu_share + self.service_monitor_cpu_share = service_monitor_cpu_share + self.api_server_mem_virt = api_server_mem_virt + self.schema_xmer_mem_virt = schema_xmer_mem_virt + self.service_monitor_mem_virt = service_monitor_mem_virt + self._table = 'ObjectConfigNode' + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.BOOL: + (length, self.deleted) = iprot.readBool(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.module_cpu_info = [] + (length, _etype3, _size0) = iprot.readListBegin() + read_cnt += length + for _i4 in xrange(_size0): + _elem5 = ModuleCpuInfo() + read_cnt += _elem5.read(iprot) + self.module_cpu_info.append(_elem5) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + (length, self.build_info) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.config_node_ip = [] + (length, _etype9, _size6) = iprot.readListBegin() + read_cnt += length + for _i10 in xrange(_size6): + read_cnt += iprot.readContainerElementBegin() + (length, _elem11) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.config_node_ip.append(_elem11) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.DOUBLE: + (length, self.api_server_cpu_share) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.DOUBLE: + (length, self.schema_xmer_cpu_share) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.DOUBLE: + (length, self.service_monitor_cpu_share) = iprot.readDouble(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.U32: + (length, self.api_server_mem_virt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.U32: + (length, self.schema_xmer_mem_virt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.U32: + (length, self.service_monitor_mem_virt) = iprot.readU32(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ModuleCpuState') < 0: return -1 + if self.name is not None: + annotations = {} + if self._table is None or self._table is '': return -1 + annotations['key'] = self._table + if oprot.writeFieldBegin('name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.deleted is not None: + annotations = {} + if oprot.writeFieldBegin('deleted', TType.BOOL, 2, annotations) < 0: return -1 + if oprot.writeBool(self.deleted) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.module_cpu_info is not None: + annotations = {} + annotations['aggtype'] = 'union' + if oprot.writeFieldBegin('module_cpu_info', TType.LIST, 3, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.module_cpu_info)) < 0: return -1 + for iter12 in self.module_cpu_info: + if iter12.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.build_info is not None: + annotations = {} + if oprot.writeFieldBegin('build_info', TType.STRING, 4, annotations) < 0: return -1 + if oprot.writeString(self.build_info) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.config_node_ip is not None: + annotations = {} + if oprot.writeFieldBegin('config_node_ip', TType.LIST, 5, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.config_node_ip)) < 0: return -1 + for iter13 in self.config_node_ip: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter13) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.api_server_cpu_share is not None: + annotations = {} + annotations['aggtype'] = 'stats' + if oprot.writeFieldBegin('api_server_cpu_share', TType.DOUBLE, 6, annotations) < 0: return -1 + if oprot.writeDouble(self.api_server_cpu_share) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.schema_xmer_cpu_share is not None: + annotations = {} + annotations['aggtype'] = 'stats' + if oprot.writeFieldBegin('schema_xmer_cpu_share', TType.DOUBLE, 7, annotations) < 0: return -1 + if oprot.writeDouble(self.schema_xmer_cpu_share) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.service_monitor_cpu_share is not None: + annotations = {} + annotations['aggtype'] = 'stats' + if oprot.writeFieldBegin('service_monitor_cpu_share', TType.DOUBLE, 8, annotations) < 0: return -1 + if oprot.writeDouble(self.service_monitor_cpu_share) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.api_server_mem_virt is not None: + annotations = {} + annotations['aggtype'] = 'stats' + annotations['hbin'] = '100000' + if oprot.writeFieldBegin('api_server_mem_virt', TType.U32, 9, annotations) < 0: return -1 + if oprot.writeU32(self.api_server_mem_virt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.schema_xmer_mem_virt is not None: + annotations = {} + annotations['aggtype'] = 'stats' + annotations['hbin'] = '100000' + if oprot.writeFieldBegin('schema_xmer_mem_virt', TType.U32, 10, annotations) < 0: return -1 + if oprot.writeU32(self.schema_xmer_mem_virt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.service_monitor_mem_virt is not None: + annotations = {} + annotations['aggtype'] = 'stats' + annotations['hbin'] = '100000' + if oprot.writeFieldBegin('service_monitor_mem_virt', TType.U32, 11, annotations) < 0: return -1 + if oprot.writeU32(self.service_monitor_mem_virt) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.deleted is not None: + log_str.write('deleted = ') + if self.deleted: + log_str.write('True') + else: + log_str.write('False') + log_str.write(' ') + if self.module_cpu_info is not None: + log_str.write('module_cpu_info = ') + log_str.write('[ ') + for iter14 in self.module_cpu_info: + log_str.write('<< ') + log_str.write(iter14.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.build_info is not None: + log_str.write('build_info = ') + log_str.write(self.build_info) + log_str.write(' ') + if self.config_node_ip is not None: + log_str.write('config_node_ip = ') + log_str.write('[ ') + for iter15 in self.config_node_ip: + log_str.write(iter15) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.api_server_cpu_share is not None: + log_str.write('api_server_cpu_share = ') + log_str.write(str(self.api_server_cpu_share)) + log_str.write(' ') + if self.schema_xmer_cpu_share is not None: + log_str.write('schema_xmer_cpu_share = ') + log_str.write(str(self.schema_xmer_cpu_share)) + log_str.write(' ') + if self.service_monitor_cpu_share is not None: + log_str.write('service_monitor_cpu_share = ') + log_str.write(str(self.service_monitor_cpu_share)) + log_str.write(' ') + if self.api_server_mem_virt is not None: + log_str.write('api_server_mem_virt = ') + log_str.write(str(self.api_server_mem_virt)) + log_str.write(' ') + if self.schema_xmer_mem_virt is not None: + log_str.write('schema_xmer_mem_virt = ') + log_str.write(str(self.schema_xmer_mem_virt)) + log_str.write(' ') + if self.service_monitor_mem_virt is not None: + log_str.write('service_monitor_mem_virt = ') + log_str.write(str(self.service_monitor_mem_virt)) + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ConfigCpuState(object): + """ + Attributes: + - name + - deleted + - cpu_info + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'deleted', None, None, ), # 2 + (3, TType.LIST, 'cpu_info', (TType.STRUCT,(cpuinfo.ttypes.ProcessCpuInfo, cpuinfo.ttypes.ProcessCpuInfo.thrift_spec)), None, ), # 3 + ) + + def __init__(self, name=None, deleted=None, cpu_info=None,): + self.name = name + self.deleted = deleted + self.cpu_info = cpu_info + self._table = 'ObjectConfigNode' + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.BOOL: + (length, self.deleted) = iprot.readBool(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.cpu_info = [] + (length, _etype19, _size16) = iprot.readListBegin() + read_cnt += length + for _i20 in xrange(_size16): + _elem21 = cpuinfo.ttypes.ProcessCpuInfo() + read_cnt += _elem21.read(iprot) + self.cpu_info.append(_elem21) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('ConfigCpuState') < 0: return -1 + if self.name is not None: + annotations = {} + if self._table is None or self._table is '': return -1 + annotations['key'] = self._table + if oprot.writeFieldBegin('name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.deleted is not None: + annotations = {} + if oprot.writeFieldBegin('deleted', TType.BOOL, 2, annotations) < 0: return -1 + if oprot.writeBool(self.deleted) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.cpu_info is not None: + annotations = {} + annotations['aggtype'] = 'union' + annotations['tags'] = '.module_id,.mem_virt,.cpu_share,.mem_res' + if oprot.writeFieldBegin('cpu_info', TType.LIST, 3, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.cpu_info)) < 0: return -1 + for iter22 in self.cpu_info: + if iter22.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.deleted is not None: + log_str.write('deleted = ') + if self.deleted: + log_str.write('True') + else: + log_str.write('False') + log_str.write(' ') + if self.cpu_info is not None: + log_str.write('cpu_info = ') + log_str.write('[ ') + for iter23 in self.cpu_info: + log_str.write('<< ') + log_str.write(iter23.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class NodeStatus(object): + """ + Attributes: + - name + - deleted + - status + - process_status + - process_info + - disk_usage_info + - description + - all_core_file_list + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'deleted', None, None, ), # 2 + (3, TType.STRING, 'status', None, None, ), # 3 + (4, TType.LIST, 'process_status', (TType.STRUCT,(process_info.ttypes.ProcessStatus, process_info.ttypes.ProcessStatus.thrift_spec)), None, ), # 4 + (5, TType.LIST, 'process_info', (TType.STRUCT,(process_info.ttypes.ProcessInfo, process_info.ttypes.ProcessInfo.thrift_spec)), None, ), # 5 + (6, TType.LIST, 'disk_usage_info', (TType.STRUCT,(process_info.ttypes.DiskPartitionUsageStats, process_info.ttypes.DiskPartitionUsageStats.thrift_spec)), None, ), # 6 + (7, TType.STRING, 'description', None, None, ), # 7 + (8, TType.LIST, 'all_core_file_list', (TType.STRING,None), None, ), # 8 + ) + + def __init__(self, name=None, deleted=None, status=None, process_status=None, process_info=None, disk_usage_info=None, description=None, all_core_file_list=None,): + self.name = name + self.deleted = deleted + self.status = status + self.process_status = process_status + self.process_info = process_info + self.disk_usage_info = disk_usage_info + self.description = description + self.all_core_file_list = all_core_file_list + self._table = 'ObjectConfigNode' + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return 0 + read_cnt = 0 + length = iprot.readStructBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + (length, self.name) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.BOOL: + (length, self.deleted) = iprot.readBool(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + (length, self.status) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.process_status = [] + (length, _etype27, _size24) = iprot.readListBegin() + read_cnt += length + for _i28 in xrange(_size24): + _elem29 = process_info.ttypes.ProcessStatus() + read_cnt += _elem29.read(iprot) + self.process_status.append(_elem29) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.process_info = [] + (length, _etype33, _size30) = iprot.readListBegin() + read_cnt += length + for _i34 in xrange(_size30): + _elem35 = process_info.ttypes.ProcessInfo() + read_cnt += _elem35.read(iprot) + self.process_info.append(_elem35) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.LIST: + self.disk_usage_info = [] + (length, _etype39, _size36) = iprot.readListBegin() + read_cnt += length + for _i40 in xrange(_size36): + _elem41 = process_info.ttypes.DiskPartitionUsageStats() + read_cnt += _elem41.read(iprot) + self.disk_usage_info.append(_elem41) + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + (length, self.description) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.LIST: + self.all_core_file_list = [] + (length, _etype45, _size42) = iprot.readListBegin() + read_cnt += length + for _i46 in xrange(_size42): + read_cnt += iprot.readContainerElementBegin() + (length, _elem47) = iprot.readString(); + if length < 0: return -1 + read_cnt += length + self.all_core_file_list.append(_elem47) + read_cnt += iprot.readContainerElementEnd() + read_cnt += iprot.readListEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readStructEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeStructBegin('NodeStatus') < 0: return -1 + if self.name is not None: + annotations = {} + if self._table is None or self._table is '': return -1 + annotations['key'] = self._table + if oprot.writeFieldBegin('name', TType.STRING, 1, annotations) < 0: return -1 + if oprot.writeString(self.name) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.deleted is not None: + annotations = {} + if oprot.writeFieldBegin('deleted', TType.BOOL, 2, annotations) < 0: return -1 + if oprot.writeBool(self.deleted) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.status is not None: + annotations = {} + if oprot.writeFieldBegin('status', TType.STRING, 3, annotations) < 0: return -1 + if oprot.writeString(self.status) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.process_status is not None: + annotations = {} + annotations['aggtype'] = 'union' + if oprot.writeFieldBegin('process_status', TType.LIST, 4, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.process_status)) < 0: return -1 + for iter48 in self.process_status: + if iter48.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.process_info is not None: + annotations = {} + annotations['aggtype'] = 'union' + if oprot.writeFieldBegin('process_info', TType.LIST, 5, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.process_info)) < 0: return -1 + for iter49 in self.process_info: + if iter49.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.disk_usage_info is not None: + annotations = {} + annotations['tags'] = '' + if oprot.writeFieldBegin('disk_usage_info', TType.LIST, 6, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRUCT, len(self.disk_usage_info)) < 0: return -1 + for iter50 in self.disk_usage_info: + if iter50.write(oprot) < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.description is not None: + annotations = {} + if oprot.writeFieldBegin('description', TType.STRING, 7, annotations) < 0: return -1 + if oprot.writeString(self.description) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if self.all_core_file_list is not None: + annotations = {} + if oprot.writeFieldBegin('all_core_file_list', TType.LIST, 8, annotations) < 0: return -1 + if oprot.writeListBegin(TType.STRING, len(self.all_core_file_list)) < 0: return -1 + for iter51 in self.all_core_file_list: + if oprot.writeContainerElementBegin() < 0: return -1 + if oprot.writeString(iter51) < 0: return -1 + if oprot.writeContainerElementEnd() < 0: return -1 + if oprot.writeListEnd() < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeStructEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def log(self): + log_str = cStringIO.StringIO() + if self.name is not None: + log_str.write('name = ') + log_str.write(self.name) + log_str.write(' ') + if self.deleted is not None: + log_str.write('deleted = ') + if self.deleted: + log_str.write('True') + else: + log_str.write('False') + log_str.write(' ') + if self.status is not None: + log_str.write('status = ') + log_str.write(self.status) + log_str.write(' ') + if self.process_status is not None: + log_str.write('process_status = ') + log_str.write('[ ') + for iter52 in self.process_status: + log_str.write('<< ') + log_str.write(iter52.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.process_info is not None: + log_str.write('process_info = ') + log_str.write('[ ') + for iter53 in self.process_info: + log_str.write('<< ') + log_str.write(iter53.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.disk_usage_info is not None: + log_str.write('disk_usage_info = ') + log_str.write('[ ') + for iter54 in self.disk_usage_info: + log_str.write('<< ') + log_str.write(iter54.log()) + log_str.write('>>') + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + if self.description is not None: + log_str.write('description = ') + log_str.write(self.description) + log_str.write(' ') + if self.all_core_file_list is not None: + log_str.write('all_core_file_list = ') + log_str.write('[ ') + for iter55 in self.all_core_file_list: + log_str.write(iter55) + log_str.write(', ') + log_str.write(' ]') + log_str.write(' ') + return log_str.getvalue() + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ModuleCpuStateTrace(sandesh_base.SandeshUVE): + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'data', (ModuleCpuState, ModuleCpuState.thrift_spec), None, ), # 1 + ) + + def __init__(self, data=None, table=None, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshUVE.__init__(self) + self.data = data + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 3681498004 + self._hints = 0 | SANDESH_KEY_HINT + if table is not None: + self.data._table = table + + def update_uve(self, tdata): + if self.data.name is not None: + tdata.name = self.data.name + if self.data.deleted is not None: + tdata.deleted = self.data.deleted + if self.data.module_cpu_info is not None: + tdata.module_cpu_info = self.data.module_cpu_info + if self.data.build_info is not None: + tdata.build_info = self.data.build_info + if self.data.config_node_ip is not None: + tdata.config_node_ip = self.data.config_node_ip + if self.data.api_server_cpu_share is not None: + tdata.api_server_cpu_share = self.data.api_server_cpu_share + if self.data.schema_xmer_cpu_share is not None: + tdata.schema_xmer_cpu_share = self.data.schema_xmer_cpu_share + if self.data.service_monitor_cpu_share is not None: + tdata.service_monitor_cpu_share = self.data.service_monitor_cpu_share + if self.data.api_server_mem_virt is not None: + tdata.api_server_mem_virt = self.data.api_server_mem_virt + if self.data.schema_xmer_mem_virt is not None: + tdata.schema_xmer_mem_virt = self.data.schema_xmer_mem_virt + if self.data.service_monitor_mem_virt is not None: + tdata.service_monitor_mem_virt = self.data.service_monitor_mem_virt + return tdata + + def log(self, trace=False): + log_str = cStringIO.StringIO() + if trace: + log_str.write(str(self._timestamp)) + log_str.write(' ') + log_str.write('ModuleCpuStateTrace: ') + if self.data is not None: + log_str.write('data = ') + log_str.write('<< ') + log_str.write(self.data.log()) + log_str.write('>>') + log_str.write(' ') + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.data = ModuleCpuState() + read_cnt += self.data.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('ModuleCpuStateTrace') < 0: return -1 + if self.data is not None: + annotations = {} + if oprot.writeFieldBegin('data', TType.STRUCT, 1, annotations) < 0: return -1 + if self.data.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + if self.data != other.data: + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ConfigCpuStateTrace(sandesh_base.SandeshUVE): + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'data', (ConfigCpuState, ConfigCpuState.thrift_spec), None, ), # 1 + ) + + def __init__(self, data=None, table=None, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshUVE.__init__(self) + self.data = data + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 3278957034 + self._hints = 0 | SANDESH_KEY_HINT + if table is not None: + self.data._table = table + + def update_uve(self, tdata): + if self.data.name is not None: + tdata.name = self.data.name + if self.data.deleted is not None: + tdata.deleted = self.data.deleted + if self.data.cpu_info is not None: + tdata.cpu_info = self.data.cpu_info + return tdata + + def log(self, trace=False): + log_str = cStringIO.StringIO() + if trace: + log_str.write(str(self._timestamp)) + log_str.write(' ') + log_str.write('ConfigCpuStateTrace: ') + if self.data is not None: + log_str.write('data = ') + log_str.write('<< ') + log_str.write(self.data.log()) + log_str.write('>>') + log_str.write(' ') + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.data = ConfigCpuState() + read_cnt += self.data.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('ConfigCpuStateTrace') < 0: return -1 + if self.data is not None: + annotations = {} + if oprot.writeFieldBegin('data', TType.STRUCT, 1, annotations) < 0: return -1 + if self.data.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + if self.data != other.data: + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class NodeStatusUVE(sandesh_base.SandeshUVE): + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'data', (NodeStatus, NodeStatus.thrift_spec), None, ), # 1 + ) + + def __init__(self, data=None, table=None, sandesh=sandesh_base.sandesh_global): + sandesh_base.SandeshUVE.__init__(self) + self.data = data + self._scope = sandesh.scope() + self._module = sandesh.module() + self._source = sandesh.source_id() + self._node_type = sandesh.node_type() + self._instance_id = sandesh.instance_id() + self._seqnum = 0 + self._timestamp = UTCTimestampUsec() + self._versionsig = 2778367443 + self._hints = 0 | SANDESH_KEY_HINT + if table is not None: + self.data._table = table + + def update_uve(self, tdata): + if self.data.name is not None: + tdata.name = self.data.name + if self.data.deleted is not None: + tdata.deleted = self.data.deleted + if self.data.status is not None: + tdata.status = self.data.status + if self.data.process_status is not None: + tdata.process_status = self.data.process_status + if self.data.process_info is not None: + tdata.process_info = self.data.process_info + if self.data.disk_usage_info is not None: + tdata.disk_usage_info = self.data.disk_usage_info + if self.data.description is not None: + tdata.description = self.data.description + if self.data.all_core_file_list is not None: + tdata.all_core_file_list = self.data.all_core_file_list + return tdata + + def log(self, trace=False): + log_str = cStringIO.StringIO() + if trace: + log_str.write(str(self._timestamp)) + log_str.write(' ') + log_str.write('NodeStatusUVE: ') + if self.data is not None: + log_str.write('data = ') + log_str.write('<< ') + log_str.write(self.data.log()) + log_str.write('>>') + log_str.write(' ') + return log_str.getvalue() + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return -1 + read_cnt = 0 + (length, sandesh_name) = iprot.readSandeshBegin() + if length < 0: return -1 + read_cnt += length + while True: + (length, fname, ftype, fid) = iprot.readFieldBegin() + if length < 0: return -1 + read_cnt += length + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.data = NodeStatus() + read_cnt += self.data.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + length = iprot.readFieldEnd() + if length < 0: return -1 + read_cnt += length + length = iprot.readSandeshEnd() + if length < 0: return -1 + read_cnt += length + return read_cnt + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return 0 + if oprot.writeSandeshBegin('NodeStatusUVE') < 0: return -1 + if self.data is not None: + annotations = {} + if oprot.writeFieldBegin('data', TType.STRUCT, 1, annotations) < 0: return -1 + if self.data.write(oprot) < 0: return -1 + if oprot.writeFieldEnd() < 0: return -1 + if oprot.writeFieldStop() < 0: return -1 + if oprot.writeSandeshEnd() < 0: return -1 + return 0 + + def validate(self): + return + + + def compare(self, other): + if not isinstance(other, self.__class__): + return False + if self.data != other.data: + return False + return True + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + + +_SANDESH_REQUEST_LIST = [ +] + + +_SANDESH_UVE_LIST = [ +'ModuleCpuStateTrace', +'ConfigCpuStateTrace', +'NodeStatusUVE', +] + + +_SANDESH_UVE_DATA_LIST = [ +'ModuleCpuState', +'ConfigCpuState', +'NodeStatus', +] + + +_SANDESH_ALARM_LIST = [ +] + + +_SANDESH_ALARM_DATA_LIST = [ +] diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.pyc b/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.pyc Binary files differnew file mode 100644 index 0000000..4a16093 --- /dev/null +++ b/Testcases/cfgm_common/uve/cfgm_cpuinfo/ttypes.pyc |