CACryptoBenchmark Class Reference

#include <CACryptoBenchmark.hpp>

Collaboration diagram for CACryptoBenchmark:

Public Member Functions
	CACryptoBenchmark ()
	~CACryptoBenchmark ()
void	doBenchmark ()

Static Private Member Functions
static THREAD_RETURN	benchmarkThread (void *param)
static THREAD_RETURN	timerThread (void *param)

Static Private Attributes
static const UINT32	ms_NUM_BLOCKSIZES = 5
static const UINT32	ms_BlockSizes [ms_NUM_BLOCKSIZES] = { 16,64,256,512,1024 }

Detailed Description

Definition at line 25 of file CACryptoBenchmark.hpp.

Constructor & Destructor Documentation

CACryptoBenchmark()

CACryptoBenchmark::CACryptoBenchmark

(

)

Definition at line 39 of file CACryptoBenchmark.cpp.

{
}

~CACryptoBenchmark()

CACryptoBenchmark::~CACryptoBenchmark

(

)

Definition at line 44 of file CACryptoBenchmark.cpp.

{
}

Member Function Documentation

benchmarkThread()

THREAD_RETURN CACryptoBenchmark::benchmarkThread ( void *  param )

staticprivate

Definition at line 94 of file CACryptoBenchmark.cpp.

{
  tBenchmarkParams* pParams = (tBenchmarkParams*)a_pParams;
  CASymChannelCipher* pCipher = new CASymCipherCTR();
  UINT8 iv[32];
  UINT8 key[32];
  pCipher->setKeys(key, 32);
  pCipher->setIVs(iv);
  volatile bool bTimer = true;
  CAThread* pTimerThread = new CAThread();
  pTimerThread->setMainLoop(timerThread);
  tBenchmarkTimerParams* pTimerParams = new tBenchmarkTimerParams();
  pTimerParams->timerInMillis = 3000;
  pTimerParams->bTimer = &bTimer;
  UINT32 blocksize = pParams->blocksize;
  UINT8* in = new UINT8[blocksize];
  UINT8* out = new UINT8[blocksize];
  UINT64 numCrypts = 0;
  UINT64 startTime, endTime, time;
  pTimerThread->start(pTimerParams,true,true);
  getcurrentTimeMillis(startTime);
  while (bTimer)
  {
    pCipher->crypt1(in, out, blocksize);
    numCrypts++;
  }
  getcurrentTimeMillis(endTime);
  time =diff64( endTime,startTime);
  pParams->pMutexTotalBytesProcessed->lock();
  *(pParams->outparam_pTotalBytesProcessed) += blocksize * numCrypts;
  pParams->pMutexTotalBytesProcessed->unlock();
  UINT64 bytes = numCrypts * 1000 * blocksize;
  UINT8 tmpbuff[256];
  formatBytesPerSecond(tmpbuff, 256, bytes / time);
 
  CAMsg::printMsg(LOG_DEBUG,"Did %llu crypts in %u ms - blocksize %u - %s\n", numCrypts,(UINT32) time, blocksize, tmpbuff);
  delete pCipher;
  delete pTimerThread;
  delete pTimerParams;
  delete[] in;
  delete[] out;
  THREAD_RETURN_SUCCESS;
 
}

References t_benchmarkParams::blocksize, t_benchmarkTimerParams::bTimer, CASymChannelCipher::crypt1(), diff64(), formatBytesPerSecond(), getcurrentTimeMillis(), CAMutex::lock(), t_benchmarkParams::outparam_pTotalBytesProcessed, t_benchmarkParams::pMutexTotalBytesProcessed, CAMsg::printMsg(), CASymChannelCipher::setIVs(), CASymChannelCipher::setKeys(), CAThread::setMainLoop(), CAThread::start(), THREAD_RETURN_SUCCESS, t_benchmarkTimerParams::timerInMillis, timerThread(), and CAMutex::unlock().

Referenced by doBenchmark().

Here is the call graph for this function:

Here is the caller graph for this function:

doBenchmark()

void CACryptoBenchmark::doBenchmark

(

)

Definition at line 48 of file CACryptoBenchmark.cpp.

{
  CAThreadList* pThreadList=new CAThreadList();
  CAMutex* pMutexTotlaBytes = new CAMutex();
  volatile UINT64 totalBytesProcessed;
  for (UINT32 iBlocksize = 0; iBlocksize < ms_NUM_BLOCKSIZES; iBlocksize++)
  {
    for (UINT32 numThreads = 1; numThreads <= MAX_CRYPTOBENCHMARK_THREADS; numThreads += 4)
    {
      CAMsg::printMsg(LOG_DEBUG, "Do crypto benchmark for %u threads\n", numThreads);
      totalBytesProcessed = 0;
      UINT64 startTime, endTime, time;
      getcurrentTimeMillis(startTime);
      for (UINT32 nThreads = 0; nThreads < numThreads; nThreads++)
      {
        tBenchmarkParams* pParams = new tBenchmarkParams;
        pParams->blocksize = ms_BlockSizes[iBlocksize];
        pParams->pMutexTotalBytesProcessed = pMutexTotlaBytes;
        pParams->outparam_pTotalBytesProcessed = &totalBytesProcessed;
        CAThread* pThread = new CAThread();
        pThread->setMainLoop(benchmarkThread);
        pThread->start(pParams, false, true);
        pThreadList->put(pThread);
      }
      pThreadList->waitAndRemoveAll();
      getcurrentTimeMillis(endTime);
      time = diff64(endTime, startTime);
      UINT8 tmpbuff[256];
      formatBytesPerSecond(tmpbuff, 256, (totalBytesProcessed * 1000) / time);
      CAMsg::printMsg(LOG_DEBUG, "Total crypto speed (blocksize: %u): %llu bytes in %u ms -- %s\n", ms_BlockSizes[iBlocksize],totalBytesProcessed, (UINT32)time,tmpbuff);
 
      numThreads -= (numThreads % 4); // Produce a series like: 1,4,8,12,...
    }
  }
  delete pThreadList;
  delete pMutexTotlaBytes;
}

References benchmarkThread(), t_benchmarkParams::blocksize, diff64(), formatBytesPerSecond(), getcurrentTimeMillis(), MAX_CRYPTOBENCHMARK_THREADS, ms_BlockSizes, ms_NUM_BLOCKSIZES, t_benchmarkParams::outparam_pTotalBytesProcessed, t_benchmarkParams::pMutexTotalBytesProcessed, CAMsg::printMsg(), CAThreadList::put(), CAThread::setMainLoop(), CAThread::start(), and CAThreadList::waitAndRemoveAll().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

timerThread()

THREAD_RETURN CACryptoBenchmark::timerThread ( void *  param )

staticprivate

Definition at line 86 of file CACryptoBenchmark.cpp.

{
  tBenchmarkTimerParams* pTimerParams = (tBenchmarkTimerParams*)a_pParams;
  msSleep(pTimerParams->timerInMillis);
  *(pTimerParams->bTimer) = false;
  THREAD_RETURN_SUCCESS;
}

References t_benchmarkTimerParams::bTimer, msSleep(), THREAD_RETURN_SUCCESS, and t_benchmarkTimerParams::timerInMillis.

Referenced by benchmarkThread().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

ms_BlockSizes

const UINT32 CACryptoBenchmark::ms_BlockSizes = { 16,64,256,512,1024 }

staticprivate

Definition at line 34 of file CACryptoBenchmark.hpp.

Referenced by doBenchmark().

ms_NUM_BLOCKSIZES

const UINT32 CACryptoBenchmark::ms_NUM_BLOCKSIZES = 5

staticprivate

Definition at line 33 of file CACryptoBenchmark.hpp.

Referenced by doBenchmark().

---

The documentation for this class was generated from the following files:

• CACryptoBenchmark.hpp
• CACryptoBenchmark.cpp