1 files changed, 181 insertions, 0 deletions
diff --git a/private/os2/os2ss/sbreqst.c b/private/os2/os2ss/sbreqst.c
new file mode 100644
index 000000000..5b16d5cd7
--- /dev/null
+++ b/private/os2/os2ss/sbreqst.c
@@ -0,0 +1,181 @@
+/*++
+
+Copyright (c) 1989  Microsoft Corporation
+
+Module Name:
+
+    sbreqst.c
+
+Abstract:
+
+    This module contains the Server Request thread procedure for the Sb
+    API calls exported by the OS/2 Emulation SubSystem to the Session
+    Manager SubSystem.
+
+Author:
+
+    Steve Wood (stevewo) 20-Sep-1989
+
+Revision History:
+
+--*/
+
+#include "os2srv.h"
+
+//PSB_API_ROUTINE Os2ServerSbApiDispatch[ SbMaxApiNumber+1 ] = {
+//    Os2SbCreateSession,
+//    Os2SbTerminateSession,
+//    Os2SbForeignSessionComplete,
+//    NULL
+//};
+
+#if DBG
+PSZ Os2ServerSbApiName[ SbMaxApiNumber+1 ] = {
+    "SbCreateSession",
+    "SbTerminateSession",
+    "SbForeignSessionComplete",
+    "Unknown Os2 Sb Api Number"
+};
+#endif // DBG
+
+
+NTSTATUS
+Os2SbApiHandleConnectionRequest(
+    IN PSBAPIMSG Message
+    );
+
+NTSTATUS
+Os2SbApiRequestThread(
+    IN PVOID Parameter
+    )
+{
+    NTSTATUS Status;
+    SBAPIMSG ReceiveMsg;
+    PSBAPIMSG ReplyMsg;
+
+    UNREFERENCED_PARAMETER(Parameter);
+
+    ReplyMsg = NULL;
+    while (TRUE) {
+#if DBG
+        IF_OS2_DEBUG( LPC ) {
+            KdPrint(( "OS2SRV: Sb Api Request Thread waiting...\n" ));
+            }
+#endif
+        Status = NtReplyWaitReceivePort( Os2SbApiPort,
+                                         NULL,
+                                         (PPORT_MESSAGE)ReplyMsg,
+                                         (PPORT_MESSAGE)&ReceiveMsg
+                                       );
+
+        if (Status != 0) {
+            if (NT_SUCCESS( Status )) {
+                continue;       // Try again if alerted or a failure
+                }
+            else {
+#if DBG
+                KdPrint(( "OS2SRV: ReceivePort failed - Status == %X\n", Status ));
+#endif
+                break;
+                }
+            }
+
+        //
+        // Check to see if this is a connection request and handle
+        //
+
+        if (ReceiveMsg.h.u2.s2.Type == LPC_CONNECTION_REQUEST) {
+            Os2SbApiHandleConnectionRequest( &ReceiveMsg );
+            ReplyMsg = NULL;
+            continue;
+            }
+
+        if (ReceiveMsg.ApiNumber >= SbMaxApiNumber) {
+#if DBG
+            KdPrint(( "OS2SRV: %lx is invalid Sb ApiNumber\n",
+                      ReceiveMsg.ApiNumber
+                    ));
+#endif
+
+            ReceiveMsg.ApiNumber = SbMaxApiNumber;
+            }
+
+#if DBG
+        IF_OS2_DEBUG( LPC ) {
+            KdPrint(( "OS2SRV: %s Sb Api Request received from %lx.%lx\n",
+                      Os2ServerSbApiName[ ReceiveMsg.ApiNumber ],
+                      ReceiveMsg.h.ClientId.UniqueProcess,
+                      ReceiveMsg.h.ClientId.UniqueThread
+                    ));
+	    }
+#endif // DBG
+
+        ReplyMsg = &ReceiveMsg;
+        if (ReceiveMsg.ApiNumber < SbMaxApiNumber) {
+//            if (!(*Os2ServerSbApiDispatch[ ReceiveMsg.ApiNumber ])( &ReceiveMsg )) {
+                ReplyMsg = NULL;
+ //               }
+//            }
+//        else {
+//            ReplyMsg->ReturnedStatus = STATUS_NOT_IMPLEMENTED;
+       }
+
+#if DBG
+	IF_OS2_DEBUG( LPC ) {
+            if (ReplyMsg != NULL) {
+                KdPrint(( "OS2SRV: %s Sb Api sending %lx status reply to %lx.%lx\n",
+                          Os2ServerSbApiName[ ReceiveMsg.ApiNumber ],
+                          ReplyMsg->ReturnedStatus,
+                          ReplyMsg->h.ClientId.UniqueProcess,
+                          ReplyMsg->h.ClientId.UniqueThread
+                        ));
+                }
+	    }
+#endif // DBG
+        }
+
+    NtTerminateThread( NtCurrentThread(), Status );
+	//
+	// This line should never be executed
+	//
+    return STATUS_SUCCESS;
+}
+
+
+NTSTATUS
+Os2SbApiHandleConnectionRequest(
+    IN PSBAPIMSG Message
+    )
+{
+    NTSTATUS st;
+    REMOTE_PORT_VIEW ClientView;
+    HANDLE CommunicationPort;
+
+    //
+    // The protocol for a subsystem is to connect to the session manager,
+    // then to listen and accept a connection from the session manager
+    //
+
+    ClientView.Length = sizeof(ClientView);
+    st = NtAcceptConnectPort(
+            &CommunicationPort,
+            NULL,
+            (PPORT_MESSAGE)Message,
+            TRUE,
+            NULL,
+            &ClientView
+            );
+
+    if ( !NT_SUCCESS(st) ) {
+        KdPrint(("OS2SS: Sb Accept Connection failed %lx\n",st));
+        return st;
+    }
+
+    st = NtCompleteConnectPort(CommunicationPort);
+
+    if ( !NT_SUCCESS(st) ) {
+        KdPrint(("OS2SS: Sb Complete Connection failed %lx\n",st));
+    }
+
+    return st;
+}