Rooba
/
boinc
mirror of https://github.com/BOINC/boinc.git
1
0
Fork 0
Code Issues 1 Packages Projects Releases Wiki Activity

stress test to my own test app 

git-svn-id: svn+ssh://cvs.lpds.sztaki.hu/var/lib/svn/szdg/dcapi/trunk@1003 a7169a2c-3604-0410-bc95-c702d8d87f7a
This commit is contained in:
drotos 2007-01-16 12:51:55 +00:00 committed by Adam Visegradi
parent 49c37a4f42
commit 2f72882a82
1 changed files with 42 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
dcapi/condor/tm.c
View File

@ -15,7 +15,9 @@
#include "tc.h"
DC_Workunit *wu[10];
#define MAX_WU 100
DC_Workunit *wut[MAX_WU];
extern char *_DC_state_name(DC_WUState state);
@ -51,7 +53,7 @@ create_long(int how_long)
NULL
};
char l[100];
printf("Creating long...\n");
if (how_long > 0)
{
@ -59,7 +61,7 @@ create_long(int how_long)
argv[0]= l;
}
wu= DC_createWU("long", (const char **)argv, 0, NULL);
printf("Created short wu: %p\n", wu);
printf("Created long wu: %p\n", wu);
if (!wu)
fail("DC_createWU", 0);
return(wu);
@ -273,6 +275,43 @@ t(int what)
DC_destroyWU(wu);
break;
}
case 6:
{
int i, nr= 40;
int done= 0;
DC_setMasterCb(result_cb, subresult_cb, message_cb);
printf("Creating and submitting wus...\n");
for (i= 0; i < nr; i++)
{
wut[i]= create_long(10);
DC_submitWU(wut[i]);
}
while (!done)
{
done= 1;
for (i= 0; i < nr; i++)
{
printf("waiting to finish %d...\n", i);
if (wut[i] &&
DC_getWUState(wut[i]) != DC_WU_FINISHED &&
DC_getWUState(wut[i]) != DC_WU_UNKNOWN)
{
done= 0;
process(wut[i], 1);
}
}
}
printf("All WUs finished, processing event for a while...\n");
DC_processMasterEvents(10);
printf("Destroying all WUs...\n");
for (i= 0; i < nr; i++)
{
printf("%2d\n", i);
DC_destroyWU(wut[i]);
wut[i]= NULL;
}
break;
}
}
}