wlan_bearer/wlanengine/wlan_common/wlanengine_common_3.1/src/core_operation_directed_roam.cpp
/*
* 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;
}
}
}