wlan_bearer/wlanengine/wlan_common/wlanengine_common_3.1/src/core_operation_directed_roam.cpp
changeset 0 c40eb8fe8501
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/wlan_bearer/wlanengine/wlan_common/wlanengine_common_3.1/src/core_operation_directed_roam.cpp	Tue Feb 02 02:03:13 2010 +0200
@@ -0,0 +1,251 @@
+/*
+* Copyright (c) 2005-2006 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:  State machine for a directed roam request.
+*
+*/
+
+/*
+* %version: 3 %
+*/
+
+#include "core_operation_directed_roam.h"
+#include "core_operation_roam.h"
+#include "core_operation_handle_bss_lost.h"
+#include "core_sub_operation_roam_scan.h"
+#include "core_server.h"
+#include "core_tools.h"
+#include "am_debug.h"
+
+// ======== MEMBER FUNCTIONS ========
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+//
+core_operation_directed_roam_c::core_operation_directed_roam_c(
+    u32_t request_id,
+    core_server_c* server,
+    abs_core_driverif_c* drivers,
+    abs_core_server_callback_c* adaptation,
+    const core_mac_address_s& bssid ) :
+    core_operation_base_c( core_operation_directed_roam, request_id, server, drivers, adaptation,
+        core_base_flag_drivers_needed | core_base_flag_connection_needed | core_base_flag_roam_operation ),
+    bssid_m( bssid ),
+    current_rcpi_m( 0 ),
+    is_connected_m( true_t ) 
+    {
+    DEBUG( "core_operation_directed_roam_c::core_operation_directed_roam_c()" );
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+//
+core_operation_directed_roam_c::~core_operation_directed_roam_c()
+    {
+    DEBUG( "core_operation_directed_roam_c::~core_operation_directed_roam_c()" );
+    }
+    
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+//
+core_error_e core_operation_directed_roam_c::next_state()
+    {
+    DEBUG( "core_operation_directed_roam_c::next_state()" );
+    
+    switch ( operation_state_m )
+        {
+        case core_state_init:
+            {
+            if( !server_m->get_core_settings().is_connected() )
+                {
+                DEBUG( "core_operation_directed_roam_c::next_state() - not connected, nothing to do" );
+
+                return core_error_general;
+                }
+
+            operation_state_m = core_state_scan_start;
+
+            core_mac_address_s current_bssid =
+                server_m->get_connection_data()->current_ap_data()->bssid();
+
+            DEBUG6( "core_operation_directed_roam_c::next_state() - current BSSID: %02X:%02X:%02X:%02X:%02X:%02X",
+                current_bssid.addr[0], current_bssid.addr[1], current_bssid.addr[2],
+                current_bssid.addr[3], current_bssid.addr[4], current_bssid.addr[5] );
+            DEBUG6( "core_operation_directed_roam_c::next_state() - requested BSSID: %02X:%02X:%02X:%02X:%02X:%02X",
+                bssid_m.addr[0], bssid_m.addr[1], bssid_m.addr[2],
+                bssid_m.addr[3], bssid_m.addr[4], bssid_m.addr[5] );
+
+            DEBUG( "core_operation_directed_roam_c::next_state() - requesting RCPI" );
+
+            drivers_m->get_current_rcpi(
+                request_id_m,
+                current_rcpi_m );
+
+            break;
+            }
+        case core_state_scan_start:
+            {
+            DEBUG1( "core_operation_directed_roam_c::next_state() - current RCPI is %u",
+                current_rcpi_m );
+
+            DEBUG( "core_operation_directed_roam_c::next_state() - starting a direct scan on all channels" );           
+
+            server_m->get_scan_list().set_tag(
+                core_scan_list_tag_roam_scan );
+
+            core_operation_base_c* operation = new core_sub_operation_roam_scan_c(
+                request_id_m,
+                server_m,
+                drivers_m,
+                adaptation_m,
+                server_m->get_connection_data()->ssid(),
+                server_m->get_core_settings().all_valid_scan_channels(),
+                true_t,
+                false_t );
+
+            return run_sub_operation( operation, core_state_scan_complete );
+            }
+        case core_state_scan_complete:
+            {
+            DEBUG( "core_operation_directed_roam_c::next_state() - attempting to roam" );
+
+            server_m->get_connection_data()->set_last_roam_reason(
+                core_roam_reason_directed_roam );               
+            server_m->get_connection_data()->set_last_roam_failed_reason(
+                core_roam_failed_reason_none );
+
+            core_operation_base_c* operation = NULL;
+            if( bssid_m == BROADCAST_MAC_ADDR )
+                {
+                /**
+                 * Directed roam request with no BSSID specified.
+                 * 
+                 * Any suitable AP that is better than the current AP will do. 
+                 */
+                medium_time_s admitted_medium_time(
+                    server_m->get_connection_data()->traffic_stream_list().admitted_medium_time() );
+
+                operation = new core_operation_roam_c(
+                    request_id_m,
+                    server_m,
+                    drivers_m,
+                    adaptation_m,
+                    is_connected_m,
+                    core_scan_list_tag_roam_scan,
+                    current_rcpi_m + server_m->get_device_settings().rcpi_difference,
+                    admitted_medium_time,
+                    server_m->get_connection_data()->ssid(),
+                    BROADCAST_MAC_ADDR );
+                }
+            else
+                {
+                /**
+                 * Directed roam request to a certain BSSID.
+                 */
+                operation = new core_operation_roam_c(
+                    request_id_m,
+                    server_m,
+                    drivers_m,
+                    adaptation_m,
+                    is_connected_m,
+                    core_scan_list_tag_roam_scan,
+                    server_m->get_device_settings().rcpi_trigger,
+                    MEDIUM_TIME_NOT_DEFINED,
+                    server_m->get_connection_data()->ssid(),
+                    bssid_m );
+                }
+
+            return run_sub_operation( operation, core_state_connect_success );
+            }                                   
+        case core_state_connect_success:
+            {
+            operation_state_m = core_state_rcpi_trigger;
+
+            DEBUG( "core_operation_directed_roam_c::next_state() - roamed successfully" );
+
+            server_m->cancel_roam_timer();
+
+            DEBUG( "core_operation_directed_roam_c::next_state() - reseting RCPI roam check interval" );
+            server_m->get_connection_data()->reset_rcpi_roam_interval();
+
+            DEBUG1( "core_operation_directed_roam_c::next_state() - internal RCPI threshold level is %u",
+                server_m->get_device_settings().rcpi_trigger );
+            DEBUG1( "core_operation_directed_roam_c::next_state() - external RCPI threshold level is %u",
+                server_m->get_core_settings().rcp_decline_boundary() );
+
+            u8_t trigger_level = server_m->get_core_settings().rcp_decline_boundary();
+            if ( trigger_level < server_m->get_device_settings().rcpi_trigger )
+                {
+                trigger_level = server_m->get_device_settings().rcpi_trigger;
+                }
+            DEBUG1( "core_operation_directed_roam_c::next_state() - arming RCPI roam trigger (%u)",
+                trigger_level );
+
+            drivers_m->set_rcpi_trigger_level(
+                request_id_m,
+                trigger_level );
+
+            break;
+            }
+        case core_state_connect_failure:
+            {
+            DEBUG( "core_operation_directed_roam_c::next_state() - roaming failed" );
+
+            if( !is_connected_m )
+                {
+                DEBUG( "core_operation_directed_roam_c::next_state() - no longer connected, scheduling bss_lost operation" );
+
+                core_operation_base_c* operation = new core_operation_handle_bss_lost_c(
+                    REQUEST_ID_CORE_INTERNAL,
+                    server_m,
+                    drivers_m,
+                    adaptation_m,
+                    core_operation_handle_bss_lost_c::core_bss_lost_reason_failed_directed_roam );
+
+                server_m->queue_int_operation( operation );
+                }
+
+            return core_error_general;
+            }
+        case core_state_rcpi_trigger:
+            {
+            return core_error_ok;
+            }
+        default:
+            {
+            ASSERT( false_t );
+            }
+        }
+
+    return core_error_request_pending;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+//
+core_error_e core_operation_directed_roam_c::cancel()
+    {
+    DEBUG( "core_operation_directed_roam_c::cancel() " );    
+
+    switch ( operation_state_m )
+        {
+        case core_state_connect_success:
+            {            
+            return goto_state( core_state_connect_failure );
+            }
+        default:
+            {
+            return failure_reason_m;
+            }
+        }    
+    }