Commit 1e793a4c authored by Andreas Schmidt's avatar Andreas Schmidt
Browse files

Measure channel duration, which is different from transport duration.

parent 57bb9e64
Loading
Loading
Loading
Loading
+13 −344

File changed.

Preview size limit exceeded, changes collapsed.

+11 −2
Original line number Diff line number Diff line
@@ -68,6 +68,10 @@ stamps:
        Source: sender
        Thread: trans_send
        Type: cycle
    ChannelTransmit:
        Source: sender
        Thread: trans_send
        Type: time
    LinkTransmitEnd:
        Source: sender
        Thread: trans_send
@@ -79,8 +83,8 @@ stamps:

    ChannelReceive:
        Source: receiver
        Thread: trans_send
        Type: none
        Thread: trans_recv
        Type: time
    LinkReceive:
        Source: receiver
        Thread: trans_recv
@@ -164,6 +168,11 @@ durations:
        Stop: PrrtSendPacketEnd
        Source: sender

    Channel:
        Start: ChannelTransmit
        Stop: ChannelReceive
        Source: sender

    ReceiverIPC:
        Start: PrrtReturnPackage
        Stop: PrrtReceivePackage
+2 −2
Original line number Diff line number Diff line
@@ -49,11 +49,11 @@ def evaluate(sender_file, receiver_file, config, kind=0):
    cr = config["cycle_reference"]

    # Determine Channel Duration
    df["Channel_D"] = df[tr["receiver"]["Start"] + "_T"] - df[tr["sender"]["Stop"] + "_T"]
    df["Transport_D"] = df[tr["receiver"]["Start"] + "_T"] - df[tr["sender"]["Stop"] + "_T"]

    # Correlate Receiver Timestamps with Sender Timestamps (subtracting Channel Duration)
    for s in _stamp_name_by_src_and_type(stamps, "receiver", kind=["time"]):
        df[s + "_T"] -= df["Channel_D"]
        df[s + "_T"] -= df["Transport_D"]

    for src in config["threads"]:
        # Generate Processing Duration