aboutsummaryrefslogtreecommitdiff
path: root/process/work.cpp
blob: 9747b41689803209aa1c5141dc29f4f48eebc454 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
#include <map>
#include <utility>

#include <stdint.h>
#include <string.h>
#include <stdio.h>

#include "work.h"
#include "../lib.h"
#include "process.h"

using namespace std;


work::work(unsigned long address)
{
	strncpy(handler, kernel_function(address), 31);
	raw_count = 0;
}


static map<unsigned long, class work *> all_work;
static map<unsigned long, uint64_t> running_since;

void work::fire(uint64_t time, uint64_t work_struct)
{
	running_since[work_struct] = time;
}

uint64_t work::done(uint64_t time, uint64_t work_struct)
{
	int64_t delta;

	if (running_since[work_struct] > time)
		return 0;

	delta = time - running_since[work_struct];
	if (delta < 0)
		printf("GOT HERE %llin", delta);
	accumulated_runtime += delta;

	raw_count++;

	return delta;
}



static void add_work(const pair<unsigned long, class work*>& elem)
{
	all_power.push_back(elem.second);
}

void all_work_to_all_power(void)
{
	for_each(all_work.begin(), all_work.end(), add_work);

}


const char * work::description(void)
{
	if (child_runtime > accumulated_runtime)
		child_runtime = 0;

	sprintf(desc, "Work  %24s      time  %5.2fms    wakeups %4.1f  (total: %i)",
			handler,  (accumulated_runtime - child_runtime) / 1000000.0 / measurement_time, 
			wake_ups / measurement_time, raw_count);
	return desc;
}


class work * find_create_work(uint64_t func)
{
	class work * work;
	if (all_work[func])
		return all_work[func];

	work = new class work(func);
	all_work[func] = work;
	return work;
	
}