Commit 83816869 authored by Michael Hanselmann's avatar Michael Hanselmann
Browse files

rpc: Convert file-storage-related calls


Signed-off-by: default avatarMichael Hanselmann <hansmi@google.com>
Reviewed-by: default avatarIustin Pop <iustin@google.com>
parent d6cf4107
......@@ -342,5 +342,6 @@ _MISC_CALLS = [
]
CALLS = {
"RpcClientDefault": (_IMPEXP_CALLS + _X509_CALLS + _OS_CALLS + _NODE_CALLS),
"RpcClientDefault": (_IMPEXP_CALLS + _X509_CALLS + _OS_CALLS + _NODE_CALLS +
_FILE_STORAGE_CALLS),
}
......@@ -1336,37 +1336,6 @@ class RpcRunner(_generated_rpc.RpcClientDefault):
return self._MultiNodeCall(node_list, "test_delay", [duration],
read_timeout=int(duration + 5))
@_RpcTimeout(_TMO_FAST)
def call_file_storage_dir_create(self, node, file_storage_dir):
"""Create the given file storage directory.
This is a single-node call.
"""
return self._SingleNodeCall(node, "file_storage_dir_create",
[file_storage_dir])
@_RpcTimeout(_TMO_FAST)
def call_file_storage_dir_remove(self, node, file_storage_dir):
"""Remove the given file storage directory.
This is a single-node call.
"""
return self._SingleNodeCall(node, "file_storage_dir_remove",
[file_storage_dir])
@_RpcTimeout(_TMO_FAST)
def call_file_storage_dir_rename(self, node, old_file_storage_dir,
new_file_storage_dir):
"""Rename file storage directory.
This is a single-node call.
"""
return self._SingleNodeCall(node, "file_storage_dir_rename",
[old_file_storage_dir, new_file_storage_dir])
@classmethod
@_RpcTimeout(_TMO_URGENT)
def call_jobqueue_update(cls, node_list, address_list, file_name, content):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment