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
|
/* $Id: winchildren.h 3313 2020-03-16 02:31:38Z bird $ */
/** @file
* Child process creation and management for kmk.
*/
/*
* Copyright (c) 2018 knut st. osmundsen <bird-kBuild-spamx@anduin.net>
*
* This file is part of kBuild.
*
* kBuild 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; either version 3 of the License, or
* (at your option) any later version.
*
* kBuild 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 kBuild. If not, see <http://www.gnu.org/licenses/>
*
*/
#ifndef INCLUDED_WINCHILDREN_H
#define INCLUDED_WINCHILDREN_H
/** Child processor group allocator state. */
typedef struct MKWINCHILDCPUGROUPALLOCSTATE
{
/** The group index for the worker allocator.
* This is ever increasing and must be modded by g_cProcessorGroups. */
unsigned int idxGroup;
/** The processor in group index for the worker allocator. */
unsigned int idxProcessorInGroup;
} MKWINCHILDCPUGROUPALLOCSTATE;
/** Pointer to a CPU group allocator state. */
typedef MKWINCHILDCPUGROUPALLOCSTATE *PMKWINCHILDCPUGROUPALLOCSTATE;
#ifdef DECLARE_HANDLE
/**
* A childcare worker pipe.
*/
typedef struct WINCCWPIPE
{
/** My end of the pipe. */
HANDLE hPipeMine;
/** The child end of the pipe. */
HANDLE hPipeChild;
/** The event for asynchronous reading. */
HANDLE hEvent;
/** Which pipe this is (1 == stdout, 2 == stderr). */
unsigned char iWhich;
/** Set if we've got a read pending already. */
BOOL fReadPending;
/** Indicator that we've written out something. This is cleared before
* we start catching output from a new child and use in the CL.exe
* supression heuristics. */
BOOL fHaveWrittenOut;
/** Number of bytes at the start of the buffer that we've already
* written out. We try write out whole lines. */
DWORD cbWritten;
/** The buffer offset of the read currently pending. */
DWORD offPendingRead;
/** Read buffer size. */
DWORD cbBuffer;
/** The read buffer allocation. */
unsigned char *pbBuffer;
/** Overlapped I/O structure. */
OVERLAPPED Overlapped;
} WINCCWPIPE;
#endif
typedef struct WINCCWPIPE *PWINCCWPIPE;
void MkWinChildInit(unsigned int cJobSlot);
void MkWinChildReExecMake(char **papszArgs, char **papszEnv);
intptr_t MkWinChildGetCompleteEventHandle(void);
int MkWinChildCreate(char **papszArgs, char **papszEnv, const char *pszShell, struct child *pMkChild, pid_t *pPid);
int MkWinChildCreateWithStdOutPipe(char **papszArgs, char **papszEnv, int fdErr, pid_t *pPid, int *pfdReadPipe);
void MkWinChildInitCpuGroupAllocator(PMKWINCHILDCPUGROUPALLOCSTATE pState);
unsigned int MkWinChildAllocateCpuGroup(PMKWINCHILDCPUGROUPALLOCSTATE pState);
#ifdef KMK
struct KMKBUILTINENTRY;
int MkWinChildCreateBuiltIn(struct KMKBUILTINENTRY const *pBuiltIn, int cArgs, char **papszArgs,
char **papszEnv, struct child *pMkChild, pid_t *pPid);
int MkWinChildCreateAppend(const char *pszFilename, char **ppszAppend, size_t cbAppend, int fTruncate,
struct child *pMkChild, pid_t *pPid);
int MkWinChildCreateSubmit(intptr_t hEvent, void *pvSubmitWorker, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr,
struct child *pMkChild, pid_t *pPid);
PWINCCWPIPE MkWinChildcareCreateWorkerPipe(unsigned iWhich, unsigned int idxWorker);
void MkWinChildcareWorkerDrainPipes(struct WINCHILD *pChild, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr);
void MkWinChildcareDeleteWorkerPipe(PWINCCWPIPE pPipe);
int MkWinChildCreateRedirect(intptr_t hProcess, pid_t *pPid);
# ifdef DECLARE_HANDLE
int MkWinChildBuiltInExecChild(void *pvWorker, const char *pszExecutable, char **papszArgs, BOOL fQuotedArgv,
char **papszEnvVars, const char *pszCwd, BOOL pafReplace[3], HANDLE pahReplace[3]);
# endif
#endif /* KMK */
int MkWinChildKill(pid_t pid, int iSignal, struct child *pMkChild);
int MkWinChildWait(int fBlock, pid_t *pPid, int *piExitCode, int *piSignal, int *pfCoreDumped, struct child **ppMkChild);
void MkWinChildExclusiveAcquire(void);
void MkWinChildExclusiveRelease(void);
#undef CLOSE_ON_EXEC
#define CLOSE_ON_EXEC(a_fd) MkWinChildUnrelatedCloseOnExec(a_fd)
int MkWinChildUnrelatedCloseOnExec(int fd);
#endif
|
