kernel/src/thread.cpp at master · vstambolic/kernel · GitHub

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
84
85
86
87
88
#include "thread.h"

#include "PCB.h"
#include "timer.h"
#include "utils.h"

/*--------------- ID getters ---------------*/

ID Thread::getId() {
	if (myPCB)
		return myPCB->get_id();
	else
		return -1;
}
ID Thread::getRunningId() {
	return PCB::get_running_id();
}

Thread* Thread::getThreadById(ID id) {
	return PCB::get_thread_by_id(id);
}
/*--------------- Constructor ---------------*/

Thread::Thread (StackSize stackSize, Time timeSlice) {
		myPCB = new PCB(stackSize, timeSlice, this);
}

Thread::~Thread() {
		if (myPCB) {
			waitToComplete();
			delete myPCB;
		}
}

/* Thread operations */

void Thread::start() {
	if (myPCB)
		myPCB->start();
}

void Thread::waitToComplete() {
	if (myPCB)
		myPCB->put_on_hold();
}

void dispatch() {
	DISABLE_INTERRUPTS
		switch_context_code = DEMANDED;
		timer();
	ENABLE_INTERRUPTS
}

/* Signal operations */
void Thread::signal(SignalId signal) {
	if (myPCB)
		myPCB->signal(signal);
}

void Thread::registerHandler(SignalId signal, SignalHandler handler) {
	if (myPCB)
		myPCB->register_handler(signal, handler);
}

void Thread::unregisterAllHandlers(SignalId id) {
	if (myPCB)
		myPCB->unregister_all_handlers(id);
}
void Thread::swap(SignalId id, SignalHandler hand1, SignalHandler hand2) {
	if (myPCB)
		myPCB->swap(id, hand1, hand2);
}
void Thread::blockSignal(SignalId signal) {
	if (myPCB)
		myPCB->block_signal(signal);
}
void Thread::blockSignalGlobally(SignalId signal) {
	PCB::block_signal_globally(signal);
}
void Thread::unblockSignal(SignalId signal) {
	if (myPCB)
		myPCB->unblock_signal(signal);
}
void Thread::unblockSignalGlobally(SignalId signal) {
	PCB::unblock_signal_globally(signal);
}