Hello Mike!


-- CUT -------- Begin test.cpp -------- CUT --
#include 

#include 
#include 
#include 
#include 
#include 

#define INCL_ERRORS
#define INCL_DOSSEMAPHORES
#define INCL_DOSPROCESS
#define INCL_DOSMEMMGR
#include 

#define INCL_REXXSAA
#include 

#include "Test.h"



ULONG APIENTRY _Export GetPID(
                     PSZ name,
                     LONG argc,
                     RXSTRING argv[],
                     PSZ queuename,
                     PRXSTRING retstr) {

   PTIB ptib;
   PPIB ppib;
   APIRET ulrc = 0;

   ulrc = DosGetInfoBlocks(&ptib, &ppib);

   sprintf(retstr->strptr, "%lu", ppib->pib_ulpid);
   retstr->strlength = strlen(retstr->strptr);
   return 0;
}

ULONG APIENTRY _Export GetTID(
                     PSZ name,
                     LONG argc,
                     RXSTRING argv[],
                     PSZ queuename,
                     PRXSTRING retstr) {

   PTIB ptib;
   PPIB ppib;
   APIRET ulrc = 0;

   ulrc = DosGetInfoBlocks(&ptib, &ppib);

   sprintf(retstr->strptr, "%lu", ptib->tib_ptib2->tib2_ultid);
   retstr->strlength = strlen(retstr->strptr);
   return 0;
}

ULONG APIENTRY _Export TimeOut(
                      PSZ name,
                      LONG argc,
                      RXSTRING argv[],
                      PSZ queuename,
                      PRXSTRING retstr) {

   TID tid = 0;
   TimerData *timerdata = 0;
   APIRET ulrc = 0;

   if (argc == 3) {
      ulrc =
DosAllocMem((PPVOID)&timerdata,sizeof(TimerData),PAG_COMMIT|PAG_READ|PAG_WRITE)
;

      cout << "---" << endl;
      cout << argv[0].strptr << endl;
      cout << argv[1].strptr << endl;
      cout << argv[2].strptr << endl;
      cout << "---" << endl;

      timerdata->processId    = atol(argv[0].strptr);
      timerdata->threadId     = atol(argv[1].strptr);
      timerdata->milliseconds = atol(argv[2].strptr);
      ulrc = DosCreateThread(&tid, RexxTimeoutThread, (ULONG)timerdata, 0, 8192);

      sprintf(retstr->strptr, "%lu", tid);
      retstr->strlength = strlen(retstr->strptr);
   }
   else {
      return 1;
   }

   return 0;
}

ULONG APIENTRY _Export CancelTimeOut(
                            PSZ name,
                            LONG argc,
                            RXSTRING argv[],
                            PSZ queuename,
                            PRXSTRING retstr) {

   APIRET ulrc = 0;
   char eventsem[256] = {0};
   HEV hev = 0;

   if (argc == 2) {

      sprintf(eventsem,"\\SEM32\\REXXTIMEOUT\\%lu\\%lu",
              atol(argv[0].strptr),
              atol(argv[1].strptr));

      ulrc = DosOpenEventSem(eventsem, &hev);

      ulrc = DosPostEventSem(hev);

      ulrc = DosCloseEventSem(hev);

      sprintf(retstr->strptr, "%lu", 0);
      retstr->strlength = strlen(retstr->strptr);
   }
   else {
      return 1;
   }

   return 0;
}

void APIENTRY RexxTimeoutThread(ULONG data) {
   TimerData *timerdata = (TimerData*) data;
   APIRET ulrc = 0;
   char eventsem[256] = {0};
   HEV hev = 0;

   sprintf(eventsem,"\\SEM32\\REXXTIMEOUT\\%lu\\%lu",
           timerdata->processId,
           timerdata->threadId);
   cout << "eventsem = " << eventsem << endl;

   ulrc = DosCreateEventSem(eventsem, &hev, 0, 0);
   if (ulrc) {
      cerr << "DosCreateEventSem() = " << ulrc << endl;
   }
   ulrc = DosWaitEventSem(hev,timerdata->milliseconds);
   if (ulrc == ERROR_TIMEOUT) {
      ulrc = RexxSetHalt(timerdata->processId, timerdata->threadId);
      if (ulrc) {
         cerr << "RexxSetHalt() = " << ulrc << endl;
      }
   }
   else
   if (ulrc) {
      cerr << "DosWaitEventSem() = " << ulrc << endl;
   }

   ulrc = DosCloseEventSem(hev);
   ulrc = DosFreeMem(timerdata);
}

-- CUT --------- End test.cpp --------- CUT --

Doug

--- GoldED/2 2.50+