scalos/main/ChildProcess.c

   1 // ChildProcess.c
   2 // $Date$
   3 // $Revision$
   4
   5
   6 #include <exec/types.h>
   7 #include <utility/hooks.h>
   8 #include <workbench/workbench.h>
   9 #include <workbench/startup.h>
  10 #include <dos/dostags.h>
  11 #include <dos/datetime.h>
  12
  13 #define __USE_SYSBASE
  14
  15 #include <proto/dos.h>
  16 #include <proto/exec.h>
  17 #include <proto/utility.h>
  18 #include "debug.h"
  19 #include <proto/scalos.h>
  20
  21 #include <clib/alib_protos.h>
  22
  23 #include <defs.h>
  24 #include <scalos/scalos.h>
  25
  26 #include <stdlib.h>
  27 #include <stdio.h>
  28 #include <string.h>
  29
  30 #include "scalos_structures.h"
  31 #include "functions.h"
  32 #include "Variables.h"
  33
  34 //----------------------------------------------------------------------------
  35
  36 // local data structures
  37
  38 //----------------------------------------------------------------------------
  39
  40 // local data items
  41
  42 //----------------------------------------------------------------------------
  43
  44 // local functions
  45
  46 static SAVEDS(void) INTERRUPT ProcRunnerTask(void);
  47
  48 //----------------------------------------------------------------------------
  49
  50 // NumLongs : number of longwords in ArgArray (!!not number of entries!!)
  51 BOOL RunProcess(struct ScaWindowTask *wt, RUNPROCFUNC Routine, ULONG NumLongs,
  52         struct WBArg *ArgArray, struct MsgPort *ReplyPort)
  53 {
  54         BOOL Success = FALSE;
  55         struct SM_RunProcess *msg;
  56         ULONG NumBytes;
  57
  58         d1(kprintf("%s/%s/%ld: START  wt=%08lx  Routine=%08lx  NumLongs=%lu  ArgArray=%08lx  ReplyPort=%08lx\n", \
  59                 __FILE__, __FUNC__, __LINE__, wt, Routine, NumLongs, ArgArray, ReplyPort));
  60
  61         if (NumLongs > 77)
  62                 return FALSE;
  63
  64         NumBytes = NumLongs * sizeof(ULONG);
  65
  66         msg = (struct SM_RunProcess *) SCA_AllocMessage(MTYP_RunProcess, NumBytes);
  67         if (msg)
  68                 {
  69                 msg->ScalosMessage.sm_Message.mn_ReplyPort = ReplyPort;
  70                 msg->WindowTask = wt;
  71                 msg->EntryPoint = Routine;
  72
  73                 if (NumBytes > 0)
  74                         CopyMem(ArgArray, &msg->Flags, NumBytes);
  75
  76                 d1(KPrintF("%s/%s/%ld: msg=%08lx  iwt=%08lx  Routine=%08lx\n", __FILE__, __FUNC__, __LINE__, msg, wt, Routine));
  77
  78                 Success = ChildProcessRun((struct internalScaWindowTask *) wt,
  79                         &msg->ScalosMessage,
  80                         NP_Priority, 0,
  81                         NP_Name, (IPTR) "Scalos_SubProcess_Runner",
  82                         TAG_END);
  83                 }
  84
  85         d1(kprintf("%s/%s/%ld: Success=%ld\n", __FILE__, __FUNC__, __LINE__, Success));
  86
  87         return Success;
  88 }
  89
  90 //----------------------------------------------------------------------------
  91
  92 BOOL ChildProcessRun(struct internalScaWindowTask *iwt, struct ScalosMessage *msg, Tag FirstTag, ...)
  93 {
  94         va_list args;
  95         struct TagItem *TagList = NULL;
  96         BOOL Success = FALSE;
  97         struct SM_StartChildProcess *mStart = NULL;
  98         struct MsgPort *StartReplyPort;
  99
 100         d1(KPrintF("%s/%s/%ld: START\n", __FILE__, __FUNC__, __LINE__));
 101
 102         va_start(args, FirstTag);
 103
 104         do      {
 105                 STATIC_PATCHFUNC(ProcRunnerTask)
 106                 struct Process *newProc;
 107                 BPTR WBPath;
 108
 109                 StartReplyPort = CreateMsgPort();
 110                 if (NULL == StartReplyPort)
 111                         break;
 112
 113                 mStart = (struct SM_StartChildProcess *) SCA_AllocMessage(MTYP_StartChildProcess, 0);
 114                 if (NULL == mStart)
 115                         break;
 116
 117                 mStart->ScalosMessage.sm_Message.mn_ReplyPort = StartReplyPort;
 118                 mStart->smscp_WindowTask = &iwt->iwt_WindowTask;
 119
 120                 TagList = ScalosVTagList(FirstTag, args);
 121                 if (NULL == TagList)
 122                         break;
 123
 124                 ScalosObtainSemaphoreShared(&iwt->iwt_ChildProcessSemaphore);
 125
 126                 WBPath = DupWBPathList();
 127                 d1(kprintf("%s/%s/%ld: WBPath=%08lx\n", __FILE__, __FUNC__, __LINE__, WBPath));
 128
 129                 newProc = CreateNewProcTags(NP_WindowPtr, NULL,
 130                         NP_StackSize, CurrentPrefs.pref_DefaultStackSize,
 131                         NP_Cli, TRUE,
 132                         NP_Entry, (IPTR) PATCH_NEWFUNC(ProcRunnerTask),
 133                         WBPath ? NP_Path : TAG_IGNORE, WBPath,
 134                         TAG_MORE, TagList,
 135                         TAG_END);
 136
 137                 d1(kprintf("%s/%s/%ld: newProc=%08lx\n", __FILE__, __FUNC__, __LINE__, newProc));
 138
 139                 if (NULL == newProc)
 140                         {
 141                         ScalosReleaseSemaphore(&iwt->iwt_ChildProcessSemaphore);
 142                         break;
 143                         }
 144
 145                 d1(kprintf("%s/%s/%ld: sending SM_StartChildProcess\n", __FILE__, __FUNC__, __LINE__));
 146
 147                 PutMsg(&newProc->pr_MsgPort, &mStart->ScalosMessage.sm_Message);
 148
 149                 d1(kprintf("%s/%s/%ld: wait for SM_StartChildProcess reply\n", __FILE__, __FUNC__, __LINE__));
 150
 151                 // wait for message reply fro child process
 152                 WaitPort(StartReplyPort);
 153                 mStart = (struct SM_StartChildProcess *) GetMsg(StartReplyPort);
 154
 155                 d1(kprintf("%s/%s/%ld: SM_StartChildProcess reply received - mStart=%08lx\n", __FILE__, __FUNC__, __LINE__, mStart));
 156
 157                 if (NULL == mStart)
 158                         {
 159                         ScalosReleaseSemaphore(&iwt->iwt_ChildProcessSemaphore);
 160                         break;
 161                         }
 162
 163                 // keep semaphore locked until we have received the SM_StartChildProcess
 164                 // and know that the child process has locked the semaphore
 165                 ScalosReleaseSemaphore(&iwt->iwt_ChildProcessSemaphore);
 166
 167                 d1(kprintf("%s/%s/%ld: send SM_RunProcess msg=%08lx\n", __FILE__, __FUNC__, __LINE__, msg));
 168
 169                 PutMsg(&newProc->pr_MsgPort, &msg->sm_Message);
 170                 msg = NULL;
 171
 172                 Success = TRUE;
 173                 d1(kprintf("%s/%s/%ld: Success=%ld\n", __FILE__, __FUNC__, __LINE__, Success));
 174                 } while (0);
 175
 176         if (StartReplyPort)
 177                 DeleteMsgPort(StartReplyPort);
 178         if (mStart)
 179                 SCA_FreeMessage(&mStart->ScalosMessage);
 180         if (TagList)
 181                 FreeTagItems(TagList);
 182         if (msg)
 183                 SCA_FreeMessage(msg);
 184
 185         va_end(args);
 186
 187         d1(kprintf("%s/%s/%ld: END Success=%ld\n", __FILE__, __FUNC__, __LINE__, Success));
 188
 189         return Success;
 190 }
 191
 192 //----------------------------------------------------------------------------
 193
 194 // SubProcess Runner Task
 195 static SAVEDS(void) INTERRUPT ProcRunnerTask(void)
 196 {
 197         struct Process *myProc = (struct Process *) FindTask(NULL);
 198         struct internalScaWindowTask *iwt = NULL;
 199         struct SM_StartChildProcess *mStart;
 200         struct SM_RunProcess *msg;
 201
 202         d1(kprintf("%s/%s/%ld: START\n", __FILE__, __FUNC__, __LINE__));
 203
 204         // Scalos MUST not quit while subprocess is running
 205         ScalosObtainSemaphoreShared(&QuitSemaphore);
 206
 207         d1(kprintf("%s/%s/%ld: wait for MTYP_StartChildProcess\n", __FILE__, __FUNC__, __LINE__));
 208
 209         // First, wait for MTYP_StartChildProcess message and reply it
 210         do      {
 211                 WaitPort(&myProc->pr_MsgPort);
 212                 mStart = (struct SM_StartChildProcess *) GetMsg(&myProc->pr_MsgPort);
 213
 214                 d1(kprintf("%s/%s/%ld: mStart=%08lx\n", __FILE__, __FUNC__, __LINE__, mStart));
 215                 if (mStart)
 216                         {
 217                         iwt = (struct internalScaWindowTask *) mStart->smscp_WindowTask;
 218
 219                         d1(kprintf("%s/%s/%ld: MTYP_StartChildProcess received - iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, iwt));
 220
 221                         if (iwt)
 222                                 {
 223                                 ScalosObtainSemaphoreShared(&iwt->iwt_ChildProcessSemaphore);
 224                                 }
 225
 226                         ReplyMsg(&mStart->ScalosMessage.sm_Message);
 227                         }
 228                 } while (NULL == mStart);
 229
 230         d1(kprintf("%s/%s/%ld: wait for SM_RunProcess - iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, iwt));
 231
 232         do      {
 233                 WaitPort(&myProc->pr_MsgPort);
 234                 msg = (struct SM_RunProcess *) GetMsg(&myProc->pr_MsgPort);
 235                 } while (NULL == msg);
 236
 237         d1(KPrintF("%s/%s/%ld: SM_RunProcess received - msg=%08lx  ReplyPort=%08lx  Len=%lu\n", \
 238                 __FILE__, __FUNC__, __LINE__, msg, msg->ScalosMessage.sm_Message.mn_ReplyPort, \
 239                 msg->ScalosMessage.sm_Message.mn_Length));
 240
 241         if (ID_IMSG == msg->ScalosMessage.sm_Signature)
 242                 {
 243                 struct SM_AsyncBackFill *smab;
 244
 245                 switch (msg->ScalosMessage.sm_MessageType)
 246                         {
 247                 case MTYP_RunProcess:
 248                         d1(kprintf("%s/%s/%ld: MTYP_RunProcess msg=%08lx  iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, msg, iwt));
 249
 250                         (msg->EntryPoint)(&msg->Flags, msg);
 251                         break;
 252
 253                 case MTYP_AsyncBackFill:
 254                         smab = (struct SM_AsyncBackFill *) msg;
 255
 256                         d1(KPrintF("%s/%s/%ld: MTYP_AsyncBackFill msg=%08lx  ReplyPort=%08lx  iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, smab, msg->ScalosMessage.sm_Message.mn_ReplyPort, iwt));
 257                         d1(KPrintF("%s/%s/%ld: smab_BackfillFunc=%08lx\n", __FILE__, __FUNC__, __LINE__, smab->smab_BackfillFunc));
 258
 259                         (smab->smab_BackfillFunc)(NULL, msg);
 260                         break;
 261
 262                 default:
 263                         d1(kprintf("%s/%s/%ld: unkown sm_MessageType=%ld  msg=%08lx  iwt=%08lx\n", \
 264                                 __FILE__, __FUNC__, __LINE__, msg->ScalosMessage.sm_MessageType, msg, iwt));
 265                         break;
 266                         }
 267
 268                 d1(KPrintF("%s/%s/%ld: msg=%08lx  ReplyPort=%08lx  MsgType=%08lx\n", \
 269                         __FILE__, __FUNC__, __LINE__, msg, msg->ScalosMessage.sm_Message.mn_ReplyPort, msg->ScalosMessage.sm_MessageType));
 270                 }
 271
 272         d1(KPrintF("%s/%s/%ld: msg=%08lx  ReplyPort=%08lx\n", __FILE__, __FUNC__, __LINE__, msg, msg->ScalosMessage.sm_Message.mn_ReplyPort));
 273
 274         if (msg->ScalosMessage.sm_Message.mn_ReplyPort)
 275                 {
 276                 d1(Forbid(); KPrintF("%s/%s/%ld: MsgList Head=%08lx  TailPred=%08lx\n", \
 277                         __FILE__, __FUNC__, __LINE__, msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_Head, \
 278                         msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_TailPred); Permit());
 279
 280                 ReplyMsg(&msg->ScalosMessage.sm_Message);
 281
 282                 d1(Forbid(); KPrintF("%s/%s/%ld: MsgList Head=%08lx  Succ=%08lx  TailPred=%08lx  Pred=%08lx\n", \
 283                         __FILE__, __FUNC__, __LINE__, \
 284                         msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_Head, \
 285                         msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_Head->ln_Succ, \
 286                         msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_TailPred, \
 287                         msg->ScalosMessage.sm_Message.mn_ReplyPort->mp_MsgList.lh_TailPred->ln_Pred); Permit());
 288                 }
 289         else
 290                 SCA_FreeMessage(&msg->ScalosMessage);
 291
 292         if (iwt)
 293                 {
 294                 d1(kprintf("%s/%s/%ld: iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, iwt));
 295                 ScalosReleaseSemaphore(&iwt->iwt_ChildProcessSemaphore);
 296                 }
 297
 298         d1(kprintf("%s/%s/%ld: iwt=%08lx\n", __FILE__, __FUNC__, __LINE__, iwt));
 299
 300         ScalosReleaseSemaphore(&QuitSemaphore);
 301
 302         d1(kprintf("%s/%s/%ld: END\n", __FILE__, __FUNC__, __LINE__));
 303 }
 304
 305 //----------------------------------------------------------------------------
 306
 307