qdevice: Implement shutdown command

Signed-off-by: Jan Friesse <jfriesse@redhat.com>

qdevices/qdevice-ipc.c

@@ -135,6 +135,20 @@ qdevice_ipc_send_error(struct qdevice_instance *instance, struct unix_socket_cli
 	return (res ? 0 : -1);
 }
 
+int
+qdevice_ipc_send_buffer(struct qdevice_instance *instance, struct unix_socket_client *client)
+{
+
+	if (dynar_str_prepend(&client->send_buffer, "OK\n") != 0) {
+		qdevice_log(LOG_ERR, "Can't send error to client (buffer too small)");
+
+		return (-1);
+	}
+
+	unix_socket_client_write_buffer(client, 1);
+
+	return (0);
+}
 
 static void
 qdevice_ipc_parse_line(struct qdevice_instance *instance, struct unix_socket_client *client)
@@ -142,6 +156,9 @@ qdevice_ipc_parse_line(struct qdevice_instance *instance, struct unix_socket_cli
 	struct dynar_simple_lex lex;
 	struct dynar *token;
 	char *str;
+	struct qdevice_ipc_user_data *ipc_user_data;
+
+	ipc_user_data = (struct qdevice_ipc_user_data *)client->user_data;
 
 	dynar_simple_lex_init(&lex, &client->receive_buffer);
 	token = dynar_simple_lex_token_next(&lex);
@@ -160,7 +177,12 @@ qdevice_ipc_parse_line(struct qdevice_instance *instance, struct unix_socket_cli
 		}
 	} else if (strcasecmp(str, "shutdown") == 0) {
 		qdevice_log(LOG_DEBUG, "IPC client requested shutdown");
-		// Send output?
+
+		ipc_user_data->shutdown_requested = 1;
+
+		if (qdevice_ipc_send_buffer(instance, client) != 0) {
+			client->schedule_disconnect = 1;
+		}
 	} else if (strcasecmp(str, "status") == 0) {
 		qdevice_log(LOG_DEBUG, "IPC client requested status display");
 		// Send output
@@ -214,6 +236,9 @@ void
 qdevice_ipc_io_write(struct qdevice_instance *instance, struct unix_socket_client *client)
 {
 	int res;
+	struct qdevice_ipc_user_data *ipc_user_data;
+
+	ipc_user_data = (struct qdevice_ipc_user_data *)client->user_data;
 
 	res = unix_socket_client_io_write(client);
 
@@ -238,6 +263,10 @@ qdevice_ipc_io_write(struct qdevice_instance *instance, struct unix_socket_clien
 		unix_socket_client_write_buffer(client, 0);
 		client->schedule_disconnect = 1;
 
+		if (ipc_user_data->shutdown_requested) {
+			qdevice_ipc_destroy(instance);
+		}
+
 		break;
 	}
 }

qdevices/qdevice-ipc.h

@@ -43,6 +43,7 @@ extern "C" {
 
 struct qdevice_ipc_user_data {
 	void *model_data;
+	int shutdown_requested;
 };
 
 extern int		qdevice_ipc_init(struct qdevice_instance *instance);
@@ -65,6 +66,9 @@ extern int		qdevice_ipc_send_error(struct qdevice_instance *instance,
     struct unix_socket_client *client, const char *error_fmt, ...)
     __attribute__((__format__(__printf__, 3, 4)));
 
+extern int		qdevice_ipc_send_buffer(struct qdevice_instance *instance,
+    struct unix_socket_client *client);
+
 #ifdef __cplusplus
 }
 #endif