Stop time is not handled correctly with decentralized coordination

[edwardalee]

Minimal example:

target C {
    timeout: 5 sec,
    coordination: decentralized
}

reactor Count {
    output out:int;
    state c:int(0);
    timer t(0, 1 sec);
    reaction(t) -> out {=
        lf_set(out, self->c++);
    =}
}
reactor Print {
    input in:int;
    reaction(in) {=
        lf_print("***** Received: %d", in->value);
    =}
}

federated reactor {
    c = new Count();
    p = new Print();
    c.out -> p.in;
}

This gives the following execution:

Federate 1: ***** Received: 0
Federate 1: ***** Received: 1
Federate 1: ***** Received: 2
Federate 1: ***** Received: 3
Federate 1: ***** Received: 4
Federate 1: WARNING: Received message too late. Already at stopping time. Discarding message.
Federate 1 has resigned.

Notice that the input at time 5 is lost. Adding an STP offset does not help. It still gets lost.

[edwardalee]

Oops, sorry, adding an STP offset does in fact fix this problem. I believe the behavior is actually correct!