Revision 77921a95 daemons/ganeti-masterd
b/daemons/ganeti-masterd | ||
---|---|---|
247 | 247 |
elif method == luxi.REQ_QUERY_INSTANCES: |
248 | 248 |
(names, fields, use_locking) = args |
249 | 249 |
logging.info("Received instance query request for %s", names) |
250 |
if use_locking: |
|
251 |
raise errors.OpPrereqError("Sync queries are not allowed") |
|
250 | 252 |
op = opcodes.OpQueryInstances(names=names, output_fields=fields, |
251 | 253 |
use_locking=use_locking) |
252 | 254 |
return self._Query(op) |
... | ... | |
254 | 256 |
elif method == luxi.REQ_QUERY_NODES: |
255 | 257 |
(names, fields, use_locking) = args |
256 | 258 |
logging.info("Received node query request for %s", names) |
259 |
if use_locking: |
|
260 |
raise errors.OpPrereqError("Sync queries are not allowed") |
|
257 | 261 |
op = opcodes.OpQueryNodes(names=names, output_fields=fields, |
258 | 262 |
use_locking=use_locking) |
259 | 263 |
return self._Query(op) |
260 | 264 |
|
261 | 265 |
elif method == luxi.REQ_QUERY_EXPORTS: |
262 | 266 |
nodes, use_locking = args |
267 |
if use_locking: |
|
268 |
raise errors.OpPrereqError("Sync queries are not allowed") |
|
263 | 269 |
logging.info("Received exports query request") |
264 | 270 |
op = opcodes.OpQueryExports(nodes=nodes, use_locking=use_locking) |
265 | 271 |
return self._Query(op) |
Also available in: Unified diff