diff options
Diffstat (limited to 'nss/cmd/libpkix/perf/nss_threads.c')
| -rw-r--r-- | nss/cmd/libpkix/perf/nss_threads.c | 222 |
1 files changed, 108 insertions, 114 deletions
diff --git a/nss/cmd/libpkix/perf/nss_threads.c b/nss/cmd/libpkix/perf/nss_threads.c index eadf5f0..202f128 100644 --- a/nss/cmd/libpkix/perf/nss_threads.c +++ b/nss/cmd/libpkix/perf/nss_threads.c @@ -34,131 +34,125 @@ struct ThreadDataStr { PRUint32 iterations; }; -static void ThreadEntry(void* data) +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); + 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) +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); + 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) +static void +finish(char* message, int code) { - (void) printf(message); - exit(code); + (void)printf(message); + exit(code); } -static void usage(char* progname) +static void +usage(char* progname) { - (void) printf("Usage : %s <duration> <threads> <certnickname>\n\n", - progname); - finish("", 0); + (void)printf("Usage : %s <duration> <threads> <certnickname>\n\n", + progname); + finish("", 0); } -int nss_threads(int argc, char** argv) +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); + 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); } |