xref: /dpdk/examples/vm_power_manager/vm_power_cli.c (revision 3998e2a07220844d3f3c17f76a781ced3efe0de0)
1*3998e2a0SBruce Richardson /* SPDX-License-Identifier: BSD-3-Clause
2*3998e2a0SBruce Richardson  * Copyright(c) 2010-2014 Intel Corporation
33842bf24SAlan Carew  */
43842bf24SAlan Carew 
53842bf24SAlan Carew #include <stdlib.h>
63842bf24SAlan Carew #include <stdint.h>
73842bf24SAlan Carew #include <inttypes.h>
83842bf24SAlan Carew #include <stdio.h>
93842bf24SAlan Carew #include <string.h>
103842bf24SAlan Carew #include <termios.h>
113842bf24SAlan Carew #include <errno.h>
123842bf24SAlan Carew 
133842bf24SAlan Carew #include <cmdline_rdline.h>
143842bf24SAlan Carew #include <cmdline_parse.h>
153842bf24SAlan Carew #include <cmdline_parse_string.h>
163842bf24SAlan Carew #include <cmdline_parse_num.h>
173842bf24SAlan Carew #include <cmdline_socket.h>
183842bf24SAlan Carew #include <cmdline.h>
193842bf24SAlan Carew 
203842bf24SAlan Carew #include "vm_power_cli.h"
213842bf24SAlan Carew #include "channel_manager.h"
223842bf24SAlan Carew #include "channel_monitor.h"
233842bf24SAlan Carew #include "power_manager.h"
243842bf24SAlan Carew #include "channel_commands.h"
253842bf24SAlan Carew 
263842bf24SAlan Carew struct cmd_quit_result {
273842bf24SAlan Carew 	cmdline_fixed_string_t quit;
283842bf24SAlan Carew };
293842bf24SAlan Carew 
303842bf24SAlan Carew static void cmd_quit_parsed(__attribute__((unused)) void *parsed_result,
313842bf24SAlan Carew 		struct cmdline *cl,
323842bf24SAlan Carew 		__attribute__((unused)) void *data)
333842bf24SAlan Carew {
343842bf24SAlan Carew 	channel_monitor_exit();
353842bf24SAlan Carew 	channel_manager_exit();
363842bf24SAlan Carew 	power_manager_exit();
373842bf24SAlan Carew 	cmdline_quit(cl);
383842bf24SAlan Carew }
393842bf24SAlan Carew 
403842bf24SAlan Carew cmdline_parse_token_string_t cmd_quit_quit =
413842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_quit_result, quit, "quit");
423842bf24SAlan Carew 
433842bf24SAlan Carew cmdline_parse_inst_t cmd_quit = {
443842bf24SAlan Carew 	.f = cmd_quit_parsed,  /* function to call */
453842bf24SAlan Carew 	.data = NULL,      /* 2nd arg of func */
463842bf24SAlan Carew 	.help_str = "close the application",
473842bf24SAlan Carew 	.tokens = {        /* token list, NULL terminated */
483842bf24SAlan Carew 		(void *)&cmd_quit_quit,
493842bf24SAlan Carew 		NULL,
503842bf24SAlan Carew 	},
513842bf24SAlan Carew };
523842bf24SAlan Carew 
533842bf24SAlan Carew /* *** VM operations *** */
543842bf24SAlan Carew struct cmd_show_vm_result {
553842bf24SAlan Carew 	cmdline_fixed_string_t show_vm;
563842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
573842bf24SAlan Carew };
583842bf24SAlan Carew 
593842bf24SAlan Carew static void
603842bf24SAlan Carew cmd_show_vm_parsed(void *parsed_result, struct cmdline *cl,
613842bf24SAlan Carew 		__attribute__((unused)) void *data)
623842bf24SAlan Carew {
633842bf24SAlan Carew 	struct cmd_show_vm_result *res = parsed_result;
643842bf24SAlan Carew 	struct vm_info info;
653842bf24SAlan Carew 	unsigned i;
663842bf24SAlan Carew 
673842bf24SAlan Carew 	if (get_info_vm(res->vm_name, &info) != 0)
683842bf24SAlan Carew 		return;
693842bf24SAlan Carew 	cmdline_printf(cl, "VM: '%s', status = ", info.name);
703842bf24SAlan Carew 	if (info.status == CHANNEL_MGR_VM_ACTIVE)
713842bf24SAlan Carew 		cmdline_printf(cl, "ACTIVE\n");
723842bf24SAlan Carew 	else
733842bf24SAlan Carew 		cmdline_printf(cl, "INACTIVE\n");
743842bf24SAlan Carew 	cmdline_printf(cl, "Channels %u\n", info.num_channels);
753842bf24SAlan Carew 	for (i = 0; i < info.num_channels; i++) {
763842bf24SAlan Carew 		cmdline_printf(cl, "  [%u]: %s, status = ", i,
773842bf24SAlan Carew 				info.channels[i].channel_path);
783842bf24SAlan Carew 		switch (info.channels[i].status) {
793842bf24SAlan Carew 		case CHANNEL_MGR_CHANNEL_CONNECTED:
803842bf24SAlan Carew 			cmdline_printf(cl, "CONNECTED\n");
813842bf24SAlan Carew 			break;
823842bf24SAlan Carew 		case CHANNEL_MGR_CHANNEL_DISCONNECTED:
833842bf24SAlan Carew 			cmdline_printf(cl, "DISCONNECTED\n");
843842bf24SAlan Carew 			break;
853842bf24SAlan Carew 		case CHANNEL_MGR_CHANNEL_DISABLED:
863842bf24SAlan Carew 			cmdline_printf(cl, "DISABLED\n");
873842bf24SAlan Carew 			break;
883842bf24SAlan Carew 		case CHANNEL_MGR_CHANNEL_PROCESSING:
893842bf24SAlan Carew 			cmdline_printf(cl, "PROCESSING\n");
903842bf24SAlan Carew 			break;
913842bf24SAlan Carew 		default:
923842bf24SAlan Carew 			cmdline_printf(cl, "UNKNOWN\n");
933842bf24SAlan Carew 			break;
943842bf24SAlan Carew 		}
953842bf24SAlan Carew 	}
963842bf24SAlan Carew 	cmdline_printf(cl, "Virtual CPU(s): %u\n", info.num_vcpus);
973842bf24SAlan Carew 	for (i = 0; i < info.num_vcpus; i++) {
983842bf24SAlan Carew 		cmdline_printf(cl, "  [%u]: Physical CPU Mask 0x%"PRIx64"\n", i,
993842bf24SAlan Carew 				info.pcpu_mask[i]);
1003842bf24SAlan Carew 	}
1013842bf24SAlan Carew }
1023842bf24SAlan Carew 
1033842bf24SAlan Carew 
1043842bf24SAlan Carew 
1053842bf24SAlan Carew cmdline_parse_token_string_t cmd_vm_show =
1063842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_show_vm_result,
1073842bf24SAlan Carew 				show_vm, "show_vm");
1083842bf24SAlan Carew cmdline_parse_token_string_t cmd_show_vm_name =
1093842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_show_vm_result,
1103842bf24SAlan Carew 			vm_name, NULL);
1113842bf24SAlan Carew 
1123842bf24SAlan Carew cmdline_parse_inst_t cmd_show_vm_set = {
1133842bf24SAlan Carew 	.f = cmd_show_vm_parsed,
1143842bf24SAlan Carew 	.data = NULL,
1153842bf24SAlan Carew 	.help_str = "show_vm <vm_name>, prints the information on the "
1163842bf24SAlan Carew 			"specified VM(s), the information lists the number of vCPUS, the "
1173842bf24SAlan Carew 			"pinning to pCPU(s) as a bit mask, along with any communication "
1183842bf24SAlan Carew 			"channels associated with each VM",
1193842bf24SAlan Carew 	.tokens = {
1203842bf24SAlan Carew 		(void *)&cmd_vm_show,
1213842bf24SAlan Carew 		(void *)&cmd_show_vm_name,
1223842bf24SAlan Carew 		NULL,
1233842bf24SAlan Carew 	},
1243842bf24SAlan Carew };
1253842bf24SAlan Carew 
1263842bf24SAlan Carew /* *** vCPU to pCPU mapping operations *** */
1273842bf24SAlan Carew struct cmd_set_pcpu_mask_result {
1283842bf24SAlan Carew 	cmdline_fixed_string_t set_pcpu_mask;
1293842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
1303842bf24SAlan Carew 	uint8_t vcpu;
1313842bf24SAlan Carew 	uint64_t core_mask;
1323842bf24SAlan Carew };
1333842bf24SAlan Carew 
1343842bf24SAlan Carew static void
1353842bf24SAlan Carew cmd_set_pcpu_mask_parsed(void *parsed_result, struct cmdline *cl,
1363842bf24SAlan Carew 		__attribute__((unused)) void *data)
1373842bf24SAlan Carew {
1383842bf24SAlan Carew 	struct cmd_set_pcpu_mask_result *res = parsed_result;
1393842bf24SAlan Carew 
1403842bf24SAlan Carew 	if (set_pcpus_mask(res->vm_name, res->vcpu, res->core_mask) == 0)
1413842bf24SAlan Carew 		cmdline_printf(cl, "Pinned vCPU(%"PRId8") to pCPU core "
1423842bf24SAlan Carew 				"mask(0x%"PRIx64")\n", res->vcpu, res->core_mask);
1433842bf24SAlan Carew 	else
1443842bf24SAlan Carew 		cmdline_printf(cl, "Unable to pin vCPU(%"PRId8") to pCPU core "
1453842bf24SAlan Carew 				"mask(0x%"PRIx64")\n", res->vcpu, res->core_mask);
1463842bf24SAlan Carew }
1473842bf24SAlan Carew 
1483842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_pcpu_mask =
1493842bf24SAlan Carew 		TOKEN_STRING_INITIALIZER(struct cmd_set_pcpu_mask_result,
1503842bf24SAlan Carew 				set_pcpu_mask, "set_pcpu_mask");
1513842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_pcpu_mask_vm_name =
1523842bf24SAlan Carew 		TOKEN_STRING_INITIALIZER(struct cmd_set_pcpu_mask_result,
1533842bf24SAlan Carew 				vm_name, NULL);
1543842bf24SAlan Carew cmdline_parse_token_num_t set_pcpu_mask_vcpu =
1553842bf24SAlan Carew 		TOKEN_NUM_INITIALIZER(struct cmd_set_pcpu_mask_result,
1563842bf24SAlan Carew 				vcpu, UINT8);
1573842bf24SAlan Carew cmdline_parse_token_num_t set_pcpu_mask_core_mask =
1583842bf24SAlan Carew 		TOKEN_NUM_INITIALIZER(struct cmd_set_pcpu_mask_result,
1593842bf24SAlan Carew 				core_mask, UINT64);
1603842bf24SAlan Carew 
1613842bf24SAlan Carew 
1623842bf24SAlan Carew cmdline_parse_inst_t cmd_set_pcpu_mask_set = {
1633842bf24SAlan Carew 		.f = cmd_set_pcpu_mask_parsed,
1643842bf24SAlan Carew 		.data = NULL,
1653842bf24SAlan Carew 		.help_str = "set_pcpu_mask <vm_name> <vcpu> <pcpu>, Set the binding "
1663842bf24SAlan Carew 				"of Virtual CPU on VM to the Physical CPU mask.",
1673842bf24SAlan Carew 				.tokens = {
1683842bf24SAlan Carew 						(void *)&cmd_set_pcpu_mask,
1693842bf24SAlan Carew 						(void *)&cmd_set_pcpu_mask_vm_name,
1703842bf24SAlan Carew 						(void *)&set_pcpu_mask_vcpu,
1713842bf24SAlan Carew 						(void *)&set_pcpu_mask_core_mask,
1723842bf24SAlan Carew 						NULL,
1733842bf24SAlan Carew 		},
1743842bf24SAlan Carew };
1753842bf24SAlan Carew 
1763842bf24SAlan Carew struct cmd_set_pcpu_result {
1773842bf24SAlan Carew 	cmdline_fixed_string_t set_pcpu;
1783842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
1793842bf24SAlan Carew 	uint8_t vcpu;
1803842bf24SAlan Carew 	uint8_t core;
1813842bf24SAlan Carew };
1823842bf24SAlan Carew 
1833842bf24SAlan Carew static void
1843842bf24SAlan Carew cmd_set_pcpu_parsed(void *parsed_result, struct cmdline *cl,
1853842bf24SAlan Carew 		__attribute__((unused)) void *data)
1863842bf24SAlan Carew {
1873842bf24SAlan Carew 	struct cmd_set_pcpu_result *res = parsed_result;
1883842bf24SAlan Carew 
1893842bf24SAlan Carew 	if (set_pcpu(res->vm_name, res->vcpu, res->core) == 0)
1903842bf24SAlan Carew 		cmdline_printf(cl, "Pinned vCPU(%"PRId8") to pCPU core "
1913842bf24SAlan Carew 				"%"PRId8")\n", res->vcpu, res->core);
1923842bf24SAlan Carew 	else
1933842bf24SAlan Carew 		cmdline_printf(cl, "Unable to pin vCPU(%"PRId8") to pCPU core "
1943842bf24SAlan Carew 				"%"PRId8")\n", res->vcpu, res->core);
1953842bf24SAlan Carew }
1963842bf24SAlan Carew 
1973842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_pcpu =
1983842bf24SAlan Carew 		TOKEN_STRING_INITIALIZER(struct cmd_set_pcpu_result,
1993842bf24SAlan Carew 				set_pcpu, "set_pcpu");
2003842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_pcpu_vm_name =
2013842bf24SAlan Carew 		TOKEN_STRING_INITIALIZER(struct cmd_set_pcpu_result,
2023842bf24SAlan Carew 				vm_name, NULL);
2033842bf24SAlan Carew cmdline_parse_token_num_t set_pcpu_vcpu =
2043842bf24SAlan Carew 		TOKEN_NUM_INITIALIZER(struct cmd_set_pcpu_result,
2053842bf24SAlan Carew 				vcpu, UINT8);
2063842bf24SAlan Carew cmdline_parse_token_num_t set_pcpu_core =
2073842bf24SAlan Carew 		TOKEN_NUM_INITIALIZER(struct cmd_set_pcpu_result,
2083842bf24SAlan Carew 				core, UINT64);
2093842bf24SAlan Carew 
2103842bf24SAlan Carew 
2113842bf24SAlan Carew cmdline_parse_inst_t cmd_set_pcpu_set = {
2123842bf24SAlan Carew 		.f = cmd_set_pcpu_parsed,
2133842bf24SAlan Carew 		.data = NULL,
2143842bf24SAlan Carew 		.help_str = "set_pcpu <vm_name> <vcpu> <pcpu>, Set the binding "
2153842bf24SAlan Carew 				"of Virtual CPU on VM to the Physical CPU.",
2163842bf24SAlan Carew 				.tokens = {
2173842bf24SAlan Carew 						(void *)&cmd_set_pcpu,
2183842bf24SAlan Carew 						(void *)&cmd_set_pcpu_vm_name,
2193842bf24SAlan Carew 						(void *)&set_pcpu_vcpu,
2203842bf24SAlan Carew 						(void *)&set_pcpu_core,
2213842bf24SAlan Carew 						NULL,
2223842bf24SAlan Carew 		},
2233842bf24SAlan Carew };
2243842bf24SAlan Carew 
2253842bf24SAlan Carew struct cmd_vm_op_result {
2263842bf24SAlan Carew 	cmdline_fixed_string_t op_vm;
2273842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
2283842bf24SAlan Carew };
2293842bf24SAlan Carew 
2303842bf24SAlan Carew static void
2313842bf24SAlan Carew cmd_vm_op_parsed(void *parsed_result, struct cmdline *cl,
2323842bf24SAlan Carew 		__attribute__((unused)) void *data)
2333842bf24SAlan Carew {
2343842bf24SAlan Carew 	struct cmd_vm_op_result *res = parsed_result;
2353842bf24SAlan Carew 
2363842bf24SAlan Carew 	if (!strcmp(res->op_vm, "add_vm")) {
2373842bf24SAlan Carew 		if (add_vm(res->vm_name) < 0)
2383842bf24SAlan Carew 			cmdline_printf(cl, "Unable to add VM '%s'\n", res->vm_name);
2393842bf24SAlan Carew 	} else if (remove_vm(res->vm_name) < 0)
2403842bf24SAlan Carew 		cmdline_printf(cl, "Unable to remove VM '%s'\n", res->vm_name);
2413842bf24SAlan Carew }
2423842bf24SAlan Carew 
2433842bf24SAlan Carew cmdline_parse_token_string_t cmd_vm_op =
2443842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_vm_op_result,
2453842bf24SAlan Carew 			op_vm, "add_vm#rm_vm");
2463842bf24SAlan Carew cmdline_parse_token_string_t cmd_vm_name =
2473842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_vm_op_result,
2483842bf24SAlan Carew 			vm_name, NULL);
2493842bf24SAlan Carew 
2503842bf24SAlan Carew cmdline_parse_inst_t cmd_vm_op_set = {
2513842bf24SAlan Carew 	.f = cmd_vm_op_parsed,
2523842bf24SAlan Carew 	.data = NULL,
2533842bf24SAlan Carew 	.help_str = "add_vm|rm_vm <name>, add a VM for "
2543842bf24SAlan Carew 			"subsequent operations with the CLI or remove a previously added "
2553842bf24SAlan Carew 			"VM from the VM Power Manager",
2563842bf24SAlan Carew 	.tokens = {
2573842bf24SAlan Carew 		(void *)&cmd_vm_op,
2583842bf24SAlan Carew 		(void *)&cmd_vm_name,
2593842bf24SAlan Carew 	NULL,
2603842bf24SAlan Carew 	},
2613842bf24SAlan Carew };
2623842bf24SAlan Carew 
2633842bf24SAlan Carew /* *** VM channel operations *** */
2643842bf24SAlan Carew struct cmd_channels_op_result {
2653842bf24SAlan Carew 	cmdline_fixed_string_t op;
2663842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
2673842bf24SAlan Carew 	cmdline_fixed_string_t channel_list;
2683842bf24SAlan Carew };
2693842bf24SAlan Carew static void
2703842bf24SAlan Carew cmd_channels_op_parsed(void *parsed_result, struct cmdline *cl,
2713842bf24SAlan Carew 			__attribute__((unused)) void *data)
2723842bf24SAlan Carew {
2733842bf24SAlan Carew 	unsigned num_channels = 0, channel_num, i;
2743842bf24SAlan Carew 	int channels_added;
2753842bf24SAlan Carew 	unsigned channel_list[CHANNEL_CMDS_MAX_VM_CHANNELS];
2763842bf24SAlan Carew 	char *token, *remaining, *tail_ptr;
2773842bf24SAlan Carew 	struct cmd_channels_op_result *res = parsed_result;
2783842bf24SAlan Carew 
2793842bf24SAlan Carew 	if (!strcmp(res->channel_list, "all")) {
2803842bf24SAlan Carew 		channels_added = add_all_channels(res->vm_name);
2813842bf24SAlan Carew 		cmdline_printf(cl, "Added %d channels for VM '%s'\n",
2823842bf24SAlan Carew 				channels_added, res->vm_name);
2833842bf24SAlan Carew 		return;
2843842bf24SAlan Carew 	}
2853842bf24SAlan Carew 
2863842bf24SAlan Carew 	remaining = res->channel_list;
2873842bf24SAlan Carew 	while (1) {
2883842bf24SAlan Carew 		if (remaining == NULL || remaining[0] == '\0')
2893842bf24SAlan Carew 			break;
2903842bf24SAlan Carew 
2913842bf24SAlan Carew 		token = strsep(&remaining, ",");
2923842bf24SAlan Carew 		if (token == NULL)
2933842bf24SAlan Carew 			break;
2943842bf24SAlan Carew 		errno = 0;
2953842bf24SAlan Carew 		channel_num = (unsigned)strtol(token, &tail_ptr, 10);
2965b628fe1SBruce Richardson 		if ((errno != 0) || tail_ptr == NULL || (*tail_ptr != '\0'))
2973842bf24SAlan Carew 			break;
2983842bf24SAlan Carew 
2993842bf24SAlan Carew 		if (channel_num == CHANNEL_CMDS_MAX_VM_CHANNELS) {
3003842bf24SAlan Carew 			cmdline_printf(cl, "Channel number '%u' exceeds the maximum number "
3013842bf24SAlan Carew 					"of allowable channels(%u) for VM '%s'\n", channel_num,
3023842bf24SAlan Carew 					CHANNEL_CMDS_MAX_VM_CHANNELS, res->vm_name);
3033842bf24SAlan Carew 			return;
3043842bf24SAlan Carew 		}
3053842bf24SAlan Carew 		channel_list[num_channels++] = channel_num;
3063842bf24SAlan Carew 	}
3073842bf24SAlan Carew 	for (i = 0; i < num_channels; i++)
3083842bf24SAlan Carew 		cmdline_printf(cl, "[%u]: Adding channel %u\n", i, channel_list[i]);
3093842bf24SAlan Carew 
3103842bf24SAlan Carew 	channels_added = add_channels(res->vm_name, channel_list,
3113842bf24SAlan Carew 			num_channels);
3123842bf24SAlan Carew 	cmdline_printf(cl, "Enabled %d channels for '%s'\n", channels_added,
3133842bf24SAlan Carew 			res->vm_name);
3143842bf24SAlan Carew }
3153842bf24SAlan Carew 
3163842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_op =
3173842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_op_result,
3183842bf24SAlan Carew 				op, "add_channels");
3193842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_vm_name =
3203842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_op_result,
3213842bf24SAlan Carew 			vm_name, NULL);
3223842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_list =
3233842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_op_result,
3243842bf24SAlan Carew 			channel_list, NULL);
3253842bf24SAlan Carew 
3263842bf24SAlan Carew cmdline_parse_inst_t cmd_channels_op_set = {
3273842bf24SAlan Carew 	.f = cmd_channels_op_parsed,
3283842bf24SAlan Carew 	.data = NULL,
3293842bf24SAlan Carew 	.help_str = "add_channels <vm_name> <list>|all, add "
3303842bf24SAlan Carew 			"communication channels for the specified VM, the "
3313842bf24SAlan Carew 			"virtio channels must be enabled in the VM "
3323842bf24SAlan Carew 			"configuration(qemu/libvirt) and the associated VM must be active. "
3333842bf24SAlan Carew 			"<list> is a comma-separated list of channel numbers to add, using "
3343842bf24SAlan Carew 			"the keyword 'all' will attempt to add all channels for the VM",
3353842bf24SAlan Carew 	.tokens = {
3363842bf24SAlan Carew 		(void *)&cmd_channels_op,
3373842bf24SAlan Carew 		(void *)&cmd_channels_vm_name,
3383842bf24SAlan Carew 		(void *)&cmd_channels_list,
3393842bf24SAlan Carew 		NULL,
3403842bf24SAlan Carew 	},
3413842bf24SAlan Carew };
3423842bf24SAlan Carew 
3433842bf24SAlan Carew struct cmd_channels_status_op_result {
3443842bf24SAlan Carew 	cmdline_fixed_string_t op;
3453842bf24SAlan Carew 	cmdline_fixed_string_t vm_name;
3463842bf24SAlan Carew 	cmdline_fixed_string_t channel_list;
3473842bf24SAlan Carew 	cmdline_fixed_string_t status;
3483842bf24SAlan Carew };
3493842bf24SAlan Carew 
3503842bf24SAlan Carew static void
3513842bf24SAlan Carew cmd_channels_status_op_parsed(void *parsed_result, struct cmdline *cl,
3523842bf24SAlan Carew 		       __attribute__((unused)) void *data)
3533842bf24SAlan Carew {
3543842bf24SAlan Carew 	unsigned num_channels = 0, channel_num;
3553842bf24SAlan Carew 	int changed;
3563842bf24SAlan Carew 	unsigned channel_list[CHANNEL_CMDS_MAX_VM_CHANNELS];
3573842bf24SAlan Carew 	char *token, *remaining, *tail_ptr;
3583842bf24SAlan Carew 	struct cmd_channels_status_op_result *res = parsed_result;
3593842bf24SAlan Carew 	enum channel_status status;
3603842bf24SAlan Carew 
3613842bf24SAlan Carew 	if (!strcmp(res->status, "enabled"))
3623842bf24SAlan Carew 		status = CHANNEL_MGR_CHANNEL_CONNECTED;
3633842bf24SAlan Carew 	else
3643842bf24SAlan Carew 		status = CHANNEL_MGR_CHANNEL_DISABLED;
3653842bf24SAlan Carew 
3663842bf24SAlan Carew 	if (!strcmp(res->channel_list, "all")) {
3673842bf24SAlan Carew 		changed = set_channel_status_all(res->vm_name, status);
3683842bf24SAlan Carew 		cmdline_printf(cl, "Updated status of %d channels "
3693842bf24SAlan Carew 				"for VM '%s'\n", changed, res->vm_name);
3703842bf24SAlan Carew 		return;
3713842bf24SAlan Carew 	}
3723842bf24SAlan Carew 	remaining = res->channel_list;
3733842bf24SAlan Carew 	while (1) {
3743842bf24SAlan Carew 		if (remaining == NULL || remaining[0] == '\0')
3753842bf24SAlan Carew 			break;
3763842bf24SAlan Carew 		token = strsep(&remaining, ",");
3773842bf24SAlan Carew 		if (token == NULL)
3783842bf24SAlan Carew 			break;
3793842bf24SAlan Carew 		errno = 0;
3803842bf24SAlan Carew 		channel_num = (unsigned)strtol(token, &tail_ptr, 10);
3815b628fe1SBruce Richardson 		if ((errno != 0) || tail_ptr == NULL || (*tail_ptr != '\0'))
3823842bf24SAlan Carew 			break;
3833842bf24SAlan Carew 
3843842bf24SAlan Carew 		if (channel_num == CHANNEL_CMDS_MAX_VM_CHANNELS) {
3853842bf24SAlan Carew 			cmdline_printf(cl, "%u exceeds the maximum number of allowable "
3863842bf24SAlan Carew 					"channels(%u) for VM '%s'\n", channel_num,
3873842bf24SAlan Carew 					CHANNEL_CMDS_MAX_VM_CHANNELS, res->vm_name);
3883842bf24SAlan Carew 			return;
3893842bf24SAlan Carew 		}
3903842bf24SAlan Carew 		channel_list[num_channels++] = channel_num;
3913842bf24SAlan Carew 	}
3923842bf24SAlan Carew 	changed = set_channel_status(res->vm_name, channel_list, num_channels,
3933842bf24SAlan Carew 			status);
3943842bf24SAlan Carew 	cmdline_printf(cl, "Updated status of %d channels "
3953842bf24SAlan Carew 					"for VM '%s'\n", changed, res->vm_name);
3963842bf24SAlan Carew }
3973842bf24SAlan Carew 
3983842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_status_op =
3993842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_status_op_result,
4003842bf24SAlan Carew 				op, "set_channel_status");
4013842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_status_vm_name =
4023842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_status_op_result,
4033842bf24SAlan Carew 			vm_name, NULL);
4043842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_status_list =
4053842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_status_op_result,
4063842bf24SAlan Carew 			channel_list, NULL);
4073842bf24SAlan Carew cmdline_parse_token_string_t cmd_channels_status =
4083842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_channels_status_op_result,
4093842bf24SAlan Carew 			status, "enabled#disabled");
4103842bf24SAlan Carew 
4113842bf24SAlan Carew cmdline_parse_inst_t cmd_channels_status_op_set = {
4123842bf24SAlan Carew 	.f = cmd_channels_status_op_parsed,
4133842bf24SAlan Carew 	.data = NULL,
4143842bf24SAlan Carew 	.help_str = "set_channel_status <vm_name> <list>|all enabled|disabled, "
4153842bf24SAlan Carew 			" enable or disable the communication channels in "
4163842bf24SAlan Carew 			"list(comma-separated) for the specified VM, alternatively "
4173842bf24SAlan Carew 			"list can be replaced with keyword 'all'. "
4183842bf24SAlan Carew 			"Disabled channels will still receive packets on the host, "
4193842bf24SAlan Carew 			"however the commands they specify will be ignored. "
4203842bf24SAlan Carew 			"Set status to 'enabled' to begin processing requests again.",
4213842bf24SAlan Carew 	.tokens = {
4223842bf24SAlan Carew 		(void *)&cmd_channels_status_op,
4233842bf24SAlan Carew 		(void *)&cmd_channels_status_vm_name,
4243842bf24SAlan Carew 		(void *)&cmd_channels_status_list,
4253842bf24SAlan Carew 		(void *)&cmd_channels_status,
4263842bf24SAlan Carew 		NULL,
4273842bf24SAlan Carew 	},
4283842bf24SAlan Carew };
4293842bf24SAlan Carew 
4303842bf24SAlan Carew /* *** CPU Frequency operations *** */
4313842bf24SAlan Carew struct cmd_show_cpu_freq_mask_result {
4323842bf24SAlan Carew 	cmdline_fixed_string_t show_cpu_freq_mask;
4333842bf24SAlan Carew 	uint64_t core_mask;
4343842bf24SAlan Carew };
4353842bf24SAlan Carew 
4363842bf24SAlan Carew static void
4373842bf24SAlan Carew cmd_show_cpu_freq_mask_parsed(void *parsed_result, struct cmdline *cl,
4383842bf24SAlan Carew 		       __attribute__((unused)) void *data)
4393842bf24SAlan Carew {
4403842bf24SAlan Carew 	struct cmd_show_cpu_freq_mask_result *res = parsed_result;
4413842bf24SAlan Carew 	unsigned i;
4423842bf24SAlan Carew 	uint64_t mask = res->core_mask;
4433842bf24SAlan Carew 	uint32_t freq;
4443842bf24SAlan Carew 
4453842bf24SAlan Carew 	for (i = 0; mask; mask &= ~(1ULL << i++)) {
4463842bf24SAlan Carew 		if ((mask >> i) & 1) {
4473842bf24SAlan Carew 			freq = power_manager_get_current_frequency(i);
4483842bf24SAlan Carew 			if (freq > 0)
4493842bf24SAlan Carew 				cmdline_printf(cl, "Core %u: %"PRId32"\n", i, freq);
4503842bf24SAlan Carew 		}
4513842bf24SAlan Carew 	}
4523842bf24SAlan Carew }
4533842bf24SAlan Carew 
4543842bf24SAlan Carew cmdline_parse_token_string_t cmd_show_cpu_freq_mask =
4553842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_show_cpu_freq_mask_result,
4563842bf24SAlan Carew 			show_cpu_freq_mask, "show_cpu_freq_mask");
4573842bf24SAlan Carew cmdline_parse_token_num_t cmd_show_cpu_freq_mask_core_mask =
4583842bf24SAlan Carew 	TOKEN_NUM_INITIALIZER(struct cmd_show_cpu_freq_mask_result,
4593842bf24SAlan Carew 			core_mask, UINT64);
4603842bf24SAlan Carew 
4613842bf24SAlan Carew cmdline_parse_inst_t cmd_show_cpu_freq_mask_set = {
4623842bf24SAlan Carew 	.f = cmd_show_cpu_freq_mask_parsed,
4633842bf24SAlan Carew 	.data = NULL,
4643842bf24SAlan Carew 	.help_str = "show_cpu_freq_mask <mask>, Get the current frequency for each "
4653842bf24SAlan Carew 			"core specified in the mask",
4663842bf24SAlan Carew 	.tokens = {
4673842bf24SAlan Carew 		(void *)&cmd_show_cpu_freq_mask,
4683842bf24SAlan Carew 		(void *)&cmd_show_cpu_freq_mask_core_mask,
4693842bf24SAlan Carew 		NULL,
4703842bf24SAlan Carew 	},
4713842bf24SAlan Carew };
4723842bf24SAlan Carew 
4733842bf24SAlan Carew struct cmd_set_cpu_freq_mask_result {
4743842bf24SAlan Carew 	cmdline_fixed_string_t set_cpu_freq_mask;
4753842bf24SAlan Carew 	uint64_t core_mask;
4763842bf24SAlan Carew 	cmdline_fixed_string_t cmd;
4773842bf24SAlan Carew };
4783842bf24SAlan Carew 
4793842bf24SAlan Carew static void
4803842bf24SAlan Carew cmd_set_cpu_freq_mask_parsed(void *parsed_result, struct cmdline *cl,
4813842bf24SAlan Carew 			__attribute__((unused)) void *data)
4823842bf24SAlan Carew {
4833842bf24SAlan Carew 	struct cmd_set_cpu_freq_mask_result *res = parsed_result;
4843842bf24SAlan Carew 	int ret = -1;
4853842bf24SAlan Carew 
4863842bf24SAlan Carew 	if (!strcmp(res->cmd , "up"))
4873842bf24SAlan Carew 		ret = power_manager_scale_mask_up(res->core_mask);
4883842bf24SAlan Carew 	else if (!strcmp(res->cmd , "down"))
4893842bf24SAlan Carew 		ret = power_manager_scale_mask_down(res->core_mask);
4903842bf24SAlan Carew 	else if (!strcmp(res->cmd , "min"))
4913842bf24SAlan Carew 		ret = power_manager_scale_mask_min(res->core_mask);
4923842bf24SAlan Carew 	else if (!strcmp(res->cmd , "max"))
4933842bf24SAlan Carew 		ret = power_manager_scale_mask_max(res->core_mask);
494567997b9SDavid Hunt 	else if (!strcmp(res->cmd, "enable_turbo"))
495567997b9SDavid Hunt 		ret = power_manager_enable_turbo_mask(res->core_mask);
496567997b9SDavid Hunt 	else if (!strcmp(res->cmd, "disable_turbo"))
497567997b9SDavid Hunt 		ret = power_manager_disable_turbo_mask(res->core_mask);
4983842bf24SAlan Carew 	if (ret < 0) {
4993842bf24SAlan Carew 		cmdline_printf(cl, "Error scaling core_mask(0x%"PRIx64") '%s' , not "
5003842bf24SAlan Carew 				"all cores specified have been scaled\n",
5013842bf24SAlan Carew 				res->core_mask, res->cmd);
5023842bf24SAlan Carew 	};
5033842bf24SAlan Carew }
5043842bf24SAlan Carew 
5053842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_cpu_freq_mask =
5063842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_set_cpu_freq_mask_result,
5073842bf24SAlan Carew 			set_cpu_freq_mask, "set_cpu_freq_mask");
5083842bf24SAlan Carew cmdline_parse_token_num_t cmd_set_cpu_freq_mask_core_mask =
5093842bf24SAlan Carew 	TOKEN_NUM_INITIALIZER(struct cmd_set_cpu_freq_mask_result,
5103842bf24SAlan Carew 			core_mask, UINT64);
5113842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_cpu_freq_mask_result =
5123842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_set_cpu_freq_mask_result,
513567997b9SDavid Hunt 			cmd, "up#down#min#max#enable_turbo#disable_turbo");
5143842bf24SAlan Carew 
5153842bf24SAlan Carew cmdline_parse_inst_t cmd_set_cpu_freq_mask_set = {
5163842bf24SAlan Carew 	.f = cmd_set_cpu_freq_mask_parsed,
5173842bf24SAlan Carew 	.data = NULL,
518567997b9SDavid Hunt 	.help_str = "set_cpu_freq <core_mask> <up|down|min|max|enable_turbo|disable_turbo>, adjust the current "
519567997b9SDavid Hunt 			"frequency for the cores specified in <core_mask>",
5203842bf24SAlan Carew 	.tokens = {
5213842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq_mask,
5223842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq_mask_core_mask,
5233842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq_mask_result,
5243842bf24SAlan Carew 		NULL,
5253842bf24SAlan Carew 	},
5263842bf24SAlan Carew };
5273842bf24SAlan Carew 
5283842bf24SAlan Carew 
5293842bf24SAlan Carew 
5303842bf24SAlan Carew struct cmd_show_cpu_freq_result {
5313842bf24SAlan Carew 	cmdline_fixed_string_t show_cpu_freq;
5323842bf24SAlan Carew 	uint8_t core_num;
5333842bf24SAlan Carew };
5343842bf24SAlan Carew 
5353842bf24SAlan Carew static void
5363842bf24SAlan Carew cmd_show_cpu_freq_parsed(void *parsed_result, struct cmdline *cl,
5373842bf24SAlan Carew 		       __attribute__((unused)) void *data)
5383842bf24SAlan Carew {
5393842bf24SAlan Carew 	struct cmd_show_cpu_freq_result *res = parsed_result;
5403842bf24SAlan Carew 	uint32_t curr_freq = power_manager_get_current_frequency(res->core_num);
5413842bf24SAlan Carew 
5423842bf24SAlan Carew 	if (curr_freq == 0) {
5433842bf24SAlan Carew 		cmdline_printf(cl, "Unable to get frequency for core %u\n",
5443842bf24SAlan Carew 				res->core_num);
5453842bf24SAlan Carew 		return;
5463842bf24SAlan Carew 	}
5473842bf24SAlan Carew 	cmdline_printf(cl, "Core %u frequency: %"PRId32"\n", res->core_num,
5483842bf24SAlan Carew 			curr_freq);
5493842bf24SAlan Carew }
5503842bf24SAlan Carew 
5513842bf24SAlan Carew cmdline_parse_token_string_t cmd_show_cpu_freq =
5523842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_show_cpu_freq_result,
5533842bf24SAlan Carew 			show_cpu_freq, "show_cpu_freq");
5543842bf24SAlan Carew 
5553842bf24SAlan Carew cmdline_parse_token_num_t cmd_show_cpu_freq_core_num =
5563842bf24SAlan Carew 	TOKEN_NUM_INITIALIZER(struct cmd_show_cpu_freq_result,
5573842bf24SAlan Carew 			core_num, UINT8);
5583842bf24SAlan Carew 
5593842bf24SAlan Carew cmdline_parse_inst_t cmd_show_cpu_freq_set = {
5603842bf24SAlan Carew 	.f = cmd_show_cpu_freq_parsed,
5613842bf24SAlan Carew 	.data = NULL,
5623842bf24SAlan Carew 	.help_str = "Get the current frequency for the specified core",
5633842bf24SAlan Carew 	.tokens = {
5643842bf24SAlan Carew 		(void *)&cmd_show_cpu_freq,
5653842bf24SAlan Carew 		(void *)&cmd_show_cpu_freq_core_num,
5663842bf24SAlan Carew 		NULL,
5673842bf24SAlan Carew 	},
5683842bf24SAlan Carew };
5693842bf24SAlan Carew 
5703842bf24SAlan Carew struct cmd_set_cpu_freq_result {
5713842bf24SAlan Carew 	cmdline_fixed_string_t set_cpu_freq;
5723842bf24SAlan Carew 	uint8_t core_num;
5733842bf24SAlan Carew 	cmdline_fixed_string_t cmd;
5743842bf24SAlan Carew };
5753842bf24SAlan Carew 
5763842bf24SAlan Carew static void
5773842bf24SAlan Carew cmd_set_cpu_freq_parsed(void *parsed_result, struct cmdline *cl,
5783842bf24SAlan Carew 		       __attribute__((unused)) void *data)
5793842bf24SAlan Carew {
5803842bf24SAlan Carew 	int ret = -1;
5813842bf24SAlan Carew 	struct cmd_set_cpu_freq_result *res = parsed_result;
5823842bf24SAlan Carew 
5833842bf24SAlan Carew 	if (!strcmp(res->cmd , "up"))
5843842bf24SAlan Carew 		ret = power_manager_scale_core_up(res->core_num);
5853842bf24SAlan Carew 	else if (!strcmp(res->cmd , "down"))
5863842bf24SAlan Carew 		ret = power_manager_scale_core_down(res->core_num);
5873842bf24SAlan Carew 	else if (!strcmp(res->cmd , "min"))
5883842bf24SAlan Carew 		ret = power_manager_scale_core_min(res->core_num);
5893842bf24SAlan Carew 	else if (!strcmp(res->cmd , "max"))
5903842bf24SAlan Carew 		ret = power_manager_scale_core_max(res->core_num);
591567997b9SDavid Hunt 	else if (!strcmp(res->cmd, "enable_turbo"))
592567997b9SDavid Hunt 		ret = power_manager_enable_turbo_core(res->core_num);
593567997b9SDavid Hunt 	else if (!strcmp(res->cmd, "disable_turbo"))
594567997b9SDavid Hunt 		ret = power_manager_disable_turbo_core(res->core_num);
5953842bf24SAlan Carew 	if (ret < 0) {
5963842bf24SAlan Carew 		cmdline_printf(cl, "Error scaling core(%u) '%s'\n", res->core_num,
5973842bf24SAlan Carew 				res->cmd);
5983842bf24SAlan Carew 	}
5993842bf24SAlan Carew }
6003842bf24SAlan Carew 
6013842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_cpu_freq =
6023842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_set_cpu_freq_result,
6033842bf24SAlan Carew 			set_cpu_freq, "set_cpu_freq");
604b68bc0b8SOlivier Matz cmdline_parse_token_num_t cmd_set_cpu_freq_core_num =
6053842bf24SAlan Carew 	TOKEN_NUM_INITIALIZER(struct cmd_set_cpu_freq_result,
6063842bf24SAlan Carew 			core_num, UINT8);
6073842bf24SAlan Carew cmdline_parse_token_string_t cmd_set_cpu_freq_cmd_cmd =
6083842bf24SAlan Carew 	TOKEN_STRING_INITIALIZER(struct cmd_set_cpu_freq_result,
609567997b9SDavid Hunt 			cmd, "up#down#min#max#enable_turbo#disable_turbo");
6103842bf24SAlan Carew 
6113842bf24SAlan Carew cmdline_parse_inst_t cmd_set_cpu_freq_set = {
6123842bf24SAlan Carew 	.f = cmd_set_cpu_freq_parsed,
6133842bf24SAlan Carew 	.data = NULL,
614567997b9SDavid Hunt 	.help_str = "set_cpu_freq <core_num> <up|down|min|max|enable_turbo|disable_turbo>, adjust the current "
615567997b9SDavid Hunt 			"frequency for the specified core",
6163842bf24SAlan Carew 	.tokens = {
6173842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq,
6183842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq_core_num,
6193842bf24SAlan Carew 		(void *)&cmd_set_cpu_freq_cmd_cmd,
6203842bf24SAlan Carew 		NULL,
6213842bf24SAlan Carew 	},
6223842bf24SAlan Carew };
6233842bf24SAlan Carew 
6243842bf24SAlan Carew cmdline_parse_ctx_t main_ctx[] = {
6253842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_quit,
6263842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_vm_op_set,
6273842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_channels_op_set,
6283842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_channels_status_op_set,
6293842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_show_vm_set,
6303842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_show_cpu_freq_mask_set,
6313842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_set_cpu_freq_mask_set,
6323842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_show_cpu_freq_set,
6333842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_set_cpu_freq_set,
6343842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_set_pcpu_mask_set,
6353842bf24SAlan Carew 		(cmdline_parse_inst_t *)&cmd_set_pcpu_set,
6363842bf24SAlan Carew 		NULL,
6373842bf24SAlan Carew };
6383842bf24SAlan Carew 
6393842bf24SAlan Carew void
6403842bf24SAlan Carew run_cli(__attribute__((unused)) void *arg)
6413842bf24SAlan Carew {
6423842bf24SAlan Carew 	struct cmdline *cl;
6433842bf24SAlan Carew 
6443842bf24SAlan Carew 	cl = cmdline_stdin_new(main_ctx, "vmpower> ");
6453842bf24SAlan Carew 	if (cl == NULL)
6463842bf24SAlan Carew 		return;
6473842bf24SAlan Carew 
6483842bf24SAlan Carew 	cmdline_interact(cl);
6493842bf24SAlan Carew 	cmdline_stdin_exit(cl);
6503842bf24SAlan Carew }
651