Revision 66baeccc
| b/daemons/ganeti-masterd | ||
|---|---|---|
| 255 | 255 |
op = opcodes.OpQueryConfigValues(output_fields=fields) |
| 256 | 256 |
return self._Query(op) |
| 257 | 257 |
|
| 258 |
elif method == luxi.REQ_QUERY_CLUSTER_INFO: |
|
| 259 |
op = opcodes.OpQueryClusterInfo() |
|
| 260 |
return self._Query(op) |
|
| 261 |
|
|
| 258 | 262 |
elif method == luxi.REQ_QUEUE_SET_DRAIN_FLAG: |
| 259 | 263 |
drain_flag = args |
| 260 | 264 |
return queue.SetDrainFlag(drain_flag) |
| b/lib/luxi.py | ||
|---|---|---|
| 54 | 54 |
REQ_QUERY_NODES = "QueryNodes" |
| 55 | 55 |
REQ_QUERY_EXPORTS = "QueryExports" |
| 56 | 56 |
REQ_QUERY_CONFIG_VALUES = "QueryConfigValues" |
| 57 |
REQ_QUERY_CLUSTER_INFO = "QueryClusterInfo" |
|
| 57 | 58 |
REQ_QUEUE_SET_DRAIN_FLAG = "SetDrainFlag" |
| 58 | 59 |
|
| 59 | 60 |
DEF_CTMO = 10 |
| ... | ... | |
| 366 | 367 |
def QueryExports(self, nodes, use_locking): |
| 367 | 368 |
return self.CallMethod(REQ_QUERY_EXPORTS, (nodes, use_locking)) |
| 368 | 369 |
|
| 370 |
def QueryClusterInfo(self): |
|
| 371 |
return self.CallMethod(REQ_QUERY_CLUSTER_INFO, ()) |
|
| 372 |
|
|
| 369 | 373 |
def QueryConfigValues(self, fields): |
| 370 | 374 |
return self.CallMethod(REQ_QUERY_CONFIG_VALUES, fields) |
| 371 | 375 |
|
Also available in: Unified diff