-
Notifications
You must be signed in to change notification settings - Fork 11
/
comm95b.c
355 lines (258 loc) · 9.42 KB
/
comm95b.c
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
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
/*
* Common routines and variables used by Prime95, Saver95, and NTPrime
*
* Comm95a contains information used only during setup
* Comm95b contains information used only during execution
* Comm95c contains information used during setup and execution
*
* Copyright 1995-2023 Mersenne Research, Inc. All rights reserved
*
*/
/* Common global variables */
#define MAX_THREAD_HANDLES 1024
HANDLE THREAD_HANDLES[MAX_THREAD_HANDLES] = {0};
int NUM_THREAD_HANDLES = 0;
/* Common routines */
/* Clear the array of active thread handles */
void clearThreadHandleArray (void)
{
NUM_THREAD_HANDLES = 0;
}
/* Set the thread priority correctly. Most screen savers run at priority 4. */
/* Most application's run at priority 9 when in foreground, 7 when in */
/* background. In selecting the proper thread priority I've assumed the */
/* program usually runs in the background. */
void setOsThreadPriority (
int priority) /* Priority, 1=low, 9=high */
{
HANDLE h;
int pri_class, thread_pri;
/* Get and remember the thread handle */
h = GetCurrentThread ();
if (NUM_THREAD_HANDLES < MAX_THREAD_HANDLES)
THREAD_HANDLES[NUM_THREAD_HANDLES++] = h;
/* Set the thread priority */
if (priority <= 1) pri_class = NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_IDLE;
if (priority == 2) pri_class = IDLE_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_LOWEST;
if (priority == 3) pri_class = IDLE_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_BELOW_NORMAL;
if (priority == 4) pri_class = BELOW_NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_LOWEST;
if (priority == 5) pri_class = BELOW_NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_BELOW_NORMAL;
if (priority == 6) pri_class = NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_LOWEST;
if (priority == 7) pri_class = NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_BELOW_NORMAL;
if (priority == 8) pri_class = ABOVE_NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_LOWEST;
if (priority >= 9) pri_class = ABOVE_NORMAL_PRIORITY_CLASS, thread_pri = THREAD_PRIORITY_BELOW_NORMAL;
SetPriorityClass (GetCurrentProcess (), pri_class);
SetThreadPriority (h, thread_pri);
/* Disable thread priority boost */
SetThreadPriorityBoost (h, TRUE);
}
/* Register a thread termination. We remove the thread handle from the list of active workers. */
void registerThreadTermination (void)
{
int i;
HANDLE h;
/* Get the thread handle and remove it from the thread handle array */
h = GetCurrentThread ();
for (i = 0; i < NUM_THREAD_HANDLES; i++) {
if (THREAD_HANDLES[i] != h) break;
THREAD_HANDLES[i] = THREAD_HANDLES[--NUM_THREAD_HANDLES];
break;
}
}
/* When stopping or exiting we raise the priority of all workers so that they can terminate in a timely fashion even if there are other CPU bound tasks running. */
void raiseAllWorkersPriority (void)
{
int i;
SetPriorityClass (GetCurrentProcess (), NORMAL_PRIORITY_CLASS);
/* Loop through the thread handle array raising priority and */
/* setting affinity to run on any CPU. */
for (i = 0; i < NUM_THREAD_HANDLES; i++) {
SetThreadPriority (THREAD_HANDLES[i], THREAD_PRIORITY_ABOVE_NORMAL);
SetThreadAffinityMask (THREAD_HANDLES[i], -1);
}
}
/* Enumerate processes so that we can pause if a user-specified process */
/* is running. This code is adapted from Microsoft's knowledge base article */
/* Q175030. */
#if 0 //formerly #ifndef X86_64
#include <psapi.h>
#include <tlhelp32.h>
void checkPauseListCallback (void)
{
OSVERSIONINFO osver;
BOOL bFlag;
LPDWORD lpdwPIDs = NULL;
DWORD dwSize, dwSize2, dwIndex;
char szFileName[ MAX_PATH ];
// Check to see if were running under Windows95 or Windows NT.
osver.dwOSVersionInfoSize = sizeof( osver );
if ( !GetVersionEx( &osver ) ) return;
// If Windows NT:
if ( osver.dwPlatformId == VER_PLATFORM_WIN32_NT ) {
// Call the PSAPI function EnumProcesses to get all of the
// ProcID's currently in the system.
// NOTE: In the documentation, the third parameter of
// EnumProcesses is named cbNeeded, which implies that you
// can call the function once to find out how much space to
// allocate for a buffer and again to fill the buffer.
// This is not the case. The cbNeeded parameter returns
// the number of PIDs returned, so if your buffer size is
// zero cbNeeded returns zero.
// NOTE: The "HeapAlloc" loop here ensures that we
// actually allocate a buffer large enough for all the
// PIDs in the system.
dwSize2 = 256 * sizeof (DWORD);
do {
if (lpdwPIDs) {
HeapFree (GetProcessHeap(), 0, lpdwPIDs);
dwSize2 *= 2;
}
lpdwPIDs = (LPDWORD)
HeapAlloc (GetProcessHeap(), 0, dwSize2);
if (lpdwPIDs == NULL) goto ntdone;
if (!EnumProcesses (lpdwPIDs, dwSize2, &dwSize)) goto ntdone;
} while (dwSize == dwSize2);
// How many ProcID's did we get?
dwSize /= sizeof (DWORD);
// Loop through each ProcID.
for (dwIndex = 0; dwIndex < dwSize; dwIndex++) {
HMODULE hMod;
HANDLE hProcess;
// Open the process (if we can... security does not
// permit every process in the system).
hProcess = OpenProcess(
PROCESS_QUERY_INFORMATION | PROCESS_VM_READ,
FALSE, lpdwPIDs[ dwIndex ] );
if (!hProcess) continue;
// Here we call EnumProcessModules to get only the
// first module in the process this is important,
// because this will be the .EXE module for which we
// will retrieve the full path name in a second.
if (!EnumProcessModules (hProcess, &hMod, sizeof (hMod), &dwSize2)) {
CloseHandle (hProcess);
continue;
}
// Get Full pathname:
if (!GetModuleFileNameEx (hProcess, hMod, szFileName, sizeof (szFileName))) {
CloseHandle (hProcess);
continue;
}
CloseHandle (hProcess);
// Regardless of OpenProcess success or failure, we
// still call the enum func with the ProcID.
isInPauseList (szFileName);
}
ntdone: if (lpdwPIDs) HeapFree (GetProcessHeap(), 0, lpdwPIDs);
return;
}
// If Windows 32-bit:
else if (osver.dwPlatformId == VER_PLATFORM_WIN32_WINDOWS) {
HANDLE hSnapShot = NULL;
PROCESSENTRY32 procentry;
// Get a handle to a Toolhelp snapshot of the systems processes.
hSnapShot = CreateToolhelp32Snapshot (TH32CS_SNAPPROCESS, 0);
if (hSnapShot == INVALID_HANDLE_VALUE) {
hSnapShot = NULL;
goto done95;
}
// Get the first process' information.
procentry.dwSize = sizeof (PROCESSENTRY32);
bFlag = Process32First (hSnapShot, &procentry);
// While there are processes, keep looping.
while (bFlag) {
// Call the enum func with the filename and ProcID.
isInPauseList (procentry.szExeFile);
procentry.dwSize = sizeof(PROCESSENTRY32);
bFlag = Process32Next (hSnapShot, &procentry);
}
// Free the library.
done95: if (hSnapShot) CloseHandle (hSnapShot);
return;
}
// Unknown OS type
return;
}
#else
/* The 64-bit version does not need to dynamically load DLLs. */
#include <tlhelp32.h>
#include <psapi.h>
void checkPauseListCallback (void)
{
// The code below is our second attempt, trying to solve the running as administrator problem
// This gets the name of the executable, but not the full path name. Thus this is a partial fix
// and we must include both methods.
HANDLE hProcessSnap;
PROCESSENTRY32 pe32;
// Take a snapshot of all processes in the system.
hProcessSnap = CreateToolhelp32Snapshot (TH32CS_SNAPPROCESS, 0);
if (hProcessSnap != INVALID_HANDLE_VALUE) {
// Retrieve information about the first process, then next processes
// looking for any process that forces us to pause
pe32.dwSize = sizeof (PROCESSENTRY32);
if (Process32First (hProcessSnap, &pe32)) do {
isInPauseList (pe32.szExeFile);
} while (Process32Next (hProcessSnap, &pe32));
// Cleanup
CloseHandle( hProcessSnap );
}
// The code below was our original attempt, but there was a complaint that this will not
// detect some processes running as administrator (not enough privilege to OpenProcess).
{
LPDWORD lpdwPIDs = NULL;
DWORD dwSize, dwSize2, dwIndex;
char szFileName[ MAX_PATH ];
// Call the PSAPI function EnumProcesses to get all of the
// ProcID's currently in the system.
dwSize2 = 256 * sizeof (DWORD);
do {
if (lpdwPIDs) {
HeapFree (GetProcessHeap(), 0, lpdwPIDs);
dwSize2 *= 2;
}
lpdwPIDs = (LPDWORD)
HeapAlloc (GetProcessHeap(), 0, dwSize2);
if (lpdwPIDs == NULL) goto ntdone;
if (!EnumProcesses (lpdwPIDs, dwSize2, &dwSize))
goto ntdone;
} while (dwSize == dwSize2);
// How many ProcID's did we get?
dwSize /= sizeof (DWORD);
// Loop through each ProcID.
for (dwIndex = 0; dwIndex < dwSize; dwIndex++) {
HMODULE hMod;
HANDLE hProcess;
// Open the process (if we can... security does not
// permit every process in the system).
hProcess = OpenProcess (
PROCESS_QUERY_INFORMATION | PROCESS_VM_READ,
FALSE, lpdwPIDs[ dwIndex ] );
if (!hProcess) continue;
// Here we call EnumProcessModules to get only the
// first module in the process this is important,
// because this will be the .EXE module for which we
// will retrieve the full path name in a second.
if (!EnumProcessModules (hProcess, &hMod, sizeof (hMod), &dwSize2)) {
CloseHandle (hProcess);
continue;
}
// Get Full pathname:
if (!GetModuleFileNameEx (hProcess, hMod, szFileName, sizeof (szFileName))) {
CloseHandle (hProcess);
continue;
}
CloseHandle (hProcess);
// Does this process force us to pause?
isInPauseList (szFileName);
}
ntdone: if (lpdwPIDs) HeapFree (GetProcessHeap(), 0, lpdwPIDs);
}
}
#endif
/* Get the load average - Windows does not support this */
double get_load_average (void)
{
return (-1.0);
}
/* Tell malloc to free memory back to the OS */
void mallocFreeForOS () {
}