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
|
#
# Copyright (C) 2010-2012 CEA/DAM
#
# This file is part of ClusterShell.
#
# ClusterShell is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# ClusterShell is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with ClusterShell; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
"""
CLI error handling helper functions
"""
from __future__ import print_function
try:
import configparser
except ImportError:
# Python 2 compat
import ConfigParser as configparser
import errno
import logging
import os.path
from resource import getrlimit, RLIMIT_NOFILE
import signal
import sys
from ClusterShell.Engine.Engine import EngineNotSupportedError
from ClusterShell.NodeUtils import GroupResolverConfigError
from ClusterShell.NodeUtils import GroupResolverIllegalCharError
from ClusterShell.NodeUtils import GroupResolverSourceError
from ClusterShell.NodeUtils import GroupSourceError
from ClusterShell.NodeUtils import GroupSourceNoUpcall
from ClusterShell.NodeSet import NodeSetExternalError, NodeSetParseError
from ClusterShell.NodeSet import RangeSetParseError
from ClusterShell.Propagation import RouteResolvingError
from ClusterShell.Topology import TopologyError
from ClusterShell.Worker.EngineClient import EngineClientError
from ClusterShell.Worker.Worker import WorkerError
GENERIC_ERRORS = (configparser.Error,
EngineNotSupportedError,
EngineClientError,
NodeSetExternalError,
NodeSetParseError,
RangeSetParseError,
GroupResolverConfigError,
GroupResolverIllegalCharError,
GroupResolverSourceError,
GroupSourceError,
GroupSourceNoUpcall,
RouteResolvingError,
TopologyError,
TypeError,
IOError,
OSError,
KeyboardInterrupt,
ValueError,
WorkerError)
LOGGER = logging.getLogger(__name__)
def handle_generic_error(excobj):
"""handle error given `excobj' generic script exception"""
prog = os.path.basename(sys.argv[0])
try:
raise excobj
except EngineNotSupportedError as exc:
msgfmt = "%s: I/O events engine '%s' not supported on this host"
print(msgfmt % (prog, exc.engineid), file=sys.stderr)
except EngineClientError as exc:
print("%s: EngineClientError: %s" % (prog, exc), file=sys.stderr)
except NodeSetExternalError as exc:
print("%s: External error: %s" % (prog, exc), file=sys.stderr)
except (NodeSetParseError, RangeSetParseError) as exc:
print("%s: Parse error: %s" % (prog, exc), file=sys.stderr)
except GroupResolverIllegalCharError as exc:
print('%s: Illegal group character: "%s"' % (prog, exc),
file=sys.stderr)
except GroupResolverConfigError as exc:
print('%s: Group resolver error: %s' % (prog, exc), file=sys.stderr)
except GroupResolverSourceError as exc:
print('%s: Unknown group source: "%s"' % (prog, exc), file=sys.stderr)
except GroupSourceNoUpcall as exc:
msgfmt = '%s: No %s upcall defined for group source "%s"'
print(msgfmt % (prog, exc, exc.group_source.name), file=sys.stderr)
except GroupSourceError as exc:
print("%s: Group error: %s" % (prog, exc), file=sys.stderr)
except (RouteResolvingError, TopologyError) as exc:
print("%s: TREE MODE: %s" % (prog, exc), file=sys.stderr)
except configparser.Error as exc:
print("%s: %s" % (prog, exc), file=sys.stderr)
except (TypeError, ValueError, WorkerError) as exc:
print("%s: %s" % (prog, exc), file=sys.stderr)
except (IOError, OSError) as exc: # see PEP 3151
if exc.errno == errno.EPIPE:
# be quiet on broken pipe
LOGGER.debug(exc)
else:
print("ERROR: %s" % exc, file=sys.stderr)
if exc.errno == errno.EMFILE:
print("ERROR: maximum number of open file descriptors: "
"soft=%d hard=%d" % getrlimit(RLIMIT_NOFILE),
file=sys.stderr)
except KeyboardInterrupt as exc:
return 128 + signal.SIGINT
except:
assert False, "wrong GENERIC_ERRORS"
# Exit with error code 1 (generic failure)
return 1
|
