CAQueue.cpp File Reference

#include "StdAfx.h"
#include "CAQueue.hpp"
#include "CAMsg.hpp"
#include "CAUtil.hpp"
#include "CAThread.hpp"

Include dependency graph for CAQueue.cpp:

Go to the source code of this file.

Classes
struct	__queue_test

Macros
#define	TEST_SIZE   1000000

Functions
THREAD_RETURN	producer (void *param)
THREAD_RETURN	consumer (void *param)

Macro Definition Documentation

TEST_SIZE

#define TEST_SIZE   1000000

Function Documentation

consumer()

THREAD_RETURN consumer

(

void *

param

)

Definition at line 411 of file CAQueue.cpp.

  {
  struct __queue_test* pTest = (struct __queue_test *)param;
  UINT32 aktSize=992;
  UINT8 buff[992];
  UINT8 b = 0;
  UINT32 burst=1;
  do
    {
    aktSize = 992;
    if (pTest->pQueue->getOrWait(buff, &aktSize) != E_SUCCESS)
      THREAD_RETURN_ERROR;
    if (buff[0]!=b)
      THREAD_RETURN_ERROR;
    b++;
    burst--;
    if (burst == 0)
      {
      burst = rand() % 10 + 1;
      msSleep(rand() % 100);
 
      }
    } while (pTest->len>10);
  THREAD_RETURN_SUCCESS;
  }

References __queue_test::buff, E_SUCCESS, CAQueue::getOrWait(), __queue_test::len, msSleep(), __queue_test::pQueue, THREAD_RETURN_ERROR, and THREAD_RETURN_SUCCESS.

Referenced by CAQueue::test().

Here is the call graph for this function:

Here is the caller graph for this function:

producer()

THREAD_RETURN producer

(

void *

param

)

Definition at line 388 of file CAQueue.cpp.

  {
  struct __queue_test* pTest = (struct __queue_test *)param;
  UINT8 buff[992];
  UINT8 b = 0;
  UINT32 burst=1;
  while (pTest->len>10)
    {
    buff[0] = b;
    b++;
    if (pTest->pQueue->add(buff, 992) != E_SUCCESS)
      THREAD_RETURN_ERROR;
    burst--;
    if (burst == 0)
      {
      burst = rand() % 10+1;
        msSleep(rand() % 100);
 
      }
    }
  THREAD_RETURN_SUCCESS;
  }

References CAQueue::add(), __queue_test::buff, E_SUCCESS, __queue_test::len, msSleep(), __queue_test::pQueue, THREAD_RETURN_ERROR, and THREAD_RETURN_SUCCESS.

Referenced by CAQueue::test().

Here is the call graph for this function:

Here is the caller graph for this function: