CPAL Playground

/* Copyright (C) 2015, RealTime-at-Work, All Rights Reserved
 *
 * You may use, copy, reproduce, and distribute this sample cource code for any non-commercial purpose.
 * Some purposes which can be non-commercial are teaching, academic research,
 * public demonstrations and personal experimentation. You may also distribute this Software
 * with books or other teaching materials, or publish the Software on websites,
 * that are intended to teaching for academic or other non-commercial purposes.
 *
 * In return, we simply require that you agree: 
 * 1. That you will not remove any copyright or other notices from the Software.
 * 2. THAT THE SOFTWARE COMES "AS IS", WITH NO WARRANTIES. THIS MEANS NO EXPRESS, 
 *    IMPLIED OR STATUTORY WARRANTY.
 */

/**
 * A classical publish / subscribe protocol. 
 * @keywords protocol, publish subscribe; identifier of process; loop over
 */
enum Frame_Kind {
  PUBLISH, SUBSCRIBE, ACK, UNSUBSCRIBE
};

struct Frame {
  uint32: destinator;
  Frame_Kind: kind;
  uint32: data;
};

processdef Publisher(
  in uint32: sensor,
  in queue<uint32>: subscribers,
  out channel<Frame>: port)
{
  state Emitting {
    var Frame: frame;
    frame.kind = Frame_Kind.PUBLISH;
    frame.data = sensor;
    loop over subscribers with it {
      frame.destinator = it.current;
      port.push(frame);
    }
  }
}

processdef Subscription_Manager(
  in channel<Frame>: port_in,
  out queue<uint32>: subscribers,
  out channel<Frame>: port_out)
{
  state Init {
  }
  on (true) {
    IO.println("%u is listening for subscription management.", self.pid);
  } to Listening;
  
  state Listening {
    var Frame: frame;
    var Frame: answer;
    while (port_in.not_empty()) {
      frame = port_in.pop();
      if (frame.destinator == self.pid) {
        if (frame.kind == Frame_Kind.SUBSCRIBE) {
          if (subscribers.not_full()) {
            IO.println("%u has subscribed to %u.", frame.data, self.pid);
            subscribers.push(frame.data);
            answer.kind = Frame_Kind.ACK;
            answer.destinator = frame.data;
            answer.data = self.pid;
            port_out.push(answer);
          }
        } else if (frame.kind == Frame_Kind.UNSUBSCRIBE) {
          loop over subscribers with it {
            if (it.current == frame.data) {
              IO.println("removing");
              it.remove_current();
              IO.println("%u has unsubsribed from %u.", frame.data, self.pid);
              subscribers.push(frame.data);
              answer.kind = Frame_Kind.ACK;
              answer.destinator = frame.data;
              answer.data = self.pid;
              port_out.push(answer);
            }
          }
        }
      }
    }
  }
}

var uint32: pin_adc16d_0_1;
var queue<uint32>: ipOfSubscribers[50];
var queue<Frame>: eth0_out[50];
var queue<Frame>: eth0_in[50];

process Subscription_Manager: sub_mnger[500ms](eth0_in, ipOfSubscribers, eth0_out);
process Publisher: publisher1[100ms, 10ms](pin_adc16d_0_1, ipOfSubscribers, eth0_out);

/* == For simulation purpose: == */
processdef Signal_Simulator(out uint32: sensor)
{
  state Main {
    var uint32: x = uint32.cast(time64.time());
    sensor = x - (x * x * x) / 6 + (x * x * x * x * x) / 120 - (x * x * x * x * x * x * x) / 5040;
  } 
}

process Signal_Simulator: simu[100ms](pin_adc16d_0_1);

processdef Client(
  in channel<Frame>: port_in,
  in uint32: service_id,
  out channel<Frame>: port_out)
{
  static var bool: finish = false;
  state Init {
    var Frame: f;
    f.kind = Frame_Kind.SUBSCRIBE;
    f.data = self.pid;
    f.destinator = service_id;
    port_out.push(f);
  }
  on (true) to Main;
  
  state Main {
    var uint32: x;
    while (port_in.not_empty()) {
      /* The following line assumes the client is the only one to use this link. Add a network switch if mandatory.*/
      var Frame: msg = port_in.pop(); 
      if (msg.destinator == self.pid) {
        x = msg.data;
        if (x > 3700000000) {
          finish = true;
        }
      }
    }
  }
  on (finish) {
    var Frame: f;
    f.kind = Frame_Kind.UNSUBSCRIBE;
    f.data = self.pid;
    f.destinator = service_id;
    port_out.push(f);
  } to Finally;
  
  state Finally {
    /* exit(0);*/
  }
}
process Client: client1[500ms](eth0_out, sub_mnger.pid, eth0_in);

for ms or try the desktop editor with advanced diagram views

Simulation
Tasks diagram


Quiet mode disabled
[0.000000000000:ASSIGN] Assign cpal_system new value: Scheduling_Policy.FIFO
[0.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[0.000000000000:STATE] process "Subscription_Manager", instance "sub_mnger", state "Init"
[0.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[0.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.000000000000:STATE] process "Signal_Simulator", instance "simu", state "Main"
[0.000000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 0
[0.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[0.000000000000:STATE] process "Client", instance "client1", state "Init"
[0.000000000000:ASSIGN][0.000000000000] Pushed eth0_in new value: {0,Frame_Kind.SUBSCRIBE,3}
[0.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[0.010000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.010000000000:STATE] process "Publisher", instance "publisher1", state "Emitting"
[0.010000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.100000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.100000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1215752192
[0.100000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.110000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.110000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.200000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.200000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2431504384
[0.200000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.210000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.210000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.300000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.300000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 3647256576
[0.300000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.310000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.310000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.400000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.400000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 568041472
[0.400000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.410000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.410000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[0.500000000000:PRINTLN] 0 is listening for subscription management.
[0.500000000000:STATE] process "Subscription_Manager", instance "sub_mnger", state "Listening"
[0.500000000000:PRINTLN] 3 has subscribed to 0.
[0.500000000000:ASSIGN][0.500000000000] Pushed ipOfSubscribers new value: 3
[0.500000000000:ASSIGN][0.500000000000] Pushed eth0_out new value: {3,Frame_Kind.ACK,0}
[0.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[0.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.500000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1783793664
[0.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[0.500000000000:STATE] process "Client", instance "client1", state "Main"
[0.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[0.510000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.510000000000:ASSIGN][0.510000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1783793664}
[0.510000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.600000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.600000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2999545856
[0.600000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.610000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.610000000000:ASSIGN][0.610000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2999545856}
[0.610000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.700000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.700000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 4215298048
[0.700000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.710000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.710000000000:ASSIGN][0.710000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,4215298048}
[0.710000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.800000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.800000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1136082944
[0.800000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.810000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.810000000000:ASSIGN][0.810000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1136082944}
[0.810000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[0.900000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[0.900000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2351835136
[0.900000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[0.910000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[0.910000000000:ASSIGN][0.910000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2351835136}
[0.910000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[1.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[1.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.000000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 3567587328
[1.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[1.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[1.010000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.010000000000:ASSIGN][1.010000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,3567587328}
[1.010000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.100000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.100000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 488372224
[1.100000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.110000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.110000000000:ASSIGN][1.110000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,488372224}
[1.110000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.200000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.200000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1704124416
[1.200000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.210000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.210000000000:ASSIGN][1.210000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1704124416}
[1.210000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.300000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.300000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2919876608
[1.300000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.310000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.310000000000:ASSIGN][1.310000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2919876608}
[1.310000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.400000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.400000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 4135628800
[1.400000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.410000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.410000000000:ASSIGN][1.410000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,4135628800}
[1.410000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[1.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[1.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.500000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1056413696
[1.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[1.500000000000:ASSIGN][1.500000000000] Pushed eth0_in new value: {0,Frame_Kind.UNSUBSCRIBE,3}
[1.500000000000:STATE] process "Client", instance "client1", state "Finally"
[1.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[1.510000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.510000000000:ASSIGN][1.510000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1056413696}
[1.510000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.600000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.600000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2272165888
[1.600000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.610000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.610000000000:ASSIGN][1.610000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2272165888}
[1.610000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.700000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.700000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 3487918080
[1.700000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.710000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.710000000000:ASSIGN][1.710000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,3487918080}
[1.710000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.800000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.800000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 408702976
[1.800000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.810000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.810000000000:ASSIGN][1.810000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,408702976}
[1.810000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[1.900000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[1.900000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1624455168
[1.900000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[1.910000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[1.910000000000:ASSIGN][1.910000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1624455168}
[1.910000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[2.000000000000:PRINTLN] removing
[2.000000000000:PRINTLN] 3 has unsubsribed from 0.
[2.000000000000:ASSIGN][2.000000000000] Pushed ipOfSubscribers new value: 3
[2.000000000000:ASSIGN][2.000000000000] Pushed eth0_out new value: {3,Frame_Kind.ACK,0}
[2.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[2.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.000000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2840207360
[2.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[2.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[2.010000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.010000000000:ASSIGN][2.010000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2840207360}
[2.010000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.100000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.100000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 4055959552
[2.100000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.110000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.110000000000:ASSIGN][2.110000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,4055959552}
[2.110000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.200000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.200000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 976744448
[2.200000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.210000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.210000000000:ASSIGN][2.210000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,976744448}
[2.210000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.300000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.300000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2192496640
[2.300000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.310000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.310000000000:ASSIGN][2.310000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2192496640}
[2.310000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.400000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.400000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 3408248832
[2.400000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.410000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.410000000000:ASSIGN][2.410000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,3408248832}
[2.410000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[2.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[2.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.500000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 329033728
[2.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.500000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[2.500000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
[2.510000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.510000000000:ASSIGN][2.510000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,329033728}
[2.510000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.600000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.600000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 1544785920
[2.600000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.610000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.610000000000:ASSIGN][2.610000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,1544785920}
[2.610000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.700000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.700000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2760538112
[2.700000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.710000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.710000000000:ASSIGN][2.710000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,2760538112}
[2.710000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.800000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.800000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 3976290304
[2.800000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.810000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.810000000000:ASSIGN][2.810000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,3976290304}
[2.810000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[2.900000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[2.900000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 897075200
[2.900000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[2.910000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'publisher1'
[2.910000000000:ASSIGN][2.910000000000] Pushed eth0_out new value: {3,Frame_Kind.PUBLISH,897075200}
[2.910000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'publisher1'
[3.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'sub_mnger'
[3.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'sub_mnger'
[3.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'simu'
[3.000000000000:ASSIGN] Assign pin_adc16d_0_1 new value: 2112827392
[3.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'simu'
[3.000000000000:publish-subscribe-unsubscribe:STARTING_TASK] 'client1'
[3.000000000000:publish-subscribe-unsubscribe:TASK_FINISHED] 'client1'
EXIT (SUCCESS) AT 3s (3000000000000)

PID	start	end	name	state
0	0	0	sub_mnger	Init
2	0	0	simu	Main
3	0	0	client1	Init
1	10000000000	10000000000	publisher1	Emitting
2	100000000000	100000000000	simu	Main
1	110000000000	110000000000	publisher1	Emitting
2	200000000000	200000000000	simu	Main
1	210000000000	210000000000	publisher1	Emitting
2	300000000000	300000000000	simu	Main
1	310000000000	310000000000	publisher1	Emitting
2	400000000000	400000000000	simu	Main
1	410000000000	410000000000	publisher1	Emitting
0	500000000000	500000000000	sub_mnger	Listening
2	500000000000	500000000000	simu	Main
3	500000000000	500000000000	client1	Main
1	510000000000	510000000000	publisher1	Emitting
2	600000000000	600000000000	simu	Main
1	610000000000	610000000000	publisher1	Emitting
2	700000000000	700000000000	simu	Main
1	710000000000	710000000000	publisher1	Emitting
2	800000000000	800000000000	simu	Main
1	810000000000	810000000000	publisher1	Emitting
2	900000000000	900000000000	simu	Main
1	910000000000	910000000000	publisher1	Emitting
0	1000000000000	1000000000000	sub_mnger	Listening
2	1000000000000	1000000000000	simu	Main
3	1000000000000	1000000000000	client1	Main
1	1010000000000	1010000000000	publisher1	Emitting
2	1100000000000	1100000000000	simu	Main
1	1110000000000	1110000000000	publisher1	Emitting
2	1200000000000	1200000000000	simu	Main
1	1210000000000	1210000000000	publisher1	Emitting
2	1300000000000	1300000000000	simu	Main
1	1310000000000	1310000000000	publisher1	Emitting
2	1400000000000	1400000000000	simu	Main
1	1410000000000	1410000000000	publisher1	Emitting
0	1500000000000	1500000000000	sub_mnger	Listening
2	1500000000000	1500000000000	simu	Main
3	1500000000000	1500000000000	client1	Finally
1	1510000000000	1510000000000	publisher1	Emitting
2	1600000000000	1600000000000	simu	Main
1	1610000000000	1610000000000	publisher1	Emitting
2	1700000000000	1700000000000	simu	Main
1	1710000000000	1710000000000	publisher1	Emitting
2	1800000000000	1800000000000	simu	Main
1	1810000000000	1810000000000	publisher1	Emitting
2	1900000000000	1900000000000	simu	Main
1	1910000000000	1910000000000	publisher1	Emitting
0	2000000000000	2000000000000	sub_mnger	Listening
2	2000000000000	2000000000000	simu	Main
3	2000000000000	2000000000000	client1	Finally
1	2010000000000	2010000000000	publisher1	Emitting
2	2100000000000	2100000000000	simu	Main
1	2110000000000	2110000000000	publisher1	Emitting
2	2200000000000	2200000000000	simu	Main
1	2210000000000	2210000000000	publisher1	Emitting
2	2300000000000	2300000000000	simu	Main
1	2310000000000	2310000000000	publisher1	Emitting
2	2400000000000	2400000000000	simu	Main
1	2410000000000	2410000000000	publisher1	Emitting
0	2500000000000	2500000000000	sub_mnger	Listening
2	2500000000000	2500000000000	simu	Main
3	2500000000000	2500000000000	client1	Finally
1	2510000000000	2510000000000	publisher1	Emitting
2	2600000000000	2600000000000	simu	Main
1	2610000000000	2610000000000	publisher1	Emitting
2	2700000000000	2700000000000	simu	Main
1	2710000000000	2710000000000	publisher1	Emitting
2	2800000000000	2800000000000	simu	Main
1	2810000000000	2810000000000	publisher1	Emitting
2	2900000000000	2900000000000	simu	Main
1	2910000000000	2910000000000	publisher1	Emitting
0	3000000000000	3000000000000	sub_mnger	Listening
2	3000000000000	3000000000000	simu	Main
3	3000000000000	3000000000000	client1	Finally