You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
373 lines
9.6 KiB
373 lines
9.6 KiB
/*
|
|
* Copyright (c) 2005-2009 Brocade Communications Systems, Inc.
|
|
* All rights reserved
|
|
* www.brocade.com
|
|
*
|
|
* Linux driver for Brocade Fibre Channel Host Bus Adapter.
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify it
|
|
* under the terms of the GNU General Public License (GPL) Version 2 as
|
|
* published by the Free Software Foundation
|
|
*
|
|
* This program is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* General Public License for more details.
|
|
*/
|
|
|
|
/**
|
|
* rport_ftrs.c Remote port features (RPF) implementation.
|
|
*/
|
|
|
|
#include <bfa.h>
|
|
#include <bfa_svc.h>
|
|
#include "fcbuild.h"
|
|
#include "fcs_rport.h"
|
|
#include "fcs_lport.h"
|
|
#include "fcs_trcmod.h"
|
|
#include "fcs_fcxp.h"
|
|
#include "fcs.h"
|
|
|
|
BFA_TRC_FILE(FCS, RPORT_FTRS);
|
|
|
|
#define BFA_FCS_RPF_RETRIES (3)
|
|
#define BFA_FCS_RPF_RETRY_TIMEOUT (1000) /* 1 sec (In millisecs) */
|
|
|
|
static void bfa_fcs_rpf_send_rpsc2(void *rport_cbarg,
|
|
struct bfa_fcxp_s *fcxp_alloced);
|
|
static void bfa_fcs_rpf_rpsc2_response(void *fcsarg,
|
|
struct bfa_fcxp_s *fcxp, void *cbarg,
|
|
bfa_status_t req_status, u32 rsp_len,
|
|
u32 resid_len,
|
|
struct fchs_s *rsp_fchs);
|
|
static void bfa_fcs_rpf_timeout(void *arg);
|
|
|
|
/**
|
|
* fcs_rport_ftrs_sm FCS rport state machine events
|
|
*/
|
|
|
|
enum rpf_event {
|
|
RPFSM_EVENT_RPORT_OFFLINE = 1, /* Rport offline */
|
|
RPFSM_EVENT_RPORT_ONLINE = 2, /* Rport online */
|
|
RPFSM_EVENT_FCXP_SENT = 3, /* Frame from has been sent */
|
|
RPFSM_EVENT_TIMEOUT = 4, /* Rport SM timeout event */
|
|
RPFSM_EVENT_RPSC_COMP = 5,
|
|
RPFSM_EVENT_RPSC_FAIL = 6,
|
|
RPFSM_EVENT_RPSC_ERROR = 7,
|
|
};
|
|
|
|
static void bfa_fcs_rpf_sm_uninit(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
static void bfa_fcs_rpf_sm_rpsc_sending(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
static void bfa_fcs_rpf_sm_rpsc(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
static void bfa_fcs_rpf_sm_rpsc_retry(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
static void bfa_fcs_rpf_sm_offline(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
static void bfa_fcs_rpf_sm_online(struct bfa_fcs_rpf_s *rpf,
|
|
enum rpf_event event);
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_uninit(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pwwn);
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_RPORT_ONLINE:
|
|
if (!BFA_FCS_PID_IS_WKA(rport->pid)) {
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_rpsc_sending);
|
|
rpf->rpsc_retries = 0;
|
|
bfa_fcs_rpf_send_rpsc2(rpf, NULL);
|
|
break;
|
|
};
|
|
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_rpsc_sending(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_FCXP_SENT:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_rpsc);
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_offline);
|
|
bfa_fcxp_walloc_cancel(rport->fcs->bfa, &rpf->fcxp_wqe);
|
|
rpf->rpsc_retries = 0;
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_rpsc(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_RPSC_COMP:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_online);
|
|
/* Update speed info in f/w via BFA */
|
|
if (rpf->rpsc_speed != BFA_PPORT_SPEED_UNKNOWN)
|
|
bfa_rport_speed(rport->bfa_rport, rpf->rpsc_speed);
|
|
else if (rpf->assigned_speed != BFA_PPORT_SPEED_UNKNOWN)
|
|
bfa_rport_speed(rport->bfa_rport, rpf->assigned_speed);
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPSC_FAIL:
|
|
/* RPSC not supported by rport */
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_online);
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPSC_ERROR:
|
|
/* need to retry...delayed a bit. */
|
|
if (rpf->rpsc_retries++ < BFA_FCS_RPF_RETRIES) {
|
|
bfa_timer_start(rport->fcs->bfa, &rpf->timer,
|
|
bfa_fcs_rpf_timeout, rpf,
|
|
BFA_FCS_RPF_RETRY_TIMEOUT);
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_rpsc_retry);
|
|
} else {
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_online);
|
|
}
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_offline);
|
|
bfa_fcxp_discard(rpf->fcxp);
|
|
rpf->rpsc_retries = 0;
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_rpsc_retry(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_TIMEOUT:
|
|
/* re-send the RPSC */
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_rpsc_sending);
|
|
bfa_fcs_rpf_send_rpsc2(rpf, NULL);
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
bfa_timer_stop(&rpf->timer);
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_offline);
|
|
rpf->rpsc_retries = 0;
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_online(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pwwn);
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_offline);
|
|
rpf->rpsc_retries = 0;
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_sm_offline(struct bfa_fcs_rpf_s *rpf, enum rpf_event event)
|
|
{
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pwwn);
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_trc(rport->fcs, event);
|
|
|
|
switch (event) {
|
|
case RPFSM_EVENT_RPORT_ONLINE:
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_rpsc_sending);
|
|
bfa_fcs_rpf_send_rpsc2(rpf, NULL);
|
|
break;
|
|
|
|
case RPFSM_EVENT_RPORT_OFFLINE:
|
|
break;
|
|
|
|
default:
|
|
bfa_assert(0);
|
|
}
|
|
}
|
|
/**
|
|
* Called when Rport is created.
|
|
*/
|
|
void bfa_fcs_rpf_init(struct bfa_fcs_rport_s *rport)
|
|
{
|
|
struct bfa_fcs_rpf_s *rpf = &rport->rpf;
|
|
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
rpf->rport = rport;
|
|
|
|
bfa_sm_set_state(rpf, bfa_fcs_rpf_sm_uninit);
|
|
}
|
|
|
|
/**
|
|
* Called when Rport becomes online
|
|
*/
|
|
void bfa_fcs_rpf_rport_online(struct bfa_fcs_rport_s *rport)
|
|
{
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
|
|
if (__fcs_min_cfg(rport->port->fcs))
|
|
return;
|
|
|
|
if (bfa_fcs_fabric_is_switched(rport->port->fabric))
|
|
bfa_sm_send_event(&rport->rpf, RPFSM_EVENT_RPORT_ONLINE);
|
|
}
|
|
|
|
/**
|
|
* Called when Rport becomes offline
|
|
*/
|
|
void bfa_fcs_rpf_rport_offline(struct bfa_fcs_rport_s *rport)
|
|
{
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
|
|
if (__fcs_min_cfg(rport->port->fcs))
|
|
return;
|
|
|
|
bfa_sm_send_event(&rport->rpf, RPFSM_EVENT_RPORT_OFFLINE);
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_timeout(void *arg)
|
|
{
|
|
struct bfa_fcs_rpf_s *rpf = (struct bfa_fcs_rpf_s *) arg;
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
|
|
bfa_trc(rport->fcs, rport->pid);
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_TIMEOUT);
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_send_rpsc2(void *rpf_cbarg, struct bfa_fcxp_s *fcxp_alloced)
|
|
{
|
|
struct bfa_fcs_rpf_s *rpf = (struct bfa_fcs_rpf_s *)rpf_cbarg;
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
struct bfa_fcs_port_s *port = rport->port;
|
|
struct fchs_s fchs;
|
|
int len;
|
|
struct bfa_fcxp_s *fcxp;
|
|
|
|
bfa_trc(rport->fcs, rport->pwwn);
|
|
|
|
fcxp = fcxp_alloced ? fcxp_alloced : bfa_fcs_fcxp_alloc(port->fcs);
|
|
if (!fcxp) {
|
|
bfa_fcxp_alloc_wait(port->fcs->bfa, &rpf->fcxp_wqe,
|
|
bfa_fcs_rpf_send_rpsc2, rpf);
|
|
return;
|
|
}
|
|
rpf->fcxp = fcxp;
|
|
|
|
len = fc_rpsc2_build(&fchs, bfa_fcxp_get_reqbuf(fcxp), rport->pid,
|
|
bfa_fcs_port_get_fcid(port), &rport->pid, 1);
|
|
|
|
bfa_fcxp_send(fcxp, NULL, port->fabric->vf_id, port->lp_tag, BFA_FALSE,
|
|
FC_CLASS_3, len, &fchs, bfa_fcs_rpf_rpsc2_response,
|
|
rpf, FC_MAX_PDUSZ, FC_RA_TOV);
|
|
rport->stats.rpsc_sent++;
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_FCXP_SENT);
|
|
|
|
}
|
|
|
|
static void
|
|
bfa_fcs_rpf_rpsc2_response(void *fcsarg, struct bfa_fcxp_s *fcxp, void *cbarg,
|
|
bfa_status_t req_status, u32 rsp_len,
|
|
u32 resid_len, struct fchs_s *rsp_fchs)
|
|
{
|
|
struct bfa_fcs_rpf_s *rpf = (struct bfa_fcs_rpf_s *) cbarg;
|
|
struct bfa_fcs_rport_s *rport = rpf->rport;
|
|
struct fc_ls_rjt_s *ls_rjt;
|
|
struct fc_rpsc2_acc_s *rpsc2_acc;
|
|
u16 num_ents;
|
|
|
|
bfa_trc(rport->fcs, req_status);
|
|
|
|
if (req_status != BFA_STATUS_OK) {
|
|
bfa_trc(rport->fcs, req_status);
|
|
if (req_status == BFA_STATUS_ETIMER)
|
|
rport->stats.rpsc_failed++;
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_RPSC_ERROR);
|
|
return;
|
|
}
|
|
|
|
rpsc2_acc = (struct fc_rpsc2_acc_s *) BFA_FCXP_RSP_PLD(fcxp);
|
|
if (rpsc2_acc->els_cmd == FC_ELS_ACC) {
|
|
rport->stats.rpsc_accs++;
|
|
num_ents = bfa_os_ntohs(rpsc2_acc->num_pids);
|
|
bfa_trc(rport->fcs, num_ents);
|
|
if (num_ents > 0) {
|
|
bfa_assert(rpsc2_acc->port_info[0].pid != rport->pid);
|
|
bfa_trc(rport->fcs,
|
|
bfa_os_ntohs(rpsc2_acc->port_info[0].pid));
|
|
bfa_trc(rport->fcs,
|
|
bfa_os_ntohs(rpsc2_acc->port_info[0].speed));
|
|
bfa_trc(rport->fcs,
|
|
bfa_os_ntohs(rpsc2_acc->port_info[0].index));
|
|
bfa_trc(rport->fcs,
|
|
rpsc2_acc->port_info[0].type);
|
|
|
|
if (rpsc2_acc->port_info[0].speed == 0) {
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_RPSC_ERROR);
|
|
return;
|
|
}
|
|
|
|
rpf->rpsc_speed = fc_rpsc_operspeed_to_bfa_speed(
|
|
bfa_os_ntohs(rpsc2_acc->port_info[0].speed));
|
|
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_RPSC_COMP);
|
|
}
|
|
} else {
|
|
ls_rjt = (struct fc_ls_rjt_s *) BFA_FCXP_RSP_PLD(fcxp);
|
|
bfa_trc(rport->fcs, ls_rjt->reason_code);
|
|
bfa_trc(rport->fcs, ls_rjt->reason_code_expl);
|
|
rport->stats.rpsc_rejects++;
|
|
if (ls_rjt->reason_code == FC_LS_RJT_RSN_CMD_NOT_SUPP)
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_RPSC_FAIL);
|
|
else
|
|
bfa_sm_send_event(rpf, RPFSM_EVENT_RPSC_ERROR);
|
|
}
|
|
}
|
|
|