Revision be6c403e lib/jqueue.py
b/lib/jqueue.py | ||
---|---|---|
1800 | 1800 |
logging.error("Failed to upload file %s to node %s: %s", |
1801 | 1801 |
file_name, node_name, msg) |
1802 | 1802 |
|
1803 |
# Set queue drained flag |
|
1804 |
result = \ |
|
1805 |
self._GetRpc(addrs).call_jobqueue_set_drain_flag([node_name], |
|
1806 |
self._drained) |
|
1807 |
msg = result[node_name].fail_msg |
|
1808 |
if msg: |
|
1809 |
logging.error("Failed to set queue drained flag on node %s: %s", |
|
1810 |
node_name, msg) |
|
1811 |
|
|
1803 | 1812 |
self._nodes[node_name] = node.primary_ip |
1804 | 1813 |
|
1805 | 1814 |
@locking.ssynchronized(_LOCK) |
... | ... | |
2123 | 2132 |
@param drain_flag: Whether to set or unset the drain flag |
2124 | 2133 |
|
2125 | 2134 |
""" |
2135 |
# Change flag locally |
|
2126 | 2136 |
jstore.SetDrainFlag(drain_flag) |
2127 | 2137 |
|
2128 | 2138 |
self._drained = drain_flag |
2129 | 2139 |
|
2140 |
# ... and on all nodes |
|
2141 |
(names, addrs) = self._GetNodeIp() |
|
2142 |
result = \ |
|
2143 |
self._GetRpc(addrs).call_jobqueue_set_drain_flag(names, drain_flag) |
|
2144 |
self._CheckRpcResult(result, self._nodes, |
|
2145 |
"Setting queue drain flag to %s" % drain_flag) |
|
2146 |
|
|
2130 | 2147 |
return True |
2131 | 2148 |
|
2132 | 2149 |
@_RequireOpenQueue |
Also available in: Unified diff