/*

* Copyright (c) 2006-2007 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0""

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  Class for storing virtual traffic streams.

*

*/

/*

* %version: 1 %

*/

#include "core_virtual_traffic_stream_list.h"

#include "core_tools.h"

#include "core_am_tools.h"

#include "am_debug.h"

// ======== MEMBER FUNCTIONS ========

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

core_virtual_traffic_stream_list_c::core_virtual_traffic_stream_list_c() :

    ts_list_m( ),

    next_stream_id_m( 0 )

    {

    DEBUG( "core_virtual_traffic_stream_list_c::core_virtual_traffic_stream_list_c()" );

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

core_virtual_traffic_stream_list_c::~core_virtual_traffic_stream_list_c()

    {

    DEBUG( "core_virtual_traffic_stream_list_c::~core_virtual_traffic_stream_list_c()" );

    for( entry_s* iter = ts_list_m.first(); iter; iter = ts_list_m.next() )

        {

        delete iter->traffic_stream;

        }

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

u32_t core_virtual_traffic_stream_list_c::count() const

    {

    return ts_list_m.count();

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

core_error_e core_virtual_traffic_stream_list_c::add_traffic_stream(

    const core_virtual_traffic_stream_c& stream )

    {

    entry_s* entry = new entry_s;

    if( entry )

        {        

        entry->traffic_stream = new core_virtual_traffic_stream_c(

            stream.requested_tid(),

            stream.tid(),

            stream.user_priority(),

            stream.is_automatic_stream(),

            stream.params(),

            stream.id(),

            stream.status() );

        if( entry->traffic_stream )

            {

            ts_list_m.append( entry );

            }

        else

            {

            DEBUG( "core_virtual_traffic_stream_list_c::add_traffic_stream() - unable to create core_virtual_traffic_stream_c" );

            delete entry;

            entry = NULL;

            return core_error_no_memory;

            }

        }

    else

        {

        DEBUG( "core_virtual_traffic_stream_list_c::update_traffic_stream() - unable to create entry_s" );

        return core_error_no_memory;

        }

    return core_error_ok;         

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

core_error_e core_virtual_traffic_stream_list_c::add_traffic_stream(

    u8_t requested_tid,

    u8_t tid,

    u8_t user_priority,

    bool_t is_automatic_stream,

    const core_traffic_stream_params_s& params,

    u32_t& stream_id,

    core_traffic_stream_status_e stream_status )

    {

    entry_s* entry = new entry_s;

    if( entry )

        {

        stream_id = next_stream_id_m++;

        entry->traffic_stream = new core_virtual_traffic_stream_c(

            requested_tid,

            tid,

            user_priority,

            is_automatic_stream,

            params,

            stream_id,

            stream_status );

        if( entry->traffic_stream )

            {

            ts_list_m.append( entry );

            }

        else

            {

            DEBUG( "core_virtual_traffic_stream_list_c::add_traffic_stream() - unable to create core_virtual_traffic_stream_c" );

            delete entry;

            entry = NULL;

            return core_error_no_memory;

            }

        }

    else

        {

        DEBUG( "core_virtual_traffic_stream_list_c::update_traffic_stream() - unable to create entry_s" );

        return core_error_no_memory;

        }

    return core_error_ok;         

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

void core_virtual_traffic_stream_list_c::remove_traffic_stream_by_tid(

    u8_t tid )

    {

    DEBUG1( "core_virtual_traffic_stream_list_c::remove_traffic_stream_by_tid() - removing an entry with TID %u",

        tid );

    core_type_list_iterator_c<entry_s> ts_iter( ts_list_m );

    for( entry_s* iter = ts_iter.first(); iter; iter = ts_iter.next() )

        {

        if( iter->traffic_stream->tid() == tid )

            {

            DEBUG( "core_virtual_traffic_stream_list_c::remove_traffic_stream_by_tid() - matching entry found" );

            ts_iter.remove();

            }

        }

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

void core_virtual_traffic_stream_list_c::remove_traffic_stream_by_id(

    u32_t stream_id )

    {

    DEBUG1( "core_virtual_traffic_stream_list_c::remove_traffic_stream_by_tid() - removing an entry with stream ID %u",

        stream_id );

    core_type_list_iterator_c<entry_s> ts_iter( ts_list_m );

    for( entry_s* iter = ts_iter.first(); iter; iter = ts_iter.next() )

        {

        if( iter->traffic_stream->id() == stream_id )

            {

            DEBUG( "core_virtual_traffic_stream_list_c::remove_traffic_stream_by_tid() - matching entry found" );

            ts_iter.remove();

            }

        }   

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

core_access_class_traffic_mode_e core_virtual_traffic_stream_list_c::traffic_mode_by_ac(

    core_access_class_e access_class )

    {

    core_type_list_iterator_c<entry_s> ts_iter( ts_list_m );

    for( entry_s* iter = ts_iter.first(); iter; iter = ts_iter.next() )

        {

        if( iter->traffic_stream->access_class() == access_class &&

            !iter->traffic_stream->is_automatic_stream() )

            {

            return core_access_class_traffic_mode_manual;

            }

        }   

    return core_access_class_traffic_mode_automatic;

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

void core_virtual_traffic_stream_list_c::print_contents()

    {

    core_type_list_iterator_c<entry_s> ts_iter( ts_list_m );

    for( entry_s* iter = ts_iter.first(); iter; iter = ts_iter.next() )

        {

        DEBUG1( "core_virtual_traffic_stream_list_c::print_contents() - stream ID: %u",

            iter->traffic_stream->id() );

        DEBUG1( "core_virtual_traffic_stream_list_c::print_contents() - requested TID: %u",

            iter->traffic_stream->requested_tid() );

        DEBUG1( "core_virtual_traffic_stream_list_c::print_contents() - current TID: %u",

            iter->traffic_stream->tid() );

        DEBUG1( "core_virtual_traffic_stream_list_c::print_contents() - UP: %u",

            iter->traffic_stream->user_priority() );

        if( iter->traffic_stream->is_automatic_stream() )

            {

            DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - automatic: yes" );

            }

        else

            {

            DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - automatic: no" );

            }

        switch( iter->traffic_stream->params().direction )

            {

            case core_traffic_stream_direction_uplink:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - direction: uplink" );

                break;

            case core_traffic_stream_direction_downlink:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - direction: downlink" );

                break;

            case core_traffic_stream_direction_bidirectional:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - direction: bi-directional" );

                break;

            }

        switch ( iter->traffic_stream->status() )

            {

            case core_traffic_stream_status_undefined:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_undefined" );

                break;            

            case core_traffic_stream_status_active:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_active" );

                break;

            case core_traffic_stream_status_inactive_not_required:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_inactive_not_required" );

                break;

            case core_traffic_stream_status_inactive_deleted_by_ap:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_inactive_deleted_by_ap" );

                break;

            case core_traffic_stream_status_inactive_no_bandwidth:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_inactive_no_bandwidth" );

                break;

            case core_traffic_stream_status_inactive_invalid_parameters:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_inactive_invalid_parameters" );

                break;

            case core_traffic_stream_status_inactive_other:

                DEBUG( "core_virtual_traffic_stream_list_c::print_contents() - status: core_traffic_stream_status_inactive_other" );

                break;

            }

        DEBUG( "core_virtual_traffic_stream_list_c::print_contents()" );

        }

    }

// ---------------------------------------------------------------------------

// ---------------------------------------------------------------------------

//

u8_t core_virtual_traffic_stream_list_c::next_tid()

    {

    bool_t tid_array[MAX_TRAFFIC_STREAM_TID] =

        { false_t, false_t, false_t, false_t, false_t,false_t,false_t,false_t };

    for( entry_s* iter = ts_list_m.first(); iter; iter = ts_list_m.next() )

        {

        if( iter->traffic_stream->requested_tid() != TRAFFIC_STREAM_TID_NONE )

            {

            /**

             * Both active and inactive streams that were requested

             * with a certain TID.

             */            

            tid_array[iter->traffic_stream->requested_tid()] = true_t;            

            }

        else if( iter->traffic_stream->tid() != TRAFFIC_STREAM_TID_NONE ) 

            {

            /**

             * Active streams.

             */

            tid_array[iter->traffic_stream->tid()] = true_t;            

            }

        }

    u8_t tid( 0 );

    while( tid < MAX_TRAFFIC_STREAM_TID )

        {

        if( !tid_array[tid] )

            {

            return tid;

            }

        else

            {

            ++tid;

            }

        }

    return MAX_TRAFFIC_STREAM_TID;

    }