ResponseProducer

Package: inet.queueing.source

ResponseProducer

compound module

This module is capable of generating several different streams of packets, one after the other. For each traffic category, the packets are produced by a separate token based server. The traffic stream can be started by adding tokens the corresponding server module. The packet data, packet length, and timing distributions can be configured in the corresponding packet provider.

See also: RequestConsumer

PassivePacketSource TokenBasedServer PacketMultiplexer SignalBasedTokenGenerator

Usage diagram

The following diagram shows usage relationships between types. Unresolved types are missing from the diagram.

Inheritance diagram

The following diagram shows inheritance relationships for this type. Unresolved types are missing from the diagram.

Parameters

Name Type Default value Description
numKind int
requestConsumerModule string "^.sink"

Properties

Name Value Description
display i=block/source

Gates

Name Direction Size Description
out output

Unassigned submodule parameters

Name Type Default value Description
provider.displayStringTextFormat string "created %p pk (%l)"

determines the text that is written on top of the submodule

provider.packetNameFormat string "%n-%c"

%n module name, %c packet number, %l packet length, %d packet data, %t simulation time, %e event number

provider.packetRepresentation string "byteCount"

determines the chunk of the packet data

provider.packetLength int
provider.packetData int -1
provider.providingInterval double 0s

elapsed time between subsequent packets allowed to be popped by the connected packet collector, 0 means any number of packets can be popped at the same simulation time

server.displayStringTextFormat string "contains %n tk\nserved %p pk (%l)"

determines the text that is written on top of the submodule

server.initialNumTokens double 0

initial number of tokens

server.maxNumTokens double nan

maximum number of tokens

server.tokenConsumptionPerPacket double 1

how many tokens are consumed per processed packet

server.tokenConsumptionPerBit double 0

how may tokens are consumed per processed bit

multiplexer.displayStringTextFormat string "passed %p pk (%l)"

determines the text that is written on top of the submodule

tokenGenerator.serverModule string "^." + requestConsumerModule + ".server"

module path of the packet server where the tokens are generated via C++ method call

tokenGenerator.displayStringTextFormat string "generated %t tk\nto %s"

determines display string text above the submodule

tokenGenerator.subscriptionModule string "^"
tokenGenerator.signals string "tokensDepleted"
tokenGenerator.numTokens double 1

number of tokens generated repeatedly

Source code

//
// This module is capable of generating several different streams of packets,
// one after the other. For each traffic category, the packets are produced by
// a separate token based server. The traffic stream can be started by adding
// tokens the corresponding server module. The packet data, packet length, and
// timing distributions can be configured in the corresponding packet provider.
//
// @see ~RequestConsumer
//
module ResponseProducer like IActivePacketSource
{
    parameters:
        int numKind;
        string requestConsumerModule = default("^.sink");
        @display("i=block/source");
    gates:
        output out;
    submodules:
        provider[numKind]: PassivePacketSource {
            @display("p=300,100,row,200");
        }
        server[numKind]: TokenBasedServer {
            @display("p=300,225,row,200");
        }
        multiplexer: PacketMultiplexer {
            @display("p=300,350");
        }
        tokenGenerator: SignalBasedTokenGenerator {
            serverModule = default("^." + requestConsumerModule + ".server");
            signals = default("tokensDepleted");
            @display("p=100,100");
        }
    connections:
        for i=0..sizeof(provider) - 1 {
            provider[i].out --> server[i].in;
            server[i].out --> multiplexer.in++;
        }
        multiplexer.out --> { @display("m=s"); } --> out;
}
File: src/inet/queueing/source/ResponseProducer.ned