--- /dev/null
+/* $Id: init.c,v 1.3 2002/10/29 04:45:54 rex Exp $
+ *
+ * PROJECT : ReactOS / POSIX+ Environment Subsystem Server
+ * FILE : reactos/subsys/psx/server/srv/init.c
+ * DESCRIPTION: POSIX+ server initialization.
+ * DATE : 2001-05-05
+ * AUTHOR : Emanuele Aliberti <eal@users.sf.net>
+ *
+ * --------------------------------------------------------------------
+ *
+ * This software 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 2 of the
+ * License, or (at your option) any later version.
+ *
+ * This software 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 software; see the file COPYING. If not, write
+ * to the Free Software Foundation, Inc., 675 Mass Ave, Cambridge,
+ * MA 02139, USA.
+ *
+ * --------------------------------------------------------------------
+ */
+#include <psxss.h>
+#include <napi/teb.h>
+
+#ifdef __PSXSS_ON_W32__
+#include <windows.h>
+#endif
+
+/*** GLOBALS *********************************************************/
+
+SERVER Server =
+{
+ /* .Heap */
+ INVALID_HANDLE_VALUE,
+ /* .Directory */
+ {
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME,
+ {0,0,NULL}
+ },
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME"\\"PSX_NS_SESSION_DIRECTORY_NAME,
+ {0,0,NULL}
+ },
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME"\\"PSX_NS_SYSTEM_DIRECTORY_NAME,
+ {0,0,NULL}
+ },
+ },
+ /* .Port */
+ {
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME"\\"PSX_NS_API_PORT_NAME,
+ {0,0,NULL},
+ ApiPortListener
+ },
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME"\\"PSX_NS_SBAPI_PORT_NAME,
+ {0,0,NULL},
+ SbApiPortListener
+ },
+ { INVALID_HANDLE_VALUE,
+ L"\\"PSX_NS_SUBSYSTEM_DIRECTORY_NAME"\\"PSX_NS_SESSIONAPI_PORT_NAME,
+ {0,0,NULL},
+ SessionPortListener
+ }
+ }
+};
+
+/*** FUNCTIONS *******************************************************/
+
+/**********************************************************************
+ * PdxInitializeHeap/0 PRIVATE
+ *
+ * DESCRIPTION
+ * Initialize the PSX server process' heap.
+ */
+PRIVATE HANDLE STDCALL
+PdxInitializeHeap (VOID)
+{
+ return Server.Heap = (HANDLE)NtCurrentPeb()->ProcessHeap;
+}
+/**********************************************************************
+ * PdxCreateDirectory/1 PRIVATE
+ *
+ * DESCRIPTION
+ * Create a directory in the system name space.
+ */
+PRIVATE NTSTATUS STDCALL
+PdxCreateDirectory (
+ IN ULONG ulIndex
+ )
+{
+ OBJECT_ATTRIBUTES ObjectAttributes;
+ NTSTATUS Status;
+
+ RtlCreateUnicodeString (
+ & Server.Directory[ulIndex].usName,
+ Server.Directory[ulIndex].wsName
+ );
+ InitializeObjectAttributes (
+ & ObjectAttributes,
+ & Server.Directory[ulIndex].usName,
+ 0,
+ NULL,
+ NULL
+ );
+ Status = NtCreateDirectoryObject(
+ & Server.Directory[ulIndex].hObject,
+ DIRECTORY_ALL_ACCESS,
+ & ObjectAttributes
+ );
+ if (!NT_SUCCESS(Status))
+ {
+ debug_print(
+ L"PSXSS: %s directory creation failed (Status = %08x)",
+ Server.Directory[ulIndex].wsName,
+ Status
+ );
+
+ }
+ return Status;
+}
+/**********************************************************************
+ * PdxInitializeDirectories/0 PRIVATE
+ *
+ * DESCRIPTION
+ * Create the directories used by the POSIX+ subsystem
+ * components in the system name space.
+ */
+PRIVATE NTSTATUS STDCALL
+PdxInitializeDirectories (VOID)
+{
+ NTSTATUS Status;
+ ULONG ulIndex;
+
+ for ( ulIndex = 0;
+ (ulIndex < (sizeof Server.Directory / sizeof Server.Directory[0]));
+ ulIndex ++)
+ {
+ Status = PdxCreateDirectory (ulIndex);
+ if (!NT_SUCCESS(Status)) return Status;
+ }
+ return STATUS_SUCCESS;
+}
+/**********************************************************************
+ * PdxInitializeListener/1 PRIVATE
+ *
+ * DESCRIPTION
+ * Initialize a thread to make an LPC port listen.
+ */
+PRIVATE NTSTATUS STDCALL
+PdxInitializeListener (ULONG ulIndex)
+{
+ NTSTATUS Status;
+ OBJECT_ATTRIBUTES Oa;
+ ULONG ulThreadIndex;
+
+ RtlInitUnicodeString (
+ & Server.Port[ulIndex].usName,
+ Server.Port[ulIndex].wsName
+ );
+ InitializeObjectAttributes(
+ & Oa,
+ & Server.Port[ulIndex].usName,
+ 0,
+ NULL,
+ NULL
+ );
+ /* Create the listening LPC port */
+ Status = NtCreatePort (
+ & Server.Port[ulIndex].hObject,
+ & Oa,
+ 260,
+ 328,
+ 0
+ );
+ if (!NT_SUCCESS(Status))
+ {
+ debug_print(
+ L"PSXSS: Unable to create port \"%s\": Status %08x\n",
+ Server.Port[ulIndex].wsName,
+ Status);
+ return Status;
+ }
+ /*
+ * Create the server thread that will process
+ * messages sent to this port.
+ */
+ for ( ulThreadIndex = 0;
+ (ulThreadIndex < PSXSS_THREADS_PER_PORT);
+ ulThreadIndex ++
+ )
+ {
+#ifdef __PSXSS_ON_W32__
+ Server.Port[ulIndex].ThreadInfo[ulThreadIndex].hObject =
+ CreateThread (
+ NULL,
+ 0,
+ (PTHREAD_START_ROUTINE) Server.Port[ulIndex].EntryPoint,
+ (PVOID) ulIndex,
+ CREATE_SUSPENDED,
+ & Server.Port[ulIndex].ThreadInfo[ulThreadIndex].Id
+ );
+ if (NULL == Server.Port[ulIndex].ThreadInfo[ulThreadIndex].hObject)
+#else
+ if (!NT_SUCCESS(Status))
+#endif
+ {
+ debug_print(
+ L"PSXSS: Unable to create a server thread for port \"%s\": Status %08x\n",
+ Server.Port[ulIndex].wsName,
+ Status
+ );
+ NtClose (Server.Port[ulIndex].hObject);
+ return Status;
+ }
+ }
+ return STATUS_SUCCESS;
+}
+/**********************************************************************
+ * PsxInitializeListeners/0 PRIVATE
+ *
+ * DESCRIPTION
+ * Initialize the LPC ports and associate threads.
+ */
+PRIVATE NTSTATUS STDCALL
+PdxInitializeListeners (VOID)
+{
+ NTSTATUS Status;
+ ULONG ulIndex;
+
+ for ( ulIndex = 0;
+ (ulIndex < (sizeof Server.Port / sizeof Server.Port[0]));
+ ulIndex ++)
+ {
+ Status = PdxInitializeListener (ulIndex);
+ if (!NT_SUCCESS(Status)) return Status;
+ }
+ return STATUS_SUCCESS;
+}
+/**********************************************************************
+ * PdxRunServer/0 PRIVATE
+ *
+ * DESCRIPTION
+ * Wake up all suspended threads.
+ */
+PRIVATE NTSTATUS STDCALL
+PdxRunServer (VOID)
+{
+ NTSTATUS Status;
+ ULONG ulIndex;
+ ULONG ulThreadIndex;
+
+ for ( ulIndex = 0;
+ (ulIndex < (sizeof Server.Port / sizeof Server.Port[0]));
+ ulIndex ++)
+ {
+ for (ulThreadIndex = 0;
+ (ulThreadIndex < PSXSS_THREADS_PER_PORT);
+ ulThreadIndex ++
+ )
+ {
+#ifdef __PSXSS_ON_W32__
+ if (0xFFFFFFFF == ResumeThread (Server.Port[ulIndex].ThreadInfo[ulThreadIndex].hObject))
+#else
+ Status = NtResumeThread (Server.Port[ulIndex].ThreadInfo[ulThreadIndex].hObject, NULL);
+ if (!NT_SUCCESS(Status))
+#endif
+ {
+ debug_print(
+ L"PSXSS: "__FUNCTION__": NtResumeThread failed with Status = %08x",
+ Status
+ );
+ return Status;
+ }
+ }
+ }
+ return STATUS_SUCCESS;
+}
+/**********************************************************************
+ * PsxServerInitialization/2
+ *
+ * DESCRIPTION
+ * Initialize the PSX server process.
+ */
+NTSTATUS STDCALL
+PsxServerInitialization (
+ IN ULONG ArgumentCount,
+ IN PWSTR *ArgumentArray
+ )
+{
+ NTSTATUS Status;
+
+ /* Get our heap */
+ PdxInitializeHeap ();
+ /* Initialize POSIX+ and Sessions */
+ Status = PdxInitializeDirectories ();
+ if (!NT_SUCCESS(Status)) return Status;
+ /* LPCs dispatchers */
+ Status = PdxInitializeListeners ();
+ if (!NT_SUCCESS(Status)) return Status;
+ /* Terminal manager */
+ Status = PsxInitializeSessions ();
+ if (!NT_SUCCESS(Status)) return Status;
+ /* Process manager */
+ Status = PsxInitializeProcesses ();
+ if (!NT_SUCCESS(Status)) return Status;
+ /* OK. Run! */
+ Status = PdxRunServer ();
+ /* Done */
+ return Status;
+}
+/* EOF */
projects / reactos.git / blobdiff