Source code
Revision control
Copy as Markdown
Other Tools
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* 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
#include "nspr.h"
#include "prpriv.h"
#include "prinrval.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
PRMonitor *mon;
PRInt32 count;
PRInt32 alive;
#define SLEEP_TIME 4 /* secs */
void PR_CALLBACK
Level_2_Thread(void *arg)
{
PR_Sleep(PR_MillisecondsToInterval(4 * 1000));
printf("Level_2_Thread[0x%lx] exiting\n",PR_GetCurrentThread());
return;
}
void PR_CALLBACK
Level_1_Thread(void *arg)
{
PRUint32 tmp = (PRUint32)arg;
PRThreadScope scope = (PRThreadScope) tmp;
PRThread *thr;
thr = PR_CreateThreadGCAble(PR_USER_THREAD,
Level_2_Thread,
NULL,
PR_PRIORITY_HIGH,
scope,
PR_JOINABLE_THREAD,
0);
if (!thr) {
printf("Could not create thread!\n");
} else {
printf("Level_1_Thread[0x%lx] created %15s thread 0x%lx\n",
PR_GetCurrentThread(),
(scope == PR_GLOBAL_THREAD) ?
"PR_GLOBAL_THREAD" : "PR_LOCAL_THREAD",
thr);
PR_JoinThread(thr);
}
PR_EnterMonitor(mon);
alive--;
PR_Notify(mon);
PR_ExitMonitor(mon);
printf("Thread[0x%lx] exiting\n",PR_GetCurrentThread());
}
static PRStatus PR_CALLBACK print_thread(PRThread *thread, int i, void *arg)
{
PRInt32 words;
PRWord *registers;
printf(
"\nprint_thread[0x%lx]: %-20s - i = %ld\n",thread,
(PR_GLOBAL_THREAD == PR_GetThreadScope(thread)) ?
"PR_GLOBAL_THREAD" : "PR_LOCAL_THREAD", i);
registers = PR_GetGCRegisters(thread, 0, (int *)&words);
if (registers)
printf("Registers R0 = 0x%x R1 = 0x%x R2 = 0x%x R3 = 0x%x\n",
registers[0],registers[1],registers[2],registers[3]);
printf("Stack Pointer = 0x%lx\n", PR_GetSP(thread));
return PR_SUCCESS;
}
static void Level_0_Thread(PRThreadScope scope1, PRThreadScope scope2)
{
PRThread *thr;
PRThread *me = PR_GetCurrentThread();
int n;
PRInt32 words;
PRWord *registers;
alive = 0;
mon = PR_NewMonitor();
alive = count;
for (n=0; n<count; n++) {
thr = PR_CreateThreadGCAble(PR_USER_THREAD,
Level_1_Thread,
(void *)scope2,
PR_PRIORITY_NORMAL,
scope1,
PR_UNJOINABLE_THREAD,
0);
if (!thr) {
printf("Could not create thread!\n");
alive--;
}
printf("Level_0_Thread[0x%lx] created %15s thread 0x%lx\n",
PR_GetCurrentThread(),
(scope1 == PR_GLOBAL_THREAD) ?
"PR_GLOBAL_THREAD" : "PR_LOCAL_THREAD",
thr);
PR_Sleep(0);
}
PR_SuspendAll();
PR_EnumerateThreads(print_thread, NULL);
registers = PR_GetGCRegisters(me, 1, (int *)&words);
if (registers)
printf("My Registers: R0 = 0x%x R1 = 0x%x R2 = 0x%x R3 = 0x%x\n",
registers[0],registers[1],registers[2],registers[3]);
printf("My Stack Pointer = 0x%lx\n", PR_GetSP(me));
PR_ResumeAll();
/* Wait for all threads to exit */
PR_EnterMonitor(mon);
while (alive) {
PR_Wait(mon, PR_INTERVAL_NO_TIMEOUT);
}
PR_ExitMonitor(mon);
PR_DestroyMonitor(mon);
}
static void CreateThreadsUU(void)
{
Level_0_Thread(PR_LOCAL_THREAD, PR_LOCAL_THREAD);
}
static void CreateThreadsUK(void)
{
Level_0_Thread(PR_LOCAL_THREAD, PR_GLOBAL_THREAD);
}
static void CreateThreadsKU(void)
{
Level_0_Thread(PR_GLOBAL_THREAD, PR_LOCAL_THREAD);
}
static void CreateThreadsKK(void)
{
Level_0_Thread(PR_GLOBAL_THREAD, PR_GLOBAL_THREAD);
}
int main(int argc, char **argv)
{
PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 0);
PR_STDIO_INIT();
if (argc > 1) {
count = atoi(argv[1]);
} else {
count = 5;
}
printf("\n\n%20s%30s\n\n"," ","Suspend_Resume Test");
CreateThreadsUU();
CreateThreadsUK();
CreateThreadsKU();
CreateThreadsKK();
PR_SetConcurrency(2);
printf("\n%20s%30s\n\n"," ","Added 2nd CPU\n");
CreateThreadsUK();
CreateThreadsKK();
CreateThreadsUU();
CreateThreadsKU();
PR_Cleanup();
return 0;
}