---

testsem.cc

Go to the documentation of this file.

#ifdef VXWORKS
extern "C"
{
#include <vxWorks.h>
#include <stdio.h>              /* feof(), stdin, fputs(), etc. */
#include <errno.h>              /* errno */
#include <taskLib.h>            /* taskSpawn */
}
#else
extern "C"
{
#include <stdio.h>              /* feof(), stdin, fputs(), etc. */
#include <errno.h>              /* perror() */
}
#endif
#include "semaphore.hh"
#include "timer.hh"             /* esleep() */

#ifdef VXWORKS
static int semtaker_done = 0;
static void
semtaker ()
{
  RCS_SEMAPHORE sem (0x100, RCS_SEMAPHORE_NOCREATE);

  semtaker_done = 0;
  while (!semtaker_done)
    {
      sem.wait ();
      printf ("semtaker got semaphore\n");
      esleep (2.0);             /* wait 2 seconds */
      sem.post ();
      printf ("semtaker gave semaphore\n");
      esleep (2.0);
    }

  printf ("semtaker quit\n");
}
#endif

#ifdef VXWORKS
extern "C" int testsem ();      /* make it easily shell-accessible */
int
testsem ()                      /* run this in the foreground */
#else
int
main (int argc, char **argv)
#endif
{
  RCS_SEMAPHORE *sem;

#if defined (VXWORKS)
  sem = new RCS_SEMAPHORE (0x100, RCS_SEMAPHORE_CREATE, 0664, 0);
  taskSpawn ("semtaker", 100, VX_FP_TASK, 8000, (FUNCPTR) semtaker);
#else
  if (argc > 1)
    {
      /* any cmd line args mean this is the semaphore creator */
      sem = new RCS_SEMAPHORE (0x100, RCS_SEMAPHORE_CREATE, 0664, 0);
    }
  else
    {
      sem = new RCS_SEMAPHORE (0x100, RCS_SEMAPHORE_NOCREATE);
    }
#endif

  /* run give and take, interactively */
  while (!feof (stdin))
    {
#define BUFFERSIZE 80
      char buf[BUFFERSIZE];
      fputs ("give, take, or quit (g/t/q)? ", stdout);
      fgets (buf, BUFFERSIZE, stdin);

      if (buf[0] == 'q')
        break;
      if (buf[0] == 'g')
        {
          /* give it */
          if (sem->post () == -1)
            {
              fputs ("can't give it\n", stdout);
            }
          else
            {
              fputs ("gave it\n", stdout);
              printf ("val = %d\n", sem->getvalue ());
            }
        }
      if (buf[0] == 't')
        {
          /* take it */
          if (sem->wait () == -1)
            {
              fputs ("can't give it\n", stdout);
            }
          else
            {
              fputs ("took it\n", stdout);
              printf ("val = %d\n", sem->getvalue ());
            }
        }
    }

#if defined (VXWORKS)
  semtaker_done = 1;
#endif

  delete sem;
}

---