OperatingSystemsFileSystem/Monitor.h at master · jovan-djukic/OperatingSystemsFileSystem · 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
#ifndef _MONITOR_H_
#define _MONITOR_H_

#include <Windows.h>

class ReadersWritersMonitor {
public:
	ReadersWritersMonitor();
	virtual void startRead();
	virtual void endRead();
	virtual void startWrite();
	virtual void endWrite();
	virtual ~ReadersWritersMonitor() = 0;
protected:
	virtual bool readerEntryWaitCondition() = 0;
	virtual bool readerExitWakeConditon() = 0;
	virtual bool writerEntryWaitCondition() = 0;
	virtual bool writerExitWakeCondition() = 0;

	bool isBusy;
	int numOfReaders, numOfReadersWaiting, numOfWritersWaiting;
	CONDITION_VARIABLE readersCondition, writersCondition;
	CRITICAL_SECTION monitorCriticalSection;
};

class WriterPreferance : public ReadersWritersMonitor {
public:
	WriterPreferance();
private:
	bool readerEntryWaitCondition() override;
	bool readerExitWakeConditon() override;
	bool writerEntryWaitCondition() override;
	bool writerExitWakeCondition() override;
};

class ReaderPreferance : public ReadersWritersMonitor {
public:
	ReaderPreferance();
private:
	bool readerEntryWaitCondition() override;
	bool readerExitWakeConditon() override;
	bool writerEntryWaitCondition() override;
	bool writerExitWakeCondition() override;
};

class UpgradeMonitor : public ReadersWritersMonitor {
public:
	UpgradeMonitor();
private:
	bool readerEntryWaitCondition() override;
	bool readerExitWakeConditon() override;
	bool writerEntryWaitCondition() override;
	bool writerExitWakeCondition() override;
};

class ModuleMonitor {
public:
	ModuleMonitor(int);
	void startRead();
	void endRead();
	void startWrite();
	void endWrite();
	void putBlock();
	~ModuleMonitor();
private:
	CRITICAL_SECTION monitorCriticalSection, moduleCriticalSection;
	CONDITION_VARIABLE condition;
	int lineSize, numOfBlocksRead, numOfBlocksToBeWriten;
	bool requestPut, requestPending;
};

class Flag {
public:
	Flag();
	~Flag();
	bool flagValue();
	void setFlag(bool);
private:
	CRITICAL_SECTION criticalSection;
	bool flag;
};

#endif