src/monitor/ZoneReader.cpp

   1 /** Aesalon, a tool to visualize program behaviour in real time.
   2         Copyright (C) 2009-2011, Aesalon development team.
   3
   4         Aesalon is distributed under the terms of the GNU GPLv3. See
   5         the included file LICENSE for more information.
   6
   7         @file src/monitor/ZoneReader.cpp
   8 */
   9
  10 #include "monitor/ZoneReader.h"
  11 #include "shm/PacketHeader.h"
  12 #include "util/MessageSystem.h"
  13 #include "comm/Packet.h"
  14 #include "monitor/Coordinator.h"
  15 #include "monitor/MarshalList.h"
  16
  17 namespace Monitor {
  18
  19 ZoneReader::ZoneReader(SHMReader *shmReader) : m_shmReader(shmReader) {
  20
  21 }
  22
  23 ZoneReader::~ZoneReader() {
  24
  25 }
  26
  27 void ZoneReader::run() {
  28         run(this);
  29 }
  30
  31 void ZoneReader::start() {
  32         pthread_create(&m_threadID, NULL, run, this);
  33 }
  34
  35 void ZoneReader::wait() {
  36         pthread_join(m_threadID, NULL);
  37 }
  38
  39 void *ZoneReader::run(void *voidInstance) {
  40         Message(Debug, "Beginning ZoneReader loop . . .");
  41         ZoneReader *instance = static_cast<ZoneReader *>(voidInstance);
  42         SHMReader *reader = instance->m_shmReader;
  43         SHMReader::ReadBroker broker;
  44
  45         MarshalList *marshalList = Coordinator::instance()->marshalList();
  46         DataOutputController *doc = Coordinator::instance()->dataOutputController();
  47
  48         while(true) {
  49                 reader->waitForPacket();
  50                 int32_t zone = reader->zoneWithData();
  51                 if(zone == -1) break;
  52
  53                 SHM::PacketHeader *packetHeader;
  54                 broker.setupRequest(zone, sizeof(SHM::PacketHeader));
  55                 reader->processRequest(broker);
  56                 packetHeader = static_cast<SHM::PacketHeader *>(broker.data());
  57
  58                 uint8_t *packetData;
  59                 broker.setupRequest(zone, packetHeader->packetSize);
  60                 reader->processRequest(broker);
  61                 packetData = static_cast<uint8_t *>(broker.data());
  62
  63                 Message(Log, "Recieved packet from module " << packetHeader->moduleID << ", size " << packetHeader->packetSize);
  64
  65                 Comm::Packet packet(Comm::PacketHeader(packetHeader->moduleID, reader->zoneProcessID(zone),
  66                         reader->zoneThreadID(zone), packetHeader->packetSize), packetData);
  67
  68                 MarshalWrapper *marshal = marshalList->marshal(packetHeader->moduleID);
  69
  70                 if(marshal == NULL) doc->output(&packet);
  71                 else {
  72                         Comm::Packet *repacket = marshal->interface()->marshal(&packet);
  73                         if(repacket != NULL) doc->output(repacket);
  74                 }
  75         }
  76
  77         Message(Debug, "Ending ZoneReader loop . . .");
  78
  79         return NULL;
  80 }
  81
  82 } // namespace Monitor