1 |
#include "Semaphore.h" |
2 |
|
3 |
#ifdef linux
|
4 |
|
5 |
Semaphore::Semaphore()
|
6 |
{
|
7 |
needs_attach = 1;
|
8 |
}
|
9 |
|
10 |
Semaphore::Semaphore(char* path, char id, unsigned int permissions) |
11 |
{ |
12 |
arg.val = 1; |
13 |
needs_attach = 1; |
14 |
key_t key; |
15 |
key = ftok(path,id); //skapar nyckel |
16 |
semid = semget(key , 1 , IPC_CREAT | IPC_EXCL | permissions); |
17 |
semctl(semid , 0 , SETVAL , arg); |
18 |
|
19 |
if(semid == -1)
|
20 |
{ |
21 |
cout << "Kunde inte skapa semafor" << endl << "Kan bero på att semaforen redan finns" << endl; |
22 |
}
|
23 |
else |
24 |
{ |
25 |
cout << "Du har skapat en semafor." << endl; |
26 |
needs_attach = 0; |
27 |
} |
28 |
|
29 |
} |
30 |
|
31 |
Semaphore::~Semaphore()
|
32 |
{
|
33 |
if(semctl(semid , 0 , IPC_RMID , arg) == -1)
|
34 |
{
|
35 |
cout << "Lyckades inte ta död på semaforen" << endl;
|
36 |
}
|
37 |
else
|
38 |
{
|
39 |
cout << "Semaforen är död" << endl;
|
40 |
}
|
41 |
}
|
42 |
|
43 |
void Semaphore::attach(char* path, char id, unsigned int permissions) |
44 |
{ |
45 |
if(needs_attach) |
46 |
{ |
47 |
key_t key; |
48 |
key = ftok(path ,id); //skapar nyckel |
49 |
semid = semget(key , 1 , permissions); //IPC_CREAT | IPC_EXCL | |
50 |
|
51 |
if(semid == -1) |
52 |
{
|
53 |
cout<<"Du har inte blivit kopplad till en semafor"<< endl <<" "<<endl; |
54 |
}
|
55 |
else |
56 |
{ |
57 |
cout<<"Du har nu kopplat dig till en semafor."<<endl; |
58 |
needs_attach = 0; |
59 |
} |
60 |
} |
61 |
} |
62 |
|
63 |
void Semaphore::signal() //Måste ligga utanför objektet |
64 |
{ |
65 |
static sembuf sb; |
66 |
|
67 |
sb.sem_num = 0; |
68 |
sb.sem_flg = 0; //Kan vara: SEM_UNDO eller IPC_NOWAIT , mm |
69 |
sb.sem_op = 1; |
70 |
|
71 |
if(semop(semid , &sb , 1) == -1) |
72 |
{ |
73 |
// perror("Signalfel hos semaforen i signal-funktionen"); |
74 |
cout << "Signalfel hos semaforen i signal-funktionen" << endl;
|
75 |
exit(1); |
76 |
} |
77 |
} |
78 |
|
79 |
void Semaphore::wait() |
80 |
{ |
81 |
static sembuf sb; |
82 |
|
83 |
sb.sem_num = 0; |
84 |
|
85 |
sb.sem_flg = 0; //kan vara SEM_UNDO eller IPC_NOWAIT |
86 |
|
87 |
sb.sem_op = -1; |
88 |
|
89 |
|
90 |
if(semop(semid , &sb , 1) == -1) |
91 |
{ |
92 |
// perror("Signalfel hos semaforen i wait-funktionen"); |
93 |
cout << "Signalfel hos semaforen i wait-funktionen" << endl;
|
94 |
exit(1); |
95 |
} |
96 |
} |
97 |
|
98 |
int Semaphore::semset(int i) |
99 |
{ |
100 |
arg.val = i; |
101 |
return semctl(semid , 0 , SETVAL , arg); |
102 |
} |
103 |
|
104 |
#endif |
105 |
|
106 |
|
107 |
|
108 |
|
109 |
|
110 |
|
111 |
|
112 |
|
113 |
|
114 |
|
115 |
|
116 |
|
117 |
|
118 |
|
119 |
|
120 |
|
121 |
|