blob: 84be5f7ed14f4db9c05e7f36b37bdaac62ec1578 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
/* $Id: ClientWatcher.h $ */
/** @file
* VirtualBox API client session watcher
*/
/*
* Copyright (C) 2013-2022 Oracle and/or its affiliates.
*
* This file is part of VirtualBox base platform packages, as
* available from https://www.virtualbox.org.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation, in version 3 of the
* License.
*
* This program is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, see <https://www.gnu.org/licenses>.
*
* SPDX-License-Identifier: GPL-3.0-only
*/
#ifndef MAIN_INCLUDED_ClientWatcher_h
#define MAIN_INCLUDED_ClientWatcher_h
#ifndef RT_WITHOUT_PRAGMA_ONCE
# pragma once
#endif
#include <list>
#include <VBox/com/ptr.h>
#include <VBox/com/AutoLock.h>
#include "VirtualBoxImpl.h"
#if defined(RT_OS_WINDOWS)
# define CWUPDATEREQARG NULL
# define CWUPDATEREQTYPE HANDLE
# define CW_MAX_CLIENTS _16K /**< Max number of clients we can watch (windows). */
# ifndef DEBUG /* The debug version triggers worker thread code much much earlier. */
# define CW_MAX_CLIENTS_PER_THREAD 63 /**< Max clients per watcher thread (windows). */
# else
# define CW_MAX_CLIENTS_PER_THREAD 3 /**< Max clients per watcher thread (windows). */
# endif
# define CW_MAX_HANDLES_PER_THREAD (CW_MAX_CLIENTS_PER_THREAD + 1) /**< Max handles per thread. */
#elif defined(RT_OS_OS2)
# define CWUPDATEREQARG NIL_RTSEMEVENT
# define CWUPDATEREQTYPE RTSEMEVENT
#elif defined(VBOX_WITH_SYS_V_IPC_SESSION_WATCHER) || defined(VBOX_WITH_GENERIC_SESSION_WATCHER)
# define CWUPDATEREQARG NIL_RTSEMEVENT
# define CWUPDATEREQTYPE RTSEMEVENT
#else
# error "Port me!"
#endif
/**
* Class which checks for API clients which have crashed/exited, and takes
* the necessary cleanup actions. Singleton.
*/
class VirtualBox::ClientWatcher
{
public:
/**
* Constructor which creates a usable instance
*
* @param pVirtualBox Reference to VirtualBox object
*/
ClientWatcher(const ComObjPtr<VirtualBox> &pVirtualBox);
/**
* Default destructor. Cleans everything up.
*/
~ClientWatcher();
bool isReady();
void update();
void addProcess(RTPROCESS pid);
private:
/**
* Default constructor. Don't use, will not create a sensible instance.
*/
ClientWatcher();
static DECLCALLBACK(int) worker(RTTHREAD hThreadSelf, void *pvUser);
uint32_t reapProcesses(void);
VirtualBox *mVirtualBox;
RTTHREAD mThread;
CWUPDATEREQTYPE mUpdateReq;
util::RWLockHandle mLock;
typedef std::list<RTPROCESS> ProcessList;
ProcessList mProcesses;
#if defined(VBOX_WITH_SYS_V_IPC_SESSION_WATCHER) || defined(VBOX_WITH_GENERIC_SESSION_WATCHER)
uint8_t mUpdateAdaptCtr;
#endif
#ifdef RT_OS_WINDOWS
/** Indicate a real update request is pending.
* To avoid race conditions this must be set before mUpdateReq is signalled and
* read after resetting mUpdateReq. */
volatile bool mfUpdateReq;
/** Set when the worker threads are supposed to shut down. */
volatile bool mfTerminate;
/** Number of active subworkers.
* When decremented to 0, subworker zero is signalled. */
uint32_t volatile mcActiveSubworkers;
/** Number of valid handles in mahWaitHandles. */
uint32_t mcWaitHandles;
/** The wait interval (usually INFINITE). */
uint32_t mcMsWait;
/** Per subworker data. Subworker 0 is the main worker and does not have a
* pReq pointer since. */
struct PerSubworker
{
/** The wait result. */
DWORD dwWait;
/** The subworker index. */
uint32_t iSubworker;
/** The subworker thread handle. */
RTTHREAD hThread;
/** Self pointer (for worker thread). */
VirtualBox::ClientWatcher *pSelf;
} maSubworkers[(CW_MAX_CLIENTS + CW_MAX_CLIENTS_PER_THREAD - 1) / CW_MAX_CLIENTS_PER_THREAD];
/** Wait handle array. The mUpdateReq manual reset event handle is inserted
* every 64 entries, first entry being 0. */
HANDLE mahWaitHandles[CW_MAX_CLIENTS + (CW_MAX_CLIENTS + CW_MAX_CLIENTS_PER_THREAD - 1) / CW_MAX_CLIENTS_PER_THREAD];
void subworkerWait(VirtualBox::ClientWatcher::PerSubworker *pSubworker, uint32_t cMsWait);
static DECLCALLBACK(int) subworkerThread(RTTHREAD hThreadSelf, void *pvUser);
void winResetHandleArray(uint32_t cProcHandles);
#endif
};
#endif /* !MAIN_INCLUDED_ClientWatcher_h */
/* vi: set tabstop=4 shiftwidth=4 expandtab: */
|
