Source code

Revision control

Copy as Markdown

Other Tools

/* 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/. */
/*
* nssThreads.c
*
* NSS Performance Evaluation application (multi-threaded)
*
*/
#include <stdio.h>
#include <string.h>
#include "secutil.h"
#include "nspr.h"
#include "prtypes.h"
#include "prtime.h"
#include "prlong.h"
#include "pk11func.h"
#include "secasn1.h"
#include "cert.h"
#include "cryptohi.h"
#include "secoid.h"
#include "certdb.h"
#include "nss.h"
typedef struct ThreadDataStr tData;
struct ThreadDataStr {
CERTCertificate* cert;
PRIntervalTime duration;
PRUint32 iterations;
};
static void
ThreadEntry(void* data)
{
tData* tdata = (tData*)data;
PRIntervalTime duration = tdata->duration;
PRTime now = PR_Now();
PRIntervalTime start = PR_IntervalNow();
PR_ASSERT(duration);
if (!duration) {
return;
}
do {
SECStatus rv = CERT_VerifyCertificate(CERT_GetDefaultCertDB(),
tdata->cert,
PR_TRUE,
certificateUsageEmailSigner,
now,
NULL,
NULL,
NULL);
if (rv != SECSuccess) {
(void)fprintf(stderr, "Validation failed.\n");
PORT_Assert(0);
return;
}
tdata->iterations++;
} while ((PR_IntervalNow() - start) < duration);
}
static void
Test(CERTCertificate* cert, PRIntervalTime duration, PRUint32 threads)
{
tData data;
tData** alldata;
PRIntervalTime starttime, endtime, elapsed;
PRUint32 msecs;
float total = 0;
PRThread** pthreads = NULL;
PRUint32 i = 0;
data.duration = duration;
data.cert = cert;
data.iterations = 0;
starttime = PR_IntervalNow();
pthreads = (PRThread**)PR_Malloc(threads * sizeof(PRThread*));
alldata = (tData**)PR_Malloc(threads * sizeof(tData*));
for (i = 0; i < threads; i++) {
alldata[i] = (tData*)PR_Malloc(sizeof(tData));
*alldata[i] = data;
pthreads[i] =
PR_CreateThread(PR_USER_THREAD,
ThreadEntry,
(void*)alldata[i],
PR_PRIORITY_NORMAL,
PR_GLOBAL_THREAD,
PR_JOINABLE_THREAD,
0);
}
for (i = 0; i < threads; i++) {
tData* args = alldata[i];
PR_JoinThread(pthreads[i]);
total += args->iterations;
PR_Free((void*)args);
}
PR_Free((void*)pthreads);
PR_Free((void*)alldata);
endtime = PR_IntervalNow();
endtime = PR_IntervalNow();
elapsed = endtime - starttime;
msecs = PR_IntervalToMilliseconds(elapsed);
total /= msecs;
total *= 1000;
(void)fprintf(stdout, "%f operations per second.\n", total);
}
static void
finish(char* message, int code)
{
(void)printf(message);
exit(code);
}
static void
usage(char* progname)
{
(void)printf("Usage : %s <duration> <threads> <certnickname>\n\n",
progname);
finish("", 0);
}
int
nss_threads(int argc, char** argv)
{
SECStatus rv = SECSuccess;
CERTCertDBHandle* handle = NULL;
CERTCertificate* cert = NULL;
PRIntervalTime duration = PR_SecondsToInterval(1);
PRUint32 threads = 1;
if (argc != 4) {
usage(argv[0]);
}
if (atoi(argv[1]) > 0) {
duration = PR_SecondsToInterval(atoi(argv[1]));
}
if (atoi(argv[2]) > 0) {
threads = atoi(argv[2]);
}
handle = CERT_GetDefaultCertDB();
PR_ASSERT(handle);
cert = CERT_FindCertByNicknameOrEmailAddr(handle, argv[3]);
if (!cert) {
finish("Unable to find certificate.\n", 1);
}
Test(cert, duration, threads);
CERT_DestroyCertificate(cert);
return (0);
}