VirtualBox

source: vbox/trunk/src/VBox/Main/include/GuestProcessImpl.h@ 69237

Last change on this file since 69237 was 63186, checked in by vboxsync, 8 years ago

ThreadTask: Cleaning up handler() methods.
  • Property svn:eol-style set to native
  • Property svn:keywords set to Author Date Id Revision
File size: 9.9 KB
Line 
1/* $Id: GuestProcessImpl.h 63186 2016-08-08 17:39:16Z vboxsync $ */
2/** @file
3 * VirtualBox Main - Guest process handling implementation.
4 */
5
6/*
7 * Copyright (C) 2012-2016 Oracle Corporation
8 *
9 * This file is part of VirtualBox Open Source Edition (OSE), as
10 * available from http://www.virtualbox.org. This file is free software;
11 * you can redistribute it and/or modify it under the terms of the GNU
12 * General Public License (GPL) as published by the Free Software
13 * Foundation, in version 2 as it comes in the "COPYING" file of the
14 * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15 * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16 */
17
18#ifndef ____H_GUESTPROCESSIMPL
19#define ____H_GUESTPROCESSIMPL
20
21#include "GuestCtrlImplPrivate.h"
22#include "GuestProcessWrap.h"
23
24#include <iprt/cpp/utils.h>
25
26class Console;
27class GuestSession;
28class GuestProcessStartTask;
29
30/**
31 * Class for handling a guest process.
32 */
33class ATL_NO_VTABLE GuestProcess :
34 public GuestProcessWrap,
35 public GuestObject
36{
37public:
38 /** @name COM and internal init/term/mapping cruft.
39 * @{ */
40 DECLARE_EMPTY_CTOR_DTOR(GuestProcess)
41
42 int init(Console *aConsole, GuestSession *aSession, ULONG aProcessID,
43 const GuestProcessStartupInfo &aProcInfo, const GuestEnvironment *pBaseEnv);
44 void uninit(void);
45 HRESULT FinalConstruct(void);
46 void FinalRelease(void);
47 /** @} */
48
49public:
50 /** @name Public internal methods.
51 * @{ */
52 int i_callbackDispatcher(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCb);
53 inline int i_checkPID(uint32_t uPID);
54 int i_onRemove(void);
55 int i_readData(uint32_t uHandle, uint32_t uSize, uint32_t uTimeoutMS, void *pvData, size_t cbData, uint32_t *pcbRead, int *pGuestRc);
56 int i_startProcess(uint32_t cMsTimeout, int *pGuestRc);
57 int i_startProcessInner(uint32_t cMsTimeout, AutoWriteLock &rLock, GuestWaitEvent *pEvent, int *pGuestRc);
58 int i_startProcessAsync(void);
59 int i_terminateProcess(uint32_t uTimeoutMS, int *pGuestRc);
60 ProcessWaitResult_T i_waitFlagsToResult(uint32_t fWaitFlags);
61 int i_waitFor(uint32_t fWaitFlags, ULONG uTimeoutMS, ProcessWaitResult_T &waitResult, int *pGuestRc);
62 int i_waitForInputNotify(GuestWaitEvent *pEvent, uint32_t uHandle, uint32_t uTimeoutMS, ProcessInputStatus_T *pInputStatus, uint32_t *pcbProcessed);
63 int i_waitForOutput(GuestWaitEvent *pEvent, uint32_t uHandle, uint32_t uTimeoutMS, void* pvData, size_t cbData, uint32_t *pcbRead);
64 int i_waitForStatusChange(GuestWaitEvent *pEvent, uint32_t uTimeoutMS, ProcessStatus_T *pProcessStatus, int *pGuestRc);
65 int i_writeData(uint32_t uHandle, uint32_t uFlags, void *pvData, size_t cbData, uint32_t uTimeoutMS, uint32_t *puWritten, int *pGuestRc);
66 /** @} */
67
68 /** @name Static internal methods.
69 * @{ */
70 static Utf8Str i_guestErrorToString(int guestRc);
71 static bool i_isGuestError(int guestRc);
72 static HRESULT i_setErrorExternal(VirtualBoxBase *pInterface, int guestRc);
73 static ProcessWaitResult_T i_waitFlagsToResultEx(uint32_t fWaitFlags, ProcessStatus_T oldStatus, ProcessStatus_T newStatus, uint32_t uProcFlags, uint32_t uProtocol);
74 static bool i_waitResultImpliesEx(ProcessWaitResult_T waitResult, ProcessStatus_T procStatus, uint32_t uProcFlags, uint32_t uProtocol);
75 /** @} */
76
77protected:
78 /** @name Protected internal methods.
79 * @{ */
80 inline bool i_isAlive(void);
81 inline bool i_hasEnded(void);
82 int i_onGuestDisconnected(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCbData);
83 int i_onProcessInputStatus(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCbData);
84 int i_onProcessNotifyIO(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCbData);
85 int i_onProcessStatusChange(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCbData);
86 int i_onProcessOutput(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCbData);
87 int i_prepareExecuteEnv(const char *pszEnv, void **ppvList, ULONG *pcbList, ULONG *pcEnvVars);
88 int i_setProcessStatus(ProcessStatus_T procStatus, int procRc);
89 static void i_startProcessThreadTask(GuestProcessStartTask *pTask);
90 /** @} */
91
92private:
93 /** Wrapped @name IProcess properties.
94 * @{ */
95 HRESULT getArguments(std::vector<com::Utf8Str> &aArguments);
96 HRESULT getEnvironment(std::vector<com::Utf8Str> &aEnvironment);
97 HRESULT getEventSource(ComPtr<IEventSource> &aEventSource);
98 HRESULT getExecutablePath(com::Utf8Str &aExecutablePath);
99 HRESULT getExitCode(LONG *aExitCode);
100 HRESULT getName(com::Utf8Str &aName);
101 HRESULT getPID(ULONG *aPID);
102 HRESULT getStatus(ProcessStatus_T *aStatus);
103 /** @} */
104
105 /** Wrapped @name IProcess methods.
106 * @{ */
107 HRESULT waitFor(ULONG aWaitFor,
108 ULONG aTimeoutMS,
109 ProcessWaitResult_T *aReason);
110 HRESULT waitForArray(const std::vector<ProcessWaitForFlag_T> &aWaitFor,
111 ULONG aTimeoutMS,
112 ProcessWaitResult_T *aReason);
113 HRESULT read(ULONG aHandle,
114 ULONG aToRead,
115 ULONG aTimeoutMS,
116 std::vector<BYTE> &aData);
117 HRESULT write(ULONG aHandle,
118 ULONG aFlags,
119 const std::vector<BYTE> &aData,
120 ULONG aTimeoutMS,
121 ULONG *aWritten);
122 HRESULT writeArray(ULONG aHandle,
123 const std::vector<ProcessInputFlag_T> &aFlags,
124 const std::vector<BYTE> &aData,
125 ULONG aTimeoutMS,
126 ULONG *aWritten);
127 HRESULT terminate(void);
128 /** @} */
129
130 /**
131 * This can safely be used without holding any locks.
132 * An AutoCaller suffices to prevent it being destroy while in use and
133 * internally there is a lock providing the necessary serialization.
134 */
135 const ComObjPtr<EventSource> mEventSource;
136
137 struct Data
138 {
139 /** The process startup information. */
140 GuestProcessStartupInfo mProcess;
141 /** Reference to the immutable session base environment. NULL if the
142 * environment feature isn't supported.
143 * @remarks If there is proof that the uninit order of GuestSession and
144 * this class is what GuestObjectBase claims, then this isn't
145 * strictly necessary. */
146 GuestEnvironment const *mpSessionBaseEnv;
147 /** Exit code if process has been terminated. */
148 LONG mExitCode;
149 /** PID reported from the guest. */
150 ULONG mPID;
151 /** The current process status. */
152 ProcessStatus_T mStatus;
153 /** The last returned process status
154 * returned from the guest side. */
155 int mLastError;
156
157 Data(void) : mpSessionBaseEnv(NULL)
158 { }
159 ~Data(void)
160 {
161 if (mpSessionBaseEnv)
162 {
163 mpSessionBaseEnv->releaseConst();
164 mpSessionBaseEnv = NULL;
165 }
166 }
167 } mData;
168
169 friend class GuestProcessStartTask;
170};
171
172/**
173 * Guest process tool flags.
174 */
175/** No flags specified; wait until process terminates.
176 * The maximum waiting time is set in the process' startup
177 * info. */
178#define GUESTPROCESSTOOL_FLAG_NONE 0
179/** Wait until next stream block from stdout has been
180 * read in completely, then return.
181 */
182#define GUESTPROCESSTOOL_FLAG_STDOUT_BLOCK RT_BIT(0)
183
184/**
185 * Structure for keeping a VBoxService toolbox tool's error info around.
186 */
187struct GuestProcessToolErrorInfo
188{
189 /** Return code from the guest side for executing the process tool. */
190 int guestRc;
191 /** The process tool's returned exit code. */
192 LONG lExitCode;
193};
194
195/**
196 * Internal class for handling the BusyBox-like tools built into VBoxService
197 * on the guest side. It's also called the VBoxService Toolbox (tm).
198 *
199 * Those initially were necessary to guarantee execution of commands (like "ls", "cat")
200 * under the behalf of a certain guest user.
201 *
202 * This class essentially helps to wrap all the gory details like process creation,
203 * information extraction and maintaining the overall status.
204 */
205class GuestProcessTool
206{
207public:
208
209 GuestProcessTool(void);
210
211 virtual ~GuestProcessTool(void);
212
213public:
214
215 int Init(GuestSession *pGuestSession, const GuestProcessStartupInfo &startupInfo, bool fAsync, int *pGuestRc);
216
217 int i_getCurrentBlock(uint32_t uHandle, GuestProcessStreamBlock &strmBlock);
218
219 int i_getRc(void) const;
220
221 GuestProcessStream &i_getStdOut(void) { return mStdOut; }
222
223 GuestProcessStream &i_getStdErr(void) { return mStdErr; }
224
225 int i_wait(uint32_t fFlags, int *pGuestRc);
226
227 int i_waitEx(uint32_t fFlags, GuestProcessStreamBlock *pStreamBlock, int *pGuestRc);
228
229 bool i_isRunning(void);
230
231 int i_terminatedOk(LONG *plExitCode = NULL);
232
233 int i_terminate(uint32_t uTimeoutMS, int *pGuestRc);
234
235public:
236
237 static int i_run(GuestSession *pGuestSession, const GuestProcessStartupInfo &startupInfo, int *pGuestRc);
238
239 static int i_runErrorInfo(GuestSession *pGuestSession, const GuestProcessStartupInfo &startupInfo, GuestProcessToolErrorInfo &errorInfo);
240
241 static int i_runEx(GuestSession *pGuestSession, const GuestProcessStartupInfo &startupInfo,
242 GuestCtrlStreamObjects *pStrmOutObjects, uint32_t cStrmOutObjects, int *pGuestRc);
243
244 static int i_runExErrorInfo(GuestSession *pGuestSession, const GuestProcessStartupInfo &startupInfo,
245 GuestCtrlStreamObjects *pStrmOutObjects, uint32_t cStrmOutObjects, GuestProcessToolErrorInfo &errorInfo);
246
247 static int i_exitCodeToRc(const GuestProcessStartupInfo &startupInfo, LONG lExitCode);
248
249 static int i_exitCodeToRc(const char *pszTool, LONG lExitCode);
250
251protected:
252
253 ComObjPtr<GuestSession> pSession;
254 ComObjPtr<GuestProcess> pProcess;
255 GuestProcessStartupInfo mStartupInfo;
256 GuestProcessStream mStdOut;
257 GuestProcessStream mStdErr;
258
259};
260
261#endif /* !____H_GUESTPROCESSIMPL */
262
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette