//
// This file is part of an OMNeT++/OMNEST simulation example.
//
// Copyright (C) 1992-2015 Andras Varga
//
// This file is distributed WITHOUT ANY WARRANTY. See the file
// `license' for details on this and other legal matters.
//

//
// A "tandem queue" for the "B" variant of the Closed Queueing Network.
//
module TandemQueue
{
    parameters:
        int numQueues;
        int ownIndex;
        double sDelay @unit(s);
        double qDelay @unit(s);
        @display("i=misc/cloud2_l");
    gates:
        input in[];
        output out[]; // in[] and out[] sizes must match

    submodules:
        switch: Switch {
            parameters:
                @display("p=60,80");
            gates:
                out[sizeof(in)];
        }
        queue[numQueues]: Queue {
            parameters:
                @display("p=60,160,row,80");
            gates:
                in[(index==0 ? sizeof(in) : 1)];
        }
    connections allowunconnected:
        // connect switch outputs outside
        for i=0..sizeof(in)-1 {
            switch.out[i] --> out[i] if i!=ownIndex;
        }

        // connect inputs to first queue inputs
        for i=0..sizeof(in)-1 {
            in[i] --> queue[0].in[i] if i!=ownIndex;
        }

        // connect switch to first queue
        switch.out[ownIndex] --> {  delay = sDelay; } --> queue[0].in[ownIndex];

        // connect queues to each other
        for i=0..numQueues-2 {
            queue[i].out --> {  delay = qDelay; } --> queue[i+1].in[0];
        }

        // connect last queue back to switch
        queue[numQueues-1].out --> {  delay = qDelay; } --> switch.in;

}