AOS_MUTEX/Algo9.h at master · kaushik/AOS_MUTEX · 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
#ifndef ALGO9_H_
#define ALGO9_H_

#include <iostream>
#include <fstream>
#include <vector>
#include "MessageFormat.h"
#include "communication.h"
#include "LexiQueue.h"
#include <pthread.h>

 using namespace std;
class Torum
{
protected:

	long sequenceNo;
	int HOLDER;
	int **quorum;
	int quorumsize;
	int NumNodes;
	bool inCS;
	Packet temppk;
	int tempDest;
	bool releaseflag;
	//vector<vector<int>> quorum;;
	pthread_mutex_t sharedQLock;
	LexiQueue *queue;
	LexiQueue *hqueue;


public:
	int ID;
	communication com;
	int flagforCS;
	char CS_FILENAME[25];

	static Torum* getInstance();
	void init();
	bool setID(int id);
	int getID();
	bool getQuorumTable(int **quorumtable,int qsize,int nnodes);
	bool requestCS();
	bool isMaster(int master,int slave);
	bool receiveRequest(Packet request);
	int receiveToken(Packet request);
	bool receiveRelease(Packet request);
	bool receiveHaveTkn(Packet request);
	bool sendToken();
	void displayStatus();

private:
	Torum(){};
	~Torum(void);
	Torum(Torum const& copy){};
	Torum& operator=(Torum const& copy){};
	static Torum* instance;
	bool EnterTheCS();
	void writeToFile(string filename,string line);
};

#endif;