Make argument to CleanCacheUnlocked mandatory

[ganeti-local] / lib / rpc.py

diff --git a/lib/rpc.py b/lib/rpc.py
index 8b5e5ba..f2c85db 100644 (file)
--- a/lib/rpc.py
+++ b/lib/rpc.py
@@ -512,6 +512,19 @@ def call_blockdev_find(node, disk):
   return c.getresult().get(node, False)
 
 
   return c.getresult().get(node, False)
 
 

+def call_blockdev_close(node, disks):
+  """Closes the given block devices.
+
+  This is a single-node call.
+
+  """
+  params = [cf.ToDict() for cf in disks]
+  c = Client("blockdev_close", params)
+  c.connect(node)
+  c.run()
+  return c.getresult().get(node, False)
+
+

 def call_upload_file(node_list, file_name):
   """Upload a file.
 
 def call_upload_file(node_list, file_name):
   """Upload a file.
 

@@ -607,6 +620,18 @@ def call_iallocator_runner(node, name, idata):
   return result
 
 
   return result
 
 

+def call_blockdev_grow(node, cf_bdev, amount):
+  """Request a snapshot of the given block device.
+
+  This is a single-node call.
+
+  """
+  c = Client("blockdev_grow", [cf_bdev.ToDict(), amount])
+  c.connect(node)
+  c.run()
+  return c.getresult().get(node, False)
+
+

 def call_blockdev_snapshot(node, cf_bdev):
   """Request a snapshot of the given block device.
 
 def call_blockdev_snapshot(node, cf_bdev):
   """Request a snapshot of the given block device.