[ceph.git] / ceph / src / spdk / test / rpc / rpc_plugin.py

from rpc.client import print_json


def malloc_create(args):
    params = {'num_blocks': 256, 'block_size': 4096}
    return args.client.call('bdev_malloc_create', params)


def malloc_delete(args):
    params = {'name': args.name}
    return args.client.call('bdev_malloc_delete', params)


def create_malloc(args):
    print_json(malloc_create(args))


def spdk_rpc_plugin_initialize(subparsers):
    p = subparsers.add_parser('create_malloc', help='Create malloc backend')
    p.set_defaults(func=create_malloc)

    p = subparsers.add_parser('delete_malloc', help='Delete malloc backend')
    p.add_argument('name', help='malloc bdev name')
    p.set_defaults(func=malloc_delete)
Commit	Line	Data
f67539c2 TL	1	from rpc.client import print_json
	2
	3
	4	def malloc_create(args):
	5	params = {'num_blocks': 256, 'block_size': 4096}
	6	return args.client.call('bdev_malloc_create', params)
	7
	8
	9	def malloc_delete(args):
	10	params = {'name': args.name}
	11	return args.client.call('bdev_malloc_delete', params)
	12
	13
	14	def create_malloc(args):
	15	print_json(malloc_create(args))
	16
	17
	18	def spdk_rpc_plugin_initialize(subparsers):
	19	p = subparsers.add_parser('create_malloc', help='Create malloc backend')
	20	p.set_defaults(func=create_malloc)
	21
	22	p = subparsers.add_parser('delete_malloc', help='Delete malloc backend')
	23	p.add_argument('name', help='malloc bdev name')
	24	p.set_defaults(func=malloc_delete)