diff options
Diffstat (limited to 'Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py')
| -rw-r--r-- | Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py | 854 |
1 files changed, 0 insertions, 854 deletions
diff --git a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py b/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py deleted file mode 100644 index 5c12c29..0000000 --- a/Testcases/cfgm_common/uve/cfgm_cpuinfo/process_info/ttypes.py +++ /dev/null @@ -1,854 +0,0 @@ -# -# 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 = [ -] |