Classes/Semaphore/Semaphore.cpp

#include "Semaphore.h"

#ifdef linux

Semaphore::Semaphore()
{ 
        needs_attach = 1;
}

Semaphore::Semaphore(char* path, char id, unsigned int permissions)
{
        arg.val = 1;
        needs_attach = 1;
        key_t key;
        key = ftok(path,id);                          //skapar nyckel   
        semid = semget(key , 1 , IPC_CREAT | IPC_EXCL | permissions);
        semctl(semid , 0 , SETVAL , arg);                                       

        if(semid == -1)
        {       
                cout << "Kunde inte skapa semafor" << endl << "Kan bero på att semaforen redan finns" << endl;          
        }
        else
        {       
                cout << "Du har skapat en semafor." << endl;
                needs_attach = 0;
        }
        
}

Semaphore::~Semaphore()
{
        if(semctl(semid , 0 , IPC_RMID , arg) == -1)    
        {
                cout << "Lyckades inte ta död på semaforen" << endl;    
        }
        else    
        {
                cout << "Semaforen är död" << endl;
        }
}

void Semaphore::attach(char* path, char id, unsigned int permissions)
{       
        if(needs_attach)
        {
                key_t key;
                key = ftok(path ,id);   //skapar nyckel 
                semid = semget(key , 1 , permissions); //IPC_CREAT | IPC_EXCL |
                                                
                if(semid == -1) 
                {
                        cout<<"Du har inte blivit kopplad till en semafor"<< endl <<"  "<<endl;         
                }
                else
                {       
                        cout<<"Du har nu kopplat dig till en semafor."<<endl;
                        needs_attach = 0;
                }
        }
}

void Semaphore::signal()        //Måste ligga utanför objektet
{       
        static sembuf sb;
        
        sb.sem_num = 0;
        sb.sem_flg = 0;         //Kan vara: SEM_UNDO eller IPC_NOWAIT , mm
        sb.sem_op = 1;
        
        if(semop(semid , &sb , 1) == -1)
        {
//              perror("Signalfel hos semaforen i signal-funktionen");
                cout << "Signalfel hos semaforen i signal-funktionen" << endl;
                exit(1);
        }
}

void Semaphore::wait()
{       
        static sembuf sb;
        
        sb.sem_num = 0; 
        
        sb.sem_flg = 0; //kan vara SEM_UNDO eller IPC_NOWAIT
        
        sb.sem_op = -1;
        
        
        if(semop(semid , &sb , 1) == -1)        
        {
//              perror("Signalfel hos semaforen i wait-funktionen");
                cout << "Signalfel hos semaforen i wait-funktionen" << endl;
                exit(1);
        }       
}

int Semaphore::semset(int i)
{
        arg.val = i;
        return semctl(semid , 0 , SETVAL , arg);        
}

#endif


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