/// ----------------------------------------*- mode: C++; -*--
/// @file testqueue.c
/// Testing fastqueue.
/// ----------------------------------------------------------
/// $Id: testqueue.c 2872 2008-02-18 10:58:03Z bless $
/// $HeadURL: https://svn.ipv6.tm.uka.de/nsis/protlib/trunk/fastqueue/testqueue.c $
// ===========================================================
//
// Copyright (C) 2005-2007, all rights reserved by
// - Institute of Telematics, Universitaet Karlsruhe (TH)
//
// More information and contact:
// https://projekte.tm.uka.de/trac/NSIS
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; version 2 of the License
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// ===========================================================

/**
 * @ingroup fastqueue
 * @{
 */

#include <stdlib.h>
#include <stdio.h>
#include <pthread.h> /* Headers for POSIX-Threads */
#include <time.h>    /* needed for getting Timestamps */

#include "fastqueue.h"

#define error_check(status,string) \
        if (status==-1) perror(string);

#define MAXELEMENTS 10000

                         /*** global variables ***/
pthread_t       producer_thread,             /* Thread Objects (sim. to TCB) */
                consumer_thread;

float           queuetime, porttime;


/** both queues must be created before monitor tasks are started **/
queue_t       *consumer_cmdq;     /** queue for consumertask **/
struct timespec ts_start,ts_end;
int status;              /* Hold status from pthread_ calls */

void *producertask(void * argp)
{
  long i;
  fprintf(stderr,"QUEUETEST started. Please wait.\n");
  clock_gettime(CLOCK_REALTIME,&ts_start);
  for (i=1; i<=MAXELEMENTS; i++)
      enqueue_element_signal(consumer_cmdq, (void *) i);

  return NULL;
}

void *consumertask(void * argp)
{
  long j;
  /** test queue **/
  while ((j= (int) dequeue_element_wait(consumer_cmdq))<MAXELEMENTS);

  clock_gettime(CLOCK_REALTIME,&ts_end);
  queuetime= ts_end.tv_sec-ts_start.tv_sec +
             (ts_end.tv_nsec-ts_start.tv_nsec)*1E-9;
  fprintf(stderr,"QUEUETEST stopped (%d elements): %gs\n",MAXELEMENTS,queuetime);
  return NULL;
}

/**** end of source ****/

//@}