#include"iavf.h" #include"iavf_ptp.h" #include"iavf_prototype.h" /* All iavf tracepoints are defined by the include below, which must *beincludedexactlyonceacrossthewholekernelwith *CREATE_TRACE_POINTSdefined
*/ #define CREATE_TRACE_POINTS #include"iavf_trace.h"
int iavf_status_to_errno(enum iavf_status status)
{ switch (status) { case IAVF_SUCCESS: return0; case IAVF_ERR_PARAM: case IAVF_ERR_MAC_TYPE: case IAVF_ERR_INVALID_MAC_ADDR: case IAVF_ERR_INVALID_LINK_SETTINGS: case IAVF_ERR_INVALID_PD_ID: case IAVF_ERR_INVALID_QP_ID: case IAVF_ERR_INVALID_CQ_ID: case IAVF_ERR_INVALID_CEQ_ID: case IAVF_ERR_INVALID_AEQ_ID: case IAVF_ERR_INVALID_SIZE: case IAVF_ERR_INVALID_ARP_INDEX: case IAVF_ERR_INVALID_FPM_FUNC_ID: case IAVF_ERR_QP_INVALID_MSG_SIZE: case IAVF_ERR_INVALID_FRAG_COUNT: case IAVF_ERR_INVALID_ALIGNMENT: case IAVF_ERR_INVALID_PUSH_PAGE_INDEX: case IAVF_ERR_INVALID_IMM_DATA_SIZE: case IAVF_ERR_INVALID_VF_ID: case IAVF_ERR_INVALID_HMCFN_ID: case IAVF_ERR_INVALID_PBLE_INDEX: case IAVF_ERR_INVALID_SD_INDEX: case IAVF_ERR_INVALID_PAGE_DESC_INDEX: case IAVF_ERR_INVALID_SD_TYPE: case IAVF_ERR_INVALID_HMC_OBJ_INDEX: case IAVF_ERR_INVALID_HMC_OBJ_COUNT: case IAVF_ERR_INVALID_SRQ_ARM_LIMIT: return -EINVAL; case IAVF_ERR_NVM: case IAVF_ERR_NVM_CHECKSUM: case IAVF_ERR_PHY: case IAVF_ERR_CONFIG: case IAVF_ERR_UNKNOWN_PHY: case IAVF_ERR_LINK_SETUP: case IAVF_ERR_ADAPTER_STOPPED: case IAVF_ERR_PRIMARY_REQUESTS_PENDING: case IAVF_ERR_AUTONEG_NOT_COMPLETE: case IAVF_ERR_RESET_FAILED: case IAVF_ERR_BAD_PTR: case IAVF_ERR_SWFW_SYNC: case IAVF_ERR_QP_TOOMANY_WRS_POSTED: case IAVF_ERR_QUEUE_EMPTY: case IAVF_ERR_FLUSHED_QUEUE: case IAVF_ERR_OPCODE_MISMATCH: case IAVF_ERR_CQP_COMPL_ERROR: case IAVF_ERR_BACKING_PAGE_ERROR: case IAVF_ERR_NO_PBLCHUNKS_AVAILABLE: case IAVF_ERR_MEMCPY_FAILED: case IAVF_ERR_SRQ_ENABLED: case IAVF_ERR_ADMIN_QUEUE_ERROR: case IAVF_ERR_ADMIN_QUEUE_FULL: case IAVF_ERR_BAD_RDMA_CQE: case IAVF_ERR_NVM_BLANK_MODE: case IAVF_ERR_PE_DOORBELL_NOT_ENABLED: case IAVF_ERR_DIAG_TEST_FAILED: case IAVF_ERR_FIRMWARE_API_VERSION: case IAVF_ERR_ADMIN_QUEUE_CRITICAL_ERROR: return -EIO; case IAVF_ERR_DEVICE_NOT_SUPPORTED: return -ENODEV; case IAVF_ERR_NO_AVAILABLE_VSI: case IAVF_ERR_RING_FULL: return -ENOSPC; case IAVF_ERR_NO_MEMORY: return -ENOMEM; case IAVF_ERR_TIMEOUT: case IAVF_ERR_ADMIN_QUEUE_TIMEOUT: return -ETIMEDOUT; case IAVF_ERR_NOT_IMPLEMENTED: case IAVF_NOT_SUPPORTED: return -EOPNOTSUPP; case IAVF_ERR_ADMIN_QUEUE_NO_WORK: return -EALREADY; case IAVF_ERR_NOT_READY: return -EBUSY; case IAVF_ERR_BUF_TOO_SHORT: return -EMSGSIZE;
}
return -EIO;
}
int virtchnl_status_to_errno(enum virtchnl_status_code v_status)
{ switch (v_status) { case VIRTCHNL_STATUS_SUCCESS: return0; case VIRTCHNL_STATUS_ERR_PARAM: case VIRTCHNL_STATUS_ERR_INVALID_VF_ID: return -EINVAL; case VIRTCHNL_STATUS_ERR_NO_MEMORY: return -ENOMEM; case VIRTCHNL_STATUS_ERR_OPCODE_MISMATCH: case VIRTCHNL_STATUS_ERR_CQP_COMPL_ERROR: case VIRTCHNL_STATUS_ERR_ADMIN_QUEUE_ERROR: return -EIO; case VIRTCHNL_STATUS_ERR_NOT_SUPPORTED: return -EOPNOTSUPP;
}
/** *iavf_wait_for_reset-Waitforresettofinish. *@adapter:boardprivatestructure * *Returns0ifresetfinishedsuccessfully,negativeontimeoutorinterrupt.
*/ int iavf_wait_for_reset(struct iavf_adapter *adapter)
{ int ret = wait_event_interruptible_timeout(adapter->reset_waitqueue,
!iavf_is_reset_in_progress(adapter),
msecs_to_jiffies(5000));
/* If ret < 0 then it means wait was interrupted. *Ifret==0thenitmeanswegotatimeoutwhilewaiting *forresettofinish. *Ifret>0itmeansresethasfinished.
*/ if (ret > 0) return0; elseif (ret < 0) return -EINTR; else return -EBUSY;
}
/* If we did not negotiate VIRTCHNL_VF_OFFLOAD_RX_FLEX_DESC, we must *stickwiththedefaultvalueofthelegacy32byteformat.
*/ if (!IAVF_RXDID_ALLOWED(adapter)) return VIRTCHNL_RXDID_1_32B_BASE;
/* Rx timestamping requires the use of flexible NIC descriptors */ if (iavf_ptp_cap_supported(adapter, VIRTCHNL_1588_PTP_CAP_RX_TSTAMP)) { if (rxdids & BIT(VIRTCHNL_RXDID_2_FLEX_SQ_NIC)) return VIRTCHNL_RXDID_2_FLEX_SQ_NIC;
pci_warn(adapter->pdev, "Unable to negotiate flexible descriptor format\n");
}
/* Warn if the PF does not list support for the default legacy *descriptorformat.Thisshouldn'thappen,asthisistheformat *usedifVIRTCHNL_VF_OFFLOAD_RX_FLEX_DESCisnotsupported.Itis *likelycausedbyabuginthePFimplementationfailingtoindicate *supportfortheformat.
*/ if (!(rxdids & VIRTCHNL_RXDID_1_32B_BASE_M))
netdev_warn(adapter->netdev, "PF does not list support for default Rx descriptor format\n");
if (!is_valid_ether_addr(addr->sa_data)) return -EADDRNOTAVAIL;
ret = iavf_replace_primary_mac(adapter, addr->sa_data);
if (ret) return ret;
ret = wait_event_interruptible_timeout(adapter->vc_waitqueue,
iavf_is_mac_set_handled(netdev, addr->sa_data),
msecs_to_jiffies(2500));
/* If ret < 0 then it means wait was interrupted. *Ifret==0thenitmeanswegotatimeout. *elseitmeanswegotresponseforsetMACfromPF, *checkifnetdevMACwasupdatedtorequestedMAC, *ifyesthensetMACsucceededotherwiseitfailedreturn-EACCES
*/ if (ret < 0) return ret;
if (!ret) return -EAGAIN;
if (!ether_addr_equal(netdev->dev_addr, addr->sa_data)) return -EACCES;
/* Under some circumstances, we might receive a request to delete *ourowndeviceaddressfromouruclist.Becausewestorethe *deviceaddressintheVSI'sMAC/VLANfilterlist,weneedtoignore *suchrequestsandnotdeleteourdeviceaddressfromthislist.
*/ if (ether_addr_equal(addr, netdev->dev_addr)) return0;
f = iavf_find_filter(adapter, addr); if (f) {
f->remove = true;
adapter->aq_required |= IAVF_FLAG_AQ_DEL_MAC_FILTER;
} return0;
}
spin_lock_bh(&adapter->mac_vlan_list_lock); /* clear the sync flag on all filters */
__dev_uc_unsync(adapter->netdev, NULL);
__dev_mc_unsync(adapter->netdev, NULL);
/* remove all MAC filters */
list_for_each_entry_safe(f, ftmp, &adapter->mac_filter_list,
list) { if (f->add) {
list_del(&f->list);
kfree(f);
} else {
f->remove = true;
}
}
if (adapter->flags & IAVF_FLAG_PF_COMMS_FAILED) return;
if (!test_bit(__IAVF_IN_REMOVE_TASK, &adapter->crit_section)) { /* cancel any current operation */
adapter->current_op = VIRTCHNL_OP_UNKNOWN; /* Schedule operations to close down the HW. Don't wait *hereforthistocomplete.Thewatchdogisstillrunning *anditwilltakecareofthis.
*/ if (!list_empty(&adapter->mac_filter_list))
adapter->aq_required |= IAVF_FLAG_AQ_DEL_MAC_FILTER; if (!list_empty(&adapter->vlan_filter_list))
adapter->aq_required |= IAVF_FLAG_AQ_DEL_VLAN_FILTER; if (!list_empty(&adapter->cloud_filter_list))
adapter->aq_required |= IAVF_FLAG_AQ_DEL_CLOUD_FILTER; if (!list_empty(&adapter->fdir_list_head))
adapter->aq_required |= IAVF_FLAG_AQ_DEL_FDIR_FILTER; if (!list_empty(&adapter->adv_rss_list_head))
adapter->aq_required |= IAVF_FLAG_AQ_DEL_ADV_RSS_CFG;
}
/** *iavf_acquire_msix_vectors-SetuptheMSIXcapability *@adapter:boardprivatestructure *@vectors:numberofvectorstorequest * *WorkwiththeOStosetuptheMSIXvectorsneeded. * *Returns0onsuccess,negativeonfailure
**/ staticint
iavf_acquire_msix_vectors(struct iavf_adapter *adapter, int vectors)
{ int err, vector_threshold;
/* We'll want at least 3 (vector_threshold): *0)Other(AdminQueueandlink,mostly) *1)TxQ[0]Cleanup *2)RxQ[0]Cleanup
*/
vector_threshold = MIN_MSIX_COUNT;
/* The more we get, the more we will assign to Tx/Rx Cleanup *fortheseparatequeues...whereRxCleanup>=TxCleanup. *Rightnow,wesimplycareabouthowmanywe'llget;we'll *setthemuplaterwhilerequestingirq's.
*/
err = pci_enable_msix_range(adapter->pdev, adapter->msix_entries,
vector_threshold, vectors); if (err < 0) {
dev_err(&adapter->pdev->dev, "Unable to allocate MSI-X interrupts\n");
kfree(adapter->msix_entries);
adapter->msix_entries = NULL; return err;
}
/* Adjust for only the vectors we'll use, which is minimum *ofmax_msix_q_vectors+NONQ_VECS,orthenumberof *vectorswewereallocated.
*/
adapter->num_msix_vectors = err; return0;
}
/* It's easy to be greedy for MSI-X vectors, but it really doesn't do *usmuchgoodifwehavemorevectorsthanCPUs.However,wealready *limitthetotalnumberofqueuesbythenumberofCPUssowedonot *needanyfurtherlimitinghere.
*/
v_budget = min_t(int, pairs + NONQ_VECS,
(int)adapter->vf_res->max_vectors);
err = iavf_alloc_queues(adapter); if (err) {
dev_err(&adapter->pdev->dev, "Unable to allocate memory for queues\n"); goto err_alloc_queues;
}
err = iavf_set_interrupt_capability(adapter); if (err) {
dev_err(&adapter->pdev->dev, "Unable to setup interrupt capabilities\n"); goto err_set_interrupt;
}
err = iavf_alloc_q_vectors(adapter); if (err) {
dev_err(&adapter->pdev->dev, "Unable to allocate memory for queue vectors\n"); goto err_alloc_q_vectors;
}
/* If we've made it so far while ADq flag being ON, then we haven't *bailedoutanywhereinmiddle.AndADqisn'tjustenabledbutactual *resourceshavebeenallocatedintheresetpath. *NowwecantrulyclaimthatADqisenabled.
*/ if ((adapter->vf_res->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_ADQ) &&
adapter->num_tc)
dev_info(&adapter->pdev->dev, "ADq Enabled, %u TCs created",
adapter->num_tc);
/* Always take RTNL first to prevent circular lock dependency; *thedev->lock(==netdevlock)isneededtoupdatethequeuenumber.
*/
rtnl_lock();
netdev_lock(adapter->netdev);
switch (adapter->state) { case __IAVF_DOWN: /* Set the real number of queues when reset occurs while *state==__IAVF_DOWN
*/
pairs = adapter->num_active_queues;
netif_set_real_num_rx_queues(adapter->netdev, pairs);
netif_set_real_num_tx_queues(adapter->netdev, pairs);
if (adapter->netdev->reg_state != NETREG_REGISTERED) {
netdev_unlock(adapter->netdev);
netdev_released = true;
err = register_netdevice(adapter->netdev); if (err) {
dev_err(&adapter->pdev->dev, "Unable to register netdev (%d)\n",
err);
/* go back and try again.*/
netdev_lock(adapter->netdev);
iavf_free_rss(adapter);
iavf_free_misc_irq(adapter);
iavf_reset_interrupt_capability(adapter);
iavf_change_state(adapter,
__IAVF_INIT_CONFIG_ADAPTER);
netdev_unlock(adapter->netdev); goto out;
}
} break; case __IAVF_RUNNING:
pairs = adapter->num_active_queues;
netif_set_real_num_rx_queues(adapter->netdev, pairs);
netif_set_real_num_tx_queues(adapter->netdev, pairs); break;
default: break;
}
out: if (!netdev_released)
netdev_unlock(adapter->netdev);
rtnl_unlock();
}
/* keep cases separate because one ethertype for offloads can be *disabledatthesametimeasanotherisdisabled,socheckforan *enabledethertypefirst,thencheckfordisabled.Defaultto *ETH_P_8021Qsoanethertypeisspecifiedifdisablinginsertionand *stripping.
*/ if (features & (NETIF_F_HW_VLAN_STAG_RX | NETIF_F_HW_VLAN_STAG_TX))
vlan_ethertype = ETH_P_8021AD; elseif (features & (NETIF_F_HW_VLAN_CTAG_RX | NETIF_F_HW_VLAN_CTAG_TX))
vlan_ethertype = ETH_P_8021Q; elseif (prev_features & (NETIF_F_HW_VLAN_STAG_RX | NETIF_F_HW_VLAN_STAG_TX))
vlan_ethertype = ETH_P_8021AD; elseif (prev_features & (NETIF_F_HW_VLAN_CTAG_RX | NETIF_F_HW_VLAN_CTAG_TX))
vlan_ethertype = ETH_P_8021Q; else
vlan_ethertype = ETH_P_8021Q;
if (!(features & (NETIF_F_HW_VLAN_STAG_RX | NETIF_F_HW_VLAN_CTAG_RX)))
enable_stripping = false; if (!(features & (NETIF_F_HW_VLAN_STAG_TX | NETIF_F_HW_VLAN_CTAG_TX)))
enable_insertion = false;
if (VLAN_ALLOWED(adapter)) { /* VIRTCHNL_VF_OFFLOAD_VLAN only has support for toggling VLAN *strippingviavirtchnl.VLANinsertioncanbetoggledonthe *netdev,butitdoesn'trequireavirtchnlmessage
*/ if (enable_stripping)
aq_required |= IAVF_FLAG_AQ_ENABLE_VLAN_STRIPPING; else
aq_required |= IAVF_FLAG_AQ_DISABLE_VLAN_STRIPPING;
} elseif (VLAN_V2_ALLOWED(adapter)) { switch (vlan_ethertype) { case ETH_P_8021Q: if (enable_stripping)
aq_required |= IAVF_FLAG_AQ_ENABLE_CTAG_VLAN_STRIPPING; else
aq_required |= IAVF_FLAG_AQ_DISABLE_CTAG_VLAN_STRIPPING;
if (enable_insertion)
aq_required |= IAVF_FLAG_AQ_ENABLE_CTAG_VLAN_INSERTION; else
aq_required |= IAVF_FLAG_AQ_DISABLE_CTAG_VLAN_INSERTION; break; case ETH_P_8021AD: if (enable_stripping)
aq_required |= IAVF_FLAG_AQ_ENABLE_STAG_VLAN_STRIPPING; else
aq_required |= IAVF_FLAG_AQ_DISABLE_STAG_VLAN_STRIPPING;
if (!iavf_asq_done(hw)) {
dev_err(&pdev->dev, "Admin queue command never completed\n");
iavf_shutdown_adminq(hw);
iavf_change_state(adapter, __IAVF_STARTUP); goto err;
}
/* aq msg sent, awaiting reply */
err = iavf_verify_api_ver(adapter); if (err) { if (err == -EALREADY)
err = iavf_send_api_ver(adapter); else
dev_err(&pdev->dev, "Unsupported PF API version %d.%d, expected %d.%d\n",
adapter->pf_version.major,
adapter->pf_version.minor,
VIRTCHNL_VERSION_MAJOR,
VIRTCHNL_VERSION_MINOR); goto err;
}
err = iavf_send_vf_config_msg(adapter); if (err) {
dev_err(&pdev->dev, "Unable to send config request (%d)\n",
err); goto err;
}
iavf_change_state(adapter, __IAVF_INIT_GET_RESOURCES); return;
err:
iavf_change_state(adapter, __IAVF_INIT_FAILED);
}
/** *iavf_parse_vf_resource_msg-parseresponsefromVIRTCHNL_OP_GET_VF_RESOURCES *@adapter:boardprivatestructure
*/ int iavf_parse_vf_resource_msg(struct iavf_adapter *adapter)
{ int i, num_req_queues = adapter->num_req_queues; struct iavf_vsi *vsi = &adapter->vsi;
for (i = 0; i < adapter->vf_res->num_vsis; i++) { if (adapter->vf_res->vsi_res[i].vsi_type == VIRTCHNL_VSI_SRIOV)
adapter->vsi_res = &adapter->vf_res->vsi_res[i];
} if (!adapter->vsi_res) {
dev_err(&adapter->pdev->dev, "No LAN VSI found\n"); return -ENODEV;
}
if (num_req_queues &&
num_req_queues > adapter->vsi_res->num_queue_pairs) { /* Problem. The PF gave us fewer queues than what we had *negotiatedinourrequest.Needaresettoseeifwecan't *getbacktoaworkingstate.
*/
dev_err(&adapter->pdev->dev, "Requested %d queues, but PF only gave us %d.\n",
num_req_queues,
adapter->vsi_res->num_queue_pairs);
adapter->flags |= IAVF_FLAG_REINIT_MSIX_NEEDED;
adapter->num_req_queues = adapter->vsi_res->num_queue_pairs;
iavf_schedule_reset(adapter, IAVF_FLAG_RESET_NEEDED);
WARN_ON(adapter->state != __IAVF_INIT_GET_RESOURCES); /* aq msg sent, awaiting reply */ if (!adapter->vf_res) {
adapter->vf_res = kzalloc(IAVF_VIRTCHNL_VF_RESOURCE_SIZE,
GFP_KERNEL); if (!adapter->vf_res) {
err = -ENOMEM; goto err;
}
}
err = iavf_get_vf_config(adapter); if (err == -EALREADY) {
err = iavf_send_vf_config_msg(adapter); goto err;
} elseif (err == -EINVAL) { /* We only get -EINVAL if the device is in a very bad *stateorifwe'vebeendisabledforpreviousbad *behavior.Eitherway,we'redonenow.
*/
iavf_shutdown_adminq(hw);
dev_err(&pdev->dev, "Unable to get VF config due to PF error condition, not retrying\n"); return;
} if (err) {
dev_err(&pdev->dev, "Unable to get VF config (%d)\n", err); goto err_alloc;
}
err = iavf_parse_vf_resource_msg(adapter); if (err) {
dev_err(&pdev->dev, "Failed to parse VF resource message from PF (%d)\n",
err); goto err_alloc;
} /* Some features require additional messages to negotiate extended *capabilities.Theseareprocessedinsequencebythe *__IAVF_INIT_EXTENDED_CAPSdriverstate.
*/
adapter->extended_caps = IAVF_EXTENDED_CAPS;
ret = iavf_send_vf_offload_vlan_v2_msg(adapter); if (ret && ret == -EOPNOTSUPP) { /* PF does not support VIRTCHNL_VF_OFFLOAD_V2. In this case, *wedidnotsendthecapabilityexchangemessageanddonot *expectaresponse.
*/
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_VLAN_V2;
}
/* We sent the message, so move on to the next step */
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_SEND_VLAN_V2;
}
ret = iavf_get_vf_vlan_v2_caps(adapter); if (ret) goto err;
/* We've processed receipt of the VLAN V2 caps message */
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_VLAN_V2; return;
err: /* We didn't receive a reply. Make sure we try sending again when *__IAVF_INIT_FAILEDattemptstorecover.
*/
adapter->extended_caps |= IAVF_EXTENDED_CAP_SEND_VLAN_V2;
iavf_change_state(adapter, __IAVF_INIT_FAILED);
}
ret = iavf_send_vf_supported_rxdids_msg(adapter); if (ret == -EOPNOTSUPP) { /* PF does not support VIRTCHNL_VF_OFFLOAD_RX_FLEX_DESC. In this *case,wedidnotsendthecapabilityexchangemessageand *donotexpectaresponse.
*/
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_RXDID;
}
/* We sent the message, so move on to the next step */
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_SEND_RXDID;
}
ret = iavf_get_vf_supported_rxdids(adapter); if (ret) goto err;
/* We've processed the PF response to the *VIRTCHNL_OP_GET_SUPPORTED_RXDIDSmessagewesentpreviously.
*/
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_RXDID; return;
err: /* We didn't receive a reply. Make sure we try sending again when *__IAVF_INIT_FAILEDattemptstorecover.
*/
adapter->extended_caps |= IAVF_EXTENDED_CAP_SEND_RXDID;
iavf_change_state(adapter, __IAVF_INIT_FAILED);
}
/** *iavf_init_send_ptp_caps-partofqueryingforextendedPTPcapabilities *@adapter:boardprivatestructure * *Functionprocessessendoftherequestfor1588PTPcapabilitiestothePF. *MustclearIAVF_EXTENDED_CAP_SEND_PTPifthemessageisnotsent,e.g. *duetothePFnotnegotiatingVIRTCHNL_VF_PTP_CAP
*/ staticvoid iavf_init_send_ptp_caps(struct iavf_adapter *adapter)
{ if (iavf_send_vf_ptp_caps_msg(adapter) == -EOPNOTSUPP) { /* PF does not support VIRTCHNL_VF_PTP_CAP. In this case, we *didnotsendthecapabilityexchangemessageanddonot *expectaresponse.
*/
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_PTP;
}
/* We sent the message, so move on to the next step */
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_SEND_PTP;
}
/* We've processed the PF response to the VIRTCHNL_OP_1588_PTP_GET_CAPS *messagewesentpreviously.
*/
adapter->extended_caps &= ~IAVF_EXTENDED_CAP_RECV_PTP; return;
err: /* We didn't receive a reply. Make sure we try sending again when *__IAVF_INIT_FAILEDattemptstorecover.
*/
adapter->extended_caps |= IAVF_EXTENDED_CAP_SEND_PTP;
iavf_change_state(adapter, __IAVF_INIT_FAILED);
}
/* Process capability exchange for VLAN V2 */ if (adapter->extended_caps & IAVF_EXTENDED_CAP_SEND_VLAN_V2) {
iavf_init_send_offload_vlan_v2_caps(adapter); return;
} elseif (adapter->extended_caps & IAVF_EXTENDED_CAP_RECV_VLAN_V2) {
iavf_init_recv_offload_vlan_v2_caps(adapter); return;
}
/* Process capability exchange for RXDID formats */ if (adapter->extended_caps & IAVF_EXTENDED_CAP_SEND_RXDID) {
iavf_init_send_supported_rxdids(adapter); return;
} elseif (adapter->extended_caps & IAVF_EXTENDED_CAP_RECV_RXDID) {
iavf_init_recv_supported_rxdids(adapter); return;
}
/* Process capability exchange for PTP features */ if (adapter->extended_caps & IAVF_EXTENDED_CAP_SEND_PTP) {
iavf_init_send_ptp_caps(adapter); return;
} elseif (adapter->extended_caps & IAVF_EXTENDED_CAP_RECV_PTP) {
iavf_init_recv_ptp_caps(adapter); return;
}
/* When we reach here, no further extended capabilities exchanges are *necessary,sowefinallytransitioninto__IAVF_INIT_CONFIG_ADAPTER
*/
iavf_change_state(adapter, __IAVF_INIT_CONFIG_ADAPTER);
}
if (adapter->flags & IAVF_FLAG_PF_COMMS_FAILED)
iavf_change_state(adapter, __IAVF_COMM_FAILED);
switch (adapter->state) { case __IAVF_STARTUP:
iavf_startup(adapter); return30; case __IAVF_INIT_VERSION_CHECK:
iavf_init_version_check(adapter); return30; case __IAVF_INIT_GET_RESOURCES:
iavf_init_get_resources(adapter); return1; case __IAVF_INIT_EXTENDED_CAPS:
iavf_init_process_extended_caps(adapter); return1; case __IAVF_INIT_CONFIG_ADAPTER:
iavf_init_config_adapter(adapter); return1; case __IAVF_INIT_FAILED: if (test_bit(__IAVF_IN_REMOVE_TASK,
&adapter->crit_section)) { /* Do not update the state and do not reschedule *watchdogtask,iavf_removeshouldhandlethisstate *asitcanloopforever
*/ return IAVF_NO_RESCHED;
} if (++adapter->aq_wait_count > IAVF_AQ_MAX_ERR) {
dev_err(&adapter->pdev->dev, "Failed to communicate with PF; waiting before retry\n");
adapter->flags |= IAVF_FLAG_PF_COMMS_FAILED;
iavf_shutdown_adminq(hw); return5000;
} /* Try again from failed step*/
iavf_change_state(adapter, adapter->last_state); return1000; case __IAVF_COMM_FAILED: if (test_bit(__IAVF_IN_REMOVE_TASK,
&adapter->crit_section)) { /* Set state to __IAVF_INIT_FAILED and perform remove *steps.RemoveIAVF_FLAG_PF_COMMS_FAILEDsothetask *doesn'tbringthestatebackto__IAVF_COMM_FAILED.
*/
iavf_change_state(adapter, __IAVF_INIT_FAILED);
adapter->flags &= ~IAVF_FLAG_PF_COMMS_FAILED; return IAVF_NO_RESCHED;
}
reg_val = rd32(hw, IAVF_VFGEN_RSTAT) &
IAVF_VFGEN_RSTAT_VFR_STATE_MASK; if (reg_val == VIRTCHNL_VFR_VFACTIVE ||
reg_val == VIRTCHNL_VFR_COMPLETED) { /* A chance for redemption! */
dev_err(&adapter->pdev->dev, "Hardware came out of reset. Attempting reinit.\n"); /* When init task contacts the PF and *getseverythingsetupagain,it'llrestartthe *watchdogforus.Down,boy.Sit.Stay.Woof.
*/
iavf_change_state(adapter, __IAVF_STARTUP);
adapter->flags &= ~IAVF_FLAG_PF_COMMS_FAILED;
}
adapter->aq_required = 0;
adapter->current_op = VIRTCHNL_OP_UNKNOWN; return10; case __IAVF_RESETTING: return2000; case __IAVF_DOWN: case __IAVF_DOWN_PENDING: case __IAVF_TESTING: case __IAVF_RUNNING: if (adapter->current_op) { if (!iavf_asq_done(hw)) {
dev_dbg(&adapter->pdev->dev, "Admin queue timeout\n");
iavf_send_api_ver(adapter);
}
} else { int ret = iavf_process_aq_command(adapter);
/* An error will be returned if no commands were *processed;usethisopportunitytoupdatestats *iftheerrorisn't-ENOTSUPP
*/ if (ret && ret != -EOPNOTSUPP &&
adapter->state == __IAVF_RUNNING)
iavf_request_stats(adapter);
} if (adapter->state == __IAVF_RUNNING)
iavf_detect_recover_hung(&adapter->vsi); break; case __IAVF_REMOVE: default: return IAVF_NO_RESCHED;
}
netdev_lock(netdev);
msec_delay = iavf_watchdog_step(adapter); /* note that we schedule a different task */ if (adapter->state >= __IAVF_DOWN)
queue_work(adapter->wq, &adapter->adminq_task);
if (msec_delay != IAVF_NO_RESCHED)
queue_delayed_work(adapter->wq, &adapter->watchdog_task,
msecs_to_jiffies(msec_delay));
netdev_unlock(netdev);
}
/* We don't use netif_running() because it may be true prior to *ndo_open()returning,sowecan'tassumeitmeansallouropen *taskshavefinished,sincewe'renotholdingthertnl_lockhere.
*/ if (adapter->state == __IAVF_RUNNING) {
set_bit(__IAVF_VSI_DOWN, adapter->vsi.state);
netif_carrier_off(adapter->netdev);
netif_tx_disable(adapter->netdev);
adapter->link_up = false;
iavf_napi_disable_all(adapter);
iavf_irq_disable(adapter);
iavf_free_traffic_irqs(adapter);
iavf_free_all_tx_resources(adapter);
iavf_free_all_rx_resources(adapter);
}
spin_lock_bh(&adapter->mac_vlan_list_lock);
/* Delete all of the filters */
list_for_each_entry_safe(f, ftmp, &adapter->mac_filter_list, list) {
list_del(&f->list);
kfree(f);
}
/** *iavf_reconfig_qs_bw-Call-backtasktohandlehardwarereset *@adapter:boardprivatestructure * *Afterareset,theshaperparametersofqueuesneedtobereplayedagain. *Sincethenet_shaperobjectinsideTXringspersistsacrossreset, *settheupdateflagforallqueuessothatthevirtchnlmessageistriggered *forallqueues.
**/ staticvoid iavf_reconfig_qs_bw(struct iavf_adapter *adapter)
{ int i, num = 0;
for (i = 0; i < adapter->num_active_queues; i++) if (adapter->tx_rings[i].q_shaper.bw_min ||
adapter->tx_rings[i].q_shaper.bw_max) {
adapter->tx_rings[i].q_shaper_update = true;
num++;
}
if (num)
adapter->aq_required |= IAVF_FLAG_AQ_CONFIGURE_QUEUES_BW;
}
iavf_misc_irq_disable(adapter); if (adapter->flags & IAVF_FLAG_RESET_NEEDED) {
adapter->flags &= ~IAVF_FLAG_RESET_NEEDED; /* Restart the AQ here. If we have been reset but didn't *detectit,orifthePFhadtoreinit,ourAQwillbehosed.
*/
iavf_shutdown_adminq(hw);
iavf_init_adminq(hw);
iavf_request_reset(adapter);
}
adapter->flags |= IAVF_FLAG_RESET_PENDING;
/* poll until we see the reset actually happen */ for (i = 0; i < IAVF_RESET_WAIT_DETECTED_COUNT; i++) {
reg_val = rd32(hw, IAVF_VF_ARQLEN1) &
IAVF_VF_ARQLEN1_ARQENABLE_MASK; if (!reg_val) break;
usleep_range(5000, 10000);
} if (i == IAVF_RESET_WAIT_DETECTED_COUNT) {
dev_info(&adapter->pdev->dev, "Never saw reset\n"); goto continue_reset; /* act like the reset happened */
}
/* wait until the reset is complete and the PF is responding to us */ for (i = 0; i < IAVF_RESET_WAIT_COMPLETE_COUNT; i++) { /* sleep first to make sure a minimum wait time is met */
msleep(IAVF_RESET_WAIT_MS);
if (i == IAVF_RESET_WAIT_COMPLETE_COUNT) {
dev_err(&adapter->pdev->dev, "Reset never finished (%x)\n",
reg_val);
iavf_disable_vf(adapter);
netdev_unlock(netdev); return; /* Do not attempt to reinit. It's dead, Jim. */
}
continue_reset: /* If we are still early in the state machine, just restart. */ if (adapter->state <= __IAVF_INIT_FAILED) {
iavf_shutdown_adminq(hw);
iavf_change_state(adapter, __IAVF_STARTUP);
iavf_startup(adapter);
queue_delayed_work(adapter->wq, &adapter->watchdog_task,
msecs_to_jiffies(30));
netdev_unlock(netdev); return;
}
/* We don't use netif_running() because it may be true prior to *ndo_open()returning,sowecan'tassumeitmeansallouropen *taskshavefinished,sincewe'renotholdingthertnl_lockhere.
*/
running = adapter->state == __IAVF_RUNNING;
/* free the Tx/Rx rings and descriptors, might be better to just *re-usethemsometimeinthefuture
*/
iavf_free_all_rx_resources(adapter);
iavf_free_all_tx_resources(adapter);
adapter->flags |= IAVF_FLAG_QUEUES_DISABLED; /* kill and reinit the admin queue */
iavf_shutdown_adminq(hw);
adapter->current_op = VIRTCHNL_OP_UNKNOWN;
status = iavf_init_adminq(hw); if (status) {
dev_info(&adapter->pdev->dev, "Failed to init adminq: %d\n",
status); goto reset_err;
}
adapter->aq_required = 0;
if ((adapter->flags & IAVF_FLAG_REINIT_MSIX_NEEDED) ||
(adapter->flags & IAVF_FLAG_REINIT_ITR_NEEDED)) {
err = iavf_reinit_interrupt_scheme(adapter, running); if (err) goto reset_err;
}
if (RSS_AQ(adapter)) {
adapter->aq_required |= IAVF_FLAG_AQ_CONFIGURE_RSS;
} else {
err = iavf_init_rss(adapter); if (err) goto reset_err;
}
/* Certain capabilities require an extended negotiation process using *extramessagesthatmustbeprocessedaftergettingtheVF *configuration.TherelatedcheckssuchasVLAN_V2_ALLOWED()arenot *reliablehere,sincetheconfigurationhasnotyetbeennegotiated. * *Alwayssettheseflags,sincethemrelatedVIRTCHNLmessageswon't *besentuntilafterVIRTCHNL_OP_GET_VF_RESOURCES.
*/
adapter->aq_required |= IAVF_FLAG_AQ_EXTENDED_CAPS;
spin_lock_bh(&adapter->mac_vlan_list_lock);
/* Delete filter for the current MAC address, it could have *beenchangedbythePFviaadministrativelysetMAC. *Willbere-addedviaVIRTCHNL_OP_GET_VF_RESOURCES.
*/
list_for_each_entry_safe(f, ftmp, &adapter->mac_filter_list, list) { if (ether_addr_equal(f->macaddr, adapter->hw.mac.addr)) {
list_del(&f->list);
kfree(f);
}
} /* re-add all MAC filters */
list_for_each_entry(f, &adapter->mac_filter_list, list) {
f->add = true;
}
spin_unlock_bh(&adapter->mac_vlan_list_lock);
/* check if TCs are running and re-add all cloud filters */
spin_lock_bh(&adapter->cloud_filter_list_lock); if ((vfres->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_ADQ) &&
adapter->num_tc) {
list_for_each_entry(cf, &adapter->cloud_filter_list, list) {
cf->add = true;
}
}
spin_unlock_bh(&adapter->cloud_filter_list_lock);
/* We were running when the reset started, so we need to restore some *statehere.
*/ if (running) { /* allocate transmit descriptors */
err = iavf_setup_all_tx_resources(adapter); if (err) goto reset_err;
for (i = 0; i < adapter->num_active_queues; i++) if (adapter->rx_rings[i].desc)
iavf_free_rx_resources(&adapter->rx_rings[i]);
}
/** *iavf_validate_tx_bandwidth-validatethemaxTxbandwidth *@adapter:boardprivatestructure *@max_tx_rate:maxTxbwforatc
**/ staticint iavf_validate_tx_bandwidth(struct iavf_adapter *adapter,
u64 max_tx_rate)
{ int speed = 0, ret = 0;
if (ADV_LINK_SUPPORT(adapter)) { if (adapter->link_speed_mbps < U32_MAX) {
speed = adapter->link_speed_mbps; goto validate_bw;
} else {
dev_err(&adapter->pdev->dev, "Unknown link speed\n"); return -EINVAL;
}
}
switch (adapter->link_speed) { case VIRTCHNL_LINK_SPEED_40GB:
speed = SPEED_40000; break; case VIRTCHNL_LINK_SPEED_25GB:
speed = SPEED_25000; break; case VIRTCHNL_LINK_SPEED_20GB:
speed = SPEED_20000; break; case VIRTCHNL_LINK_SPEED_10GB:
speed = SPEED_10000; break; case VIRTCHNL_LINK_SPEED_5GB:
speed = SPEED_5000; break; case VIRTCHNL_LINK_SPEED_2_5GB:
speed = SPEED_2500; break; case VIRTCHNL_LINK_SPEED_1GB:
speed = SPEED_1000; break; case VIRTCHNL_LINK_SPEED_100MB:
speed = SPEED_100; break; default: break;
}
validate_bw: if (max_tx_rate > speed) {
dev_err(&adapter->pdev->dev, "Invalid tx rate specified\n");
ret = -EINVAL;
}
return ret;
}
/** *iavf_validate_ch_config-validatequeuemappinginfo *@adapter:boardprivatestructure *@mqprio_qopt:queueparameters * *Thisfunctionvalidatesiftheconfigprovidedbytheuserto *configurequeuechannelsisvalidornot.Returns0onavalid *config.
**/ staticint iavf_validate_ch_config(struct iavf_adapter *adapter, struct tc_mqprio_qopt_offload *mqprio_qopt)
{
u64 total_max_rate = 0;
u32 tx_rate_rem = 0; int i, num_qps = 0;
u64 tx_rate = 0; int ret = 0;
if (mqprio_qopt->qopt.num_tc > IAVF_MAX_TRAFFIC_CLASS ||
mqprio_qopt->qopt.num_tc < 1) return -EINVAL;
for (i = 0; i <= mqprio_qopt->qopt.num_tc - 1; i++) { if (!mqprio_qopt->qopt.count[i] ||
mqprio_qopt->qopt.offset[i] != num_qps) return -EINVAL; if (mqprio_qopt->min_rate[i]) {
dev_err(&adapter->pdev->dev, "Invalid min tx rate (greater than 0) specified for TC%d\n",
i); return -EINVAL;
}
/* convert to Mbps */
tx_rate = div_u64(mqprio_qopt->max_rate[i],
IAVF_MBPS_DIVISOR);
if (mqprio_qopt->max_rate[i] &&
tx_rate < IAVF_MBPS_QUANTA) {
dev_err(&adapter->pdev->dev, "Invalid max tx rate for TC%d, minimum %dMbps\n",
i, IAVF_MBPS_QUANTA); return -EINVAL;
}
/* add queue channel */ if (mode == TC_MQPRIO_MODE_CHANNEL) { if (!(vfres->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_ADQ)) {
dev_err(&adapter->pdev->dev, "ADq not supported\n"); return -EOPNOTSUPP;
} if (adapter->ch_config.state != __IAVF_TC_INVALID) {
dev_err(&adapter->pdev->dev, "TC configuration already exists\n"); return -EINVAL;
}
ret = iavf_validate_ch_config(adapter, mqprio_qopt); if (ret) return ret; /* Return if same TC config is requested */ if (iavf_is_tc_config_same(adapter, &mqprio_qopt->qopt)) return0;
adapter->num_tc = num_tc;
for (i = 0; i < IAVF_MAX_TRAFFIC_CLASS; i++) { if (i < num_tc) {
adapter->ch_config.ch_info[i].count =
mqprio_qopt->qopt.count[i];
adapter->ch_config.ch_info[i].offset =
mqprio_qopt->qopt.offset[i];
total_qps += mqprio_qopt->qopt.count[i];
max_tx_rate = mqprio_qopt->max_rate[i]; /* convert to Mbps */
max_tx_rate = div_u64(max_tx_rate,
IAVF_MBPS_DIVISOR);
adapter->ch_config.ch_info[i].max_tx_rate =
max_tx_rate;
} else {
adapter->ch_config.ch_info[i].count = 1;
adapter->ch_config.ch_info[i].offset = 0;
}
}
/* Take snapshot of original config such as "num_active_queues" *ItisusedlaterwhendeleteADQflowisexercised,sothat *oncedeleteADQflowcompletes,VFshallgobacktoits *originalqueueconfiguration
*/
/* Store queue info based on TC so that VF gets configured *withcorrectnumberofqueueswhenVFcompletesADQconfig *flow
*/
adapter->ch_config.total_qps = total_qps;
netif_tx_stop_all_queues(netdev);
netif_tx_disable(netdev);
adapter->aq_required |= IAVF_FLAG_AQ_ENABLE_CHANNELS;
netdev_reset_tc(netdev); /* Report the tc mapping up the stack */
netdev_set_num_tc(adapter->netdev, num_tc); for (i = 0; i < IAVF_MAX_TRAFFIC_CLASS; i++) {
u16 qcount = mqprio_qopt->qopt.count[i];
u16 qoffset = mqprio_qopt->qopt.offset[i];
if (i < num_tc)
netdev_set_tc_queue(netdev, netdev_tc++, qcount,
qoffset);
}
} exit: if (test_bit(__IAVF_IN_REMOVE_TASK, &adapter->crit_section)) return0;
if (n_proto_key == ETH_P_ALL) {
n_proto_key = 0;
n_proto_mask = 0;
}
n_proto = n_proto_key & n_proto_mask; if (n_proto != ETH_P_IP && n_proto != ETH_P_IPV6) return -EINVAL; if (n_proto == ETH_P_IPV6) { /* specify flow type as TCP IPv6 */
vf->flow_type = VIRTCHNL_TCP_V6_FLOW;
}
if (match.key->ip_proto != IPPROTO_TCP) {
dev_info(&adapter->pdev->dev, "Only TCP transport is supported\n"); return -EINVAL;
}
}
if (flow_rule_match_key(rule, FLOW_DISSECTOR_KEY_ETH_ADDRS)) { struct flow_match_eth_addrs match;
flow_rule_match_eth_addrs(rule, &match);
/* use is_broadcast and is_zero to check for all 0xf or 0 */ if (!is_zero_ether_addr(match.mask->dst)) { if (is_broadcast_ether_addr(match.mask->dst)) {
field_flags |= IAVF_CLOUD_FIELD_OMAC;
} else {
dev_err(&adapter->pdev->dev, "Bad ether dest mask %pM\n",
match.mask->dst); return -EINVAL;
}
}
if (!is_zero_ether_addr(match.key->dst)) if (is_valid_ether_addr(match.key->dst) ||
is_multicast_ether_addr(match.key->dst)) { /* set the mask if a valid dst_mac address */ for (i = 0; i < ETH_ALEN; i++)
vf->mask.tcp_spec.dst_mac[i] |= 0xff;
ether_addr_copy(vf->data.tcp_spec.dst_mac,
match.key->dst);
}
if (!is_zero_ether_addr(match.key->src)) if (is_valid_ether_addr(match.key->src) ||
is_multicast_ether_addr(match.key->src)) { /* set the mask if a valid dst_mac address */ for (i = 0; i < ETH_ALEN; i++)
vf->mask.tcp_spec.src_mac[i] |= 0xff;
ether_addr_copy(vf->data.tcp_spec.src_mac,
match.key->src);
}
}
if (flow_rule_match_key(rule, FLOW_DISSECTOR_KEY_VLAN)) { struct flow_match_vlan match;
if (flow_rule_has_control_flags(match.mask->flags,
f->common.extack)) return -EOPNOTSUPP;
}
if (addr_type == FLOW_DISSECTOR_KEY_IPV4_ADDRS) { struct flow_match_ipv4_addrs match;
flow_rule_match_ipv4_addrs(rule, &match); if (match.mask->dst) { if (match.mask->dst == cpu_to_be32(0xffffffff)) {
field_flags |= IAVF_CLOUD_FIELD_IIP;
} else {
dev_err(&adapter->pdev->dev, "Bad ip dst mask 0x%08x\n",
be32_to_cpu(match.mask->dst)); return -EINVAL;
}
}
if (match.mask->src) { if (match.mask->src == cpu_to_be32(0xffffffff)) {
field_flags |= IAVF_CLOUD_FIELD_IIP;
} else {
dev_err(&adapter->pdev->dev, "Bad ip src mask 0x%08x\n",
be32_to_cpu(match.mask->src)); return -EINVAL;
}
}
if (field_flags & IAVF_CLOUD_FIELD_TEN_ID) {
dev_info(&adapter->pdev->dev, "Tenant id not allowed for ip filter\n"); return -EINVAL;
} if (match.key->dst) {
vf->mask.tcp_spec.dst_ip[0] |= cpu_to_be32(0xffffffff);
vf->data.tcp_spec.dst_ip[0] = match.key->dst;
} if (match.key->src) {
vf->mask.tcp_spec.src_ip[0] |= cpu_to_be32(0xffffffff);
vf->data.tcp_spec.src_ip[0] = match.key->src;
}
}
if (addr_type == FLOW_DISSECTOR_KEY_IPV6_ADDRS) { struct flow_match_ipv6_addrs match;
flow_rule_match_ipv6_addrs(rule, &match);
/* validate mask, make sure it is not IPV6_ADDR_ANY */ if (ipv6_addr_any(&match.mask->dst)) {
dev_err(&adapter->pdev->dev, "Bad ipv6 dst mask 0x%02x\n",
IPV6_ADDR_ANY); return -EINVAL;
}
/* src and dest IPv6 address should not be LOOPBACK *(0:0:0:0:0:0:0:1)whichcanberepresentedas::1
*/ if (ipv6_addr_loopback(&match.key->dst) ||
ipv6_addr_loopback(&match.key->src)) {
dev_err(&adapter->pdev->dev, "ipv6 addr should not be loopback\n"); return -EINVAL;
} if (!ipv6_addr_any(&match.mask->dst) ||
!ipv6_addr_any(&match.mask->src))
field_flags |= IAVF_CLOUD_FIELD_IIP;
for (i = 0; i < 4; i++)
vf->mask.tcp_spec.dst_ip[i] |= cpu_to_be32(0xffffffff);
memcpy(&vf->data.tcp_spec.dst_ip, &match.key->dst.s6_addr32, sizeof(vf->data.tcp_spec.dst_ip)); for (i = 0; i < 4; i++)
vf->mask.tcp_spec.src_ip[i] |= cpu_to_be32(0xffffffff);
memcpy(&vf->data.tcp_spec.src_ip, &match.key->src.s6_addr32, sizeof(vf->data.tcp_spec.src_ip));
} if (flow_rule_match_key(rule, FLOW_DISSECTOR_KEY_PORTS)) { struct flow_match_ports match;
flow_rule_match_ports(rule, &match); if (match.mask->src) { if (match.mask->src == cpu_to_be16(0xffff)) {
field_flags |= IAVF_CLOUD_FIELD_IIP;
} else {
dev_err(&adapter->pdev->dev, "Bad src port mask %u\n",
be16_to_cpu(match.mask->src)); return -EINVAL;
}
}
if (match.mask->dst) { if (match.mask->dst == cpu_to_be16(0xffff)) {
field_flags |= IAVF_CLOUD_FIELD_IIP;
} else {
dev_err(&adapter->pdev->dev, "Bad dst port mask %u\n",
be16_to_cpu(match.mask->dst)); return -EINVAL;
}
} if (match.key->dst) {
vf->mask.tcp_spec.dst_port |= cpu_to_be16(0xffff);
vf->data.tcp_spec.dst_port = match.key->dst;
}
/** *iavf_handle_tclass-Forwardtoatrafficclassonthedevice *@adapter:boardprivatestructure *@tc:trafficclassindexonthedevice *@filter:pointertocloudfilterstructure
*/ staticint iavf_handle_tclass(struct iavf_adapter *adapter, u32 tc, struct iavf_cloud_filter *filter)
{ if (tc == 0) return0; if (tc < adapter->num_tc) { if (!filter->f.data.tcp_spec.dst_port) {
dev_err(&adapter->pdev->dev, "Specify destination port to redirect to traffic class other than TC0\n"); return -EINVAL;
}
} /* redirect to a traffic class on the same device */
filter->f.action = VIRTCHNL_ACTION_TC_REDIRECT;
filter->f.action_meta = tc; return0;
}
/* bail out here if filter already exists */
spin_lock_bh(&adapter->cloud_filter_list_lock); if (iavf_find_cf(adapter, &cls_flower->cookie)) {
dev_err(&adapter->pdev->dev, "Failed to add TC Flower filter, it already exists\n");
err = -EEXIST; goto spin_unlock;
}
spin_unlock_bh(&adapter->cloud_filter_list_lock);
/* set the mask to all zeroes to begin with */
memset(&filter->f.mask.tcp_spec, 0, sizeof(struct virtchnl_l4_spec)); /* start out with flow type and eth type IPv4 to begin with */
filter->f.flow_type = VIRTCHNL_TCP_V4_FLOW;
err = iavf_parse_cls_flower(adapter, cls_flower, filter); if (err) goto err;
err = iavf_handle_tclass(adapter, tc, filter); if (err) goto err;
/* add filter to the list */
spin_lock_bh(&adapter->cloud_filter_list_lock);
list_add_tail(&filter->list, &adapter->cloud_filter_list);
adapter->num_cloud_filters++;
filter->add = true;
adapter->aq_required |= IAVF_FLAG_AQ_ADD_CLOUD_FILTER;
spin_unlock:
spin_unlock_bh(&adapter->cloud_filter_list_lock);
err: if (err)
kfree(filter);
/* The parser lib at the PF expects the packet starting with MAC hdr */ switch (ntohs(cls_u32->common.protocol)) { case ETH_P_802_3: break; case ETH_P_IP:
spec_h = (struct ethhdr *)hdrs->raw.spec;
mask_h = (struct ethhdr *)hdrs->raw.mask;
spec_h->h_proto = htons(ETH_P_IP);
mask_h->h_proto = htons(0xFFFF);
off_base += ETH_HLEN; break; default:
NL_SET_ERR_MSG_MOD(extack, "Only 802_3 and ip filter protocols are supported");
status = -EOPNOTSUPP; goto free_alloc;
}
for (i = 0; i < cls_u32->knode.sel->nkeys; i++) {
__be32 val, mask; int off;
off = off_base + cls_u32->knode.sel->keys[i].off;
val = cls_u32->knode.sel->keys[i].val;
mask = cls_u32->knode.sel->keys[i].mask;
if (off >= sizeof(hdrs->raw.spec)) {
NL_SET_ERR_MSG_MOD(extack, "Input exceeds maximum allowed.");
status = -EINVAL; goto free_alloc;
}
/* Remove flags which we do not want to send after close or we want to *sendbeforedisablequeues.
*/
aq_to_restore &= ~(IAVF_FLAG_AQ_GET_CONFIG |
IAVF_FLAG_AQ_ENABLE_QUEUES |
IAVF_FLAG_AQ_CONFIGURE_QUEUES |
IAVF_FLAG_AQ_ADD_VLAN_FILTER |
IAVF_FLAG_AQ_ADD_MAC_FILTER |
IAVF_FLAG_AQ_ADD_CLOUD_FILTER |
IAVF_FLAG_AQ_ADD_FDIR_FILTER |
IAVF_FLAG_AQ_ADD_ADV_RSS_CFG);
/* We explicitly don't free resources here because the hardware is *stillactiveandcanDMAintomemory.Resourcesareclearedin *iavf_virtchnl_completion()afterwegetconfirmationfromthePF *driverthattheringshavebeenstopped. * *Also,wewaitforstatetotransitionto__IAVF_DOWNbefore *returning.Statechangeoccursiniavf_virtchnl_completion()after *VFresourcesarereleased(whichoccursafterPFdriverprocessesand *respondstoadminqueuecommands).
*/
status = wait_event_timeout(adapter->down_waitqueue,
adapter->state == __IAVF_DOWN,
msecs_to_jiffies(500)); if (!status)
netdev_warn(netdev, "Device resources not yet released\n");
netdev_lock(netdev);
adapter->aq_required |= aq_to_restore;
return0;
}
/** *iavf_change_mtu-ChangetheMaximumTransferUnit *@netdev:networkinterfacedevicestructure *@new_mtu:newvalueformaximumframesize * *Returns0onsuccess,negativeonfailure
**/ staticint iavf_change_mtu(struct net_device *netdev, int new_mtu)
{ struct iavf_adapter *adapter = netdev_priv(netdev); int ret = 0;
netdev_dbg(netdev, "changing MTU from %d to %d\n",
netdev->mtu, new_mtu);
WRITE_ONCE(netdev->mtu, new_mtu);
if (netif_running(netdev)) {
iavf_schedule_reset(adapter, IAVF_FLAG_RESET_NEEDED);
ret = iavf_wait_for_reset(adapter); if (ret < 0)
netdev_warn(netdev, "MTU change interrupted waiting for reset"); elseif (ret)
netdev_warn(netdev, "MTU change timed out waiting for reset");
}
/* No point in doing any of this if neither checksum nor GSO are *beingrequestedforthisframe.Wecanruleoutbothbyjust *checkingforCHECKSUM_PARTIAL
*/ if (skb->ip_summed != CHECKSUM_PARTIAL) return features;
/* We cannot support GSO if the MSS is going to be less than *64bytes.IfitisthenweneedtodropsupportforGSO.
*/ if (skb_is_gso(skb) && (skb_shinfo(skb)->gso_size < 64))
features &= ~NETIF_F_GSO_MASK;
/* MACLEN can support at most 63 words */
len = skb_network_offset(skb); if (len & ~(63 * 2)) goto out_err;
/* IPLEN and EIPLEN can support at most 127 dwords */
len = skb_network_header_len(skb); if (len & ~(127 * 4)) goto out_err;
if (skb->encapsulation) { /* L4TUNLEN can support 127 words */
len = skb_inner_network_header(skb) - skb_transport_header(skb); if (len & ~(127 * 2)) goto out_err;
/* IPLEN can support at most 127 dwords */
len = skb_inner_transport_header(skb) -
skb_inner_network_header(skb); if (len & ~(127 * 4)) goto out_err;
}
/* No need to validate L4LEN as TCP is the only protocol with a *flexiblevalueandwesupportallpossiblevaluessupported *byTCP,whichisatmost15dwords
*/
return features;
out_err: return features & ~(NETIF_F_CSUM_MASK | NETIF_F_GSO_MASK);
}
if (!num_non_zero_vlan && (netdev->features & vlan_strip) &&
!(netdev->features & NETIF_F_RXFCS) && is_vlan_strip) {
requested_features &= ~vlan_strip;
netdev_info(netdev, "Disabling VLAN stripping as FCS/CRC stripping is also disabled and there is no VLAN configured\n"); return requested_features;
}
if ((netdev->features & NETIF_F_RXFCS) && is_vlan_strip) {
requested_features &= ~vlan_strip; if (!(netdev->features & vlan_strip))
netdev_info(netdev, "To enable VLAN stripping, first need to enable FCS/CRC stripping");
return requested_features;
}
if (num_non_zero_vlan && is_vlan_strip &&
!(netdev->features & NETIF_F_RXFCS)) {
requested_features &= ~NETIF_F_RXFCS;
netdev_info(netdev, "To disable FCS/CRC stripping, first need to disable VLAN stripping");
}
/* advertise to stack only if offloads for encapsulated packets is *supported
*/ if (vfres->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_ENCAP) {
hw_enc_features |= NETIF_F_GSO_UDP_TUNNEL |
NETIF_F_GSO_GRE |
NETIF_F_GSO_GRE_CSUM |
NETIF_F_GSO_IPXIP4 |
NETIF_F_GSO_IPXIP6 |
NETIF_F_GSO_UDP_TUNNEL_CSUM |
NETIF_F_GSO_PARTIAL | 0;
if (!(vfres->vf_cap_flags &
VIRTCHNL_VF_OFFLOAD_ENCAP_CSUM))
netdev->gso_partial_features |=
NETIF_F_GSO_UDP_TUNNEL_CSUM;
netdev->gso_partial_features |= NETIF_F_GSO_GRE_CSUM;
netdev->hw_enc_features |= NETIF_F_TSO_MANGLEID;
netdev->hw_enc_features |= hw_enc_features;
} /* record features VLANs can make use of */
netdev->vlan_features |= hw_enc_features | NETIF_F_TSO_MANGLEID;
/* Write features and hw_features separately to avoid polluting *with,ordropping,featuresthataresetwhenweregistered.
*/
hw_features = hw_enc_features;
/* get HW VLAN features that can be toggled */
hw_vlan_features = iavf_get_netdev_vlan_hw_features(adapter);
/* Enable HW TC offload if ADQ or tc U32 is supported */ if (vfres->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_ADQ ||
TC_U32_SUPPORT(adapter))
hw_features |= NETIF_F_HW_TC;
if (vfres->vf_cap_flags & VIRTCHNL_VF_OFFLOAD_USO)
hw_features |= NETIF_F_GSO_UDP_L4;
/* Do not turn on offloads when they are requested to be turned off. *TSOneedsminimum576bytestoworkcorrectly.
*/ if (netdev->wanted_features) { if (!(netdev->wanted_features & NETIF_F_TSO) ||
netdev->mtu < 576)
netdev->features &= ~NETIF_F_TSO; if (!(netdev->wanted_features & NETIF_F_TSO6) ||
netdev->mtu < 576)
netdev->features &= ~NETIF_F_TSO6; if (!(netdev->wanted_features & NETIF_F_TSO_ECN))
netdev->features &= ~NETIF_F_TSO_ECN; if (!(netdev->wanted_features & NETIF_F_GRO))
netdev->features &= ~NETIF_F_GRO; if (!(netdev->wanted_features & NETIF_F_GSO))
netdev->features &= ~NETIF_F_GSO;
}
queue_delayed_work(adapter->wq, &adapter->watchdog_task,
msecs_to_jiffies(5 * (pdev->devfn & 0x07))); /* Initialization goes on in the work. Do not add more of it below. */ return0;
if (test_and_set_bit(__IAVF_IN_REMOVE_TASK, &adapter->crit_section)) return;
/* Wait until port initialization is complete. *Thereareflowswhereregister/unregisternetdevmayrace.
*/ while (1) {
netdev_lock(netdev); if (adapter->state == __IAVF_RUNNING ||
adapter->state == __IAVF_DOWN ||
adapter->state == __IAVF_INIT_FAILED) {
netdev_unlock(netdev); break;
} /* Simply return if we already went through iavf_shutdown */ if (adapter->state == __IAVF_REMOVE) {
netdev_unlock(netdev); return;
}
iavf_request_reset(adapter);
msleep(50); /* If the FW isn't responding, kick it once, but only once. */ if (!iavf_asq_done(hw)) {
iavf_request_reset(adapter);
msleep(50);
}
iavf_ptp_release(adapter);
iavf_misc_irq_disable(adapter); /* Shut down all the garbage mashers on the detention level */
netdev_unlock(netdev);
cancel_work_sync(&adapter->reset_task);
cancel_delayed_work_sync(&adapter->watchdog_task);
cancel_work_sync(&adapter->adminq_task);
netdev_lock(netdev);
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung und die Messung sind noch experimentell.