1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
#!/router/bin/python
#from rpc_exceptions import RPCExceptionHandler, WrappedRPCError
from jsonrpclib import Fault, ProtocolError, AppError
class RPCError(Exception):
"""
This is the general RPC error exception class from which :exc:`trex_exceptions.TRexException` inherits.
Every exception in this class has as error format according to JSON-RPC convention convention: code, message and data.
"""
def __init__(self, code, message, remote_data = None):
self.code = code
self.msg = message or self._default_message
self.data = remote_data
self.args = (code, self.msg, remote_data)
def __str__(self):
return self.__repr__()
def __repr__(self):
if self.args[2] is not None:
return u"[errcode:%r] %r. Extended data: %r" % (self.args[0], self.args[1], self.args[2])
else:
return u"[errcode:%r] %r" % (self.args[0], self.args[1])
class TRexException(RPCError):
"""
This is the most general T-Rex exception.
All exceptions inherits from this class has an error code and a default message which describes the most common use case of the error.
This exception isn't used by default and will only when an unrelated to ProtocolError will occur, and it can't be resolved to any of the deriviate exceptions.
"""
code = -10
_default_message = 'T-Rex encountered an unexpected error. please contact T-Rex dev team.'
# api_name = 'TRex'
class TRexError(TRexException):
"""
This is the most general T-Rex exception.
This exception isn't used by default and will only when an unrelated to ProtocolError will occur, and it can't be resolved to any of the deriviate exceptions.
"""
code = -11
_default_message = 'T-Rex run failed due to wrong input parameters, or due to reachability issues.'
class TRexWarning(TRexException):
""" Indicates a warning from T-Rex server. When this exception raises it normally used to indicate required data isn't ready yet """
code = -12
_default_message = 'T-Rex is starting (data is not available yet).'
class TRexRequestDenied(TRexException):
""" Indicates the desired reques was denied by the server """
code = -33
_default_message = 'T-Rex desired request denied because the requested resource is already taken. Try again once T-Rex is back in IDLE state.'
class TRexInUseError(TRexException):
"""
Indicates that T-Rex is currently in use
"""
code = -13
_default_message = 'T-Rex is already being used by another user or process. Try again once T-Rex is back in IDLE state.'
class TRexRunFailedError(TRexException):
""" Indicates that T-Rex has failed due to some reason. This Exception is used when T-Rex process itself terminates due to unknown reason """
code = -14
_default_message = ''
class TRexIncompleteRunError(TRexException):
"""
Indicates that T-Rex has failed due to some reason.
This Exception is used when T-Rex process itself terminated with error fault or it has been terminated by an external intervention in the OS.
"""
code = -15
_default_message = 'T-Rex run was terminated unexpectedly by outer process or by the hosting OS'
EXCEPTIONS = [TRexException, TRexError, TRexWarning, TRexInUseError, TRexRequestDenied, TRexRunFailedError, TRexIncompleteRunError]
class CExceptionHandler(object):
"""
CExceptionHandler is responsible for generating T-Rex API related exceptions in client side.
"""
def __init__(self, exceptions):
"""
Instatiate a CExceptionHandler object
:parameters:
exceptions : list
a list of all T-Rex acceptable exception objects.
default list:
- :exc:`trex_exceptions.TRexException`
- :exc:`trex_exceptions.TRexError`
- :exc:`trex_exceptions.TRexWarning`
- :exc:`trex_exceptions.TRexInUseError`
- :exc:`trex_exceptions.TRexRequestDenied`
- :exc:`trex_exceptions.TRexRunFailedError`
- :exc:`trex_exceptions.TRexIncompleteRunError`
"""
if isinstance(exceptions, type):
exceptions = [ exceptions, ]
self.exceptions = exceptions
self.exceptions_dict = dict((e.code, e) for e in self.exceptions)
def gen_exception (self, err):
"""
Generates an exception based on a general ProtocolError exception object `err`.
When T-Rex is reserved, no other user can start new T-Rex runs.
:parameters:
err : exception
a ProtocolError exception raised by :class:`trex_client.CTRexClient` class
:return:
A T-Rex exception from the exception list defined in class creation.
If such exception wasn't found, returns a TRexException exception
"""
code, message, data = err
try:
exp = self.exceptions_dict[code]
return exp(exp.code, message, data)
except KeyError:
# revert to TRexException when unknown error application raised
return TRexException(err)
exception_handler = CExceptionHandler( EXCEPTIONS )
|
