GVMMR0.cpp@ 57062

Last change on this file since 57062 was 56287, checked in by vboxsync, 10 years ago
VMM: Updated (C) year.
Property svn:eol-style set to `native` Property svn:keywords set to `Id Revision`
File size: 87.3 KB

Line
1	/* $Id: GVMMR0.cpp 56287 2015-06-09 11:15:22Z vboxsync $ */
2	/** @file
3	* GVMM - Global VM Manager.
4	*/
5
6	/*
7	* Copyright (C) 2007-2015 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
19	/** @page pg_gvmm GVMM - The Global VM Manager
20	*
21	* The Global VM Manager lives in ring-0. Its main function at the moment is
22	* to manage a list of all running VMs, keep a ring-0 only structure (GVM) for
23	* each of them, and assign them unique identifiers (so GMM can track page
24	* owners). The GVMM also manage some of the host CPU resources, like the
25	* periodic preemption timer.
26	*
27	* The GVMM will create a ring-0 object for each VM when it is registered, this
28	* is both for session cleanup purposes and for having a point where it is
29	* possible to implement usage polices later (in SUPR0ObjRegister).
30	*
31	*
32	* @section sec_gvmm_ppt Periodic Preemption Timer (PPT)
33	*
34	* On system that sports a high resolution kernel timer API, we use per-cpu
35	* timers to generate interrupts that preempts VT-x, AMD-V and raw-mode guest
36	* execution. The timer frequency is calculating by taking the max
37	* TMCalcHostTimerFrequency for all VMs running on a CPU for the last ~160 ms
38	* (RT_ELEMENTS((PGVMMHOSTCPU)0, Ppt.aHzHistory) *
39	* GVMMHOSTCPU_PPT_HIST_INTERVAL_NS).
40	*
41	* The TMCalcHostTimerFrequency() part of the things gets its takes the max
42	* TMTimerSetFrequencyHint() value and adjusts by the current catch-up percent,
43	* warp drive percent and some fudge factors. VMMR0.cpp reports the result via
44	* GVMMR0SchedUpdatePeriodicPreemptionTimer() before switching to the VT-x,
45	* AMD-V and raw-mode execution environments.
46	*/
47
48
49	/*******************************************************************************
50	* Header Files *
51	*******************************************************************************/
52	#define LOG_GROUP LOG_GROUP_GVMM
53	#include <VBox/vmm/gvmm.h>
54	#include <VBox/vmm/gmm.h>
55	#include "GVMMR0Internal.h"
56	#include <VBox/vmm/gvm.h>
57	#include <VBox/vmm/vm.h>
58	#include <VBox/vmm/vmcpuset.h>
59	#include <VBox/vmm/vmm.h>
60	#include <VBox/param.h>
61	#include <VBox/err.h>
62
63	#include <iprt/asm.h>
64	#include <iprt/asm-amd64-x86.h>
65	#include <iprt/mem.h>
66	#include <iprt/semaphore.h>
67	#include <iprt/time.h>
68	#include <VBox/log.h>
69	#include <iprt/thread.h>
70	#include <iprt/process.h>
71	#include <iprt/param.h>
72	#include <iprt/string.h>
73	#include <iprt/assert.h>
74	#include <iprt/mem.h>
75	#include <iprt/memobj.h>
76	#include <iprt/mp.h>
77	#include <iprt/cpuset.h>
78	#include <iprt/spinlock.h>
79	#include <iprt/timer.h>
80
81	#include "dtrace/VBoxVMM.h"
82
83
84	/*******************************************************************************
85	* Defined Constants And Macros *
86	*******************************************************************************/
87	#if defined(RT_OS_LINUX) \|\| defined(RT_OS_SOLARIS) \|\| defined(DOXYGEN_RUNNING)
88	/** Define this to enable the periodic preemption timer. */
89	# define GVMM_SCHED_WITH_PPT
90	#endif
91
92
93	/*******************************************************************************
94	* Structures and Typedefs *
95	*******************************************************************************/
96
97	/**
98	* Global VM handle.
99	*/
100	typedef struct GVMHANDLE
101	{
102	/** The index of the next handle in the list (free or used). (0 is nil.) */
103	uint16_t volatile iNext;
104	/** Our own index / handle value. */
105	uint16_t iSelf;
106	/** The process ID of the handle owner.
107	* This is used for access checks. */
108	RTPROCESS ProcId;
109	/** The pointer to the ring-0 only (aka global) VM structure. */
110	PGVM pGVM;
111	/** The ring-0 mapping of the shared VM instance data. */
112	PVM pVM;
113	/** The virtual machine object. */
114	void *pvObj;
115	/** The session this VM is associated with. */
116	PSUPDRVSESSION pSession;
117	/** The ring-0 handle of the EMT0 thread.
118	* This is used for ownership checks as well as looking up a VM handle by thread
119	* at times like assertions. */
120	RTNATIVETHREAD hEMT0;
121	} GVMHANDLE;
122	/** Pointer to a global VM handle. */
123	typedef GVMHANDLE *PGVMHANDLE;
124
125	/** Number of GVM handles (including the NIL handle). */
126	#if HC_ARCH_BITS == 64
127	# define GVMM_MAX_HANDLES 8192
128	#else
129	# define GVMM_MAX_HANDLES 128
130	#endif
131
132	/**
133	* Per host CPU GVMM data.
134	*/
135	typedef struct GVMMHOSTCPU
136	{
137	/** Magic number (GVMMHOSTCPU_MAGIC). */
138	uint32_t volatile u32Magic;
139	/** The CPU ID. */
140	RTCPUID idCpu;
141	/** The CPU set index. */
142	uint32_t idxCpuSet;
143
144	#ifdef GVMM_SCHED_WITH_PPT
145	/** Periodic preemption timer data. */
146	struct
147	{
148	/** The handle to the periodic preemption timer. */
149	PRTTIMER pTimer;
150	/** Spinlock protecting the data below. */
151	RTSPINLOCK hSpinlock;
152	/** The smalles Hz that we need to care about. (static) */
153	uint32_t uMinHz;
154	/** The number of ticks between each historization. */
155	uint32_t cTicksHistoriziationInterval;
156	/** The current historization tick (counting up to
157	* cTicksHistoriziationInterval and then resetting). */
158	uint32_t iTickHistorization;
159	/** The current timer interval. This is set to 0 when inactive. */
160	uint32_t cNsInterval;
161	/** The current timer frequency. This is set to 0 when inactive. */
162	uint32_t uTimerHz;
163	/** The current max frequency reported by the EMTs.
164	* This gets historicize and reset by the timer callback. This is
165	* read without holding the spinlock, so needs atomic updating. */
166	uint32_t volatile uDesiredHz;
167	/** Whether the timer was started or not. */
168	bool volatile fStarted;
169	/** Set if we're starting timer. */
170	bool volatile fStarting;
171	/** The index of the next history entry (mod it). */
172	uint32_t iHzHistory;
173	/** Historicized uDesiredHz values. The array wraps around, new entries
174	* are added at iHzHistory. This is updated approximately every
175	* GVMMHOSTCPU_PPT_HIST_INTERVAL_NS by the timer callback. */
176	uint32_t aHzHistory[8];
177	/** Statistics counter for recording the number of interval changes. */
178	uint32_t cChanges;
179	/** Statistics counter for recording the number of timer starts. */
180	uint32_t cStarts;
181	} Ppt;
182	#endif /* GVMM_SCHED_WITH_PPT */
183
184	} GVMMHOSTCPU;
185	/** Pointer to the per host CPU GVMM data. */
186	typedef GVMMHOSTCPU *PGVMMHOSTCPU;
187	/** The GVMMHOSTCPU::u32Magic value (Petra, Tanya & Rachel Haden). */
188	#define GVMMHOSTCPU_MAGIC UINT32_C(0x19711011)
189	/** The interval on history entry should cover (approximately) give in
190	* nanoseconds. */
191	#define GVMMHOSTCPU_PPT_HIST_INTERVAL_NS UINT32_C(20000000)
192
193
194	/**
195	* The GVMM instance data.
196	*/
197	typedef struct GVMM
198	{
199	/** Eyecatcher / magic. */
200	uint32_t u32Magic;
201	/** The index of the head of the free handle chain. (0 is nil.) */
202	uint16_t volatile iFreeHead;
203	/** The index of the head of the active handle chain. (0 is nil.) */
204	uint16_t volatile iUsedHead;
205	/** The number of VMs. */
206	uint16_t volatile cVMs;
207	/** Alignment padding. */
208	uint16_t u16Reserved;
209	/** The number of EMTs. */
210	uint32_t volatile cEMTs;
211	/** The number of EMTs that have halted in GVMMR0SchedHalt. */
212	uint32_t volatile cHaltedEMTs;
213	/** Alignment padding. */
214	uint32_t u32Alignment;
215	/** When the next halted or sleeping EMT will wake up.
216	* This is set to 0 when it needs recalculating and to UINT64_MAX when
217	* there are no halted or sleeping EMTs in the GVMM. */
218	uint64_t uNsNextEmtWakeup;
219	/** The lock used to serialize VM creation, destruction and associated events that
220	* isn't performance critical. Owners may acquire the list lock. */
221	RTSEMFASTMUTEX CreateDestroyLock;
222	/** The lock used to serialize used list updates and accesses.
223	* This indirectly includes scheduling since the scheduler will have to walk the
224	* used list to examin running VMs. Owners may not acquire any other locks. */
225	RTSEMFASTMUTEX UsedLock;
226	/** The handle array.
227	* The size of this array defines the maximum number of currently running VMs.
228	* The first entry is unused as it represents the NIL handle. */
229	GVMHANDLE aHandles[GVMM_MAX_HANDLES];
230
231	/** @gcfgm{/GVMM/cEMTsMeansCompany, 32-bit, 0, UINT32_MAX, 1}
232	* The number of EMTs that means we no longer consider ourselves alone on a
233	* CPU/Core.
234	*/
235	uint32_t cEMTsMeansCompany;
236	/** @gcfgm{/GVMM/MinSleepAlone,32-bit, 0, 100000000, 750000, ns}
237	* The minimum sleep time for when we're alone, in nano seconds.
238	*/
239	uint32_t nsMinSleepAlone;
240	/** @gcfgm{/GVMM/MinSleepCompany,32-bit,0, 100000000, 15000, ns}
241	* The minimum sleep time for when we've got company, in nano seconds.
242	*/
243	uint32_t nsMinSleepCompany;
244	/** @gcfgm{/GVMM/EarlyWakeUp1, 32-bit, 0, 100000000, 25000, ns}
245	* The limit for the first round of early wakeups, given in nano seconds.
246	*/
247	uint32_t nsEarlyWakeUp1;
248	/** @gcfgm{/GVMM/EarlyWakeUp2, 32-bit, 0, 100000000, 50000, ns}
249	* The limit for the second round of early wakeups, given in nano seconds.
250	*/
251	uint32_t nsEarlyWakeUp2;
252
253	/** The number of entries in the host CPU array (aHostCpus). */
254	uint32_t cHostCpus;
255	/** Per host CPU data (variable length). */
256	GVMMHOSTCPU aHostCpus[1];
257	} GVMM;
258	/** Pointer to the GVMM instance data. */
259	typedef GVMM *PGVMM;
260
261	/** The GVMM::u32Magic value (Charlie Haden). */
262	#define GVMM_MAGIC UINT32_C(0x19370806)
263
264
265
266	/*******************************************************************************
267	* Global Variables *
268	*******************************************************************************/
269	/** Pointer to the GVMM instance data.
270	* (Just my general dislike for global variables.) */
271	static PGVMM g_pGVMM = NULL;
272
273	/** Macro for obtaining and validating the g_pGVMM pointer.
274	* On failure it will return from the invoking function with the specified return value.
275	*
276	* @param pGVMM The name of the pGVMM variable.
277	* @param rc The return value on failure. Use VERR_GVMM_INSTANCE for VBox
278	* status codes.
279	*/
280	#define GVMM_GET_VALID_INSTANCE(pGVMM, rc) \
281	do { \
282	(pGVMM) = g_pGVMM;\
283	AssertPtrReturn((pGVMM), (rc)); \
284	AssertMsgReturn((pGVMM)->u32Magic == GVMM_MAGIC, ("%p - %#x\n", (pGVMM), (pGVMM)->u32Magic), (rc)); \
285	} while (0)
286
287	/** Macro for obtaining and validating the g_pGVMM pointer, void function variant.
288	* On failure it will return from the invoking function.
289	*
290	* @param pGVMM The name of the pGVMM variable.
291	*/
292	#define GVMM_GET_VALID_INSTANCE_VOID(pGVMM) \
293	do { \
294	(pGVMM) = g_pGVMM;\
295	AssertPtrReturnVoid((pGVMM)); \
296	AssertMsgReturnVoid((pGVMM)->u32Magic == GVMM_MAGIC, ("%p - %#x\n", (pGVMM), (pGVMM)->u32Magic)); \
297	} while (0)
298
299
300	/*******************************************************************************
301	* Internal Functions *
302	*******************************************************************************/
303	static void gvmmR0InitPerVMData(PGVM pGVM);
304	static DECLCALLBACK(void) gvmmR0HandleObjDestructor(void pvObj, void pvGVMM, void *pvHandle);
305	static int gvmmR0ByVM(PVM pVM, PGVM ppGVM, PGVMM ppGVMM, bool fTakeUsedLock);
306	static int gvmmR0ByVMAndEMT(PVM pVM, VMCPUID idCpu, PGVM ppGVM, PGVMM ppGVMM);
307	#ifdef GVMM_SCHED_WITH_PPT
308	static DECLCALLBACK(void) gvmmR0SchedPeriodicPreemptionTimerCallback(PRTTIMER pTimer, void *pvUser, uint64_t iTick);
309	#endif
310
311
312	/**
313	* Initializes the GVMM.
314	*
315	* This is called while owning the loader semaphore (see supdrvIOCtl_LdrLoad()).
316	*
317	* @returns VBox status code.
318	*/
319	GVMMR0DECL(int) GVMMR0Init(void)
320	{
321	LogFlow(("GVMMR0Init:\n"));
322
323	/*
324	* Allocate and initialize the instance data.
325	*/
326	uint32_t cHostCpus = RTMpGetArraySize();
327	AssertMsgReturn(cHostCpus > 0 && cHostCpus < _64K, ("%d", (int)cHostCpus), VERR_GVMM_HOST_CPU_RANGE);
328
329	PGVMM pGVMM = (PGVMM)RTMemAllocZ(RT_UOFFSETOF(GVMM, aHostCpus[cHostCpus]));
330	if (!pGVMM)
331	return VERR_NO_MEMORY;
332	int rc = RTSemFastMutexCreate(&pGVMM->CreateDestroyLock);
333	if (RT_SUCCESS(rc))
334	{
335	rc = RTSemFastMutexCreate(&pGVMM->UsedLock);
336	if (RT_SUCCESS(rc))
337	{
338	pGVMM->u32Magic = GVMM_MAGIC;
339	pGVMM->iUsedHead = 0;
340	pGVMM->iFreeHead = 1;
341
342	/* the nil handle */
343	pGVMM->aHandles[0].iSelf = 0;
344	pGVMM->aHandles[0].iNext = 0;
345
346	/* the tail */
347	unsigned i = RT_ELEMENTS(pGVMM->aHandles) - 1;
348	pGVMM->aHandles[i].iSelf = i;
349	pGVMM->aHandles[i].iNext = 0; /* nil */
350
351	/* the rest */
352	while (i-- > 1)
353	{
354	pGVMM->aHandles[i].iSelf = i;
355	pGVMM->aHandles[i].iNext = i + 1;
356	}
357
358	/* The default configuration values. */
359	uint32_t cNsResolution = RTSemEventMultiGetResolution();
360	pGVMM->cEMTsMeansCompany = 1; /** @todo should be adjusted to relative to the cpu count or something... */
361	if (cNsResolution >= 5*RT_NS_100US)
362	{
363	pGVMM->nsMinSleepAlone = 750000 /* ns (0.750 ms) /; /* @todo this should be adjusted to be 75% (or something) of the scheduler granularity... */
364	pGVMM->nsMinSleepCompany = 15000 /* ns (0.015 ms) */;
365	pGVMM->nsEarlyWakeUp1 = 25000 /* ns (0.025 ms) */;
366	pGVMM->nsEarlyWakeUp2 = 50000 /* ns (0.050 ms) */;
367	}
368	else if (cNsResolution > RT_NS_100US)
369	{
370	pGVMM->nsMinSleepAlone = cNsResolution / 2;
371	pGVMM->nsMinSleepCompany = cNsResolution / 4;
372	pGVMM->nsEarlyWakeUp1 = 0;
373	pGVMM->nsEarlyWakeUp2 = 0;
374	}
375	else
376	{
377	pGVMM->nsMinSleepAlone = 2000;
378	pGVMM->nsMinSleepCompany = 2000;
379	pGVMM->nsEarlyWakeUp1 = 0;
380	pGVMM->nsEarlyWakeUp2 = 0;
381	}
382
383	/* The host CPU data. */
384	pGVMM->cHostCpus = cHostCpus;
385	uint32_t iCpu = cHostCpus;
386	RTCPUSET PossibleSet;
387	RTMpGetSet(&PossibleSet);
388	while (iCpu-- > 0)
389	{
390	pGVMM->aHostCpus[iCpu].idxCpuSet = iCpu;
391	#ifdef GVMM_SCHED_WITH_PPT
392	pGVMM->aHostCpus[iCpu].Ppt.pTimer = NULL;
393	pGVMM->aHostCpus[iCpu].Ppt.hSpinlock = NIL_RTSPINLOCK;
394	pGVMM->aHostCpus[iCpu].Ppt.uMinHz = 5; /** @todo Add some API which figures this one out. (not that important) */
395	pGVMM->aHostCpus[iCpu].Ppt.cTicksHistoriziationInterval = 1;
396	//pGVMM->aHostCpus[iCpu].Ppt.iTickHistorization = 0;
397	//pGVMM->aHostCpus[iCpu].Ppt.cNsInterval = 0;
398	//pGVMM->aHostCpus[iCpu].Ppt.uTimerHz = 0;
399	//pGVMM->aHostCpus[iCpu].Ppt.uDesiredHz = 0;
400	//pGVMM->aHostCpus[iCpu].Ppt.fStarted = false;
401	//pGVMM->aHostCpus[iCpu].Ppt.fStarting = false;
402	//pGVMM->aHostCpus[iCpu].Ppt.iHzHistory = 0;
403	//pGVMM->aHostCpus[iCpu].Ppt.aHzHistory = {0};
404	#endif
405
406	if (RTCpuSetIsMember(&PossibleSet, iCpu))
407	{
408	pGVMM->aHostCpus[iCpu].idCpu = RTMpCpuIdFromSetIndex(iCpu);
409	pGVMM->aHostCpus[iCpu].u32Magic = GVMMHOSTCPU_MAGIC;
410
411	#ifdef GVMM_SCHED_WITH_PPT
412	rc = RTTimerCreateEx(&pGVMM->aHostCpus[iCpu].Ppt.pTimer,
413	5010001000 /* whatever */,
414	RTTIMER_FLAGS_CPU(iCpu) \| RTTIMER_FLAGS_HIGH_RES,
415	gvmmR0SchedPeriodicPreemptionTimerCallback,
416	&pGVMM->aHostCpus[iCpu]);
417	if (RT_SUCCESS(rc))
418	rc = RTSpinlockCreate(&pGVMM->aHostCpus[iCpu].Ppt.hSpinlock, RTSPINLOCK_FLAGS_INTERRUPT_SAFE, "GVMM/CPU");
419	if (RT_FAILURE(rc))
420	{
421	while (iCpu < cHostCpus)
422	{
423	RTTimerDestroy(pGVMM->aHostCpus[iCpu].Ppt.pTimer);
424	RTSpinlockDestroy(pGVMM->aHostCpus[iCpu].Ppt.hSpinlock);
425	pGVMM->aHostCpus[iCpu].Ppt.hSpinlock = NIL_RTSPINLOCK;
426	iCpu++;
427	}
428	break;
429	}
430	#endif
431	}
432	else
433	{
434	pGVMM->aHostCpus[iCpu].idCpu = NIL_RTCPUID;
435	pGVMM->aHostCpus[iCpu].u32Magic = 0;
436	}
437	}
438	if (RT_SUCCESS(rc))
439	{
440	g_pGVMM = pGVMM;
441	LogFlow(("GVMMR0Init: pGVMM=%p cHostCpus=%u\n", pGVMM, cHostCpus));
442	return VINF_SUCCESS;
443	}
444
445	/* bail out. */
446	RTSemFastMutexDestroy(pGVMM->UsedLock);
447	pGVMM->UsedLock = NIL_RTSEMFASTMUTEX;
448	}
449	RTSemFastMutexDestroy(pGVMM->CreateDestroyLock);
450	pGVMM->CreateDestroyLock = NIL_RTSEMFASTMUTEX;
451	}
452
453	RTMemFree(pGVMM);
454	return rc;
455	}
456
457
458	/**
459	* Terminates the GVM.
460	*
461	* This is called while owning the loader semaphore (see supdrvLdrFree()).
462	* And unless something is wrong, there should be absolutely no VMs
463	* registered at this point.
464	*/
465	GVMMR0DECL(void) GVMMR0Term(void)
466	{
467	LogFlow(("GVMMR0Term:\n"));
468
469	PGVMM pGVMM = g_pGVMM;
470	g_pGVMM = NULL;
471	if (RT_UNLIKELY(!VALID_PTR(pGVMM)))
472	{
473	SUPR0Printf("GVMMR0Term: pGVMM=%p\n", pGVMM);
474	return;
475	}
476
477	/*
478	* First of all, stop all active timers.
479	*/
480	uint32_t cActiveTimers = 0;
481	uint32_t iCpu = pGVMM->cHostCpus;
482	while (iCpu-- > 0)
483	{
484	ASMAtomicWriteU32(&pGVMM->aHostCpus[iCpu].u32Magic, ~GVMMHOSTCPU_MAGIC);
485	#ifdef GVMM_SCHED_WITH_PPT
486	if ( pGVMM->aHostCpus[iCpu].Ppt.pTimer != NULL
487	&& RT_SUCCESS(RTTimerStop(pGVMM->aHostCpus[iCpu].Ppt.pTimer)))
488	cActiveTimers++;
489	#endif
490	}
491	if (cActiveTimers)
492	RTThreadSleep(1); /* fudge */
493
494	/*
495	* Invalidate the and free resources.
496	*/
497	pGVMM->u32Magic = ~GVMM_MAGIC;
498	RTSemFastMutexDestroy(pGVMM->UsedLock);
499	pGVMM->UsedLock = NIL_RTSEMFASTMUTEX;
500	RTSemFastMutexDestroy(pGVMM->CreateDestroyLock);
501	pGVMM->CreateDestroyLock = NIL_RTSEMFASTMUTEX;
502
503	pGVMM->iFreeHead = 0;
504	if (pGVMM->iUsedHead)
505	{
506	SUPR0Printf("GVMMR0Term: iUsedHead=%#x! (cVMs=%#x cEMTs=%#x)\n", pGVMM->iUsedHead, pGVMM->cVMs, pGVMM->cEMTs);
507	pGVMM->iUsedHead = 0;
508	}
509
510	#ifdef GVMM_SCHED_WITH_PPT
511	iCpu = pGVMM->cHostCpus;
512	while (iCpu-- > 0)
513	{
514	RTTimerDestroy(pGVMM->aHostCpus[iCpu].Ppt.pTimer);
515	pGVMM->aHostCpus[iCpu].Ppt.pTimer = NULL;
516	RTSpinlockDestroy(pGVMM->aHostCpus[iCpu].Ppt.hSpinlock);
517	pGVMM->aHostCpus[iCpu].Ppt.hSpinlock = NIL_RTSPINLOCK;
518	}
519	#endif
520
521	RTMemFree(pGVMM);
522	}
523
524
525	/**
526	* A quick hack for setting global config values.
527	*
528	* @returns VBox status code.
529	*
530	* @param pSession The session handle. Used for authentication.
531	* @param pszName The variable name.
532	* @param u64Value The new value.
533	*/
534	GVMMR0DECL(int) GVMMR0SetConfig(PSUPDRVSESSION pSession, const char *pszName, uint64_t u64Value)
535	{
536	/*
537	* Validate input.
538	*/
539	PGVMM pGVMM;
540	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
541	AssertPtrReturn(pSession, VERR_INVALID_HANDLE);
542	AssertPtrReturn(pszName, VERR_INVALID_POINTER);
543
544	/*
545	* String switch time!
546	*/
547	if (strncmp(pszName, RT_STR_TUPLE("/GVMM/")))
548	return VERR_CFGM_VALUE_NOT_FOUND; /* borrow status codes from CFGM... */
549	int rc = VINF_SUCCESS;
550	pszName += sizeof("/GVMM/") - 1;
551	if (!strcmp(pszName, "cEMTsMeansCompany"))
552	{
553	if (u64Value <= UINT32_MAX)
554	pGVMM->cEMTsMeansCompany = u64Value;
555	else
556	rc = VERR_OUT_OF_RANGE;
557	}
558	else if (!strcmp(pszName, "MinSleepAlone"))
559	{
560	if (u64Value <= RT_NS_100MS)
561	pGVMM->nsMinSleepAlone = u64Value;
562	else
563	rc = VERR_OUT_OF_RANGE;
564	}
565	else if (!strcmp(pszName, "MinSleepCompany"))
566	{
567	if (u64Value <= RT_NS_100MS)
568	pGVMM->nsMinSleepCompany = u64Value;
569	else
570	rc = VERR_OUT_OF_RANGE;
571	}
572	else if (!strcmp(pszName, "EarlyWakeUp1"))
573	{
574	if (u64Value <= RT_NS_100MS)
575	pGVMM->nsEarlyWakeUp1 = u64Value;
576	else
577	rc = VERR_OUT_OF_RANGE;
578	}
579	else if (!strcmp(pszName, "EarlyWakeUp2"))
580	{
581	if (u64Value <= RT_NS_100MS)
582	pGVMM->nsEarlyWakeUp2 = u64Value;
583	else
584	rc = VERR_OUT_OF_RANGE;
585	}
586	else
587	rc = VERR_CFGM_VALUE_NOT_FOUND;
588	return rc;
589	}
590
591
592	/**
593	* A quick hack for getting global config values.
594	*
595	* @returns VBox status code.
596	*
597	* @param pSession The session handle. Used for authentication.
598	* @param pszName The variable name.
599	* @param u64Value The new value.
600	*/
601	GVMMR0DECL(int) GVMMR0QueryConfig(PSUPDRVSESSION pSession, const char pszName, uint64_t pu64Value)
602	{
603	/*
604	* Validate input.
605	*/
606	PGVMM pGVMM;
607	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
608	AssertPtrReturn(pSession, VERR_INVALID_HANDLE);
609	AssertPtrReturn(pszName, VERR_INVALID_POINTER);
610	AssertPtrReturn(pu64Value, VERR_INVALID_POINTER);
611
612	/*
613	* String switch time!
614	*/
615	if (strncmp(pszName, RT_STR_TUPLE("/GVMM/")))
616	return VERR_CFGM_VALUE_NOT_FOUND; /* borrow status codes from CFGM... */
617	int rc = VINF_SUCCESS;
618	pszName += sizeof("/GVMM/") - 1;
619	if (!strcmp(pszName, "cEMTsMeansCompany"))
620	*pu64Value = pGVMM->cEMTsMeansCompany;
621	else if (!strcmp(pszName, "MinSleepAlone"))
622	*pu64Value = pGVMM->nsMinSleepAlone;
623	else if (!strcmp(pszName, "MinSleepCompany"))
624	*pu64Value = pGVMM->nsMinSleepCompany;
625	else if (!strcmp(pszName, "EarlyWakeUp1"))
626	*pu64Value = pGVMM->nsEarlyWakeUp1;
627	else if (!strcmp(pszName, "EarlyWakeUp2"))
628	*pu64Value = pGVMM->nsEarlyWakeUp2;
629	else
630	rc = VERR_CFGM_VALUE_NOT_FOUND;
631	return rc;
632	}
633
634
635	/**
636	* Try acquire the 'used' lock.
637	*
638	* @returns IPRT status code, see RTSemFastMutexRequest.
639	* @param pGVMM The GVMM instance data.
640	*/
641	DECLINLINE(int) gvmmR0UsedLock(PGVMM pGVMM)
642	{
643	LogFlow(("++gvmmR0UsedLock(%p)\n", pGVMM));
644	int rc = RTSemFastMutexRequest(pGVMM->UsedLock);
645	LogFlow(("gvmmR0UsedLock(%p)->%Rrc\n", pGVMM, rc));
646	return rc;
647	}
648
649
650	/**
651	* Release the 'used' lock.
652	*
653	* @returns IPRT status code, see RTSemFastMutexRelease.
654	* @param pGVMM The GVMM instance data.
655	*/
656	DECLINLINE(int) gvmmR0UsedUnlock(PGVMM pGVMM)
657	{
658	LogFlow(("--gvmmR0UsedUnlock(%p)\n", pGVMM));
659	int rc = RTSemFastMutexRelease(pGVMM->UsedLock);
660	AssertRC(rc);
661	return rc;
662	}
663
664
665	/**
666	* Try acquire the 'create & destroy' lock.
667	*
668	* @returns IPRT status code, see RTSemFastMutexRequest.
669	* @param pGVMM The GVMM instance data.
670	*/
671	DECLINLINE(int) gvmmR0CreateDestroyLock(PGVMM pGVMM)
672	{
673	LogFlow(("++gvmmR0CreateDestroyLock(%p)\n", pGVMM));
674	int rc = RTSemFastMutexRequest(pGVMM->CreateDestroyLock);
675	LogFlow(("gvmmR0CreateDestroyLock(%p)->%Rrc\n", pGVMM, rc));
676	return rc;
677	}
678
679
680	/**
681	* Release the 'create & destroy' lock.
682	*
683	* @returns IPRT status code, see RTSemFastMutexRequest.
684	* @param pGVMM The GVMM instance data.
685	*/
686	DECLINLINE(int) gvmmR0CreateDestroyUnlock(PGVMM pGVMM)
687	{
688	LogFlow(("--gvmmR0CreateDestroyUnlock(%p)\n", pGVMM));
689	int rc = RTSemFastMutexRelease(pGVMM->CreateDestroyLock);
690	AssertRC(rc);
691	return rc;
692	}
693
694
695	/**
696	* Request wrapper for the GVMMR0CreateVM API.
697	*
698	* @returns VBox status code.
699	* @param pReq The request buffer.
700	*/
701	GVMMR0DECL(int) GVMMR0CreateVMReq(PGVMMCREATEVMREQ pReq)
702	{
703	/*
704	* Validate the request.
705	*/
706	if (!VALID_PTR(pReq))
707	return VERR_INVALID_POINTER;
708	if (pReq->Hdr.cbReq != sizeof(*pReq))
709	return VERR_INVALID_PARAMETER;
710	if (!VALID_PTR(pReq->pSession))
711	return VERR_INVALID_POINTER;
712
713	/*
714	* Execute it.
715	*/
716	PVM pVM;
717	pReq->pVMR0 = NULL;
718	pReq->pVMR3 = NIL_RTR3PTR;
719	int rc = GVMMR0CreateVM(pReq->pSession, pReq->cCpus, &pVM);
720	if (RT_SUCCESS(rc))
721	{
722	pReq->pVMR0 = pVM;
723	pReq->pVMR3 = pVM->pVMR3;
724	}
725	return rc;
726	}
727
728
729	/**
730	* Allocates the VM structure and registers it with GVM.
731	*
732	* The caller will become the VM owner and there by the EMT.
733	*
734	* @returns VBox status code.
735	* @param pSession The support driver session.
736	* @param cCpus Number of virtual CPUs for the new VM.
737	* @param ppVM Where to store the pointer to the VM structure.
738	*
739	* @thread EMT.
740	*/
741	GVMMR0DECL(int) GVMMR0CreateVM(PSUPDRVSESSION pSession, uint32_t cCpus, PVM *ppVM)
742	{
743	LogFlow(("GVMMR0CreateVM: pSession=%p\n", pSession));
744	PGVMM pGVMM;
745	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
746
747	AssertPtrReturn(ppVM, VERR_INVALID_POINTER);
748	*ppVM = NULL;
749
750	if ( cCpus == 0
751	\|\| cCpus > VMM_MAX_CPU_COUNT)
752	return VERR_INVALID_PARAMETER;
753
754	RTNATIVETHREAD hEMT0 = RTThreadNativeSelf();
755	AssertReturn(hEMT0 != NIL_RTNATIVETHREAD, VERR_GVMM_BROKEN_IPRT);
756	RTPROCESS ProcId = RTProcSelf();
757	AssertReturn(ProcId != NIL_RTPROCESS, VERR_GVMM_BROKEN_IPRT);
758
759	/*
760	* The whole allocation process is protected by the lock.
761	*/
762	int rc = gvmmR0CreateDestroyLock(pGVMM);
763	AssertRCReturn(rc, rc);
764
765	/*
766	* Allocate a handle first so we don't waste resources unnecessarily.
767	*/
768	uint16_t iHandle = pGVMM->iFreeHead;
769	if (iHandle)
770	{
771	PGVMHANDLE pHandle = &pGVMM->aHandles[iHandle];
772
773	/* consistency checks, a bit paranoid as always. */
774	if ( !pHandle->pVM
775	&& !pHandle->pGVM
776	&& !pHandle->pvObj
777	&& pHandle->iSelf == iHandle)
778	{
779	pHandle->pvObj = SUPR0ObjRegister(pSession, SUPDRVOBJTYPE_VM, gvmmR0HandleObjDestructor, pGVMM, pHandle);
780	if (pHandle->pvObj)
781	{
782	/*
783	* Move the handle from the free to used list and perform permission checks.
784	*/
785	rc = gvmmR0UsedLock(pGVMM);
786	AssertRC(rc);
787
788	pGVMM->iFreeHead = pHandle->iNext;
789	pHandle->iNext = pGVMM->iUsedHead;
790	pGVMM->iUsedHead = iHandle;
791	pGVMM->cVMs++;
792
793	pHandle->pVM = NULL;
794	pHandle->pGVM = NULL;
795	pHandle->pSession = pSession;
796	pHandle->hEMT0 = NIL_RTNATIVETHREAD;
797	pHandle->ProcId = NIL_RTPROCESS;
798
799	gvmmR0UsedUnlock(pGVMM);
800
801	rc = SUPR0ObjVerifyAccess(pHandle->pvObj, pSession, NULL);
802	if (RT_SUCCESS(rc))
803	{
804	/*
805	* Allocate the global VM structure (GVM) and initialize it.
806	*/
807	PGVM pGVM = (PGVM)RTMemAllocZ(RT_UOFFSETOF(GVM, aCpus[cCpus]));
808	if (pGVM)
809	{
810	pGVM->u32Magic = GVM_MAGIC;
811	pGVM->hSelf = iHandle;
812	pGVM->pVM = NULL;
813	pGVM->cCpus = cCpus;
814
815	gvmmR0InitPerVMData(pGVM);
816	GMMR0InitPerVMData(pGVM);
817
818	/*
819	* Allocate the shared VM structure and associated page array.
820	*/
821	const uint32_t cbVM = RT_UOFFSETOF(VM, aCpus[cCpus]);
822	const uint32_t cPages = RT_ALIGN_32(cbVM, PAGE_SIZE) >> PAGE_SHIFT;
823	rc = RTR0MemObjAllocLow(&pGVM->gvmm.s.VMMemObj, cPages << PAGE_SHIFT, false /* fExecutable */);
824	if (RT_SUCCESS(rc))
825	{
826	PVM pVM = (PVM)RTR0MemObjAddress(pGVM->gvmm.s.VMMemObj); AssertPtr(pVM);
827	memset(pVM, 0, cPages << PAGE_SHIFT);
828	pVM->enmVMState = VMSTATE_CREATING;
829	pVM->pVMR0 = pVM;
830	pVM->pSession = pSession;
831	pVM->hSelf = iHandle;
832	pVM->cbSelf = cbVM;
833	pVM->cCpus = cCpus;
834	pVM->uCpuExecutionCap = 100; /* default is no cap. */
835	pVM->offVMCPU = RT_UOFFSETOF(VM, aCpus);
836	AssertCompileMemberAlignment(VM, cpum, 64);
837	AssertCompileMemberAlignment(VM, tm, 64);
838	AssertCompileMemberAlignment(VM, aCpus, PAGE_SIZE);
839
840	rc = RTR0MemObjAllocPage(&pGVM->gvmm.s.VMPagesMemObj, cPages * sizeof(SUPPAGE), false /* fExecutable */);
841	if (RT_SUCCESS(rc))
842	{
843	PSUPPAGE paPages = (PSUPPAGE)RTR0MemObjAddress(pGVM->gvmm.s.VMPagesMemObj); AssertPtr(paPages);
844	for (uint32_t iPage = 0; iPage < cPages; iPage++)
845	{
846	paPages[iPage].uReserved = 0;
847	paPages[iPage].Phys = RTR0MemObjGetPagePhysAddr(pGVM->gvmm.s.VMMemObj, iPage);
848	Assert(paPages[iPage].Phys != NIL_RTHCPHYS);
849	}
850
851	/*
852	* Map them into ring-3.
853	*/
854	rc = RTR0MemObjMapUser(&pGVM->gvmm.s.VMMapObj, pGVM->gvmm.s.VMMemObj, (RTR3PTR)-1, 0,
855	RTMEM_PROT_READ \| RTMEM_PROT_WRITE, NIL_RTR0PROCESS);
856	if (RT_SUCCESS(rc))
857	{
858	pVM->pVMR3 = RTR0MemObjAddressR3(pGVM->gvmm.s.VMMapObj);
859	AssertPtr((void *)pVM->pVMR3);
860
861	/* Initialize all the VM pointers. */
862	for (uint32_t i = 0; i < cCpus; i++)
863	{
864	pVM->aCpus[i].pVMR0 = pVM;
865	pVM->aCpus[i].pVMR3 = pVM->pVMR3;
866	pVM->aCpus[i].idHostCpu = NIL_RTCPUID;
867	pVM->aCpus[i].hNativeThreadR0 = NIL_RTNATIVETHREAD;
868	}
869
870	rc = RTR0MemObjMapUser(&pGVM->gvmm.s.VMPagesMapObj, pGVM->gvmm.s.VMPagesMemObj, (RTR3PTR)-1,
871	0 /* uAlignment */, RTMEM_PROT_READ \| RTMEM_PROT_WRITE,
872	NIL_RTR0PROCESS);
873	if (RT_SUCCESS(rc))
874	{
875	pVM->paVMPagesR3 = RTR0MemObjAddressR3(pGVM->gvmm.s.VMPagesMapObj);
876	AssertPtr((void *)pVM->paVMPagesR3);
877
878	/* complete the handle - take the UsedLock sem just to be careful. */
879	rc = gvmmR0UsedLock(pGVMM);
880	AssertRC(rc);
881
882	pHandle->pVM = pVM;
883	pHandle->pGVM = pGVM;
884	pHandle->hEMT0 = hEMT0;
885	pHandle->ProcId = ProcId;
886	pGVM->pVM = pVM;
887	pGVM->aCpus[0].hEMT = hEMT0;
888	pVM->aCpus[0].hNativeThreadR0 = hEMT0;
889	pGVMM->cEMTs += cCpus;
890
891	rc = VMMR0ThreadCtxHookCreateForEmt(&pVM->aCpus[0]);
892	if (RT_SUCCESS(rc))
893	{
894	VBOXVMM_R0_GVMM_VM_CREATED(pGVM, pVM, ProcId, (void *)hEMT0, cCpus);
895
896	gvmmR0UsedUnlock(pGVMM);
897	gvmmR0CreateDestroyUnlock(pGVMM);
898
899	*ppVM = pVM;
900	Log(("GVMMR0CreateVM: pVM=%p pVMR3=%p pGVM=%p hGVM=%d\n", pVM, pVM->pVMR3, pGVM, iHandle));
901	return VINF_SUCCESS;
902	}
903	}
904
905	RTR0MemObjFree(pGVM->gvmm.s.VMMapObj, false /* fFreeMappings */);
906	pGVM->gvmm.s.VMMapObj = NIL_RTR0MEMOBJ;
907	}
908	RTR0MemObjFree(pGVM->gvmm.s.VMPagesMemObj, false /* fFreeMappings */);
909	pGVM->gvmm.s.VMPagesMemObj = NIL_RTR0MEMOBJ;
910	}
911	RTR0MemObjFree(pGVM->gvmm.s.VMMemObj, false /* fFreeMappings */);
912	pGVM->gvmm.s.VMMemObj = NIL_RTR0MEMOBJ;
913	}
914	}
915	}
916	/* else: The user wasn't permitted to create this VM. */
917
918	/*
919	* The handle will be freed by gvmmR0HandleObjDestructor as we release the
920	* object reference here. A little extra mess because of non-recursive lock.
921	*/
922	void *pvObj = pHandle->pvObj;
923	pHandle->pvObj = NULL;
924	gvmmR0CreateDestroyUnlock(pGVMM);
925
926	SUPR0ObjRelease(pvObj, pSession);
927
928	SUPR0Printf("GVMMR0CreateVM: failed, rc=%d\n", rc);
929	return rc;
930	}
931
932	rc = VERR_NO_MEMORY;
933	}
934	else
935	rc = VERR_GVMM_IPE_1;
936	}
937	else
938	rc = VERR_GVM_TOO_MANY_VMS;
939
940	gvmmR0CreateDestroyUnlock(pGVMM);
941	return rc;
942	}
943
944
945	/**
946	* Initializes the per VM data belonging to GVMM.
947	*
948	* @param pGVM Pointer to the global VM structure.
949	*/
950	static void gvmmR0InitPerVMData(PGVM pGVM)
951	{
952	AssertCompile(RT_SIZEOFMEMB(GVM,gvmm.s) <= RT_SIZEOFMEMB(GVM,gvmm.padding));
953	AssertCompile(RT_SIZEOFMEMB(GVMCPU,gvmm.s) <= RT_SIZEOFMEMB(GVMCPU,gvmm.padding));
954	pGVM->gvmm.s.VMMemObj = NIL_RTR0MEMOBJ;
955	pGVM->gvmm.s.VMMapObj = NIL_RTR0MEMOBJ;
956	pGVM->gvmm.s.VMPagesMemObj = NIL_RTR0MEMOBJ;
957	pGVM->gvmm.s.VMPagesMapObj = NIL_RTR0MEMOBJ;
958	pGVM->gvmm.s.fDoneVMMR0Init = false;
959	pGVM->gvmm.s.fDoneVMMR0Term = false;
960
961	for (VMCPUID i = 0; i < pGVM->cCpus; i++)
962	{
963	pGVM->aCpus[i].gvmm.s.HaltEventMulti = NIL_RTSEMEVENTMULTI;
964	pGVM->aCpus[i].hEMT = NIL_RTNATIVETHREAD;
965	}
966	}
967
968
969	/**
970	* Does the VM initialization.
971	*
972	* @returns VBox status code.
973	* @param pVM Pointer to the VM.
974	*/
975	GVMMR0DECL(int) GVMMR0InitVM(PVM pVM)
976	{
977	LogFlow(("GVMMR0InitVM: pVM=%p\n", pVM));
978
979	/*
980	* Validate the VM structure, state and handle.
981	*/
982	PGVM pGVM;
983	PGVMM pGVMM;
984	int rc = gvmmR0ByVMAndEMT(pVM, 0 /* idCpu */, &pGVM, &pGVMM);
985	if (RT_SUCCESS(rc))
986	{
987	if ( !pGVM->gvmm.s.fDoneVMMR0Init
988	&& pGVM->aCpus[0].gvmm.s.HaltEventMulti == NIL_RTSEMEVENTMULTI)
989	{
990	for (VMCPUID i = 0; i < pGVM->cCpus; i++)
991	{
992	rc = RTSemEventMultiCreate(&pGVM->aCpus[i].gvmm.s.HaltEventMulti);
993	if (RT_FAILURE(rc))
994	{
995	pGVM->aCpus[i].gvmm.s.HaltEventMulti = NIL_RTSEMEVENTMULTI;
996	break;
997	}
998	}
999	}
1000	else
1001	rc = VERR_WRONG_ORDER;
1002	}
1003
1004	LogFlow(("GVMMR0InitVM: returns %Rrc\n", rc));
1005	return rc;
1006	}
1007
1008
1009	/**
1010	* Indicates that we're done with the ring-0 initialization
1011	* of the VM.
1012	*
1013	* @param pVM Pointer to the VM.
1014	* @thread EMT(0)
1015	*/
1016	GVMMR0DECL(void) GVMMR0DoneInitVM(PVM pVM)
1017	{
1018	/* Validate the VM structure, state and handle. */
1019	PGVM pGVM;
1020	PGVMM pGVMM;
1021	int rc = gvmmR0ByVMAndEMT(pVM, 0 /* idCpu */, &pGVM, &pGVMM);
1022	AssertRCReturnVoid(rc);
1023
1024	/* Set the indicator. */
1025	pGVM->gvmm.s.fDoneVMMR0Init = true;
1026	}
1027
1028
1029	/**
1030	* Indicates that we're doing the ring-0 termination of the VM.
1031	*
1032	* @returns true if termination hasn't been done already, false if it has.
1033	* @param pVM Pointer to the VM.
1034	* @param pGVM Pointer to the global VM structure. Optional.
1035	* @thread EMT(0)
1036	*/
1037	GVMMR0DECL(bool) GVMMR0DoingTermVM(PVM pVM, PGVM pGVM)
1038	{
1039	/* Validate the VM structure, state and handle. */
1040	AssertPtrNullReturn(pGVM, false);
1041	AssertReturn(!pGVM \|\| pGVM->u32Magic == GVM_MAGIC, false);
1042	if (!pGVM)
1043	{
1044	PGVMM pGVMM;
1045	int rc = gvmmR0ByVMAndEMT(pVM, 0 /* idCpu */, &pGVM, &pGVMM);
1046	AssertRCReturn(rc, false);
1047	}
1048
1049	/* Set the indicator. */
1050	if (pGVM->gvmm.s.fDoneVMMR0Term)
1051	return false;
1052	pGVM->gvmm.s.fDoneVMMR0Term = true;
1053	return true;
1054	}
1055
1056
1057	/**
1058	* Destroys the VM, freeing all associated resources (the ring-0 ones anyway).
1059	*
1060	* This is call from the vmR3DestroyFinalBit and from a error path in VMR3Create,
1061	* and the caller is not the EMT thread, unfortunately. For security reasons, it
1062	* would've been nice if the caller was actually the EMT thread or that we somehow
1063	* could've associated the calling thread with the VM up front.
1064	*
1065	* @returns VBox status code.
1066	* @param pVM Pointer to the VM.
1067	*
1068	* @thread EMT(0) if it's associated with the VM, otherwise any thread.
1069	*/
1070	GVMMR0DECL(int) GVMMR0DestroyVM(PVM pVM)
1071	{
1072	LogFlow(("GVMMR0DestroyVM: pVM=%p\n", pVM));
1073	PGVMM pGVMM;
1074	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
1075
1076	/*
1077	* Validate the VM structure, state and caller.
1078	*/
1079	AssertPtrReturn(pVM, VERR_INVALID_POINTER);
1080	AssertReturn(!((uintptr_t)pVM & PAGE_OFFSET_MASK), VERR_INVALID_POINTER);
1081	AssertMsgReturn(pVM->enmVMState >= VMSTATE_CREATING && pVM->enmVMState <= VMSTATE_TERMINATED, ("%d\n", pVM->enmVMState),
1082	VERR_WRONG_ORDER);
1083
1084	uint32_t hGVM = pVM->hSelf;
1085	AssertReturn(hGVM != NIL_GVM_HANDLE, VERR_INVALID_HANDLE);
1086	AssertReturn(hGVM < RT_ELEMENTS(pGVMM->aHandles), VERR_INVALID_HANDLE);
1087
1088	PGVMHANDLE pHandle = &pGVMM->aHandles[hGVM];
1089	AssertReturn(pHandle->pVM == pVM, VERR_NOT_OWNER);
1090
1091	RTPROCESS ProcId = RTProcSelf();
1092	RTNATIVETHREAD hSelf = RTThreadNativeSelf();
1093	AssertReturn( ( pHandle->hEMT0 == hSelf
1094	&& pHandle->ProcId == ProcId)
1095	\|\| pHandle->hEMT0 == NIL_RTNATIVETHREAD, VERR_NOT_OWNER);
1096
1097	/*
1098	* Lookup the handle and destroy the object.
1099	* Since the lock isn't recursive and we'll have to leave it before dereferencing the
1100	* object, we take some precautions against racing callers just in case...
1101	*/
1102	int rc = gvmmR0CreateDestroyLock(pGVMM);
1103	AssertRC(rc);
1104
1105	/* Be careful here because we might theoretically be racing someone else cleaning up. */
1106	if ( pHandle->pVM == pVM
1107	&& ( ( pHandle->hEMT0 == hSelf
1108	&& pHandle->ProcId == ProcId)
1109	\|\| pHandle->hEMT0 == NIL_RTNATIVETHREAD)
1110	&& VALID_PTR(pHandle->pvObj)
1111	&& VALID_PTR(pHandle->pSession)
1112	&& VALID_PTR(pHandle->pGVM)
1113	&& pHandle->pGVM->u32Magic == GVM_MAGIC)
1114	{
1115	void *pvObj = pHandle->pvObj;
1116	pHandle->pvObj = NULL;
1117	gvmmR0CreateDestroyUnlock(pGVMM);
1118
1119	for (VMCPUID idCpu = 0; idCpu < pVM->cCpus; idCpu++)
1120	{
1121	/** @todo Can we busy wait here for all thread-context hooks to be
1122	* deregistered before releasing (destroying) it? Only until we find a
1123	* solution for not deregistering hooks everytime we're leaving HMR0
1124	* context. */
1125	VMMR0ThreadCtxHookDestroyForEmt(&pVM->aCpus[idCpu]);
1126	}
1127
1128	SUPR0ObjRelease(pvObj, pHandle->pSession);
1129	}
1130	else
1131	{
1132	SUPR0Printf("GVMMR0DestroyVM: pHandle=%p:{.pVM=%p, .hEMT0=%p, .ProcId=%u, .pvObj=%p} pVM=%p hSelf=%p\n",
1133	pHandle, pHandle->pVM, pHandle->hEMT0, pHandle->ProcId, pHandle->pvObj, pVM, hSelf);
1134	gvmmR0CreateDestroyUnlock(pGVMM);
1135	rc = VERR_GVMM_IPE_2;
1136	}
1137
1138	return rc;
1139	}
1140
1141
1142	/**
1143	* Performs VM cleanup task as part of object destruction.
1144	*
1145	* @param pGVM The GVM pointer.
1146	*/
1147	static void gvmmR0CleanupVM(PGVM pGVM)
1148	{
1149	if ( pGVM->gvmm.s.fDoneVMMR0Init
1150	&& !pGVM->gvmm.s.fDoneVMMR0Term)
1151	{
1152	if ( pGVM->gvmm.s.VMMemObj != NIL_RTR0MEMOBJ
1153	&& RTR0MemObjAddress(pGVM->gvmm.s.VMMemObj) == pGVM->pVM)
1154	{
1155	LogFlow(("gvmmR0CleanupVM: Calling VMMR0TermVM\n"));
1156	VMMR0TermVM(pGVM->pVM, pGVM);
1157	}
1158	else
1159	AssertMsgFailed(("gvmmR0CleanupVM: VMMemObj=%p pVM=%p\n", pGVM->gvmm.s.VMMemObj, pGVM->pVM));
1160	}
1161
1162	GMMR0CleanupVM(pGVM);
1163	}
1164
1165
1166	/**
1167	* Handle destructor.
1168	*
1169	* @param pvGVMM The GVM instance pointer.
1170	* @param pvHandle The handle pointer.
1171	*/
1172	static DECLCALLBACK(void) gvmmR0HandleObjDestructor(void pvObj, void pvGVMM, void *pvHandle)
1173	{
1174	LogFlow(("gvmmR0HandleObjDestructor: %p %p %p\n", pvObj, pvGVMM, pvHandle));
1175
1176	/*
1177	* Some quick, paranoid, input validation.
1178	*/
1179	PGVMHANDLE pHandle = (PGVMHANDLE)pvHandle;
1180	AssertPtr(pHandle);
1181	PGVMM pGVMM = (PGVMM)pvGVMM;
1182	Assert(pGVMM == g_pGVMM);
1183	const uint16_t iHandle = pHandle - &pGVMM->aHandles[0];
1184	if ( !iHandle
1185	\|\| iHandle >= RT_ELEMENTS(pGVMM->aHandles)
1186	\|\| iHandle != pHandle->iSelf)
1187	{
1188	SUPR0Printf("GVM: handle %d is out of range or corrupt (iSelf=%d)!\n", iHandle, pHandle->iSelf);
1189	return;
1190	}
1191
1192	int rc = gvmmR0CreateDestroyLock(pGVMM);
1193	AssertRC(rc);
1194	rc = gvmmR0UsedLock(pGVMM);
1195	AssertRC(rc);
1196
1197	/*
1198	* This is a tad slow but a doubly linked list is too much hassle.
1199	*/
1200	if (RT_UNLIKELY(pHandle->iNext >= RT_ELEMENTS(pGVMM->aHandles)))
1201	{
1202	SUPR0Printf("GVM: used list index %d is out of range!\n", pHandle->iNext);
1203	gvmmR0UsedUnlock(pGVMM);
1204	gvmmR0CreateDestroyUnlock(pGVMM);
1205	return;
1206	}
1207
1208	if (pGVMM->iUsedHead == iHandle)
1209	pGVMM->iUsedHead = pHandle->iNext;
1210	else
1211	{
1212	uint16_t iPrev = pGVMM->iUsedHead;
1213	int c = RT_ELEMENTS(pGVMM->aHandles) + 2;
1214	while (iPrev)
1215	{
1216	if (RT_UNLIKELY(iPrev >= RT_ELEMENTS(pGVMM->aHandles)))
1217	{
1218	SUPR0Printf("GVM: used list index %d is out of range!\n", iPrev);
1219	gvmmR0UsedUnlock(pGVMM);
1220	gvmmR0CreateDestroyUnlock(pGVMM);
1221	return;
1222	}
1223	if (RT_UNLIKELY(c-- <= 0))
1224	{
1225	iPrev = 0;
1226	break;
1227	}
1228
1229	if (pGVMM->aHandles[iPrev].iNext == iHandle)
1230	break;
1231	iPrev = pGVMM->aHandles[iPrev].iNext;
1232	}
1233	if (!iPrev)
1234	{
1235	SUPR0Printf("GVM: can't find the handle previous previous of %d!\n", pHandle->iSelf);
1236	gvmmR0UsedUnlock(pGVMM);
1237	gvmmR0CreateDestroyUnlock(pGVMM);
1238	return;
1239	}
1240
1241	Assert(pGVMM->aHandles[iPrev].iNext == iHandle);
1242	pGVMM->aHandles[iPrev].iNext = pHandle->iNext;
1243	}
1244	pHandle->iNext = 0;
1245	pGVMM->cVMs--;
1246
1247	/*
1248	* Do the global cleanup round.
1249	*/
1250	PGVM pGVM = pHandle->pGVM;
1251	if ( VALID_PTR(pGVM)
1252	&& pGVM->u32Magic == GVM_MAGIC)
1253	{
1254	pGVMM->cEMTs -= pGVM->cCpus;
1255	gvmmR0UsedUnlock(pGVMM);
1256
1257	gvmmR0CleanupVM(pGVM);
1258
1259	/*
1260	* Do the GVMM cleanup - must be done last.
1261	*/
1262	/* The VM and VM pages mappings/allocations. */
1263	if (pGVM->gvmm.s.VMPagesMapObj != NIL_RTR0MEMOBJ)
1264	{
1265	rc = RTR0MemObjFree(pGVM->gvmm.s.VMPagesMapObj, false /* fFreeMappings */); AssertRC(rc);
1266	pGVM->gvmm.s.VMPagesMapObj = NIL_RTR0MEMOBJ;
1267	}
1268
1269	if (pGVM->gvmm.s.VMMapObj != NIL_RTR0MEMOBJ)
1270	{
1271	rc = RTR0MemObjFree(pGVM->gvmm.s.VMMapObj, false /* fFreeMappings */); AssertRC(rc);
1272	pGVM->gvmm.s.VMMapObj = NIL_RTR0MEMOBJ;
1273	}
1274
1275	if (pGVM->gvmm.s.VMPagesMemObj != NIL_RTR0MEMOBJ)
1276	{
1277	rc = RTR0MemObjFree(pGVM->gvmm.s.VMPagesMemObj, false /* fFreeMappings */); AssertRC(rc);
1278	pGVM->gvmm.s.VMPagesMemObj = NIL_RTR0MEMOBJ;
1279	}
1280
1281	if (pGVM->gvmm.s.VMMemObj != NIL_RTR0MEMOBJ)
1282	{
1283	rc = RTR0MemObjFree(pGVM->gvmm.s.VMMemObj, false /* fFreeMappings */); AssertRC(rc);
1284	pGVM->gvmm.s.VMMemObj = NIL_RTR0MEMOBJ;
1285	}
1286
1287	for (VMCPUID i = 0; i < pGVM->cCpus; i++)
1288	{
1289	if (pGVM->aCpus[i].gvmm.s.HaltEventMulti != NIL_RTSEMEVENTMULTI)
1290	{
1291	rc = RTSemEventMultiDestroy(pGVM->aCpus[i].gvmm.s.HaltEventMulti); AssertRC(rc);
1292	pGVM->aCpus[i].gvmm.s.HaltEventMulti = NIL_RTSEMEVENTMULTI;
1293	}
1294	}
1295
1296	/* the GVM structure itself. */
1297	pGVM->u32Magic \|= UINT32_C(0x80000000);
1298	RTMemFree(pGVM);
1299
1300	/* Re-acquire the UsedLock before freeing the handle since we're updating handle fields. */
1301	rc = gvmmR0UsedLock(pGVMM);
1302	AssertRC(rc);
1303	}
1304	/* else: GVMMR0CreateVM cleanup. */
1305
1306	/*
1307	* Free the handle.
1308	*/
1309	pHandle->iNext = pGVMM->iFreeHead;
1310	pGVMM->iFreeHead = iHandle;
1311	ASMAtomicWriteNullPtr(&pHandle->pGVM);
1312	ASMAtomicWriteNullPtr(&pHandle->pVM);
1313	ASMAtomicWriteNullPtr(&pHandle->pvObj);
1314	ASMAtomicWriteNullPtr(&pHandle->pSession);
1315	ASMAtomicWriteHandle(&pHandle->hEMT0, NIL_RTNATIVETHREAD);
1316	ASMAtomicWriteU32(&pHandle->ProcId, NIL_RTPROCESS);
1317
1318	gvmmR0UsedUnlock(pGVMM);
1319	gvmmR0CreateDestroyUnlock(pGVMM);
1320	LogFlow(("gvmmR0HandleObjDestructor: returns\n"));
1321	}
1322
1323
1324	/**
1325	* Registers the calling thread as the EMT of a Virtual CPU.
1326	*
1327	* Note that VCPU 0 is automatically registered during VM creation.
1328	*
1329	* @returns VBox status code
1330	* @param pVM Pointer to the VM.
1331	* @param idCpu VCPU id.
1332	*/
1333	GVMMR0DECL(int) GVMMR0RegisterVCpu(PVM pVM, VMCPUID idCpu)
1334	{
1335	AssertReturn(idCpu != 0, VERR_NOT_OWNER);
1336
1337	/*
1338	* Validate the VM structure, state and handle.
1339	*/
1340	PGVM pGVM;
1341	PGVMM pGVMM;
1342	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, false /* fTakeUsedLock */);
1343	if (RT_FAILURE(rc))
1344	return rc;
1345
1346	AssertReturn(idCpu < pGVM->cCpus, VERR_INVALID_CPU_ID);
1347	AssertReturn(pGVM->aCpus[idCpu].hEMT == NIL_RTNATIVETHREAD, VERR_ACCESS_DENIED);
1348	Assert(pGVM->cCpus == pVM->cCpus);
1349	Assert(pVM->aCpus[idCpu].hNativeThreadR0 == NIL_RTNATIVETHREAD);
1350
1351	pVM->aCpus[idCpu].hNativeThreadR0 = pGVM->aCpus[idCpu].hEMT = RTThreadNativeSelf();
1352
1353	return VMMR0ThreadCtxHookCreateForEmt(&pVM->aCpus[idCpu]);
1354	}
1355
1356
1357	/**
1358	* Lookup a GVM structure by its handle.
1359	*
1360	* @returns The GVM pointer on success, NULL on failure.
1361	* @param hGVM The global VM handle. Asserts on bad handle.
1362	*/
1363	GVMMR0DECL(PGVM) GVMMR0ByHandle(uint32_t hGVM)
1364	{
1365	PGVMM pGVMM;
1366	GVMM_GET_VALID_INSTANCE(pGVMM, NULL);
1367
1368	/*
1369	* Validate.
1370	*/
1371	AssertReturn(hGVM != NIL_GVM_HANDLE, NULL);
1372	AssertReturn(hGVM < RT_ELEMENTS(pGVMM->aHandles), NULL);
1373
1374	/*
1375	* Look it up.
1376	*/
1377	PGVMHANDLE pHandle = &pGVMM->aHandles[hGVM];
1378	AssertPtrReturn(pHandle->pVM, NULL);
1379	AssertPtrReturn(pHandle->pvObj, NULL);
1380	PGVM pGVM = pHandle->pGVM;
1381	AssertPtrReturn(pGVM, NULL);
1382	AssertReturn(pGVM->pVM == pHandle->pVM, NULL);
1383
1384	return pHandle->pGVM;
1385	}
1386
1387
1388	/**
1389	* Lookup a GVM structure by the shared VM structure.
1390	*
1391	* The calling thread must be in the same process as the VM. All current lookups
1392	* are by threads inside the same process, so this will not be an issue.
1393	*
1394	* @returns VBox status code.
1395	* @param pVM Pointer to the VM.
1396	* @param ppGVM Where to store the GVM pointer.
1397	* @param ppGVMM Where to store the pointer to the GVMM instance data.
1398	* @param fTakeUsedLock Whether to take the used lock or not.
1399	* Be very careful if not taking the lock as it's possible that
1400	* the VM will disappear then.
1401	*
1402	* @remark This will not assert on an invalid pVM but try return silently.
1403	*/
1404	static int gvmmR0ByVM(PVM pVM, PGVM ppGVM, PGVMM ppGVMM, bool fTakeUsedLock)
1405	{
1406	RTPROCESS ProcId = RTProcSelf();
1407	PGVMM pGVMM;
1408	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
1409
1410	/*
1411	* Validate.
1412	*/
1413	if (RT_UNLIKELY( !VALID_PTR(pVM)
1414	\|\| ((uintptr_t)pVM & PAGE_OFFSET_MASK)))
1415	return VERR_INVALID_POINTER;
1416	if (RT_UNLIKELY( pVM->enmVMState < VMSTATE_CREATING
1417	\|\| pVM->enmVMState >= VMSTATE_TERMINATED))
1418	return VERR_INVALID_POINTER;
1419
1420	uint16_t hGVM = pVM->hSelf;
1421	if (RT_UNLIKELY( hGVM == NIL_GVM_HANDLE
1422	\|\| hGVM >= RT_ELEMENTS(pGVMM->aHandles)))
1423	return VERR_INVALID_HANDLE;
1424
1425	/*
1426	* Look it up.
1427	*/
1428	PGVMHANDLE pHandle = &pGVMM->aHandles[hGVM];
1429	PGVM pGVM;
1430	if (fTakeUsedLock)
1431	{
1432	int rc = gvmmR0UsedLock(pGVMM);
1433	AssertRCReturn(rc, rc);
1434
1435	pGVM = pHandle->pGVM;
1436	if (RT_UNLIKELY( pHandle->pVM != pVM
1437	\|\| pHandle->ProcId != ProcId
1438	\|\| !VALID_PTR(pHandle->pvObj)
1439	\|\| !VALID_PTR(pGVM)
1440	\|\| pGVM->pVM != pVM))
1441	{
1442	gvmmR0UsedUnlock(pGVMM);
1443	return VERR_INVALID_HANDLE;
1444	}
1445	}
1446	else
1447	{
1448	if (RT_UNLIKELY(pHandle->pVM != pVM))
1449	return VERR_INVALID_HANDLE;
1450	if (RT_UNLIKELY(pHandle->ProcId != ProcId))
1451	return VERR_INVALID_HANDLE;
1452	if (RT_UNLIKELY(!VALID_PTR(pHandle->pvObj)))
1453	return VERR_INVALID_HANDLE;
1454
1455	pGVM = pHandle->pGVM;
1456	if (RT_UNLIKELY(!VALID_PTR(pGVM)))
1457	return VERR_INVALID_HANDLE;
1458	if (RT_UNLIKELY(pGVM->pVM != pVM))
1459	return VERR_INVALID_HANDLE;
1460	}
1461
1462	*ppGVM = pGVM;
1463	*ppGVMM = pGVMM;
1464	return VINF_SUCCESS;
1465	}
1466
1467
1468	/**
1469	* Lookup a GVM structure by the shared VM structure.
1470	*
1471	* @returns VBox status code.
1472	* @param pVM Pointer to the VM.
1473	* @param ppGVM Where to store the GVM pointer.
1474	*
1475	* @remark This will not take the 'used'-lock because it doesn't do
1476	* nesting and this function will be used from under the lock.
1477	*/
1478	GVMMR0DECL(int) GVMMR0ByVM(PVM pVM, PGVM *ppGVM)
1479	{
1480	PGVMM pGVMM;
1481	return gvmmR0ByVM(pVM, ppGVM, &pGVMM, false /* fTakeUsedLock */);
1482	}
1483
1484
1485	/**
1486	* Lookup a GVM structure by the shared VM structure and ensuring that the
1487	* caller is an EMT thread.
1488	*
1489	* @returns VBox status code.
1490	* @param pVM Pointer to the VM.
1491	* @param idCpu The Virtual CPU ID of the calling EMT.
1492	* @param ppGVM Where to store the GVM pointer.
1493	* @param ppGVMM Where to store the pointer to the GVMM instance data.
1494	* @thread EMT
1495	*
1496	* @remark This will assert in all failure paths.
1497	*/
1498	static int gvmmR0ByVMAndEMT(PVM pVM, VMCPUID idCpu, PGVM ppGVM, PGVMM ppGVMM)
1499	{
1500	PGVMM pGVMM;
1501	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
1502
1503	/*
1504	* Validate.
1505	*/
1506	AssertPtrReturn(pVM, VERR_INVALID_POINTER);
1507	AssertReturn(!((uintptr_t)pVM & PAGE_OFFSET_MASK), VERR_INVALID_POINTER);
1508
1509	uint16_t hGVM = pVM->hSelf;
1510	AssertReturn(hGVM != NIL_GVM_HANDLE, VERR_INVALID_HANDLE);
1511	AssertReturn(hGVM < RT_ELEMENTS(pGVMM->aHandles), VERR_INVALID_HANDLE);
1512
1513	/*
1514	* Look it up.
1515	*/
1516	PGVMHANDLE pHandle = &pGVMM->aHandles[hGVM];
1517	AssertReturn(pHandle->pVM == pVM, VERR_NOT_OWNER);
1518	RTPROCESS ProcId = RTProcSelf();
1519	AssertReturn(pHandle->ProcId == ProcId, VERR_NOT_OWNER);
1520	AssertPtrReturn(pHandle->pvObj, VERR_NOT_OWNER);
1521
1522	PGVM pGVM = pHandle->pGVM;
1523	AssertPtrReturn(pGVM, VERR_NOT_OWNER);
1524	AssertReturn(pGVM->pVM == pVM, VERR_NOT_OWNER);
1525	RTNATIVETHREAD hAllegedEMT = RTThreadNativeSelf();
1526	AssertReturn(idCpu < pGVM->cCpus, VERR_INVALID_CPU_ID);
1527	AssertReturn(pGVM->aCpus[idCpu].hEMT == hAllegedEMT, VERR_NOT_OWNER);
1528
1529	*ppGVM = pGVM;
1530	*ppGVMM = pGVMM;
1531	return VINF_SUCCESS;
1532	}
1533
1534
1535	/**
1536	* Lookup a GVM structure by the shared VM structure
1537	* and ensuring that the caller is the EMT thread.
1538	*
1539	* @returns VBox status code.
1540	* @param pVM Pointer to the VM.
1541	* @param idCpu The Virtual CPU ID of the calling EMT.
1542	* @param ppGVM Where to store the GVM pointer.
1543	* @thread EMT
1544	*/
1545	GVMMR0DECL(int) GVMMR0ByVMAndEMT(PVM pVM, VMCPUID idCpu, PGVM *ppGVM)
1546	{
1547	AssertPtrReturn(ppGVM, VERR_INVALID_POINTER);
1548	PGVMM pGVMM;
1549	return gvmmR0ByVMAndEMT(pVM, idCpu, ppGVM, &pGVMM);
1550	}
1551
1552
1553	/**
1554	* Lookup a VM by its global handle.
1555	*
1556	* @returns Pointer to the VM on success, NULL on failure.
1557	* @param hGVM The global VM handle. Asserts on bad handle.
1558	*/
1559	GVMMR0DECL(PVM) GVMMR0GetVMByHandle(uint32_t hGVM)
1560	{
1561	PGVM pGVM = GVMMR0ByHandle(hGVM);
1562	return pGVM ? pGVM->pVM : NULL;
1563	}
1564
1565
1566	/**
1567	* Looks up the VM belonging to the specified EMT thread.
1568	*
1569	* This is used by the assertion machinery in VMMR0.cpp to avoid causing
1570	* unnecessary kernel panics when the EMT thread hits an assertion. The
1571	* call may or not be an EMT thread.
1572	*
1573	* @returns Pointer to the VM on success, NULL on failure.
1574	* @param hEMT The native thread handle of the EMT.
1575	* NIL_RTNATIVETHREAD means the current thread
1576	*/
1577	GVMMR0DECL(PVM) GVMMR0GetVMByEMT(RTNATIVETHREAD hEMT)
1578	{
1579	/*
1580	* No Assertions here as we're usually called in a AssertMsgN or
1581	* RTAssert* context.
1582	*/
1583	PGVMM pGVMM = g_pGVMM;
1584	if ( !VALID_PTR(pGVMM)
1585	\|\| pGVMM->u32Magic != GVMM_MAGIC)
1586	return NULL;
1587
1588	if (hEMT == NIL_RTNATIVETHREAD)
1589	hEMT = RTThreadNativeSelf();
1590	RTPROCESS ProcId = RTProcSelf();
1591
1592	/*
1593	* Search the handles in a linear fashion as we don't dare to take the lock (assert).
1594	*/
1595	for (unsigned i = 1; i < RT_ELEMENTS(pGVMM->aHandles); i++)
1596	{
1597	if ( pGVMM->aHandles[i].iSelf == i
1598	&& pGVMM->aHandles[i].ProcId == ProcId
1599	&& VALID_PTR(pGVMM->aHandles[i].pvObj)
1600	&& VALID_PTR(pGVMM->aHandles[i].pVM)
1601	&& VALID_PTR(pGVMM->aHandles[i].pGVM))
1602	{
1603	if (pGVMM->aHandles[i].hEMT0 == hEMT)
1604	return pGVMM->aHandles[i].pVM;
1605
1606	/* This is fearly safe with the current process per VM approach. */
1607	PGVM pGVM = pGVMM->aHandles[i].pGVM;
1608	VMCPUID const cCpus = pGVM->cCpus;
1609	if ( cCpus < 1
1610	\|\| cCpus > VMM_MAX_CPU_COUNT)
1611	continue;
1612	for (VMCPUID idCpu = 1; idCpu < cCpus; idCpu++)
1613	if (pGVM->aCpus[idCpu].hEMT == hEMT)
1614	return pGVMM->aHandles[i].pVM;
1615	}
1616	}
1617	return NULL;
1618	}
1619
1620
1621	/**
1622	* This is will wake up expired and soon-to-be expired VMs.
1623	*
1624	* @returns Number of VMs that has been woken up.
1625	* @param pGVMM Pointer to the GVMM instance data.
1626	* @param u64Now The current time.
1627	*/
1628	static unsigned gvmmR0SchedDoWakeUps(PGVMM pGVMM, uint64_t u64Now)
1629	{
1630	/*
1631	* Skip this if we've got disabled because of high resolution wakeups or by
1632	* the user.
1633	*/
1634	if ( !pGVMM->nsEarlyWakeUp1
1635	&& !pGVMM->nsEarlyWakeUp2)
1636	return 0;
1637
1638	/** @todo Rewrite this algorithm. See performance defect XYZ. */
1639
1640	/*
1641	* A cheap optimization to stop wasting so much time here on big setups.
1642	*/
1643	const uint64_t uNsEarlyWakeUp2 = u64Now + pGVMM->nsEarlyWakeUp2;
1644	if ( pGVMM->cHaltedEMTs == 0
1645	\|\| uNsEarlyWakeUp2 > pGVMM->uNsNextEmtWakeup)
1646	return 0;
1647
1648	/*
1649	* The first pass will wake up VMs which have actually expired
1650	* and look for VMs that should be woken up in the 2nd and 3rd passes.
1651	*/
1652	const uint64_t uNsEarlyWakeUp1 = u64Now + pGVMM->nsEarlyWakeUp1;
1653	uint64_t u64Min = UINT64_MAX;
1654	unsigned cWoken = 0;
1655	unsigned cHalted = 0;
1656	unsigned cTodo2nd = 0;
1657	unsigned cTodo3rd = 0;
1658	for (unsigned i = pGVMM->iUsedHead, cGuard = 0;
1659	i != NIL_GVM_HANDLE && i < RT_ELEMENTS(pGVMM->aHandles);
1660	i = pGVMM->aHandles[i].iNext)
1661	{
1662	PGVM pCurGVM = pGVMM->aHandles[i].pGVM;
1663	if ( VALID_PTR(pCurGVM)
1664	&& pCurGVM->u32Magic == GVM_MAGIC)
1665	{
1666	for (VMCPUID idCpu = 0; idCpu < pCurGVM->cCpus; idCpu++)
1667	{
1668	PGVMCPU pCurGVCpu = &pCurGVM->aCpus[idCpu];
1669	uint64_t u64 = ASMAtomicUoReadU64(&pCurGVCpu->gvmm.s.u64HaltExpire);
1670	if (u64)
1671	{
1672	if (u64 <= u64Now)
1673	{
1674	if (ASMAtomicXchgU64(&pCurGVCpu->gvmm.s.u64HaltExpire, 0))
1675	{
1676	int rc = RTSemEventMultiSignal(pCurGVCpu->gvmm.s.HaltEventMulti);
1677	AssertRC(rc);
1678	cWoken++;
1679	}
1680	}
1681	else
1682	{
1683	cHalted++;
1684	if (u64 <= uNsEarlyWakeUp1)
1685	cTodo2nd++;
1686	else if (u64 <= uNsEarlyWakeUp2)
1687	cTodo3rd++;
1688	else if (u64 < u64Min)
1689	u64 = u64Min;
1690	}
1691	}
1692	}
1693	}
1694	AssertLogRelBreak(cGuard++ < RT_ELEMENTS(pGVMM->aHandles));
1695	}
1696
1697	if (cTodo2nd)
1698	{
1699	for (unsigned i = pGVMM->iUsedHead, cGuard = 0;
1700	i != NIL_GVM_HANDLE && i < RT_ELEMENTS(pGVMM->aHandles);
1701	i = pGVMM->aHandles[i].iNext)
1702	{
1703	PGVM pCurGVM = pGVMM->aHandles[i].pGVM;
1704	if ( VALID_PTR(pCurGVM)
1705	&& pCurGVM->u32Magic == GVM_MAGIC)
1706	{
1707	for (VMCPUID idCpu = 0; idCpu < pCurGVM->cCpus; idCpu++)
1708	{
1709	PGVMCPU pCurGVCpu = &pCurGVM->aCpus[idCpu];
1710	uint64_t u64 = ASMAtomicUoReadU64(&pCurGVCpu->gvmm.s.u64HaltExpire);
1711	if ( u64
1712	&& u64 <= uNsEarlyWakeUp1)
1713	{
1714	if (ASMAtomicXchgU64(&pCurGVCpu->gvmm.s.u64HaltExpire, 0))
1715	{
1716	int rc = RTSemEventMultiSignal(pCurGVCpu->gvmm.s.HaltEventMulti);
1717	AssertRC(rc);
1718	cWoken++;
1719	}
1720	}
1721	}
1722	}
1723	AssertLogRelBreak(cGuard++ < RT_ELEMENTS(pGVMM->aHandles));
1724	}
1725	}
1726
1727	if (cTodo3rd)
1728	{
1729	for (unsigned i = pGVMM->iUsedHead, cGuard = 0;
1730	i != NIL_GVM_HANDLE && i < RT_ELEMENTS(pGVMM->aHandles);
1731	i = pGVMM->aHandles[i].iNext)
1732	{
1733	PGVM pCurGVM = pGVMM->aHandles[i].pGVM;
1734	if ( VALID_PTR(pCurGVM)
1735	&& pCurGVM->u32Magic == GVM_MAGIC)
1736	{
1737	for (VMCPUID idCpu = 0; idCpu < pCurGVM->cCpus; idCpu++)
1738	{
1739	PGVMCPU pCurGVCpu = &pCurGVM->aCpus[idCpu];
1740	uint64_t u64 = ASMAtomicUoReadU64(&pCurGVCpu->gvmm.s.u64HaltExpire);
1741	if ( u64
1742	&& u64 <= uNsEarlyWakeUp2)
1743	{
1744	if (ASMAtomicXchgU64(&pCurGVCpu->gvmm.s.u64HaltExpire, 0))
1745	{
1746	int rc = RTSemEventMultiSignal(pCurGVCpu->gvmm.s.HaltEventMulti);
1747	AssertRC(rc);
1748	cWoken++;
1749	}
1750	}
1751	}
1752	}
1753	AssertLogRelBreak(cGuard++ < RT_ELEMENTS(pGVMM->aHandles));
1754	}
1755	}
1756
1757	/*
1758	* Set the minimum value.
1759	*/
1760	pGVMM->uNsNextEmtWakeup = u64Min;
1761
1762	return cWoken;
1763	}
1764
1765
1766	/**
1767	* Halt the EMT thread.
1768	*
1769	* @returns VINF_SUCCESS normal wakeup (timeout or kicked by other thread).
1770	* VERR_INTERRUPTED if a signal was scheduled for the thread.
1771	* @param pVM Pointer to the VM.
1772	* @param idCpu The Virtual CPU ID of the calling EMT.
1773	* @param u64ExpireGipTime The time for the sleep to expire expressed as GIP time.
1774	* @thread EMT(idCpu).
1775	*/
1776	GVMMR0DECL(int) GVMMR0SchedHalt(PVM pVM, VMCPUID idCpu, uint64_t u64ExpireGipTime)
1777	{
1778	LogFlow(("GVMMR0SchedHalt: pVM=%p\n", pVM));
1779
1780	/*
1781	* Validate the VM structure, state and handle.
1782	*/
1783	PGVM pGVM;
1784	PGVMM pGVMM;
1785	int rc = gvmmR0ByVMAndEMT(pVM, idCpu, &pGVM, &pGVMM);
1786	if (RT_FAILURE(rc))
1787	return rc;
1788	pGVM->gvmm.s.StatsSched.cHaltCalls++;
1789
1790	PGVMCPU pCurGVCpu = &pGVM->aCpus[idCpu];
1791	Assert(!pCurGVCpu->gvmm.s.u64HaltExpire);
1792
1793	/*
1794	* Take the UsedList semaphore, get the current time
1795	* and check if anyone needs waking up.
1796	* Interrupts must NOT be disabled at this point because we ask for GIP time!
1797	*/
1798	rc = gvmmR0UsedLock(pGVMM);
1799	AssertRC(rc);
1800
1801	pCurGVCpu->gvmm.s.iCpuEmt = ASMGetApicId();
1802
1803	/* GIP hack: We might are frequently sleeping for short intervals where the
1804	difference between GIP and system time matters on systems with high resolution
1805	system time. So, convert the input from GIP to System time in that case. */
1806	Assert(ASMGetFlags() & X86_EFL_IF);
1807	const uint64_t u64NowSys = RTTimeSystemNanoTS();
1808	const uint64_t u64NowGip = RTTimeNanoTS();
1809	pGVM->gvmm.s.StatsSched.cHaltWakeUps += gvmmR0SchedDoWakeUps(pGVMM, u64NowGip);
1810
1811	/*
1812	* Go to sleep if we must...
1813	* Cap the sleep time to 1 second to be on the safe side.
1814	*/
1815	uint64_t cNsInterval = u64ExpireGipTime - u64NowGip;
1816	if ( u64NowGip < u64ExpireGipTime
1817	&& cNsInterval >= (pGVMM->cEMTs > pGVMM->cEMTsMeansCompany
1818	? pGVMM->nsMinSleepCompany
1819	: pGVMM->nsMinSleepAlone))
1820	{
1821	pGVM->gvmm.s.StatsSched.cHaltBlocking++;
1822	if (cNsInterval > RT_NS_1SEC)
1823	u64ExpireGipTime = u64NowGip + RT_NS_1SEC;
1824	if (u64ExpireGipTime < pGVMM->uNsNextEmtWakeup)
1825	pGVMM->uNsNextEmtWakeup = u64ExpireGipTime;
1826	ASMAtomicWriteU64(&pCurGVCpu->gvmm.s.u64HaltExpire, u64ExpireGipTime);
1827	ASMAtomicIncU32(&pGVMM->cHaltedEMTs);
1828	gvmmR0UsedUnlock(pGVMM);
1829
1830	rc = RTSemEventMultiWaitEx(pCurGVCpu->gvmm.s.HaltEventMulti,
1831	RTSEMWAIT_FLAGS_ABSOLUTE \| RTSEMWAIT_FLAGS_NANOSECS \| RTSEMWAIT_FLAGS_INTERRUPTIBLE,
1832	u64NowGip > u64NowSys ? u64ExpireGipTime : u64NowSys + cNsInterval);
1833
1834	ASMAtomicWriteU64(&pCurGVCpu->gvmm.s.u64HaltExpire, 0);
1835	ASMAtomicDecU32(&pGVMM->cHaltedEMTs);
1836
1837	/* Reset the semaphore to try prevent a few false wake-ups. */
1838	if (rc == VINF_SUCCESS)
1839	RTSemEventMultiReset(pCurGVCpu->gvmm.s.HaltEventMulti);
1840	else if (rc == VERR_TIMEOUT)
1841	{
1842	pGVM->gvmm.s.StatsSched.cHaltTimeouts++;
1843	rc = VINF_SUCCESS;
1844	}
1845	}
1846	else
1847	{
1848	pGVM->gvmm.s.StatsSched.cHaltNotBlocking++;
1849	gvmmR0UsedUnlock(pGVMM);
1850	RTSemEventMultiReset(pCurGVCpu->gvmm.s.HaltEventMulti);
1851	}
1852
1853	return rc;
1854	}
1855
1856
1857	/**
1858	* Worker for GVMMR0SchedWakeUp and GVMMR0SchedWakeUpAndPokeCpus that wakes up
1859	* the a sleeping EMT.
1860	*
1861	* @retval VINF_SUCCESS if successfully woken up.
1862	* @retval VINF_GVM_NOT_BLOCKED if the EMT wasn't blocked.
1863	*
1864	* @param pGVM The global (ring-0) VM structure.
1865	* @param pGVCpu The global (ring-0) VCPU structure.
1866	*/
1867	DECLINLINE(int) gvmmR0SchedWakeUpOne(PGVM pGVM, PGVMCPU pGVCpu)
1868	{
1869	pGVM->gvmm.s.StatsSched.cWakeUpCalls++;
1870
1871	/*
1872	* Signal the semaphore regardless of whether it's current blocked on it.
1873	*
1874	* The reason for this is that there is absolutely no way we can be 100%
1875	* certain that it isn't about go to go to sleep on it and just got
1876	* delayed a bit en route. So, we will always signal the semaphore when
1877	* the it is flagged as halted in the VMM.
1878	*/
1879	/** @todo we can optimize some of that by means of the pVCpu->enmState now. */
1880	int rc;
1881	if (pGVCpu->gvmm.s.u64HaltExpire)
1882	{
1883	rc = VINF_SUCCESS;
1884	ASMAtomicWriteU64(&pGVCpu->gvmm.s.u64HaltExpire, 0);
1885	}
1886	else
1887	{
1888	rc = VINF_GVM_NOT_BLOCKED;
1889	pGVM->gvmm.s.StatsSched.cWakeUpNotHalted++;
1890	}
1891
1892	int rc2 = RTSemEventMultiSignal(pGVCpu->gvmm.s.HaltEventMulti);
1893	AssertRC(rc2);
1894
1895	return rc;
1896	}
1897
1898
1899	/**
1900	* Wakes up the halted EMT thread so it can service a pending request.
1901	*
1902	* @returns VBox status code.
1903	* @retval VINF_SUCCESS if successfully woken up.
1904	* @retval VINF_GVM_NOT_BLOCKED if the EMT wasn't blocked.
1905	*
1906	* @param pVM Pointer to the VM.
1907	* @param idCpu The Virtual CPU ID of the EMT to wake up.
1908	* @param fTakeUsedLock Take the used lock or not
1909	* @thread Any but EMT.
1910	*/
1911	GVMMR0DECL(int) GVMMR0SchedWakeUpEx(PVM pVM, VMCPUID idCpu, bool fTakeUsedLock)
1912	{
1913	/*
1914	* Validate input and take the UsedLock.
1915	*/
1916	PGVM pGVM;
1917	PGVMM pGVMM;
1918	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, fTakeUsedLock);
1919	if (RT_SUCCESS(rc))
1920	{
1921	if (idCpu < pGVM->cCpus)
1922	{
1923	/*
1924	* Do the actual job.
1925	*/
1926	rc = gvmmR0SchedWakeUpOne(pGVM, &pGVM->aCpus[idCpu]);
1927
1928	if (fTakeUsedLock)
1929	{
1930	/*
1931	* While we're here, do a round of scheduling.
1932	*/
1933	Assert(ASMGetFlags() & X86_EFL_IF);
1934	const uint64_t u64Now = RTTimeNanoTS(); /* (GIP time) */
1935	pGVM->gvmm.s.StatsSched.cWakeUpWakeUps += gvmmR0SchedDoWakeUps(pGVMM, u64Now);
1936	}
1937	}
1938	else
1939	rc = VERR_INVALID_CPU_ID;
1940
1941	if (fTakeUsedLock)
1942	{
1943	int rc2 = gvmmR0UsedUnlock(pGVMM);
1944	AssertRC(rc2);
1945	}
1946	}
1947
1948	LogFlow(("GVMMR0SchedWakeUp: returns %Rrc\n", rc));
1949	return rc;
1950	}
1951
1952
1953	/**
1954	* Wakes up the halted EMT thread so it can service a pending request.
1955	*
1956	* @returns VBox status code.
1957	* @retval VINF_SUCCESS if successfully woken up.
1958	* @retval VINF_GVM_NOT_BLOCKED if the EMT wasn't blocked.
1959	*
1960	* @param pVM Pointer to the VM.
1961	* @param idCpu The Virtual CPU ID of the EMT to wake up.
1962	* @thread Any but EMT.
1963	*/
1964	GVMMR0DECL(int) GVMMR0SchedWakeUp(PVM pVM, VMCPUID idCpu)
1965	{
1966	return GVMMR0SchedWakeUpEx(pVM, idCpu, true /* fTakeUsedLock */);
1967	}
1968
1969	/**
1970	* Worker common to GVMMR0SchedPoke and GVMMR0SchedWakeUpAndPokeCpus that pokes
1971	* the Virtual CPU if it's still busy executing guest code.
1972	*
1973	* @returns VBox status code.
1974	* @retval VINF_SUCCESS if poked successfully.
1975	* @retval VINF_GVM_NOT_BUSY_IN_GC if the EMT wasn't busy in GC.
1976	*
1977	* @param pGVM The global (ring-0) VM structure.
1978	* @param pVCpu Pointer to the VMCPU.
1979	*/
1980	DECLINLINE(int) gvmmR0SchedPokeOne(PGVM pGVM, PVMCPU pVCpu)
1981	{
1982	pGVM->gvmm.s.StatsSched.cPokeCalls++;
1983
1984	RTCPUID idHostCpu = pVCpu->idHostCpu;
1985	if ( idHostCpu == NIL_RTCPUID
1986	\|\| VMCPU_GET_STATE(pVCpu) != VMCPUSTATE_STARTED_EXEC)
1987	{
1988	pGVM->gvmm.s.StatsSched.cPokeNotBusy++;
1989	return VINF_GVM_NOT_BUSY_IN_GC;
1990	}
1991
1992	/* Note: this function is not implemented on Darwin and Linux (kernel < 2.6.19) */
1993	RTMpPokeCpu(idHostCpu);
1994	return VINF_SUCCESS;
1995	}
1996
1997	/**
1998	* Pokes an EMT if it's still busy running guest code.
1999	*
2000	* @returns VBox status code.
2001	* @retval VINF_SUCCESS if poked successfully.
2002	* @retval VINF_GVM_NOT_BUSY_IN_GC if the EMT wasn't busy in GC.
2003	*
2004	* @param pVM Pointer to the VM.
2005	* @param idCpu The ID of the virtual CPU to poke.
2006	* @param fTakeUsedLock Take the used lock or not
2007	*/
2008	GVMMR0DECL(int) GVMMR0SchedPokeEx(PVM pVM, VMCPUID idCpu, bool fTakeUsedLock)
2009	{
2010	/*
2011	* Validate input and take the UsedLock.
2012	*/
2013	PGVM pGVM;
2014	PGVMM pGVMM;
2015	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, fTakeUsedLock);
2016	if (RT_SUCCESS(rc))
2017	{
2018	if (idCpu < pGVM->cCpus)
2019	rc = gvmmR0SchedPokeOne(pGVM, &pVM->aCpus[idCpu]);
2020	else
2021	rc = VERR_INVALID_CPU_ID;
2022
2023	if (fTakeUsedLock)
2024	{
2025	int rc2 = gvmmR0UsedUnlock(pGVMM);
2026	AssertRC(rc2);
2027	}
2028	}
2029
2030	LogFlow(("GVMMR0SchedWakeUpAndPokeCpus: returns %Rrc\n", rc));
2031	return rc;
2032	}
2033
2034
2035	/**
2036	* Pokes an EMT if it's still busy running guest code.
2037	*
2038	* @returns VBox status code.
2039	* @retval VINF_SUCCESS if poked successfully.
2040	* @retval VINF_GVM_NOT_BUSY_IN_GC if the EMT wasn't busy in GC.
2041	*
2042	* @param pVM Pointer to the VM.
2043	* @param idCpu The ID of the virtual CPU to poke.
2044	*/
2045	GVMMR0DECL(int) GVMMR0SchedPoke(PVM pVM, VMCPUID idCpu)
2046	{
2047	return GVMMR0SchedPokeEx(pVM, idCpu, true /* fTakeUsedLock */);
2048	}
2049
2050
2051	/**
2052	* Wakes up a set of halted EMT threads so they can service pending request.
2053	*
2054	* @returns VBox status code, no informational stuff.
2055	*
2056	* @param pVM Pointer to the VM.
2057	* @param pSleepSet The set of sleepers to wake up.
2058	* @param pPokeSet The set of CPUs to poke.
2059	*/
2060	GVMMR0DECL(int) GVMMR0SchedWakeUpAndPokeCpus(PVM pVM, PCVMCPUSET pSleepSet, PCVMCPUSET pPokeSet)
2061	{
2062	AssertPtrReturn(pSleepSet, VERR_INVALID_POINTER);
2063	AssertPtrReturn(pPokeSet, VERR_INVALID_POINTER);
2064	RTNATIVETHREAD hSelf = RTThreadNativeSelf();
2065
2066	/*
2067	* Validate input and take the UsedLock.
2068	*/
2069	PGVM pGVM;
2070	PGVMM pGVMM;
2071	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, true /* fTakeUsedLock */);
2072	if (RT_SUCCESS(rc))
2073	{
2074	rc = VINF_SUCCESS;
2075	VMCPUID idCpu = pGVM->cCpus;
2076	while (idCpu-- > 0)
2077	{
2078	/* Don't try poke or wake up ourselves. */
2079	if (pGVM->aCpus[idCpu].hEMT == hSelf)
2080	continue;
2081
2082	/* just ignore errors for now. */
2083	if (VMCPUSET_IS_PRESENT(pSleepSet, idCpu))
2084	gvmmR0SchedWakeUpOne(pGVM, &pGVM->aCpus[idCpu]);
2085	else if (VMCPUSET_IS_PRESENT(pPokeSet, idCpu))
2086	gvmmR0SchedPokeOne(pGVM, &pVM->aCpus[idCpu]);
2087	}
2088
2089	int rc2 = gvmmR0UsedUnlock(pGVMM);
2090	AssertRC(rc2);
2091	}
2092
2093	LogFlow(("GVMMR0SchedWakeUpAndPokeCpus: returns %Rrc\n", rc));
2094	return rc;
2095	}
2096
2097
2098	/**
2099	* VMMR0 request wrapper for GVMMR0SchedWakeUpAndPokeCpus.
2100	*
2101	* @returns see GVMMR0SchedWakeUpAndPokeCpus.
2102	* @param pVM Pointer to the VM.
2103	* @param pReq Pointer to the request packet.
2104	*/
2105	GVMMR0DECL(int) GVMMR0SchedWakeUpAndPokeCpusReq(PVM pVM, PGVMMSCHEDWAKEUPANDPOKECPUSREQ pReq)
2106	{
2107	/*
2108	* Validate input and pass it on.
2109	*/
2110	AssertPtrReturn(pReq, VERR_INVALID_POINTER);
2111	AssertMsgReturn(pReq->Hdr.cbReq == sizeof(pReq), ("%#x != %#x\n", pReq->Hdr.cbReq, sizeof(pReq)), VERR_INVALID_PARAMETER);
2112
2113	return GVMMR0SchedWakeUpAndPokeCpus(pVM, &pReq->SleepSet, &pReq->PokeSet);
2114	}
2115
2116
2117
2118	/**
2119	* Poll the schedule to see if someone else should get a chance to run.
2120	*
2121	* This is a bit hackish and will not work too well if the machine is
2122	* under heavy load from non-VM processes.
2123	*
2124	* @returns VINF_SUCCESS if not yielded.
2125	* VINF_GVM_YIELDED if an attempt to switch to a different VM task was made.
2126	* @param pVM Pointer to the VM.
2127	* @param idCpu The Virtual CPU ID of the calling EMT.
2128	* @param u64ExpireGipTime The time for the sleep to expire expressed as GIP time.
2129	* @param fYield Whether to yield or not.
2130	* This is for when we're spinning in the halt loop.
2131	* @thread EMT(idCpu).
2132	*/
2133	GVMMR0DECL(int) GVMMR0SchedPoll(PVM pVM, VMCPUID idCpu, bool fYield)
2134	{
2135	/*
2136	* Validate input.
2137	*/
2138	PGVM pGVM;
2139	PGVMM pGVMM;
2140	int rc = gvmmR0ByVMAndEMT(pVM, idCpu, &pGVM, &pGVMM);
2141	if (RT_SUCCESS(rc))
2142	{
2143	rc = gvmmR0UsedLock(pGVMM);
2144	AssertRC(rc);
2145	pGVM->gvmm.s.StatsSched.cPollCalls++;
2146
2147	Assert(ASMGetFlags() & X86_EFL_IF);
2148	const uint64_t u64Now = RTTimeNanoTS(); /* (GIP time) */
2149
2150	if (!fYield)
2151	pGVM->gvmm.s.StatsSched.cPollWakeUps += gvmmR0SchedDoWakeUps(pGVMM, u64Now);
2152	else
2153	{
2154	/** @todo implement this... */
2155	rc = VERR_NOT_IMPLEMENTED;
2156	}
2157
2158	gvmmR0UsedUnlock(pGVMM);
2159	}
2160
2161	LogFlow(("GVMMR0SchedWakeUp: returns %Rrc\n", rc));
2162	return rc;
2163	}
2164
2165
2166	#ifdef GVMM_SCHED_WITH_PPT
2167	/**
2168	* Timer callback for the periodic preemption timer.
2169	*
2170	* @param pTimer The timer handle.
2171	* @param pvUser Pointer to the per cpu structure.
2172	* @param iTick The current tick.
2173	*/
2174	static DECLCALLBACK(void) gvmmR0SchedPeriodicPreemptionTimerCallback(PRTTIMER pTimer, void *pvUser, uint64_t iTick)
2175	{
2176	PGVMMHOSTCPU pCpu = (PGVMMHOSTCPU)pvUser;
2177	NOREF(pTimer); NOREF(iTick);
2178
2179	/*
2180	* Termination check
2181	*/
2182	if (pCpu->u32Magic != GVMMHOSTCPU_MAGIC)
2183	return;
2184
2185	/*
2186	* Do the house keeping.
2187	*/
2188	RTSpinlockAcquire(pCpu->Ppt.hSpinlock);
2189
2190	if (++pCpu->Ppt.iTickHistorization >= pCpu->Ppt.cTicksHistoriziationInterval)
2191	{
2192	/*
2193	* Historicize the max frequency.
2194	*/
2195	uint32_t iHzHistory = ++pCpu->Ppt.iHzHistory % RT_ELEMENTS(pCpu->Ppt.aHzHistory);
2196	pCpu->Ppt.aHzHistory[iHzHistory] = pCpu->Ppt.uDesiredHz;
2197	pCpu->Ppt.iTickHistorization = 0;
2198	pCpu->Ppt.uDesiredHz = 0;
2199
2200	/*
2201	* Check if the current timer frequency.
2202	*/
2203	uint32_t uHistMaxHz = 0;
2204	for (uint32_t i = 0; i < RT_ELEMENTS(pCpu->Ppt.aHzHistory); i++)
2205	if (pCpu->Ppt.aHzHistory[i] > uHistMaxHz)
2206	uHistMaxHz = pCpu->Ppt.aHzHistory[i];
2207	if (uHistMaxHz == pCpu->Ppt.uTimerHz)
2208	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2209	else if (uHistMaxHz)
2210	{
2211	/*
2212	* Reprogram it.
2213	*/
2214	pCpu->Ppt.cChanges++;
2215	pCpu->Ppt.iTickHistorization = 0;
2216	pCpu->Ppt.uTimerHz = uHistMaxHz;
2217	uint32_t const cNsInterval = RT_NS_1SEC / uHistMaxHz;
2218	pCpu->Ppt.cNsInterval = cNsInterval;
2219	if (cNsInterval < GVMMHOSTCPU_PPT_HIST_INTERVAL_NS)
2220	pCpu->Ppt.cTicksHistoriziationInterval = ( GVMMHOSTCPU_PPT_HIST_INTERVAL_NS
2221	+ GVMMHOSTCPU_PPT_HIST_INTERVAL_NS / 2 - 1)
2222	/ cNsInterval;
2223	else
2224	pCpu->Ppt.cTicksHistoriziationInterval = 1;
2225	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2226
2227	/SUPR0Printf("Cpu%u: change to %u Hz / %u ns\n", pCpu->idxCpuSet, uHistMaxHz, cNsInterval);/
2228	RTTimerChangeInterval(pTimer, cNsInterval);
2229	}
2230	else
2231	{
2232	/*
2233	* Stop it.
2234	*/
2235	pCpu->Ppt.fStarted = false;
2236	pCpu->Ppt.uTimerHz = 0;
2237	pCpu->Ppt.cNsInterval = 0;
2238	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2239
2240	/SUPR0Printf("Cpu%u: stopping (%u Hz)\n", pCpu->idxCpuSet, uHistMaxHz);/
2241	RTTimerStop(pTimer);
2242	}
2243	}
2244	else
2245	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2246	}
2247	#endif /* GVMM_SCHED_WITH_PPT */
2248
2249
2250	/**
2251	* Updates the periodic preemption timer for the calling CPU.
2252	*
2253	* The caller must have disabled preemption!
2254	* The caller must check that the host can do high resolution timers.
2255	*
2256	* @param pVM Pointer to the VM.
2257	* @param idHostCpu The current host CPU id.
2258	* @param uHz The desired frequency.
2259	*/
2260	GVMMR0DECL(void) GVMMR0SchedUpdatePeriodicPreemptionTimer(PVM pVM, RTCPUID idHostCpu, uint32_t uHz)
2261	{
2262	NOREF(pVM);
2263	#ifdef GVMM_SCHED_WITH_PPT
2264	Assert(!RTThreadPreemptIsEnabled(NIL_RTTHREAD));
2265	Assert(RTTimerCanDoHighResolution());
2266
2267	/*
2268	* Resolve the per CPU data.
2269	*/
2270	uint32_t iCpu = RTMpCpuIdToSetIndex(idHostCpu);
2271	PGVMM pGVMM = g_pGVMM;
2272	if ( !VALID_PTR(pGVMM)
2273	\|\| pGVMM->u32Magic != GVMM_MAGIC)
2274	return;
2275	AssertMsgReturnVoid(iCpu < pGVMM->cHostCpus, ("iCpu=%d cHostCpus=%d\n", iCpu, pGVMM->cHostCpus));
2276	PGVMMHOSTCPU pCpu = &pGVMM->aHostCpus[iCpu];
2277	AssertMsgReturnVoid( pCpu->u32Magic == GVMMHOSTCPU_MAGIC
2278	&& pCpu->idCpu == idHostCpu,
2279	("u32Magic=%#x idCpu=% idHostCpu=%d\n", pCpu->u32Magic, pCpu->idCpu, idHostCpu));
2280
2281	/*
2282	* Check whether we need to do anything about the timer.
2283	* We have to be a little bit careful since we might be race the timer
2284	* callback here.
2285	*/
2286	if (uHz > 16384)
2287	uHz = 16384; /** @todo add a query method for this! */
2288	if (RT_UNLIKELY( uHz > ASMAtomicReadU32(&pCpu->Ppt.uDesiredHz)
2289	&& uHz >= pCpu->Ppt.uMinHz
2290	&& !pCpu->Ppt.fStarting /* solaris paranoia */))
2291	{
2292	RTSpinlockAcquire(pCpu->Ppt.hSpinlock);
2293
2294	pCpu->Ppt.uDesiredHz = uHz;
2295	uint32_t cNsInterval = 0;
2296	if (!pCpu->Ppt.fStarted)
2297	{
2298	pCpu->Ppt.cStarts++;
2299	pCpu->Ppt.fStarted = true;
2300	pCpu->Ppt.fStarting = true;
2301	pCpu->Ppt.iTickHistorization = 0;
2302	pCpu->Ppt.uTimerHz = uHz;
2303	pCpu->Ppt.cNsInterval = cNsInterval = RT_NS_1SEC / uHz;
2304	if (cNsInterval < GVMMHOSTCPU_PPT_HIST_INTERVAL_NS)
2305	pCpu->Ppt.cTicksHistoriziationInterval = ( GVMMHOSTCPU_PPT_HIST_INTERVAL_NS
2306	+ GVMMHOSTCPU_PPT_HIST_INTERVAL_NS / 2 - 1)
2307	/ cNsInterval;
2308	else
2309	pCpu->Ppt.cTicksHistoriziationInterval = 1;
2310	}
2311
2312	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2313
2314	if (cNsInterval)
2315	{
2316	RTTimerChangeInterval(pCpu->Ppt.pTimer, cNsInterval);
2317	int rc = RTTimerStart(pCpu->Ppt.pTimer, cNsInterval);
2318	AssertRC(rc);
2319
2320	RTSpinlockAcquire(pCpu->Ppt.hSpinlock);
2321	if (RT_FAILURE(rc))
2322	pCpu->Ppt.fStarted = false;
2323	pCpu->Ppt.fStarting = false;
2324	RTSpinlockRelease(pCpu->Ppt.hSpinlock);
2325	}
2326	}
2327	#else /* !GVMM_SCHED_WITH_PPT */
2328	NOREF(idHostCpu); NOREF(uHz);
2329	#endif /* !GVMM_SCHED_WITH_PPT */
2330	}
2331
2332
2333	/**
2334	* Retrieves the GVMM statistics visible to the caller.
2335	*
2336	* @returns VBox status code.
2337	*
2338	* @param pStats Where to put the statistics.
2339	* @param pSession The current session.
2340	* @param pVM The VM to obtain statistics for. Optional.
2341	*/
2342	GVMMR0DECL(int) GVMMR0QueryStatistics(PGVMMSTATS pStats, PSUPDRVSESSION pSession, PVM pVM)
2343	{
2344	LogFlow(("GVMMR0QueryStatistics: pStats=%p pSession=%p pVM=%p\n", pStats, pSession, pVM));
2345
2346	/*
2347	* Validate input.
2348	*/
2349	AssertPtrReturn(pSession, VERR_INVALID_POINTER);
2350	AssertPtrReturn(pStats, VERR_INVALID_POINTER);
2351	pStats->cVMs = 0; /* (crash before taking the sem...) */
2352
2353	/*
2354	* Take the lock and get the VM statistics.
2355	*/
2356	PGVMM pGVMM;
2357	if (pVM)
2358	{
2359	PGVM pGVM;
2360	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, true /fTakeUsedLock/);
2361	if (RT_FAILURE(rc))
2362	return rc;
2363	pStats->SchedVM = pGVM->gvmm.s.StatsSched;
2364	}
2365	else
2366	{
2367	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
2368	memset(&pStats->SchedVM, 0, sizeof(pStats->SchedVM));
2369
2370	int rc = gvmmR0UsedLock(pGVMM);
2371	AssertRCReturn(rc, rc);
2372	}
2373
2374	/*
2375	* Enumerate the VMs and add the ones visible to the statistics.
2376	*/
2377	pStats->cVMs = 0;
2378	pStats->cEMTs = 0;
2379	memset(&pStats->SchedSum, 0, sizeof(pStats->SchedSum));
2380
2381	for (unsigned i = pGVMM->iUsedHead;
2382	i != NIL_GVM_HANDLE && i < RT_ELEMENTS(pGVMM->aHandles);
2383	i = pGVMM->aHandles[i].iNext)
2384	{
2385	PGVM pGVM = pGVMM->aHandles[i].pGVM;
2386	void *pvObj = pGVMM->aHandles[i].pvObj;
2387	if ( VALID_PTR(pvObj)
2388	&& VALID_PTR(pGVM)
2389	&& pGVM->u32Magic == GVM_MAGIC
2390	&& RT_SUCCESS(SUPR0ObjVerifyAccess(pvObj, pSession, NULL)))
2391	{
2392	pStats->cVMs++;
2393	pStats->cEMTs += pGVM->cCpus;
2394
2395	pStats->SchedSum.cHaltCalls += pGVM->gvmm.s.StatsSched.cHaltCalls;
2396	pStats->SchedSum.cHaltBlocking += pGVM->gvmm.s.StatsSched.cHaltBlocking;
2397	pStats->SchedSum.cHaltTimeouts += pGVM->gvmm.s.StatsSched.cHaltTimeouts;
2398	pStats->SchedSum.cHaltNotBlocking += pGVM->gvmm.s.StatsSched.cHaltNotBlocking;
2399	pStats->SchedSum.cHaltWakeUps += pGVM->gvmm.s.StatsSched.cHaltWakeUps;
2400
2401	pStats->SchedSum.cWakeUpCalls += pGVM->gvmm.s.StatsSched.cWakeUpCalls;
2402	pStats->SchedSum.cWakeUpNotHalted += pGVM->gvmm.s.StatsSched.cWakeUpNotHalted;
2403	pStats->SchedSum.cWakeUpWakeUps += pGVM->gvmm.s.StatsSched.cWakeUpWakeUps;
2404
2405	pStats->SchedSum.cPokeCalls += pGVM->gvmm.s.StatsSched.cPokeCalls;
2406	pStats->SchedSum.cPokeNotBusy += pGVM->gvmm.s.StatsSched.cPokeNotBusy;
2407
2408	pStats->SchedSum.cPollCalls += pGVM->gvmm.s.StatsSched.cPollCalls;
2409	pStats->SchedSum.cPollHalts += pGVM->gvmm.s.StatsSched.cPollHalts;
2410	pStats->SchedSum.cPollWakeUps += pGVM->gvmm.s.StatsSched.cPollWakeUps;
2411	}
2412	}
2413
2414	/*
2415	* Copy out the per host CPU statistics.
2416	*/
2417	uint32_t iDstCpu = 0;
2418	uint32_t cSrcCpus = pGVMM->cHostCpus;
2419	for (uint32_t iSrcCpu = 0; iSrcCpu < cSrcCpus; iSrcCpu++)
2420	{
2421	if (pGVMM->aHostCpus[iSrcCpu].idCpu != NIL_RTCPUID)
2422	{
2423	pStats->aHostCpus[iDstCpu].idCpu = pGVMM->aHostCpus[iSrcCpu].idCpu;
2424	pStats->aHostCpus[iDstCpu].idxCpuSet = pGVMM->aHostCpus[iSrcCpu].idxCpuSet;
2425	#ifdef GVMM_SCHED_WITH_PPT
2426	pStats->aHostCpus[iDstCpu].uDesiredHz = pGVMM->aHostCpus[iSrcCpu].Ppt.uDesiredHz;
2427	pStats->aHostCpus[iDstCpu].uTimerHz = pGVMM->aHostCpus[iSrcCpu].Ppt.uTimerHz;
2428	pStats->aHostCpus[iDstCpu].cChanges = pGVMM->aHostCpus[iSrcCpu].Ppt.cChanges;
2429	pStats->aHostCpus[iDstCpu].cStarts = pGVMM->aHostCpus[iSrcCpu].Ppt.cStarts;
2430	#else
2431	pStats->aHostCpus[iDstCpu].uDesiredHz = 0;
2432	pStats->aHostCpus[iDstCpu].uTimerHz = 0;
2433	pStats->aHostCpus[iDstCpu].cChanges = 0;
2434	pStats->aHostCpus[iDstCpu].cStarts = 0;
2435	#endif
2436	iDstCpu++;
2437	if (iDstCpu >= RT_ELEMENTS(pStats->aHostCpus))
2438	break;
2439	}
2440	}
2441	pStats->cHostCpus = iDstCpu;
2442
2443	gvmmR0UsedUnlock(pGVMM);
2444
2445	return VINF_SUCCESS;
2446	}
2447
2448
2449	/**
2450	* VMMR0 request wrapper for GVMMR0QueryStatistics.
2451	*
2452	* @returns see GVMMR0QueryStatistics.
2453	* @param pVM Pointer to the VM. Optional.
2454	* @param pReq Pointer to the request packet.
2455	*/
2456	GVMMR0DECL(int) GVMMR0QueryStatisticsReq(PVM pVM, PGVMMQUERYSTATISTICSSREQ pReq)
2457	{
2458	/*
2459	* Validate input and pass it on.
2460	*/
2461	AssertPtrReturn(pReq, VERR_INVALID_POINTER);
2462	AssertMsgReturn(pReq->Hdr.cbReq == sizeof(pReq), ("%#x != %#x\n", pReq->Hdr.cbReq, sizeof(pReq)), VERR_INVALID_PARAMETER);
2463
2464	return GVMMR0QueryStatistics(&pReq->Stats, pReq->pSession, pVM);
2465	}
2466
2467
2468	/**
2469	* Resets the specified GVMM statistics.
2470	*
2471	* @returns VBox status code.
2472	*
2473	* @param pStats Which statistics to reset, that is, non-zero fields indicates which to reset.
2474	* @param pSession The current session.
2475	* @param pVM The VM to reset statistics for. Optional.
2476	*/
2477	GVMMR0DECL(int) GVMMR0ResetStatistics(PCGVMMSTATS pStats, PSUPDRVSESSION pSession, PVM pVM)
2478	{
2479	LogFlow(("GVMMR0ResetStatistics: pStats=%p pSession=%p pVM=%p\n", pStats, pSession, pVM));
2480
2481	/*
2482	* Validate input.
2483	*/
2484	AssertPtrReturn(pSession, VERR_INVALID_POINTER);
2485	AssertPtrReturn(pStats, VERR_INVALID_POINTER);
2486
2487	/*
2488	* Take the lock and get the VM statistics.
2489	*/
2490	PGVMM pGVMM;
2491	if (pVM)
2492	{
2493	PGVM pGVM;
2494	int rc = gvmmR0ByVM(pVM, &pGVM, &pGVMM, true /fTakeUsedLock/);
2495	if (RT_FAILURE(rc))
2496	return rc;
2497	# define MAYBE_RESET_FIELD(field) \
2498	do { if (pStats->SchedVM. field ) { pGVM->gvmm.s.StatsSched. field = 0; } } while (0)
2499	MAYBE_RESET_FIELD(cHaltCalls);
2500	MAYBE_RESET_FIELD(cHaltBlocking);
2501	MAYBE_RESET_FIELD(cHaltTimeouts);
2502	MAYBE_RESET_FIELD(cHaltNotBlocking);
2503	MAYBE_RESET_FIELD(cHaltWakeUps);
2504	MAYBE_RESET_FIELD(cWakeUpCalls);
2505	MAYBE_RESET_FIELD(cWakeUpNotHalted);
2506	MAYBE_RESET_FIELD(cWakeUpWakeUps);
2507	MAYBE_RESET_FIELD(cPokeCalls);
2508	MAYBE_RESET_FIELD(cPokeNotBusy);
2509	MAYBE_RESET_FIELD(cPollCalls);
2510	MAYBE_RESET_FIELD(cPollHalts);
2511	MAYBE_RESET_FIELD(cPollWakeUps);
2512	# undef MAYBE_RESET_FIELD
2513	}
2514	else
2515	{
2516	GVMM_GET_VALID_INSTANCE(pGVMM, VERR_GVMM_INSTANCE);
2517
2518	int rc = gvmmR0UsedLock(pGVMM);
2519	AssertRCReturn(rc, rc);
2520	}
2521
2522	/*
2523	* Enumerate the VMs and add the ones visible to the statistics.
2524	*/
2525	if (ASMMemIsAll8(&pStats->SchedSum, sizeof(pStats->SchedSum), 0))
2526	{
2527	for (unsigned i = pGVMM->iUsedHead;
2528	i != NIL_GVM_HANDLE && i < RT_ELEMENTS(pGVMM->aHandles);
2529	i = pGVMM->aHandles[i].iNext)
2530	{
2531	PGVM pGVM = pGVMM->aHandles[i].pGVM;
2532	void *pvObj = pGVMM->aHandles[i].pvObj;
2533	if ( VALID_PTR(pvObj)
2534	&& VALID_PTR(pGVM)
2535	&& pGVM->u32Magic == GVM_MAGIC
2536	&& RT_SUCCESS(SUPR0ObjVerifyAccess(pvObj, pSession, NULL)))
2537	{
2538	# define MAYBE_RESET_FIELD(field) \
2539	do { if (pStats->SchedSum. field ) { pGVM->gvmm.s.StatsSched. field = 0; } } while (0)
2540	MAYBE_RESET_FIELD(cHaltCalls);
2541	MAYBE_RESET_FIELD(cHaltBlocking);
2542	MAYBE_RESET_FIELD(cHaltTimeouts);
2543	MAYBE_RESET_FIELD(cHaltNotBlocking);
2544	MAYBE_RESET_FIELD(cHaltWakeUps);
2545	MAYBE_RESET_FIELD(cWakeUpCalls);
2546	MAYBE_RESET_FIELD(cWakeUpNotHalted);
2547	MAYBE_RESET_FIELD(cWakeUpWakeUps);
2548	MAYBE_RESET_FIELD(cPokeCalls);
2549	MAYBE_RESET_FIELD(cPokeNotBusy);
2550	MAYBE_RESET_FIELD(cPollCalls);
2551	MAYBE_RESET_FIELD(cPollHalts);
2552	MAYBE_RESET_FIELD(cPollWakeUps);
2553	# undef MAYBE_RESET_FIELD
2554	}
2555	}
2556	}
2557
2558	gvmmR0UsedUnlock(pGVMM);
2559
2560	return VINF_SUCCESS;
2561	}
2562
2563
2564	/**
2565	* VMMR0 request wrapper for GVMMR0ResetStatistics.
2566	*
2567	* @returns see GVMMR0ResetStatistics.
2568	* @param pVM Pointer to the VM. Optional.
2569	* @param pReq Pointer to the request packet.
2570	*/
2571	GVMMR0DECL(int) GVMMR0ResetStatisticsReq(PVM pVM, PGVMMRESETSTATISTICSSREQ pReq)
2572	{
2573	/*
2574	* Validate input and pass it on.
2575	*/
2576	AssertPtrReturn(pReq, VERR_INVALID_POINTER);
2577	AssertMsgReturn(pReq->Hdr.cbReq == sizeof(pReq), ("%#x != %#x\n", pReq->Hdr.cbReq, sizeof(pReq)), VERR_INVALID_PARAMETER);
2578
2579	return GVMMR0ResetStatistics(&pReq->Stats, pReq->pSession, pVM);
2580	}
2581

Note: See TracBrowser for help on using the repository browser.

source: vbox/trunk/src/VBox/VMM/VMMR0/GVMMR0.cpp@ 57062

Download in other formats: