-
Notifications
You must be signed in to change notification settings - Fork 0
/
liftMailbox.cpp
106 lines (88 loc) · 2.13 KB
/
liftMailbox.cpp
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
#include "liftMailbox.h"
#include <sys/ipc.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#define TRAVEL_MESSAGE 1L
typedef struct travelMSG {
long mtype;
MovingDirection direction;
travelMSG(MovingDirection dir) : mtype(TRAVEL_MESSAGE), direction(dir) {};
};
#define GET_ON_MESSAGE 2L
typedef struct getOnMSG {
long mtype;
PersonState personState;
getOnMSG(Person p) : mtype(GET_ON_MESSAGE), personState(p.getState()) {};
};
#define GET_OFF_MESSAGE 3L
typedef struct getOffMSG {
long mtype;
getOffMSG() : mtype(GET_OFF_MESSAGE) {};
};
#define END_WORK_MESSAGE 4L
typedef struct endWorkMSG {
long mtype;
endWorkMSG() : mtype(END_WORK_MESSAGE) {};
};
struct longMessage {
long mtype;
char buff[200];
};
LiftMailbox::LiftMailbox(unsigned int liftId) {
key_t mailboxKey = ftok("./liftSim", liftId + 1);
if( mailboxKey == -1 ) {
perror("liftMailBox queueID:");
exit(1);
}
queueId = msgget(mailboxKey, 0666 | IPC_CREAT);
if( queueId == -1 ) {
perror("liftMailBox queueID:");
exit(1);
}
}
void LiftMailbox::travel(MovingDirection direction) {
travelMSG message(direction);
msgsnd(queueId, &message, sizeof(direction), 0);
}
void LiftMailbox::getOn(Person person) {
getOnMSG message(person);
msgsnd(queueId, &message, sizeof(message.personState), 0);
}
void LiftMailbox::getOff() {
getOffMSG message;
msgsnd(queueId, &message, 0, 0);
}
void LiftMailbox::endWork() {
endWorkMSG message;
msgsnd(queueId, &message, 0, 0);
}
void LiftMailbox::receiveMessage(Lift* lift) {
longMessage undecodedMessage;
msgrcv(queueId, &undecodedMessage, sizeof(undecodedMessage.buff), 0, 0);
switch( undecodedMessage.mtype ) {
case TRAVEL_MESSAGE: {
travelMSG message((const travelMSG&)undecodedMessage);
lift->travel(message.direction);
break;
}
case GET_ON_MESSAGE: {
getOnMSG message((const getOnMSG&)undecodedMessage);
lift->getOn( Person(message.personState) );
break;
}
case GET_OFF_MESSAGE: {
lift->getOff();
break;
}
case END_WORK_MESSAGE: {
lift->end();
break;
}
}
}
void LiftMailbox::close() {
msgctl( this->queueId, IPC_RMID, NULL );
}