2 * COPYRIGHT: See COPYING in the top level directory
3 * PROJECT: ReactOS Base API Server DLL
4 * FILE: subsystems/win/basesrv/proc.c
5 * PURPOSE: Process and Thread Management
6 * PROGRAMMERS: Alex Ionescu (alex.ionescu@reactos.org)
9 /* INCLUDES *******************************************************************/
17 /* PUBLIC SERVER APIS *********************************************************/
19 CSR_API(BaseSrvDebugProcess
)
21 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
22 return STATUS_NOT_IMPLEMENTED
;
25 CSR_API(BaseSrvRegisterThread
)
27 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
28 return STATUS_NOT_IMPLEMENTED
;
30 CSR_API(BaseSrvSxsCreateActivationContext
)
32 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
33 return STATUS_NOT_IMPLEMENTED
;
36 CSR_API(BaseSrvSetTermsrvAppInstallMode
)
38 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
39 return STATUS_NOT_IMPLEMENTED
;
42 CSR_API(BaseSrvSetTermsrvClientTimeZone
)
44 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
45 return STATUS_NOT_IMPLEMENTED
;
48 CSR_API(BaseSrvUnknown
)
50 DPRINT1("%s not yet implemented\n", __FUNCTION__
);
51 return STATUS_NOT_IMPLEMENTED
;
54 CSR_API(BaseSrvGetTempFile
)
56 static UINT BaseGetTempFileUnique
= 0;
57 PBASE_GET_TEMP_FILE GetTempFile
= &((PBASE_API_MESSAGE
)ApiMessage
)->Data
.GetTempFileRequest
;
59 /* Return 16-bits ID */
60 GetTempFile
->UniqueID
= (++BaseGetTempFileUnique
& 0xFFFF);
62 DPRINT("Returning: %u\n", GetTempFile
->UniqueID
);
64 return STATUS_SUCCESS
;
67 CSR_API(BaseSrvCreateProcess
)
70 PBASE_CREATE_PROCESS CreateProcessRequest
= &((PBASE_API_MESSAGE
)ApiMessage
)->Data
.CreateProcessRequest
;
71 HANDLE ProcessHandle
, ThreadHandle
;
72 PCSR_THREAD CsrThread
;
74 ULONG Flags
= 0, DebugFlags
= 0, VdmPower
= 0;
76 /* Get the current client thread */
77 CsrThread
= CsrGetClientThread();
78 ASSERT(CsrThread
!= NULL
);
80 Process
= CsrThread
->Process
;
82 /* Extract the flags out of the process handle */
83 Flags
= (ULONG_PTR
)CreateProcessRequest
->ProcessHandle
& 3;
84 CreateProcessRequest
->ProcessHandle
= (HANDLE
)((ULONG_PTR
)CreateProcessRequest
->ProcessHandle
& ~3);
86 /* Some things should be done if this is a VDM process */
87 if (CreateProcessRequest
->VdmBinaryType
)
89 /* We need to set the VDM power later on */
93 /* Duplicate the process handle */
94 Status
= NtDuplicateObject(Process
->ProcessHandle
,
95 CreateProcessRequest
->ProcessHandle
,
100 DUPLICATE_SAME_ACCESS
);
101 if (!NT_SUCCESS(Status
))
103 DPRINT1("Failed to duplicate process handle: %lx\n", Status
);
107 /* Duplicate the thread handle */
108 Status
= NtDuplicateObject(Process
->ProcessHandle
,
109 CreateProcessRequest
->ThreadHandle
,
114 DUPLICATE_SAME_ACCESS
);
115 if (!NT_SUCCESS(Status
))
117 DPRINT1("Failed to duplicate thread handle: %lx\n", Status
);
118 NtClose(ProcessHandle
);
122 /* If this is a VDM process, request VDM power */
125 Status
= NtSetInformationProcess(ProcessHandle
,
126 ProcessWx86Information
,
129 if (!NT_SUCCESS(Status
))
131 DPRINT1("Failed to get VDM powers\n");
132 NtClose(ProcessHandle
);
133 NtClose(ThreadHandle
);
138 /* Flags conversion. FIXME: More need conversion */
139 if (CreateProcessRequest
->CreationFlags
& CREATE_NEW_PROCESS_GROUP
)
141 DebugFlags
|= CsrProcessCreateNewGroup
;
143 if ((Flags
& 2) == 0)
145 /* We are launching a console process */
146 DebugFlags
|= CsrProcessIsConsoleApp
;
149 /* FIXME: SxS Stuff */
151 /* Call CSRSRV to create the CSR_PROCESS structure and the first CSR_THREAD */
152 Status
= CsrCreateProcess(ProcessHandle
,
154 &CreateProcessRequest
->ClientId
,
158 if (Status
== STATUS_THREAD_IS_TERMINATING
)
160 DPRINT1("Thread already dead\n");
162 /* Set the special reply value so we don't reply this message back */
163 *ReplyCode
= CsrReplyDeadClient
;
168 /* Check for other failures */
169 if (!NT_SUCCESS(Status
))
171 DPRINT1("Failed to create process/thread structures: %lx\n", Status
);
175 /* FIXME: Should notify user32 */
177 /* Check if this is a VDM process */
178 if (CreateProcessRequest
->VdmBinaryType
)
180 PVDM_CONSOLE_RECORD ConsoleRecord
;
182 if (CreateProcessRequest
->VdmTask
!= 0)
184 /* Get the console record using the task ID */
185 Status
= GetConsoleRecordBySessionId(CreateProcessRequest
->VdmTask
,
190 /* Get the console record using the console handle */
191 Status
= BaseSrvGetConsoleRecord(CreateProcessRequest
->hVDM
,
195 /* Check if it failed */
196 if (!NT_SUCCESS(Status
)) return Status
;
198 /* Store the process ID of the VDM in the console record */
199 ConsoleRecord
->ProcessId
= HandleToUlong(CreateProcessRequest
->ClientId
.UniqueProcess
);
202 /* Return the result of this operation */
206 CSR_API(BaseSrvCreateThread
)
209 PBASE_CREATE_THREAD CreateThreadRequest
= &((PBASE_API_MESSAGE
)ApiMessage
)->Data
.CreateThreadRequest
;
210 PCSR_THREAD CurrentThread
;
212 PCSR_PROCESS CsrProcess
;
214 /* Get the current CSR thread */
215 CurrentThread
= CsrGetClientThread();
218 DPRINT1("Server Thread TID: [%lx.%lx]\n",
219 CreateThreadRequest
->ClientId
.UniqueProcess
,
220 CreateThreadRequest
->ClientId
.UniqueThread
);
221 return STATUS_SUCCESS
; // server-to-server
224 /* Get the CSR Process for this request */
225 CsrProcess
= CurrentThread
->Process
;
226 if (CsrProcess
->ClientId
.UniqueProcess
!=
227 CreateThreadRequest
->ClientId
.UniqueProcess
)
229 /* This is a remote thread request -- is it within the server itself? */
230 if (CreateThreadRequest
->ClientId
.UniqueProcess
== NtCurrentTeb()->ClientId
.UniqueProcess
)
232 /* Accept this without any further work */
233 return STATUS_SUCCESS
;
236 /* Get the real CSR Process for the remote thread's process */
237 Status
= CsrLockProcessByClientId(CreateThreadRequest
->ClientId
.UniqueProcess
,
239 if (!NT_SUCCESS(Status
)) return Status
;
242 /* Duplicate the thread handle so we can own it */
243 Status
= NtDuplicateObject(CurrentThread
->Process
->ProcessHandle
,
244 CreateThreadRequest
->ThreadHandle
,
249 DUPLICATE_SAME_ACCESS
);
250 if (NT_SUCCESS(Status
))
252 /* Call CSRSRV to tell it about the new thread */
253 Status
= CsrCreateThread(CsrProcess
,
255 &CreateThreadRequest
->ClientId
,
259 /* Unlock the process and return */
260 if (CsrProcess
!= CurrentThread
->Process
) CsrUnlockProcess(CsrProcess
);
264 CSR_API(BaseSrvExitProcess
)
266 PCSR_THREAD CsrThread
= CsrGetClientThread();
267 ASSERT(CsrThread
!= NULL
);
269 /* Set the special reply value so we don't reply this message back */
270 *ReplyCode
= CsrReplyDeadClient
;
272 /* Remove the CSR_THREADs and CSR_PROCESS */
273 return CsrDestroyProcess(&CsrThread
->ClientId
,
274 (NTSTATUS
)((PBASE_API_MESSAGE
)ApiMessage
)->Data
.ExitProcessRequest
.uExitCode
);
277 CSR_API(BaseSrvGetProcessShutdownParam
)
279 PBASE_GETSET_PROCESS_SHUTDOWN_PARAMS ShutdownParametersRequest
= &((PBASE_API_MESSAGE
)ApiMessage
)->Data
.ShutdownParametersRequest
;
280 PCSR_THREAD CsrThread
= CsrGetClientThread();
283 ShutdownParametersRequest
->ShutdownLevel
= CsrThread
->Process
->ShutdownLevel
;
284 ShutdownParametersRequest
->ShutdownFlags
= CsrThread
->Process
->ShutdownFlags
;
286 return STATUS_SUCCESS
;
289 CSR_API(BaseSrvSetProcessShutdownParam
)
291 PBASE_GETSET_PROCESS_SHUTDOWN_PARAMS ShutdownParametersRequest
= &((PBASE_API_MESSAGE
)ApiMessage
)->Data
.ShutdownParametersRequest
;
292 PCSR_THREAD CsrThread
= CsrGetClientThread();
295 CsrThread
->Process
->ShutdownLevel
= ShutdownParametersRequest
->ShutdownLevel
;
296 CsrThread
->Process
->ShutdownFlags
= ShutdownParametersRequest
->ShutdownFlags
;
298 return STATUS_SUCCESS
;
301 /* PUBLIC API *****************************************************************/
305 BaseSetProcessCreateNotify(IN BASE_PROCESS_CREATE_NOTIFY_ROUTINE ProcessCreateNotifyProc
)
307 DPRINT("BASESRV: %s(%08lx) called\n", __FUNCTION__
, ProcessCreateNotifyProc
);
308 return STATUS_NOT_IMPLEMENTED
;