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

*** empty log message *** 

svn path=/trunk/boinc_samples/; revision=10940
This commit is contained in:
David Anderson 2006-08-17 21:25:14 +00:00
parent 03a5da7e14
commit 8b7fc880bc
2 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
checkin_notes
View File

@ -152,3 +152,9 @@ David 12 Aug 2006
*.vcproj
wrapper/
wrapper.C
David 16 Aug 2006
- wrapper: get it to compile on Win
wrapper/
wrapper.C

18
wrapper/wrapper.C
View File

@ -70,6 +70,7 @@ struct TASK {
void kill();
void stop();
void resume();
double cpu_time();
};
vector<TASK> tasks;
@ -77,7 +78,7 @@ vector<TASK> tasks;
bool app_suspended = false;
int TASK::parse(FILE* f) {
char tag[256], contents[1024], buf[256];
char tag[256], contents[1024];
while(get_tag(f, tag, contents)) {
if (!strcmp(tag, "/task")) {
return 0;
@ -157,8 +158,8 @@ int TASK::run() {
// pass std handles to app
//
startup_info.dwFlags = STARTF_USESTDHANDLES;
startup_info.hStdIn = GetStdHandle(STD_IN_HANDLE);
startup_info.hStdOut = GetStdHandle(STD_OUT_HANDLE);
startup_info.hStdInput = GetStdHandle(STD_INPUT_HANDLE);
startup_info.hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE);
startup_info.hStdError = GetStdHandle(STD_ERROR_HANDLE);
if (!CreateProcess(application.c_str(),
@ -267,7 +268,7 @@ void poll_boinc_messages(TASK& task) {
}
}
double cpu_time() {
double TASK::cpu_time() {
#ifdef _WIN32
FILETIME creation_time, exit_time, kernel_time, user_time;
ULARGE_INTEGER tKernel, tUser;
@ -286,6 +287,9 @@ double cpu_time() {
double cpu = totTime / 1.e7;
return cpu;
#else
// Unix variant: return elapsed wall time
// TODO: get CPU time from /proc
//
static double t=0, cpu;
if (t) {
double now = dtime();
@ -298,8 +302,8 @@ double cpu_time() {
#endif
}
void send_status_message() {
boinc_report_app_status(cpu_time(), 0, 0);
void send_status_message(TASK& task) {
boinc_report_app_status(task.cpu_time(), 0, 0);
}
int main(int argc, char** argv) {
@ -345,7 +349,7 @@ int main(int argc, char** argv) {
boinc_finish(status);
}
poll_boinc_messages(task);
send_status_message();
send_status_message(task);
boinc_sleep(1.);
}
}