VBoxServiceControl.cpp revision b47f1bf67de12aaf4f0827597196f26a5539c34b
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/* $Id$ */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** @file
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * VBoxServiceControl - Host-driven Guest Control.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Copyright (C) 2011 Oracle Corporation
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * available from http://www.virtualbox.org. This file is free software;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * you can redistribute it and/or modify it under the terms of the GNU
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * General Public License (GPL) as published by the Free Software
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/*******************************************************************************
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync* Header Files *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync*******************************************************************************/
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/asm.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/assert.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/getopt.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/mem.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/semaphore.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <iprt/thread.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <VBox/VBoxGuestLib.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include <VBox/HostServices/GuestControlSvc.h>
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include "VBoxServiceInternal.h"
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include "VBoxServiceUtils.h"
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#include "VBoxServiceControlExecThread.h"
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncusing namespace guestControl;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/*******************************************************************************
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync* Global Variables *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync*******************************************************************************/
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** The control interval (milliseconds). */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncuint32_t g_ControlInterval = 0;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** The semaphore we're blocking our main control thread on. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncRTSEMEVENTMULTI g_hControlEvent = NIL_RTSEMEVENTMULTI;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** The guest control service client ID. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncstatic uint32_t g_GuestControlSvcClientID = 0;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** How many started guest processes are kept into memory for supplying
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * information to the host. Default is 25 processes. If 0 is specified,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * the maximum number of processes is unlimited. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncuint32_t g_GuestControlProcsMaxKept = 25;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** List of guest control threads. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncRTLISTNODE g_GuestControlThreads;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** Critical section protecting g_GuestControlExecThreads. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncRTCRITSECT g_GuestControlThreadsCritSect;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsyncstatic int VBoxServiceControlStartAllowed(bool *pbAllowed);
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync/** @copydoc VBOXSERVICE::pfnPreInit */
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsyncstatic DECLCALLBACK(int) VBoxServiceControlPreInit(void)
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync{
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#ifdef VBOX_WITH_GUEST_PROPS
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Read the service options from the VM's guest properties.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Note that these options can be overridden by the command line options later.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uGuestPropSvcClientID;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc = VbglR3GuestPropConnect(&uGuestPropSvcClientID);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (rc == VERR_HGCM_SERVICE_NOT_FOUND) /* Host service is not available. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(0, "Control: Guest property service is not available, skipping\n");
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VINF_SUCCESS;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceError("Control: Failed to connect to the guest property service! Error: %Rrc\n", rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync else
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VBoxServiceReadPropUInt32(uGuestPropSvcClientID, "/VirtualBox/GuestAdd/VBoxService/--control-procs-max-kept",
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync &g_GuestControlProcsMaxKept, 0, UINT32_MAX - 1);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VbglR3GuestPropDisconnect(uGuestPropSvcClientID);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync if (rc == VERR_NOT_FOUND) /* If a value is not found, don't be sad! */
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync rc = VINF_SUCCESS;
7c1f498692cd2393f8ba68cb62be482495106f93vboxsync return rc;
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync#else
7c1f498692cd2393f8ba68cb62be482495106f93vboxsync /* Nothing to do here yet. */
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync return VINF_SUCCESS;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#endif
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** @copydoc VBOXSERVICE::pfnOption */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncstatic DECLCALLBACK(int) VBoxServiceControlOption(const char **ppszShort, int argc, char **argv, int *pi)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync{
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync int rc = -1;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (ppszShort)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* no short options */;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else if (!strcmp(argv[*pi], "--control-interval"))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VBoxServiceArgUInt32(argc, argv, "", pi,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync &g_ControlInterval, 1, UINT32_MAX - 1);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else if (!strcmp(argv[*pi], "--control-procs-max-kept"))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VBoxServiceArgUInt32(argc, argv, "", pi,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync &g_GuestControlProcsMaxKept, 0, UINT32_MAX - 1);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync return rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** @copydoc VBOXSERVICE::pfnInit */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncstatic DECLCALLBACK(int) VBoxServiceControlInit(void)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * If not specified, find the right interval default.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * Then create the event sem to block on.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if (!g_ControlInterval)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync g_ControlInterval = 1000;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc = RTSemEventMultiCreate(&g_hControlEvent);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync AssertRCReturn(rc, rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VbglR3GuestCtrlConnect(&g_GuestControlSvcClientID);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_SUCCESS(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(3, "Control: Service client ID: %#x\n", g_GuestControlSvcClientID);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync /* Init thread list. */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync RTListInit(&g_GuestControlThreads);
91f8453d16b48876deddaba298c211071d0ca3a5vboxsync rc = RTCritSectInit(&g_GuestControlThreadsCritSect);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync AssertRC(rc);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync else
4cf22805d13f50eef86e917f2c7106fe5198a2d8vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync /* If the service was not found, we disable this service without
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync causing VBoxService to fail. */
9dfcf62b7a5a289684d46ee55f6042d49509daecvboxsync if (rc == VERR_HGCM_SERVICE_NOT_FOUND) /* Host service is not available. */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(0, "Control: Guest control service is not available\n");
49e54e2ffe0c10864d06e9d1ebe24a8eb1327a6bvboxsync rc = VERR_SERVICE_DISABLED;
49e54e2ffe0c10864d06e9d1ebe24a8eb1327a6bvboxsync }
49e54e2ffe0c10864d06e9d1ebe24a8eb1327a6bvboxsync else
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceError("Control: Failed to connect to the guest control service! Error: %Rrc\n", rc);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync RTSemEventMultiDestroy(g_hControlEvent);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync g_hControlEvent = NIL_RTSEMEVENTMULTI;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync return rc;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync}
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync/** @copydoc VBOXSERVICE::pfnWorker */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsyncDECLCALLBACK(int) VBoxServiceControlWorker(bool volatile *pfShutdown)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync /*
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * Tell the control thread that it can continue
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * spawning services.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync RTThreadUserSignal(RTThreadSelf());
a59528c40bbfdcee2e315756333f8c66f35b5accvboxsync Assert(g_GuestControlSvcClientID > 0);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync int rc = VINF_SUCCESS;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
e214bb78026c1d64078b34ca9504d3f5abbc52efvboxsync /*
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * Execution loop.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync *
fc148a6b23d25a87561beaffe0ba06c3ba93bf5avboxsync * @todo
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync */
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync for (;;)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uMsg;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uint32_t uNumParms;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(3, "Control: Waiting for host msg ...\n");
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync rc = VbglR3GuestCtrlWaitForHostMsg(g_GuestControlSvcClientID, &uMsg, &uNumParms);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (rc == VERR_TOO_MUCH_DATA)
9bb98d54790a98dad0ad6d9bdc5d319b6fdf0bffvboxsync {
9bb98d54790a98dad0ad6d9bdc5d319b6fdf0bffvboxsync VBoxServiceVerbose(4, "Control: Message requires %ld parameters, but only 2 supplied -- retrying request (no error!)...\n", uNumParms);
9bb98d54790a98dad0ad6d9bdc5d319b6fdf0bffvboxsync rc = VINF_SUCCESS; /* Try to get "real" message in next block below. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync else
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(3, "Control: Getting host message failed with %Rrc\n", rc); /* VERR_GEN_IO_FAILURE seems to be normal if ran into timeout. */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if (RT_SUCCESS(rc))
629e8f58c569e4c51a98284c41754fd9f0b973f8vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(3, "Control: Msg=%u (%u parms) retrieved\n", uMsg, uNumParms);
7c1f498692cd2393f8ba68cb62be482495106f93vboxsync switch(uMsg)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync case HOST_CANCEL_PENDING_WAITS:
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(3, "Control: Host asked us to quit ...\n");
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync break;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync case HOST_EXEC_CMD:
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync rc = VBoxServiceControlHandleCmdStartProc(g_GuestControlSvcClientID, uNumParms);
801238b286a80a5dd67ba56a1f26c0bc98a2a1eavboxsync break;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync case HOST_EXEC_SET_INPUT:
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync /** @todo Make buffer size configurable via guest properties/argv! */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VBoxServiceControlHandleCmdSetInput(g_GuestControlSvcClientID, uNumParms, _1M /* Buffer size */);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync case HOST_EXEC_GET_OUTPUT:
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VBoxServiceControlHandleCmdGetOutput(g_GuestControlSvcClientID, uNumParms);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync default:
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(3, "Control: Unsupported message from host! Msg=%u\n", uMsg);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Don't terminate here; just wait for the next message. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
5704a317c3b6bdf4b59f6a6ebe45d443296b1995vboxsync VBoxServiceVerbose(3, "Control: Message was processed with rc=%Rrc\n", rc);
5704a317c3b6bdf4b59f6a6ebe45d443296b1995vboxsync }
5704a317c3b6bdf4b59f6a6ebe45d443296b1995vboxsync
5704a317c3b6bdf4b59f6a6ebe45d443296b1995vboxsync /* Do we need to shutdown? */
5704a317c3b6bdf4b59f6a6ebe45d443296b1995vboxsync if ( *pfShutdown
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync || uMsg == HOST_CANCEL_PENDING_WAITS)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VINF_SUCCESS;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Let's sleep for a bit and let others run ... */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync RTThreadYield();
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync RTSemEventMultiDestroy(g_hControlEvent);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync g_hControlEvent = NIL_RTSEMEVENTMULTI;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync return rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/**
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * Handles starting processes on the guest.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync *
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @returns IPRT status code.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param u32ClientId The HGCM client session ID.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param uNumParms The number of parameters the host is offering.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsyncint VBoxServiceControlHandleCmdStartProc(uint32_t uClientID, uint32_t uNumParms)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync{
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uint32_t uContextID;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync char szCmd[_1K];
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uint32_t uFlags;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync char szArgs[_1K];
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uint32_t uNumArgs;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync char szEnv[_64K];
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uint32_t cbEnv = sizeof(szEnv);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uNumEnvVars;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync char szUser[128];
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync char szPassword[128];
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync uint32_t uTimeLimitMS;
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync#if 0 /* for valgrind */
be6a25d1b25b8692d8c035b0549e5258c6986dc5vboxsync RT_ZERO(szCmd);
be6a25d1b25b8692d8c035b0549e5258c6986dc5vboxsync RT_ZERO(szArgs);
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync RT_ZERO(szEnv);
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync RT_ZERO(szUser);
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync RT_ZERO(szPassword);
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync#endif
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync if (uNumParms != 11)
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync return VERR_INVALID_PARAMETER;
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync int rc = VbglR3GuestCtrlExecGetHostCmd(uClientID,
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync uNumParms,
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync &uContextID,
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync /* Command */
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync szCmd, sizeof(szCmd),
1e289ac7f0c5324ef5712727fc61b2a322eb2e1avboxsync /* Flags */
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync &uFlags,
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync /* Arguments */
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync szArgs, sizeof(szArgs), &uNumArgs,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Environment */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync szEnv, &cbEnv, &uNumEnvVars,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Credentials */
251867ef7a8ad4e0d583f4ff4dbdce6071387e26vboxsync szUser, sizeof(szUser),
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync szPassword, sizeof(szPassword),
a2d9f81753c129b5e3bbe3769627dcd25a3724bdvboxsync /* Timelimit */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync &uTimeLimitMS);
251867ef7a8ad4e0d583f4ff4dbdce6071387e26vboxsync if (RT_SUCCESS(rc))
251867ef7a8ad4e0d583f4ff4dbdce6071387e26vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#ifdef DEBUG
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(3, "ControlExec: Start process szCmd=%s, uFlags=%u, szArgs=%s, szEnv=%s, szUser=%s, szPW=%s, uTimeout=%u\n",
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync szCmd, uFlags, uNumArgs ? szArgs : "<None>", uNumEnvVars ? szEnv : "<None>", szUser, szPassword, uTimeLimitMS);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync#endif
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync bool fAllowed = false;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc = VBoxServiceControlStartAllowed(&fAllowed);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceError("ControlExec: Error determining whether process can be started or not, rc=%Rrc\n", rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if ( RT_SUCCESS(rc)
000d3a358f1072f58336eaea956b19888b123e49vboxsync && fAllowed)
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync {
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync int rc = RTCritSectEnter(&g_GuestControlThreadsCritSect);
b6957a412c94dd85c0e5f9e201bb715c4b685f2fvboxsync if (RT_SUCCESS(rc))
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync {
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync /** @todo Put the following params into a struct! */
b6957a412c94dd85c0e5f9e201bb715c4b685f2fvboxsync RTLISTNODE *pThreadNode;
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync rc = VBoxServiceControlThreadStart(uClientID, uContextID,
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync szCmd, uFlags, szArgs, uNumArgs,
be6a25d1b25b8692d8c035b0549e5258c6986dc5vboxsync szEnv, cbEnv, uNumEnvVars,
be6a25d1b25b8692d8c035b0549e5258c6986dc5vboxsync szUser, szPassword, uTimeLimitMS,
a1a2e3f1c3ca7d6190c90ff67b7995b50b258794vboxsync &pThreadNode);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_SUCCESS(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Insert thread node into thread list. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*rc =*/ RTListAppend(&g_GuestControlThreads, pThreadNode);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc2 = RTCritSectLeave(&g_GuestControlThreadsCritSect);
028cf251b334848ebf6ab5afa7081e4721d994f5vboxsync if (RT_SUCCESS(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = rc2;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync else /* Process start is not allowed due to policy settings. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Tell the host. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VbglR3GuestCtrlExecReportStatus(uClientID, uContextID, 0 /* PID, invalid. */,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync PROC_STS_ERROR, VERR_MAX_PROCS_REACHED,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync NULL /* pvData */, 0 /* cbData */);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceError("ControlExec: Failed to retrieve exec start command! Error: %Rrc\n", rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync return rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/**
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Gets output from stdout/stderr of a specified guest process.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @return IPRT status code.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param uPID PID of process to retrieve the output from.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param uHandleId Stream ID (stdout = 0, stderr = 2) to get the output from.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param uTimeout Timeout (in ms) to wait for output becoming available.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param pvBuf Pointer to a pre-allocated buffer to store the output.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param cbBuf Size (in bytes) of the pre-allocated buffer.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param pcbRead Pointer to number of bytes read. Optional.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncint VBoxServiceControlExecGetOutput(uint32_t uPID, uint32_t uHandleId, uint32_t uTimeout,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync void *pvBuf, uint32_t cbBuf, uint32_t *pcbRead)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync AssertPtrReturn(pvBuf, VERR_INVALID_POINTER);
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync AssertReturn(cbBuf, VERR_INVALID_PARAMETER);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* pcbRead is optional. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync int rc = VINF_SUCCESS;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBOXSERVICECTRLREQUEST ctrlRequest;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.cbData = cbBuf;
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync ctrlRequest.pvData = (uint8_t*)pvBuf;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync switch (uHandleId)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync case OUTPUT_HANDLE_ID_STDERR:
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.enmType = VBOXSERVICECTRLREQUEST_STDERR_READ;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync case OUTPUT_HANDLE_ID_STDOUT:
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync case OUTPUT_HANDLE_ID_STDOUT_DEPRECATED:
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.enmType = VBOXSERVICECTRLREQUEST_STDOUT_READ;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync break;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync default:
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync rc = VERR_INVALID_PARAMETER;
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync break;
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync }
78dfd747e1837f5de0bc5625c39dff4b98e3d4d4vboxsync
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync if (RT_SUCCESS(rc))
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync rc = VBoxServiceControlExecThreadPerform(uPID, &ctrlRequest);
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_SUCCESS(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (pcbRead)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *pcbRead = ctrlRequest.cbData;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync return rc;
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync}
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/**
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Injects input to a specified running process.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @return IPRT status code.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param uPID PID of process to set the input for.
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync * @param fPendingClose Flag indicating whether this is the last input block sent to the process.
78dfd747e1837f5de0bc5625c39dff4b98e3d4d4vboxsync * @param pvBuf Pointer to a buffer containing the actual input data.
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync * @param cbBuf Size (in bytes) of the input buffer data.
70f7b6ff8dc13303a70e552dd7003aa672e985a2vboxsync * @param pcbWritten Pointer to number of bytes written to the process. Optional.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncint VBoxServiceControlSetInput(uint32_t uPID, bool fPendingClose,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync void *pvBuf, uint32_t cbBuf,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t *pcbWritten)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync AssertPtrReturn(pvBuf, VERR_INVALID_PARAMETER);
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync AssertReturn(cbBuf, VERR_INVALID_PARAMETER);
78dfd747e1837f5de0bc5625c39dff4b98e3d4d4vboxsync /* pcbWritten is optional. */
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync
47699a0c42ead32866009e0d91bfb349490feaf9vboxsync int rc = VINF_SUCCESS;
78dfd747e1837f5de0bc5625c39dff4b98e3d4d4vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBOXSERVICECTRLREQUEST ctrlRequest;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.cbData = cbBuf;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.pvData = pvBuf;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ctrlRequest.enmType = fPendingClose
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync ? VBOXSERVICECTRLREQUEST_STDIN_WRITE_EOF : VBOXSERVICECTRLREQUEST_STDIN_WRITE;
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync if (RT_SUCCESS(rc))
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync rc = VBoxServiceControlExecThreadPerform(uPID, &ctrlRequest);
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync if (RT_SUCCESS(rc))
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync {
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync if (pcbWritten)
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync *pcbWritten = ctrlRequest.cbData;
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync }
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync
ac2b2ae448fe887af9a3269e40afff11ebb1f9d3vboxsync return rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/**
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Handles input for a started process by copying the received data into its
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * stdin pipe.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @returns IPRT status code.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param u32ClientId The HGCM client session ID.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param uNumParms The number of parameters the host is offering.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * @param cMaxBufSize The maximum buffer size for retrieving the input data.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncint VBoxServiceControlHandleCmdSetInput(uint32_t u32ClientId, uint32_t uNumParms, size_t cbMaxBufSize)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uContextID;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uPID;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uFlags;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t cbSize;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync AssertReturn(RT_IS_POWER_OF_TWO(cbMaxBufSize), VERR_INVALID_PARAMETER);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint8_t *pabBuffer = (uint8_t*)RTMemAlloc(cbMaxBufSize);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync AssertPtrReturn(pabBuffer, VERR_NO_MEMORY);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t uStatus = INPUT_STS_UNDEFINED; /* Status sent back to the host. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uint32_t cbWritten = 0; /* Number of bytes written to the guest. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Ask the host for the input data.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc = VbglR3GuestCtrlExecGetHostCmdInput(u32ClientId, uNumParms,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync &uContextID, &uPID, &uFlags,
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync pabBuffer, cbMaxBufSize, &cbSize);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if (RT_FAILURE(rc))
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceError("ControlExec: [PID %u]: Failed to retrieve exec input command! Error: %Rrc\n",
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uPID, rc);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync else if (cbSize > cbMaxBufSize)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceError("ControlExec: [PID %u]: Too much input received! cbSize=%u, cbMaxBufSize=%u\n",
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uPID, cbSize, cbMaxBufSize);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync rc = VERR_INVALID_PARAMETER;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Is this the last input block we need to deliver? Then let the pipe know ...
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync bool fPendingClose = false;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if (uFlags & INPUT_FLAG_EOF)
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync {
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync fPendingClose = true;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(4, "ControlExec: [PID %u]: Got last input block of size %u ...\n",
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uPID, cbSize);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync rc = VBoxServiceControlSetInput(uPID, fPendingClose, pabBuffer,
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync cbSize, &cbWritten);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync VBoxServiceVerbose(4, "ControlExec: [PID %u]: Written input, rc=%Rrc, uFlags=0x%x, fPendingClose=%d, cbSize=%u, cbWritten=%u\n",
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync uPID, rc, uFlags, fPendingClose, cbSize, cbWritten);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if (RT_SUCCESS(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (cbWritten || !cbSize) /* Did we write something or was there anything to write at all? */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uStatus = INPUT_STS_WRITTEN;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uFlags = 0;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (rc == VERR_BAD_PIPE)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uStatus = INPUT_STS_TERMINATED;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync else if (rc == VERR_BUFFER_OVERFLOW)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uStatus = INPUT_STS_OVERFLOW;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync RTMemFree(pabBuffer);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * If there was an error and we did not set the host status
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * yet, then do it now.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync if ( RT_FAILURE(rc)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync && uStatus == INPUT_STS_UNDEFINED)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uStatus = INPUT_STS_ERROR;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uFlags = rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync Assert(uStatus > INPUT_STS_UNDEFINED);
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(3, "ControlExec: [PID %u]: Input processed, CID=%u, uStatus=%u, uFlags=0x%x, cbWritten=%u\n",
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uPID, uContextID, uStatus, uFlags, cbWritten);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /* Note: Since the context ID is unique the request *has* to be completed here,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * regardless whether we got data or not! Otherwise the progress object
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * on the host never will get completed! */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VbglR3GuestCtrlExecReportStatusIn(u32ClientId, uContextID, uPID,
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uStatus, uFlags, (uint32_t)cbWritten);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync VBoxServiceError("ControlExec: [PID %u]: Failed to report input status! Error: %Rrc\n",
b8c2e8ba48bd659fa09a06770a7cedfae977d73bvboxsync uPID, rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync return rc;
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync}
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/**
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Handles the guest control output command.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync *
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @return IPRT status code.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param u32ClientId idClient The HGCM client session ID.
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * @param uNumParms cParms The number of parameters the host is
d40a840eecf0146eee47c14edaef7ace1ddfb5a6vboxsync * offering.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncint VBoxServiceControlHandleCmdGetOutput(uint32_t u32ClientId, uint32_t uNumParms)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync uint32_t uContextID;
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync uint32_t uPID;
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync uint32_t uHandleID;
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync uint32_t uFlags;
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync int rc = VbglR3GuestCtrlExecGetHostCmdOutput(u32ClientId, uNumParms,
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync &uContextID, &uPID, &uHandleID, &uFlags);
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync if (RT_SUCCESS(rc))
410216171f7f7033678589acb6e342303978c918vboxsync {
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync uint32_t cbRead = 0;
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync uint8_t *pBuf = (uint8_t*)RTMemAlloc(_64K);
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync if (pBuf)
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync {
ec9dc23c50665e8603e1be5a9b6b6fd4c4d949d4vboxsync rc = VBoxServiceControlExecGetOutput(uPID, uHandleID, RT_INDEFINITE_WAIT /* Timeout */,
d1fcf24d24368926be13484524a9e378070a9157vboxsync pBuf, _64K /* cbSize */, &cbRead);
d1fcf24d24368926be13484524a9e378070a9157vboxsync if (RT_SUCCESS(rc))
d1fcf24d24368926be13484524a9e378070a9157vboxsync VBoxServiceVerbose(3, "ControlExec: [PID %u]: Got output, CID=%u, cbRead=%u, uHandle=%u, uFlags=%u\n",
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync uPID, uContextID, cbRead, uHandleID, uFlags);
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync else
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync VBoxServiceError("ControlExec: [PID %u]: Failed to retrieve output, CID=%u, uHandle=%u, rc=%Rrc\n",
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync uPID, uContextID, uHandleID, rc);
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync /* Note: Since the context ID is unique the request *has* to be completed here,
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync * regardless whether we got data or not! Otherwise the progress object
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync * on the host never will get completed! */
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync /* cbRead now contains actual size. */
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync int rc2 = VbglR3GuestCtrlExecSendOut(u32ClientId, uContextID, uPID, uHandleID, uFlags,
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync pBuf, cbRead);
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync if (RT_SUCCESS(rc))
3dd53c06fd54914761cf550503f02fce1ed5a815vboxsync rc = rc2;
7bf07b1592dfaab1a4fb6d497fd0ff1302fb7585vboxsync RTMemFree(pBuf);
d1fcf24d24368926be13484524a9e378070a9157vboxsync }
d1fcf24d24368926be13484524a9e378070a9157vboxsync else
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync rc = VERR_NO_MEMORY;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceError("ControlExec: [PID %u]: Error handling output command! Error: %Rrc\n",
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync uPID, rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync return rc;
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync/** @copydoc VBOXSERVICE::pfnStop */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncstatic DECLCALLBACK(void) VBoxServiceControlStop(void)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceVerbose(3, "Control: Stopping ...\n");
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /** @todo Later, figure what to do if we're in RTProcWait(). It's a very
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * annoying call since doesn't support timeouts in the posix world. */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync RTSemEventMultiSignal(g_hControlEvent);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync /*
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * Ask the host service to cancel all pending requests so that we can
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync * shutdown properly here.
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync */
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (g_GuestControlSvcClientID)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync {
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync int rc = VbglR3GuestCtrlCancelPendingWaits(g_GuestControlSvcClientID);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync if (RT_FAILURE(rc))
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync VBoxServiceError("Control: Cancelling pending waits failed; rc=%Rrc\n", rc);
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync }
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync}
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsyncstatic void VBoxServiceControlDestroyThreads(void)
2711c80499bbd95e3da4a6cd2dffd9f81a5dce98vboxsync{
VBoxServiceVerbose(3, "Control: Destroying threads ...\n");
int rc = RTCritSectEnter(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
{
/* Signal all threads that we want to shutdown. */
PVBOXSERVICECTRLTHREAD pThread;
RTListForEach(&g_GuestControlThreads, pThread, VBOXSERVICECTRLTHREAD, Node)
VBoxServiceControlThreadSignalShutdown(pThread);
/* Wait for threads to shutdown. */
RTListForEach(&g_GuestControlThreads, pThread, VBOXSERVICECTRLTHREAD, Node)
{
int rc2 = VBoxServiceControlExecThreadShutdown(pThread);
if (RT_FAILURE(rc2))
VBoxServiceError("Control: Guest process thread failed to stop; rc2=%Rrc\n", rc2);
}
/* Finally destroy thread list. */
pThread = RTListGetFirst(&g_GuestControlThreads, VBOXSERVICECTRLTHREAD, Node);
while (pThread)
{
PVBOXSERVICECTRLTHREAD pNext = RTListNodeGetNext(&pThread->Node, VBOXSERVICECTRLTHREAD, Node);
bool fLast = RTListNodeIsLast(&g_GuestControlThreads, &pThread->Node);
VBoxServiceControlRemoveThread(pThread);
VBoxServiceControlExecThreadDestroy(pThread);
if (fLast)
break;
pThread = pNext;
}
int rc2 = RTCritSectLeave(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
rc = rc2;
}
RTCritSectDelete(&g_GuestControlThreadsCritSect);
}
/** @copydoc VBOXSERVICE::pfnTerm */
static DECLCALLBACK(void) VBoxServiceControlTerm(void)
{
VBoxServiceVerbose(3, "Control: Terminating ...\n");
VBoxServiceControlDestroyThreads();
VbglR3GuestCtrlDisconnect(g_GuestControlSvcClientID);
g_GuestControlSvcClientID = 0;
if (g_hControlEvent != NIL_RTSEMEVENTMULTI)
{
RTSemEventMultiDestroy(g_hControlEvent);
g_hControlEvent = NIL_RTSEMEVENTMULTI;
}
}
static int VBoxServiceControlStartAllowed(bool *pbAllowed)
{
AssertPtrReturn(pbAllowed, VERR_INVALID_POINTER);
int rc = RTCritSectEnter(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
{
/*
* Check if we're respecting our memory policy by checking
* how many guest processes are started and served already.
*/
bool fLimitReached = false;
if (g_GuestControlProcsMaxKept) /* If we allow unlimited processes (=0), take a shortcut. */
{
uint32_t uProcsRunning = 0;
uint32_t uProcsStopped = 0;
PVBOXSERVICECTRLTHREAD pThread;
RTListForEach(&g_GuestControlThreads, pThread, VBOXSERVICECTRLTHREAD, Node)
{
// THREAD LOCKING!!
Assert(pThread->fStarted != pThread->fStopped);
if (pThread->fStarted)
uProcsRunning++;
else if (pThread->fStopped)
uProcsStopped++;
else
AssertMsgFailed(("ControlExec: Guest process neither started nor stopped!?\n"));
}
VBoxServiceVerbose(2, "ControlExec: Maximum served guest processes set to %u, running=%u, stopped=%u\n",
g_GuestControlProcsMaxKept, uProcsRunning, uProcsStopped);
int32_t iProcsLeft = (g_GuestControlProcsMaxKept - uProcsRunning - 1);
if (iProcsLeft < 0)
{
VBoxServiceVerbose(3, "ControlExec: Maximum running guest processes reached (%u)\n",
g_GuestControlProcsMaxKept);
fLimitReached = true;
}
}
*pbAllowed = !fLimitReached;
int rc2 = RTCritSectLeave(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
rc = rc2;
}
return rc;
}
/**
* Finds a (formerly) started process given by its PID.
*
* @return PVBOXSERVICECTRLTHREAD Process structure if found, otherwise NULL.
* @param uPID PID to search for.
*/
const PVBOXSERVICECTRLTHREAD VBoxServiceControlGetThreadByPID(uint32_t uPID)
{
PVBOXSERVICECTRLTHREAD pNode = NULL;
int rc = RTCritSectEnter(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
{
PVBOXSERVICECTRLTHREAD pNodeCur;
RTListForEach(&g_GuestControlThreads, pNodeCur, VBOXSERVICECTRLTHREAD, Node)
{
if (pNodeCur->uPID == uPID)
{
pNode = pNodeCur;
break;
}
}
int rc2 = RTCritSectLeave(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
rc = rc2;
}
return pNode;
}
void VBoxServiceControlRemoveThread(PVBOXSERVICECTRLTHREAD pThread)
{
if (!pThread)
return;
int rc = RTCritSectEnter(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
{
RTListNodeRemove(&pThread->Node);
int rc2 = RTCritSectLeave(&g_GuestControlThreadsCritSect);
if (RT_SUCCESS(rc))
rc = rc2;
}
}
/**
* The 'vminfo' service description.
*/
VBOXSERVICE g_Control =
{
/* pszName. */
"control",
/* pszDescription. */
"Host-driven Guest Control",
/* pszUsage. */
" [--control-interval <ms>] [--control-procs-max-kept <x>]\n"
" [--control-procs-mem-std[in|out|err] <KB>]"
,
/* pszOptions. */
" --control-interval Specifies the interval at which to check for\n"
" new control commands. The default is 1000 ms.\n"
" --control-procs-max-kept\n"
" Specifies how many started guest processes are\n"
" kept into memory to work with. Default is 25.\n"
,
/* methods */
VBoxServiceControlPreInit,
VBoxServiceControlOption,
VBoxServiceControlInit,
VBoxServiceControlWorker,
VBoxServiceControlStop,
VBoxServiceControlTerm
};