Operating-Systems-Repository/DataCenter.cpp at master · xaviermartinez2012/Operating-Systems-Repository · 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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
//
//  DataCenter.cpp
//  Operating Systems Projects
//
//  Created by Xavier Martinez on 9/18/16.
//  Copyright © 2016 Xavier Martinez. All rights reserved.
//

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <cstring>
#include <iostream>
#include <stdio.h>
#include <unistd.h>
#include <cstdlib>
using namespace std;

struct mBuf {
    long mtype; // required
    char message[105]; // message container
};

struct client{
    char arr[20][100];
};

struct rBuf {
    long mtype; // required
    char message[101]; // message container
};


int main(){
    // create my msgQ with key value from ftok()
    int qid = msgget(ftok(".",'u'), IPC_EXCL|IPC_CREAT|0600);
    if (qid == -1){
        cout << "Message Queue already created. Please use \"ipcrm -q <qid>\" to remove conflicting queue (to find the qid use \"ipcs -q\")." << endl;
        cout << "Exiting..." << endl;
        exit(1);
    }

    client one;
    client two;
    client three;

    int counter = 0;
    while (counter < 3) {
        mBuf tmp;
        int messageSize = sizeof(tmp)-sizeof(long);
        msgrcv(qid, (struct msgbuf *)&tmp, messageSize, 111, 0);
        cout << "R: " << tmp.message[0] << " C: " << tmp.message[1] << " S.ID: " << tmp.message[2] << tmp.message[3] << endl;
        if (tmp.message[0] == '0') {
            if (tmp.message[1] == '1') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * ((int)(tens - '0'))) + ((int)(ones - '0'));
                for (int i = 4; i < 104; i++) {
                    one.arr[index][i-4] = tmp.message[i];
                }
            }
            else if (tmp.message[1] == '2') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * ((int)(tens - '0'))) + ((int)(ones - '0'));
                for (int i = 4; i < 104; i++) {
                    two.arr[index][i-4] = tmp.message[i];
                }
            }
            else if (tmp.message[1] == '3') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * ((int)(tens - '0'))) + ((int)(ones - '0'));
                for (int i = 4; i < 104; i++) {
                    three.arr[index][i-4] = tmp.message[i];
                }
            }
        }
        else if (tmp.message[0] == '1') {
            if (tmp.message[1] == '1') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * (int)(tens - '0')) + (int)(ones - '0');
                if (index != 20) {
                    rBuf snd;
                    snd.mtype = 101;
                    int sndSize = sizeof(snd)-sizeof(long);
                    char msg[100];
                    for (int i = 0; i < 100; i++) {
                        msg[i] = one.arr[index][i];
                    }
                    strcpy(snd.message, msg);
                    msgsnd(qid, (struct msgbuf *)&snd, sndSize, 0);
                }
                else {
                    counter++;
                }
            }
            else if (tmp.message[1] == '2') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * (int)(tens - '0')) + (int)(ones - '0');
                if (index != 20) {
                    rBuf snd;
                    snd.mtype = 102;
                    int sndSize = sizeof(snd)-sizeof(long);
                    char msg[100];
                    for (int i = 0; i < 100; i++) {
                        msg[i] = two.arr[index][i];
                    }
                    strcpy(snd.message, msg);
                    msgsnd(qid, (struct msgbuf *)&snd, sndSize, 0);
                }
                else {
                    counter++;
                }
            }
            else if (tmp.message[1] == '3') {
                char tens = tmp.message[2];
                char ones = tmp.message[3];
                int index = (10 * (int)(tens - '0')) + (int)(ones - '0');
                if (index != 20) {
                    rBuf snd;
                    snd.mtype = 103;
                    int sndSize = sizeof(snd)-sizeof(long);
                    char msg[100];
                    for (int i = 0; i < 100; i++) {
                        msg[i] = three.arr[index][i];
                    }
                    strcpy(snd.message, msg);
                    msgsnd(qid, (struct msgbuf *)&snd, sndSize, 0);
                }
                else {
                    counter++;
                }
            }
        }
        else {
            cout << "An error has occured. \"R\" field of message header is missing or incorrect" << endl;
            counter = 20;
        }
    }
    msgctl (qid, IPC_RMID, NULL);
    return 0;
}