NED File src/inet/protocolelement/redundancy/StreamMerger.ned

Name	Type	Description
StreamMerger	simple module	This module merges the packets of the same stream by removing duplicates. In addition it also replaces the stream name on the packet based on the mapping parameter. For merging it maintains a separate finite buffer per stream with the last seen sequence numbers.

Source code

//
// Copyright (C) 2020 OpenSim Ltd.
//
// SPDX-License-Identifier: LGPL-3.0-or-later
//


package inet.protocolelement.redundancy;

import inet.queueing.base.PacketFilterBase;
import inet.queueing.contract.IPacketFilter;

//
// This module merges the packets of the same stream by removing duplicates. In
// addition it also replaces the stream name on the packet based on the mapping
// parameter. For merging it maintains a separate finite buffer per stream with
// the last seen sequence numbers.
//
simple StreamMerger extends PacketFilterBase like IPacketFilter
{
    parameters:
        object mapping @mutable = default({}); // map of input streams to output streams, empty string means no stream, for example {s0: "s1", ...}
        int bufferSize = default(10); // window size for sequence numbers per stream
        @class(StreamMerger);
        @display("i=block/join");
}