/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

/***********************************************************************
**
** Name: sem.c
**
** Description: Tests Semaphonre functions.
**
** Modification History:
** 20-May-97 AGarcia- Converted the test to accomodate the debug_mode flag.
**           The debug mode will print all of the printfs associated with this
*test.
**           The regress mode will be the default mode. Since the regress tool
*limits
**           the output to a one line status:PASS or FAIL,all of the printf
*statements
**           have been handled with an if (debug_mode) statement.
** 04-June-97 AGarcia removed the Test_Result function. Regress tool has been
*updated to
**          recognize the return code from tha main program.
***********************************************************************/

/***********************************************************************
** Includes
***********************************************************************/
/* Used to get the command line option */
#include "plgetopt.h"

#include "nspr.h"
#include "prpriv.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

PRIntn failed_already = 0;
PRIntn debug_mode;

/*
    Since we don't have stdin, stdout everywhere, we will fake
    it with our in-memory buffers called stdin and stdout.
*/

#define SBSIZE 1024

#include "obsolete/prsem.h"

static char stdinBuf[SBSIZE];
static char stdoutBuf[SBSIZE];

static PRUintn stdinBufIdx = 0;
static PRUintn stdoutBufIdx = 0;
static PRStatus finalResult = PR_SUCCESS;

static size_t dread(PRUintn device, char* buf, size_t bufSize) {
  PRUintn i;

  /* during first read call, initialize the stdinBuf buffer*/
  if (stdinBufIdx == 0) {
    for (i = 0; i < SBSIZE; i++) {
      stdinBuf[i] = i;
    }
  }

  /* now copy data from stdinBuf to the given buffer upto bufSize */
  for (i = 0; i < bufSize; i++) {
    if (stdinBufIdx == SBSIZE) {
      break;
    }
    buf[i] = stdinBuf[stdinBufIdx++];
  }

  return i;
}

static size_t dwrite(PRUintn device, char* buf, size_t bufSize) {
  PRUintn i, j;

  /* copy data from the given buffer upto bufSize to stdoutBuf */
  for (i = 0; i < bufSize; i++) {
    if (stdoutBufIdx == SBSIZE) {
      break;
    }
    stdoutBuf[stdoutBufIdx++] = buf[i];
  }

  /* during last write call, compare the two buffers */
  if (stdoutBufIdx == SBSIZE)
    for (j = 0; j < SBSIZE; j++)
      if (stdinBuf[j] != stdoutBuf[j]) {
        if (debug_mode) {
          printf("data mismatch for index= %d \n", j);
        }
        finalResult = PR_FAILURE;
      }

  return i;
}

/*------------------ Following is the real test program ---------*/
/*
    Program to copy standard input to standard output.  The program
    uses two threads.  One reads the input and puts the data in a
    double buffer.  The other reads the buffer contents and writes
    it to standard output.
*/

PRSemaphore* emptyBufs; /* number of empty buffers */
PRSemaphore* fullBufs;  /* number of buffers that are full */

#define BSIZE 100

struct {
  char data[BSIZE];
  PRUintn nbytes; /* number of bytes in this buffer */
} buf[2];

static void PR_CALLBACK reader(void* arg) {
  PRUintn i = 0;
  size_t nbytes;

  do {
    (void)PR_WaitSem(emptyBufs);
    nbytes = dread(0, buf[i].data, BSIZE);
    buf[i].nbytes = nbytes;
    PR_PostSem(fullBufs);
    i = (i + 1) % 2;
  } while (nbytes > 0);
}

static void writer(void) {
  PRUintn i = 0;
  size_t nbytes;

  do {
    (void)PR_WaitSem(fullBufs);
    nbytes = buf[i].nbytes;
    if (nbytes > 0) {
      nbytes = dwrite(1, buf[i].data, nbytes);
      PR_PostSem(emptyBufs);
      i = (i + 1) % 2;
    }
  } while (nbytes > 0);
}

int main(int argc, char** argv) {
  PRThread* r;

  PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 0);

  {
    /* The command line argument: -d is used to determine if the test is being
    run in debug mode. The regress tool requires only one line output:PASS or
    FAIL. All of the printfs associated with this test has been handled with a
    if (debug_mode) test. Usage: test_name -d
    */
    PLOptStatus os;
    PLOptState* opt = PL_CreateOptState(argc, argv, "d:");
    while (PL_OPT_EOL != (os = PL_GetNextOpt(opt))) {
      if (PL_OPT_BAD == os) {
        continue;
      }
      switch (opt->option) {
        case 'd': /* debug mode */
          debug_mode = 1;
          break;
        default:
          break;
      }
    }
    PL_DestroyOptState(opt);
  }

  /* main test */

  emptyBufs = PR_NewSem(2); /* two empty buffers */

  fullBufs = PR_NewSem(0); /* zero full buffers */

  /* create the reader thread */

  r = PR_CreateThread(PR_USER_THREAD, reader, 0, PR_PRIORITY_NORMAL,
                      PR_LOCAL_THREAD, PR_UNJOINABLE_THREAD, 0);

  /* Do the writer operation in this thread */
  writer();

  PR_DestroySem(emptyBufs);
  PR_DestroySem(fullBufs);

  if (finalResult == PR_SUCCESS) {
    if (debug_mode) {
      printf("sem Test Passed.\n");
    }
  } else {
    if (debug_mode) {
      printf("sem Test Failed.\n");
    }
    failed_already = 1;
  }
  PR_Cleanup();
  if (failed_already) {
    return 1;
  } else {
    return 0;
  }
}