Transit/truck.cpp at main · walterhackin/Transit · 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
#include "truck.hpp"

#include <string>

TruckNS::Truck::Truck(bool init_location, int number, int weight, int speed,
                      int lenght) {
  speed_ = speed;
  weight_ = weight;
  init_location_ = init_location;
  index_ = number;
  lenght_ = lenght;

  quantity = Semaphore(2, ftok(kPCFile, 7));
  quantity.Operation(0, 1, false);
  end = Semaphore(1, ftok(kPCFile, 6));
  main = Semaphore(1, ftok(kPCFile, 3));
  factory = Semaphore(1, ftok(kPCFile, 4));
  zero_controller = MessageQueue(ftok(kPCFile, 1));
  one_controller = MessageQueue(ftok(kPCFile, 2));
  std::vector<char> filename(100);
  sprintf(filename.data(), "Logging/LogTruck%d.txt", index_);
  file.openf(filename.data());
  std::vector<char> log(1000);
  sprintf(log.data(),
          "Был создан самосвал с такими параметрами: Скорость – %d; номер "
          "самосвала - %d вес самосвала – %d направление – %d\n",
          speed, number, weight, init_location);
  file.writef(log.data(), std::strlen(log.data()));
}

void TruckNS::Truck::StartProcess() {
  while (1) {
    if (end.IsZero(0, false)) {
      EndProcess();
    } else {
      try {
        init_location_ ? one_controller.Send({index_, weight_}, 1)
                       : zero_controller.Send(
                             {
                                 index_,
                                 weight_,
                             },
                             1);
        std::vector<char> log(1000);
        sprintf(log.data(),
                "Самосвал номер %d подъехал к регулировщику номер %d\n", index_,
                init_location_);
        file.writef(log.data(), std::strlen(log.data()));
      } catch (int) {
        EndProcess();
        exit(404);
      }
      try {
        init_location_ ? one_controller.Receive(index_ + 2, true)
                       : zero_controller.Receive(index_ + 2, true);
        std::vector<char> log(1000);
        sprintf(log.data(),
                "Самосвал номер %d получил разрешение на проед от регулировщика номер %d\n",
                index_, init_location_);
        file.writef(log.data(), std::strlen(log.data()));
      } catch (int error) {
        if (error == EINTR) {
          EndProcess();
          return;
        } else {
          EndProcess();
          exit(404);
        }
      }
      try {
        init_location_ ? factory.Operation(0, -1, false)
                       : main.Operation(0, -1, false);
        std::vector<char> log(1000);
        sprintf(log.data(),
                "Самосвал номер %d проехал мост и передал об этом сообщение регулировщику номер %d\n",
                index_, init_location_);
        file.writef(log.data(), std::strlen(log.data()));
      } catch (int) {
        exit(404);
      }
      init_location_ = !init_location_;
    }
  }
}

void TruckNS::Truck::EndProcess() {
  file.closef();
  quantity.Operation(0, -1, false);
  if (quantity.IsZero(0, false)) {
    quantity.DeleteSem();
    end.DeleteSem();
  }
  exit(0);
}