Revision c46b9782
b/daemons/ganeti-noded | ||
---|---|---|
361 | 361 |
disks = [objects.Disk.FromDict(cf) for cf in disks] |
362 | 362 |
return backend.DrbdWaitSync(nodes_ip, disks) |
363 | 363 |
|
364 |
@staticmethod |
|
365 |
def perspective_drbd_helper(params): |
|
366 |
"""Query drbd helper. |
|
367 |
|
|
368 |
""" |
|
369 |
return backend.GetDrbdUsermodeHelper() |
|
370 |
|
|
364 | 371 |
# export/import -------------------------- |
365 | 372 |
|
366 | 373 |
@staticmethod |
b/lib/backend.py | ||
---|---|---|
3055 | 3055 |
return (alldone, min_resync) |
3056 | 3056 |
|
3057 | 3057 |
|
3058 |
def GetDrbdUsermodeHelper(): |
|
3059 |
"""Returns DRBD usermode helper currently configured. |
|
3060 |
|
|
3061 |
""" |
|
3062 |
try: |
|
3063 |
return bdev.BaseDRBD.GetUsermodeHelper() |
|
3064 |
except errors.BlockDeviceError, err: |
|
3065 |
_Fail(str(err)) |
|
3066 |
|
|
3067 |
|
|
3058 | 3068 |
def PowercycleNode(hypervisor_type): |
3059 | 3069 |
"""Hard-powercycle the node. |
3060 | 3070 |
|
b/lib/rpc.py | ||
---|---|---|
993 | 993 |
return self._MultiNodeCall(node_list, "drbd_wait_sync", |
994 | 994 |
[nodes_ip, [cf.ToDict() for cf in disks]]) |
995 | 995 |
|
996 |
@_RpcTimeout(_TMO_URGENT) |
|
997 |
def call_drbd_helper(self, node_list): |
|
998 |
"""Gets drbd helper. |
|
999 |
|
|
1000 |
This is a multi-node call. |
|
1001 |
|
|
1002 |
""" |
|
1003 |
return self._MultiNodeCall(node_list, "drbd_helper", []) |
|
1004 |
|
|
996 | 1005 |
@classmethod |
997 | 1006 |
@_RpcTimeout(_TMO_NORMAL) |
998 | 1007 |
def call_upload_file(cls, node_list, file_name, address_list=None): |
Also available in: Unified diff