vmxnet3_drv.c 87 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307
  1. /*
  2. * Linux driver for VMware's vmxnet3 ethernet NIC.
  3. *
  4. * Copyright (C) 2008-2009, VMware, Inc. All Rights Reserved.
  5. *
  6. * This program is free software; you can redistribute it and/or modify it
  7. * under the terms of the GNU General Public License as published by the
  8. * Free Software Foundation; version 2 of the License and no later version.
  9. *
  10. * This program is distributed in the hope that it will be useful, but
  11. * WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE, GOOD TITLE or
  13. * NON INFRINGEMENT. See the GNU General Public License for more
  14. * details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program; if not, write to the Free Software
  18. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  19. *
  20. * The full GNU General Public License is included in this distribution in
  21. * the file called "COPYING".
  22. *
  23. * Maintained by: Shreyas Bhatewara <pv-drivers@vmware.com>
  24. *
  25. */
  26. #include <net/ip6_checksum.h>
  27. #include "vmxnet3_int.h"
  28. char vmxnet3_driver_name[] = "vmxnet3";
  29. #define VMXNET3_DRIVER_DESC "VMware vmxnet3 virtual NIC driver"
  30. /*
  31. * PCI Device ID Table
  32. * Last entry must be all 0s
  33. */
  34. static DEFINE_PCI_DEVICE_TABLE(vmxnet3_pciid_table) = {
  35. {PCI_VDEVICE(VMWARE, PCI_DEVICE_ID_VMWARE_VMXNET3)},
  36. {0}
  37. };
  38. MODULE_DEVICE_TABLE(pci, vmxnet3_pciid_table);
  39. static atomic_t devices_found;
  40. #define VMXNET3_MAX_DEVICES 10
  41. static int enable_mq = 1;
  42. static int irq_share_mode;
  43. static void
  44. vmxnet3_write_mac_addr(struct vmxnet3_adapter *adapter, u8 *mac);
  45. /*
  46. * Enable/Disable the given intr
  47. */
  48. static void
  49. vmxnet3_enable_intr(struct vmxnet3_adapter *adapter, unsigned intr_idx)
  50. {
  51. VMXNET3_WRITE_BAR0_REG(adapter, VMXNET3_REG_IMR + intr_idx * 8, 0);
  52. }
  53. static void
  54. vmxnet3_disable_intr(struct vmxnet3_adapter *adapter, unsigned intr_idx)
  55. {
  56. VMXNET3_WRITE_BAR0_REG(adapter, VMXNET3_REG_IMR + intr_idx * 8, 1);
  57. }
  58. /*
  59. * Enable/Disable all intrs used by the device
  60. */
  61. static void
  62. vmxnet3_enable_all_intrs(struct vmxnet3_adapter *adapter)
  63. {
  64. int i;
  65. for (i = 0; i < adapter->intr.num_intrs; i++)
  66. vmxnet3_enable_intr(adapter, i);
  67. adapter->shared->devRead.intrConf.intrCtrl &=
  68. cpu_to_le32(~VMXNET3_IC_DISABLE_ALL);
  69. }
  70. static void
  71. vmxnet3_disable_all_intrs(struct vmxnet3_adapter *adapter)
  72. {
  73. int i;
  74. adapter->shared->devRead.intrConf.intrCtrl |=
  75. cpu_to_le32(VMXNET3_IC_DISABLE_ALL);
  76. for (i = 0; i < adapter->intr.num_intrs; i++)
  77. vmxnet3_disable_intr(adapter, i);
  78. }
  79. static void
  80. vmxnet3_ack_events(struct vmxnet3_adapter *adapter, u32 events)
  81. {
  82. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_ECR, events);
  83. }
  84. static bool
  85. vmxnet3_tq_stopped(struct vmxnet3_tx_queue *tq, struct vmxnet3_adapter *adapter)
  86. {
  87. return tq->stopped;
  88. }
  89. static void
  90. vmxnet3_tq_start(struct vmxnet3_tx_queue *tq, struct vmxnet3_adapter *adapter)
  91. {
  92. tq->stopped = false;
  93. netif_start_subqueue(adapter->netdev, tq - adapter->tx_queue);
  94. }
  95. static void
  96. vmxnet3_tq_wake(struct vmxnet3_tx_queue *tq, struct vmxnet3_adapter *adapter)
  97. {
  98. tq->stopped = false;
  99. netif_wake_subqueue(adapter->netdev, (tq - adapter->tx_queue));
  100. }
  101. static void
  102. vmxnet3_tq_stop(struct vmxnet3_tx_queue *tq, struct vmxnet3_adapter *adapter)
  103. {
  104. tq->stopped = true;
  105. tq->num_stop++;
  106. netif_stop_subqueue(adapter->netdev, (tq - adapter->tx_queue));
  107. }
  108. /*
  109. * Check the link state. This may start or stop the tx queue.
  110. */
  111. static void
  112. vmxnet3_check_link(struct vmxnet3_adapter *adapter, bool affectTxQueue)
  113. {
  114. u32 ret;
  115. int i;
  116. unsigned long flags;
  117. spin_lock_irqsave(&adapter->cmd_lock, flags);
  118. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD, VMXNET3_CMD_GET_LINK);
  119. ret = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_CMD);
  120. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  121. adapter->link_speed = ret >> 16;
  122. if (ret & 1) { /* Link is up. */
  123. printk(KERN_INFO "%s: NIC Link is Up %d Mbps\n",
  124. adapter->netdev->name, adapter->link_speed);
  125. if (!netif_carrier_ok(adapter->netdev))
  126. netif_carrier_on(adapter->netdev);
  127. if (affectTxQueue) {
  128. for (i = 0; i < adapter->num_tx_queues; i++)
  129. vmxnet3_tq_start(&adapter->tx_queue[i],
  130. adapter);
  131. }
  132. } else {
  133. printk(KERN_INFO "%s: NIC Link is Down\n",
  134. adapter->netdev->name);
  135. if (netif_carrier_ok(adapter->netdev))
  136. netif_carrier_off(adapter->netdev);
  137. if (affectTxQueue) {
  138. for (i = 0; i < adapter->num_tx_queues; i++)
  139. vmxnet3_tq_stop(&adapter->tx_queue[i], adapter);
  140. }
  141. }
  142. }
  143. static void
  144. vmxnet3_process_events(struct vmxnet3_adapter *adapter)
  145. {
  146. int i;
  147. unsigned long flags;
  148. u32 events = le32_to_cpu(adapter->shared->ecr);
  149. if (!events)
  150. return;
  151. vmxnet3_ack_events(adapter, events);
  152. /* Check if link state has changed */
  153. if (events & VMXNET3_ECR_LINK)
  154. vmxnet3_check_link(adapter, true);
  155. /* Check if there is an error on xmit/recv queues */
  156. if (events & (VMXNET3_ECR_TQERR | VMXNET3_ECR_RQERR)) {
  157. spin_lock_irqsave(&adapter->cmd_lock, flags);
  158. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  159. VMXNET3_CMD_GET_QUEUE_STATUS);
  160. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  161. for (i = 0; i < adapter->num_tx_queues; i++)
  162. if (adapter->tqd_start[i].status.stopped)
  163. dev_err(&adapter->netdev->dev,
  164. "%s: tq[%d] error 0x%x\n",
  165. adapter->netdev->name, i, le32_to_cpu(
  166. adapter->tqd_start[i].status.error));
  167. for (i = 0; i < adapter->num_rx_queues; i++)
  168. if (adapter->rqd_start[i].status.stopped)
  169. dev_err(&adapter->netdev->dev,
  170. "%s: rq[%d] error 0x%x\n",
  171. adapter->netdev->name, i,
  172. adapter->rqd_start[i].status.error);
  173. schedule_work(&adapter->work);
  174. }
  175. }
  176. #ifdef __BIG_ENDIAN_BITFIELD
  177. /*
  178. * The device expects the bitfields in shared structures to be written in
  179. * little endian. When CPU is big endian, the following routines are used to
  180. * correctly read and write into ABI.
  181. * The general technique used here is : double word bitfields are defined in
  182. * opposite order for big endian architecture. Then before reading them in
  183. * driver the complete double word is translated using le32_to_cpu. Similarly
  184. * After the driver writes into bitfields, cpu_to_le32 is used to translate the
  185. * double words into required format.
  186. * In order to avoid touching bits in shared structure more than once, temporary
  187. * descriptors are used. These are passed as srcDesc to following functions.
  188. */
  189. static void vmxnet3_RxDescToCPU(const struct Vmxnet3_RxDesc *srcDesc,
  190. struct Vmxnet3_RxDesc *dstDesc)
  191. {
  192. u32 *src = (u32 *)srcDesc + 2;
  193. u32 *dst = (u32 *)dstDesc + 2;
  194. dstDesc->addr = le64_to_cpu(srcDesc->addr);
  195. *dst = le32_to_cpu(*src);
  196. dstDesc->ext1 = le32_to_cpu(srcDesc->ext1);
  197. }
  198. static void vmxnet3_TxDescToLe(const struct Vmxnet3_TxDesc *srcDesc,
  199. struct Vmxnet3_TxDesc *dstDesc)
  200. {
  201. int i;
  202. u32 *src = (u32 *)(srcDesc + 1);
  203. u32 *dst = (u32 *)(dstDesc + 1);
  204. /* Working backwards so that the gen bit is set at the end. */
  205. for (i = 2; i > 0; i--) {
  206. src--;
  207. dst--;
  208. *dst = cpu_to_le32(*src);
  209. }
  210. }
  211. static void vmxnet3_RxCompToCPU(const struct Vmxnet3_RxCompDesc *srcDesc,
  212. struct Vmxnet3_RxCompDesc *dstDesc)
  213. {
  214. int i = 0;
  215. u32 *src = (u32 *)srcDesc;
  216. u32 *dst = (u32 *)dstDesc;
  217. for (i = 0; i < sizeof(struct Vmxnet3_RxCompDesc) / sizeof(u32); i++) {
  218. *dst = le32_to_cpu(*src);
  219. src++;
  220. dst++;
  221. }
  222. }
  223. /* Used to read bitfield values from double words. */
  224. static u32 get_bitfield32(const __le32 *bitfield, u32 pos, u32 size)
  225. {
  226. u32 temp = le32_to_cpu(*bitfield);
  227. u32 mask = ((1 << size) - 1) << pos;
  228. temp &= mask;
  229. temp >>= pos;
  230. return temp;
  231. }
  232. #endif /* __BIG_ENDIAN_BITFIELD */
  233. #ifdef __BIG_ENDIAN_BITFIELD
  234. # define VMXNET3_TXDESC_GET_GEN(txdesc) get_bitfield32(((const __le32 *) \
  235. txdesc) + VMXNET3_TXD_GEN_DWORD_SHIFT, \
  236. VMXNET3_TXD_GEN_SHIFT, VMXNET3_TXD_GEN_SIZE)
  237. # define VMXNET3_TXDESC_GET_EOP(txdesc) get_bitfield32(((const __le32 *) \
  238. txdesc) + VMXNET3_TXD_EOP_DWORD_SHIFT, \
  239. VMXNET3_TXD_EOP_SHIFT, VMXNET3_TXD_EOP_SIZE)
  240. # define VMXNET3_TCD_GET_GEN(tcd) get_bitfield32(((const __le32 *)tcd) + \
  241. VMXNET3_TCD_GEN_DWORD_SHIFT, VMXNET3_TCD_GEN_SHIFT, \
  242. VMXNET3_TCD_GEN_SIZE)
  243. # define VMXNET3_TCD_GET_TXIDX(tcd) get_bitfield32((const __le32 *)tcd, \
  244. VMXNET3_TCD_TXIDX_SHIFT, VMXNET3_TCD_TXIDX_SIZE)
  245. # define vmxnet3_getRxComp(dstrcd, rcd, tmp) do { \
  246. (dstrcd) = (tmp); \
  247. vmxnet3_RxCompToCPU((rcd), (tmp)); \
  248. } while (0)
  249. # define vmxnet3_getRxDesc(dstrxd, rxd, tmp) do { \
  250. (dstrxd) = (tmp); \
  251. vmxnet3_RxDescToCPU((rxd), (tmp)); \
  252. } while (0)
  253. #else
  254. # define VMXNET3_TXDESC_GET_GEN(txdesc) ((txdesc)->gen)
  255. # define VMXNET3_TXDESC_GET_EOP(txdesc) ((txdesc)->eop)
  256. # define VMXNET3_TCD_GET_GEN(tcd) ((tcd)->gen)
  257. # define VMXNET3_TCD_GET_TXIDX(tcd) ((tcd)->txdIdx)
  258. # define vmxnet3_getRxComp(dstrcd, rcd, tmp) (dstrcd) = (rcd)
  259. # define vmxnet3_getRxDesc(dstrxd, rxd, tmp) (dstrxd) = (rxd)
  260. #endif /* __BIG_ENDIAN_BITFIELD */
  261. static void
  262. vmxnet3_unmap_tx_buf(struct vmxnet3_tx_buf_info *tbi,
  263. struct pci_dev *pdev)
  264. {
  265. if (tbi->map_type == VMXNET3_MAP_SINGLE)
  266. pci_unmap_single(pdev, tbi->dma_addr, tbi->len,
  267. PCI_DMA_TODEVICE);
  268. else if (tbi->map_type == VMXNET3_MAP_PAGE)
  269. pci_unmap_page(pdev, tbi->dma_addr, tbi->len,
  270. PCI_DMA_TODEVICE);
  271. else
  272. BUG_ON(tbi->map_type != VMXNET3_MAP_NONE);
  273. tbi->map_type = VMXNET3_MAP_NONE; /* to help debugging */
  274. }
  275. static int
  276. vmxnet3_unmap_pkt(u32 eop_idx, struct vmxnet3_tx_queue *tq,
  277. struct pci_dev *pdev, struct vmxnet3_adapter *adapter)
  278. {
  279. struct sk_buff *skb;
  280. int entries = 0;
  281. /* no out of order completion */
  282. BUG_ON(tq->buf_info[eop_idx].sop_idx != tq->tx_ring.next2comp);
  283. BUG_ON(VMXNET3_TXDESC_GET_EOP(&(tq->tx_ring.base[eop_idx].txd)) != 1);
  284. skb = tq->buf_info[eop_idx].skb;
  285. BUG_ON(skb == NULL);
  286. tq->buf_info[eop_idx].skb = NULL;
  287. VMXNET3_INC_RING_IDX_ONLY(eop_idx, tq->tx_ring.size);
  288. while (tq->tx_ring.next2comp != eop_idx) {
  289. vmxnet3_unmap_tx_buf(tq->buf_info + tq->tx_ring.next2comp,
  290. pdev);
  291. /* update next2comp w/o tx_lock. Since we are marking more,
  292. * instead of less, tx ring entries avail, the worst case is
  293. * that the tx routine incorrectly re-queues a pkt due to
  294. * insufficient tx ring entries.
  295. */
  296. vmxnet3_cmd_ring_adv_next2comp(&tq->tx_ring);
  297. entries++;
  298. }
  299. dev_kfree_skb_any(skb);
  300. return entries;
  301. }
  302. static int
  303. vmxnet3_tq_tx_complete(struct vmxnet3_tx_queue *tq,
  304. struct vmxnet3_adapter *adapter)
  305. {
  306. int completed = 0;
  307. union Vmxnet3_GenericDesc *gdesc;
  308. gdesc = tq->comp_ring.base + tq->comp_ring.next2proc;
  309. while (VMXNET3_TCD_GET_GEN(&gdesc->tcd) == tq->comp_ring.gen) {
  310. completed += vmxnet3_unmap_pkt(VMXNET3_TCD_GET_TXIDX(
  311. &gdesc->tcd), tq, adapter->pdev,
  312. adapter);
  313. vmxnet3_comp_ring_adv_next2proc(&tq->comp_ring);
  314. gdesc = tq->comp_ring.base + tq->comp_ring.next2proc;
  315. }
  316. if (completed) {
  317. spin_lock(&tq->tx_lock);
  318. if (unlikely(vmxnet3_tq_stopped(tq, adapter) &&
  319. vmxnet3_cmd_ring_desc_avail(&tq->tx_ring) >
  320. VMXNET3_WAKE_QUEUE_THRESHOLD(tq) &&
  321. netif_carrier_ok(adapter->netdev))) {
  322. vmxnet3_tq_wake(tq, adapter);
  323. }
  324. spin_unlock(&tq->tx_lock);
  325. }
  326. return completed;
  327. }
  328. static void
  329. vmxnet3_tq_cleanup(struct vmxnet3_tx_queue *tq,
  330. struct vmxnet3_adapter *adapter)
  331. {
  332. int i;
  333. while (tq->tx_ring.next2comp != tq->tx_ring.next2fill) {
  334. struct vmxnet3_tx_buf_info *tbi;
  335. union Vmxnet3_GenericDesc *gdesc;
  336. tbi = tq->buf_info + tq->tx_ring.next2comp;
  337. gdesc = tq->tx_ring.base + tq->tx_ring.next2comp;
  338. vmxnet3_unmap_tx_buf(tbi, adapter->pdev);
  339. if (tbi->skb) {
  340. dev_kfree_skb_any(tbi->skb);
  341. tbi->skb = NULL;
  342. }
  343. vmxnet3_cmd_ring_adv_next2comp(&tq->tx_ring);
  344. }
  345. /* sanity check, verify all buffers are indeed unmapped and freed */
  346. for (i = 0; i < tq->tx_ring.size; i++) {
  347. BUG_ON(tq->buf_info[i].skb != NULL ||
  348. tq->buf_info[i].map_type != VMXNET3_MAP_NONE);
  349. }
  350. tq->tx_ring.gen = VMXNET3_INIT_GEN;
  351. tq->tx_ring.next2fill = tq->tx_ring.next2comp = 0;
  352. tq->comp_ring.gen = VMXNET3_INIT_GEN;
  353. tq->comp_ring.next2proc = 0;
  354. }
  355. static void
  356. vmxnet3_tq_destroy(struct vmxnet3_tx_queue *tq,
  357. struct vmxnet3_adapter *adapter)
  358. {
  359. if (tq->tx_ring.base) {
  360. pci_free_consistent(adapter->pdev, tq->tx_ring.size *
  361. sizeof(struct Vmxnet3_TxDesc),
  362. tq->tx_ring.base, tq->tx_ring.basePA);
  363. tq->tx_ring.base = NULL;
  364. }
  365. if (tq->data_ring.base) {
  366. pci_free_consistent(adapter->pdev, tq->data_ring.size *
  367. sizeof(struct Vmxnet3_TxDataDesc),
  368. tq->data_ring.base, tq->data_ring.basePA);
  369. tq->data_ring.base = NULL;
  370. }
  371. if (tq->comp_ring.base) {
  372. pci_free_consistent(adapter->pdev, tq->comp_ring.size *
  373. sizeof(struct Vmxnet3_TxCompDesc),
  374. tq->comp_ring.base, tq->comp_ring.basePA);
  375. tq->comp_ring.base = NULL;
  376. }
  377. kfree(tq->buf_info);
  378. tq->buf_info = NULL;
  379. }
  380. /* Destroy all tx queues */
  381. void
  382. vmxnet3_tq_destroy_all(struct vmxnet3_adapter *adapter)
  383. {
  384. int i;
  385. for (i = 0; i < adapter->num_tx_queues; i++)
  386. vmxnet3_tq_destroy(&adapter->tx_queue[i], adapter);
  387. }
  388. static void
  389. vmxnet3_tq_init(struct vmxnet3_tx_queue *tq,
  390. struct vmxnet3_adapter *adapter)
  391. {
  392. int i;
  393. /* reset the tx ring contents to 0 and reset the tx ring states */
  394. memset(tq->tx_ring.base, 0, tq->tx_ring.size *
  395. sizeof(struct Vmxnet3_TxDesc));
  396. tq->tx_ring.next2fill = tq->tx_ring.next2comp = 0;
  397. tq->tx_ring.gen = VMXNET3_INIT_GEN;
  398. memset(tq->data_ring.base, 0, tq->data_ring.size *
  399. sizeof(struct Vmxnet3_TxDataDesc));
  400. /* reset the tx comp ring contents to 0 and reset comp ring states */
  401. memset(tq->comp_ring.base, 0, tq->comp_ring.size *
  402. sizeof(struct Vmxnet3_TxCompDesc));
  403. tq->comp_ring.next2proc = 0;
  404. tq->comp_ring.gen = VMXNET3_INIT_GEN;
  405. /* reset the bookkeeping data */
  406. memset(tq->buf_info, 0, sizeof(tq->buf_info[0]) * tq->tx_ring.size);
  407. for (i = 0; i < tq->tx_ring.size; i++)
  408. tq->buf_info[i].map_type = VMXNET3_MAP_NONE;
  409. /* stats are not reset */
  410. }
  411. static int
  412. vmxnet3_tq_create(struct vmxnet3_tx_queue *tq,
  413. struct vmxnet3_adapter *adapter)
  414. {
  415. BUG_ON(tq->tx_ring.base || tq->data_ring.base ||
  416. tq->comp_ring.base || tq->buf_info);
  417. tq->tx_ring.base = pci_alloc_consistent(adapter->pdev, tq->tx_ring.size
  418. * sizeof(struct Vmxnet3_TxDesc),
  419. &tq->tx_ring.basePA);
  420. if (!tq->tx_ring.base) {
  421. printk(KERN_ERR "%s: failed to allocate tx ring\n",
  422. adapter->netdev->name);
  423. goto err;
  424. }
  425. tq->data_ring.base = pci_alloc_consistent(adapter->pdev,
  426. tq->data_ring.size *
  427. sizeof(struct Vmxnet3_TxDataDesc),
  428. &tq->data_ring.basePA);
  429. if (!tq->data_ring.base) {
  430. printk(KERN_ERR "%s: failed to allocate data ring\n",
  431. adapter->netdev->name);
  432. goto err;
  433. }
  434. tq->comp_ring.base = pci_alloc_consistent(adapter->pdev,
  435. tq->comp_ring.size *
  436. sizeof(struct Vmxnet3_TxCompDesc),
  437. &tq->comp_ring.basePA);
  438. if (!tq->comp_ring.base) {
  439. printk(KERN_ERR "%s: failed to allocate tx comp ring\n",
  440. adapter->netdev->name);
  441. goto err;
  442. }
  443. tq->buf_info = kcalloc(tq->tx_ring.size, sizeof(tq->buf_info[0]),
  444. GFP_KERNEL);
  445. if (!tq->buf_info) {
  446. printk(KERN_ERR "%s: failed to allocate tx bufinfo\n",
  447. adapter->netdev->name);
  448. goto err;
  449. }
  450. return 0;
  451. err:
  452. vmxnet3_tq_destroy(tq, adapter);
  453. return -ENOMEM;
  454. }
  455. static void
  456. vmxnet3_tq_cleanup_all(struct vmxnet3_adapter *adapter)
  457. {
  458. int i;
  459. for (i = 0; i < adapter->num_tx_queues; i++)
  460. vmxnet3_tq_cleanup(&adapter->tx_queue[i], adapter);
  461. }
  462. /*
  463. * starting from ring->next2fill, allocate rx buffers for the given ring
  464. * of the rx queue and update the rx desc. stop after @num_to_alloc buffers
  465. * are allocated or allocation fails
  466. */
  467. static int
  468. vmxnet3_rq_alloc_rx_buf(struct vmxnet3_rx_queue *rq, u32 ring_idx,
  469. int num_to_alloc, struct vmxnet3_adapter *adapter)
  470. {
  471. int num_allocated = 0;
  472. struct vmxnet3_rx_buf_info *rbi_base = rq->buf_info[ring_idx];
  473. struct vmxnet3_cmd_ring *ring = &rq->rx_ring[ring_idx];
  474. u32 val;
  475. while (num_allocated < num_to_alloc) {
  476. struct vmxnet3_rx_buf_info *rbi;
  477. union Vmxnet3_GenericDesc *gd;
  478. rbi = rbi_base + ring->next2fill;
  479. gd = ring->base + ring->next2fill;
  480. if (rbi->buf_type == VMXNET3_RX_BUF_SKB) {
  481. if (rbi->skb == NULL) {
  482. rbi->skb = dev_alloc_skb(rbi->len +
  483. NET_IP_ALIGN);
  484. if (unlikely(rbi->skb == NULL)) {
  485. rq->stats.rx_buf_alloc_failure++;
  486. break;
  487. }
  488. rbi->skb->dev = adapter->netdev;
  489. skb_reserve(rbi->skb, NET_IP_ALIGN);
  490. rbi->dma_addr = pci_map_single(adapter->pdev,
  491. rbi->skb->data, rbi->len,
  492. PCI_DMA_FROMDEVICE);
  493. } else {
  494. /* rx buffer skipped by the device */
  495. }
  496. val = VMXNET3_RXD_BTYPE_HEAD << VMXNET3_RXD_BTYPE_SHIFT;
  497. } else {
  498. BUG_ON(rbi->buf_type != VMXNET3_RX_BUF_PAGE ||
  499. rbi->len != PAGE_SIZE);
  500. if (rbi->page == NULL) {
  501. rbi->page = alloc_page(GFP_ATOMIC);
  502. if (unlikely(rbi->page == NULL)) {
  503. rq->stats.rx_buf_alloc_failure++;
  504. break;
  505. }
  506. rbi->dma_addr = pci_map_page(adapter->pdev,
  507. rbi->page, 0, PAGE_SIZE,
  508. PCI_DMA_FROMDEVICE);
  509. } else {
  510. /* rx buffers skipped by the device */
  511. }
  512. val = VMXNET3_RXD_BTYPE_BODY << VMXNET3_RXD_BTYPE_SHIFT;
  513. }
  514. BUG_ON(rbi->dma_addr == 0);
  515. gd->rxd.addr = cpu_to_le64(rbi->dma_addr);
  516. gd->dword[2] = cpu_to_le32((ring->gen << VMXNET3_RXD_GEN_SHIFT)
  517. | val | rbi->len);
  518. num_allocated++;
  519. vmxnet3_cmd_ring_adv_next2fill(ring);
  520. }
  521. rq->uncommitted[ring_idx] += num_allocated;
  522. dev_dbg(&adapter->netdev->dev,
  523. "alloc_rx_buf: %d allocated, next2fill %u, next2comp "
  524. "%u, uncommited %u\n", num_allocated, ring->next2fill,
  525. ring->next2comp, rq->uncommitted[ring_idx]);
  526. /* so that the device can distinguish a full ring and an empty ring */
  527. BUG_ON(num_allocated != 0 && ring->next2fill == ring->next2comp);
  528. return num_allocated;
  529. }
  530. static void
  531. vmxnet3_append_frag(struct sk_buff *skb, struct Vmxnet3_RxCompDesc *rcd,
  532. struct vmxnet3_rx_buf_info *rbi)
  533. {
  534. struct skb_frag_struct *frag = skb_shinfo(skb)->frags +
  535. skb_shinfo(skb)->nr_frags;
  536. BUG_ON(skb_shinfo(skb)->nr_frags >= MAX_SKB_FRAGS);
  537. frag->page = rbi->page;
  538. frag->page_offset = 0;
  539. frag->size = rcd->len;
  540. skb->data_len += frag->size;
  541. skb_shinfo(skb)->nr_frags++;
  542. }
  543. static void
  544. vmxnet3_map_pkt(struct sk_buff *skb, struct vmxnet3_tx_ctx *ctx,
  545. struct vmxnet3_tx_queue *tq, struct pci_dev *pdev,
  546. struct vmxnet3_adapter *adapter)
  547. {
  548. u32 dw2, len;
  549. unsigned long buf_offset;
  550. int i;
  551. union Vmxnet3_GenericDesc *gdesc;
  552. struct vmxnet3_tx_buf_info *tbi = NULL;
  553. BUG_ON(ctx->copy_size > skb_headlen(skb));
  554. /* use the previous gen bit for the SOP desc */
  555. dw2 = (tq->tx_ring.gen ^ 0x1) << VMXNET3_TXD_GEN_SHIFT;
  556. ctx->sop_txd = tq->tx_ring.base + tq->tx_ring.next2fill;
  557. gdesc = ctx->sop_txd; /* both loops below can be skipped */
  558. /* no need to map the buffer if headers are copied */
  559. if (ctx->copy_size) {
  560. ctx->sop_txd->txd.addr = cpu_to_le64(tq->data_ring.basePA +
  561. tq->tx_ring.next2fill *
  562. sizeof(struct Vmxnet3_TxDataDesc));
  563. ctx->sop_txd->dword[2] = cpu_to_le32(dw2 | ctx->copy_size);
  564. ctx->sop_txd->dword[3] = 0;
  565. tbi = tq->buf_info + tq->tx_ring.next2fill;
  566. tbi->map_type = VMXNET3_MAP_NONE;
  567. dev_dbg(&adapter->netdev->dev,
  568. "txd[%u]: 0x%Lx 0x%x 0x%x\n",
  569. tq->tx_ring.next2fill,
  570. le64_to_cpu(ctx->sop_txd->txd.addr),
  571. ctx->sop_txd->dword[2], ctx->sop_txd->dword[3]);
  572. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  573. /* use the right gen for non-SOP desc */
  574. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  575. }
  576. /* linear part can use multiple tx desc if it's big */
  577. len = skb_headlen(skb) - ctx->copy_size;
  578. buf_offset = ctx->copy_size;
  579. while (len) {
  580. u32 buf_size;
  581. if (len < VMXNET3_MAX_TX_BUF_SIZE) {
  582. buf_size = len;
  583. dw2 |= len;
  584. } else {
  585. buf_size = VMXNET3_MAX_TX_BUF_SIZE;
  586. /* spec says that for TxDesc.len, 0 == 2^14 */
  587. }
  588. tbi = tq->buf_info + tq->tx_ring.next2fill;
  589. tbi->map_type = VMXNET3_MAP_SINGLE;
  590. tbi->dma_addr = pci_map_single(adapter->pdev,
  591. skb->data + buf_offset, buf_size,
  592. PCI_DMA_TODEVICE);
  593. tbi->len = buf_size;
  594. gdesc = tq->tx_ring.base + tq->tx_ring.next2fill;
  595. BUG_ON(gdesc->txd.gen == tq->tx_ring.gen);
  596. gdesc->txd.addr = cpu_to_le64(tbi->dma_addr);
  597. gdesc->dword[2] = cpu_to_le32(dw2);
  598. gdesc->dword[3] = 0;
  599. dev_dbg(&adapter->netdev->dev,
  600. "txd[%u]: 0x%Lx 0x%x 0x%x\n",
  601. tq->tx_ring.next2fill, le64_to_cpu(gdesc->txd.addr),
  602. le32_to_cpu(gdesc->dword[2]), gdesc->dword[3]);
  603. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  604. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  605. len -= buf_size;
  606. buf_offset += buf_size;
  607. }
  608. for (i = 0; i < skb_shinfo(skb)->nr_frags; i++) {
  609. struct skb_frag_struct *frag = &skb_shinfo(skb)->frags[i];
  610. tbi = tq->buf_info + tq->tx_ring.next2fill;
  611. tbi->map_type = VMXNET3_MAP_PAGE;
  612. tbi->dma_addr = pci_map_page(adapter->pdev, frag->page,
  613. frag->page_offset, frag->size,
  614. PCI_DMA_TODEVICE);
  615. tbi->len = frag->size;
  616. gdesc = tq->tx_ring.base + tq->tx_ring.next2fill;
  617. BUG_ON(gdesc->txd.gen == tq->tx_ring.gen);
  618. gdesc->txd.addr = cpu_to_le64(tbi->dma_addr);
  619. gdesc->dword[2] = cpu_to_le32(dw2 | frag->size);
  620. gdesc->dword[3] = 0;
  621. dev_dbg(&adapter->netdev->dev,
  622. "txd[%u]: 0x%llu %u %u\n",
  623. tq->tx_ring.next2fill, le64_to_cpu(gdesc->txd.addr),
  624. le32_to_cpu(gdesc->dword[2]), gdesc->dword[3]);
  625. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  626. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  627. }
  628. ctx->eop_txd = gdesc;
  629. /* set the last buf_info for the pkt */
  630. tbi->skb = skb;
  631. tbi->sop_idx = ctx->sop_txd - tq->tx_ring.base;
  632. }
  633. /* Init all tx queues */
  634. static void
  635. vmxnet3_tq_init_all(struct vmxnet3_adapter *adapter)
  636. {
  637. int i;
  638. for (i = 0; i < adapter->num_tx_queues; i++)
  639. vmxnet3_tq_init(&adapter->tx_queue[i], adapter);
  640. }
  641. /*
  642. * parse and copy relevant protocol headers:
  643. * For a tso pkt, relevant headers are L2/3/4 including options
  644. * For a pkt requesting csum offloading, they are L2/3 and may include L4
  645. * if it's a TCP/UDP pkt
  646. *
  647. * Returns:
  648. * -1: error happens during parsing
  649. * 0: protocol headers parsed, but too big to be copied
  650. * 1: protocol headers parsed and copied
  651. *
  652. * Other effects:
  653. * 1. related *ctx fields are updated.
  654. * 2. ctx->copy_size is # of bytes copied
  655. * 3. the portion copied is guaranteed to be in the linear part
  656. *
  657. */
  658. static int
  659. vmxnet3_parse_and_copy_hdr(struct sk_buff *skb, struct vmxnet3_tx_queue *tq,
  660. struct vmxnet3_tx_ctx *ctx,
  661. struct vmxnet3_adapter *adapter)
  662. {
  663. struct Vmxnet3_TxDataDesc *tdd;
  664. if (ctx->mss) { /* TSO */
  665. ctx->eth_ip_hdr_size = skb_transport_offset(skb);
  666. ctx->l4_hdr_size = ((struct tcphdr *)
  667. skb_transport_header(skb))->doff * 4;
  668. ctx->copy_size = ctx->eth_ip_hdr_size + ctx->l4_hdr_size;
  669. } else {
  670. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  671. ctx->eth_ip_hdr_size = skb_checksum_start_offset(skb);
  672. if (ctx->ipv4) {
  673. struct iphdr *iph = (struct iphdr *)
  674. skb_network_header(skb);
  675. if (iph->protocol == IPPROTO_TCP)
  676. ctx->l4_hdr_size = ((struct tcphdr *)
  677. skb_transport_header(skb))->doff * 4;
  678. else if (iph->protocol == IPPROTO_UDP)
  679. /*
  680. * Use tcp header size so that bytes to
  681. * be copied are more than required by
  682. * the device.
  683. */
  684. ctx->l4_hdr_size =
  685. sizeof(struct tcphdr);
  686. else
  687. ctx->l4_hdr_size = 0;
  688. } else {
  689. /* for simplicity, don't copy L4 headers */
  690. ctx->l4_hdr_size = 0;
  691. }
  692. ctx->copy_size = ctx->eth_ip_hdr_size +
  693. ctx->l4_hdr_size;
  694. } else {
  695. ctx->eth_ip_hdr_size = 0;
  696. ctx->l4_hdr_size = 0;
  697. /* copy as much as allowed */
  698. ctx->copy_size = min((unsigned int)VMXNET3_HDR_COPY_SIZE
  699. , skb_headlen(skb));
  700. }
  701. /* make sure headers are accessible directly */
  702. if (unlikely(!pskb_may_pull(skb, ctx->copy_size)))
  703. goto err;
  704. }
  705. if (unlikely(ctx->copy_size > VMXNET3_HDR_COPY_SIZE)) {
  706. tq->stats.oversized_hdr++;
  707. ctx->copy_size = 0;
  708. return 0;
  709. }
  710. tdd = tq->data_ring.base + tq->tx_ring.next2fill;
  711. memcpy(tdd->data, skb->data, ctx->copy_size);
  712. dev_dbg(&adapter->netdev->dev,
  713. "copy %u bytes to dataRing[%u]\n",
  714. ctx->copy_size, tq->tx_ring.next2fill);
  715. return 1;
  716. err:
  717. return -1;
  718. }
  719. static void
  720. vmxnet3_prepare_tso(struct sk_buff *skb,
  721. struct vmxnet3_tx_ctx *ctx)
  722. {
  723. struct tcphdr *tcph = (struct tcphdr *)skb_transport_header(skb);
  724. if (ctx->ipv4) {
  725. struct iphdr *iph = (struct iphdr *)skb_network_header(skb);
  726. iph->check = 0;
  727. tcph->check = ~csum_tcpudp_magic(iph->saddr, iph->daddr, 0,
  728. IPPROTO_TCP, 0);
  729. } else {
  730. struct ipv6hdr *iph = (struct ipv6hdr *)skb_network_header(skb);
  731. tcph->check = ~csum_ipv6_magic(&iph->saddr, &iph->daddr, 0,
  732. IPPROTO_TCP, 0);
  733. }
  734. }
  735. /*
  736. * Transmits a pkt thru a given tq
  737. * Returns:
  738. * NETDEV_TX_OK: descriptors are setup successfully
  739. * NETDEV_TX_OK: error occurred, the pkt is dropped
  740. * NETDEV_TX_BUSY: tx ring is full, queue is stopped
  741. *
  742. * Side-effects:
  743. * 1. tx ring may be changed
  744. * 2. tq stats may be updated accordingly
  745. * 3. shared->txNumDeferred may be updated
  746. */
  747. static int
  748. vmxnet3_tq_xmit(struct sk_buff *skb, struct vmxnet3_tx_queue *tq,
  749. struct vmxnet3_adapter *adapter, struct net_device *netdev)
  750. {
  751. int ret;
  752. u32 count;
  753. unsigned long flags;
  754. struct vmxnet3_tx_ctx ctx;
  755. union Vmxnet3_GenericDesc *gdesc;
  756. #ifdef __BIG_ENDIAN_BITFIELD
  757. /* Use temporary descriptor to avoid touching bits multiple times */
  758. union Vmxnet3_GenericDesc tempTxDesc;
  759. #endif
  760. /* conservatively estimate # of descriptors to use */
  761. count = VMXNET3_TXD_NEEDED(skb_headlen(skb)) +
  762. skb_shinfo(skb)->nr_frags + 1;
  763. ctx.ipv4 = (skb->protocol == cpu_to_be16(ETH_P_IP));
  764. ctx.mss = skb_shinfo(skb)->gso_size;
  765. if (ctx.mss) {
  766. if (skb_header_cloned(skb)) {
  767. if (unlikely(pskb_expand_head(skb, 0, 0,
  768. GFP_ATOMIC) != 0)) {
  769. tq->stats.drop_tso++;
  770. goto drop_pkt;
  771. }
  772. tq->stats.copy_skb_header++;
  773. }
  774. vmxnet3_prepare_tso(skb, &ctx);
  775. } else {
  776. if (unlikely(count > VMXNET3_MAX_TXD_PER_PKT)) {
  777. /* non-tso pkts must not use more than
  778. * VMXNET3_MAX_TXD_PER_PKT entries
  779. */
  780. if (skb_linearize(skb) != 0) {
  781. tq->stats.drop_too_many_frags++;
  782. goto drop_pkt;
  783. }
  784. tq->stats.linearized++;
  785. /* recalculate the # of descriptors to use */
  786. count = VMXNET3_TXD_NEEDED(skb_headlen(skb)) + 1;
  787. }
  788. }
  789. spin_lock_irqsave(&tq->tx_lock, flags);
  790. if (count > vmxnet3_cmd_ring_desc_avail(&tq->tx_ring)) {
  791. tq->stats.tx_ring_full++;
  792. dev_dbg(&adapter->netdev->dev,
  793. "tx queue stopped on %s, next2comp %u"
  794. " next2fill %u\n", adapter->netdev->name,
  795. tq->tx_ring.next2comp, tq->tx_ring.next2fill);
  796. vmxnet3_tq_stop(tq, adapter);
  797. spin_unlock_irqrestore(&tq->tx_lock, flags);
  798. return NETDEV_TX_BUSY;
  799. }
  800. ret = vmxnet3_parse_and_copy_hdr(skb, tq, &ctx, adapter);
  801. if (ret >= 0) {
  802. BUG_ON(ret <= 0 && ctx.copy_size != 0);
  803. /* hdrs parsed, check against other limits */
  804. if (ctx.mss) {
  805. if (unlikely(ctx.eth_ip_hdr_size + ctx.l4_hdr_size >
  806. VMXNET3_MAX_TX_BUF_SIZE)) {
  807. goto hdr_too_big;
  808. }
  809. } else {
  810. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  811. if (unlikely(ctx.eth_ip_hdr_size +
  812. skb->csum_offset >
  813. VMXNET3_MAX_CSUM_OFFSET)) {
  814. goto hdr_too_big;
  815. }
  816. }
  817. }
  818. } else {
  819. tq->stats.drop_hdr_inspect_err++;
  820. goto unlock_drop_pkt;
  821. }
  822. /* fill tx descs related to addr & len */
  823. vmxnet3_map_pkt(skb, &ctx, tq, adapter->pdev, adapter);
  824. /* setup the EOP desc */
  825. ctx.eop_txd->dword[3] = cpu_to_le32(VMXNET3_TXD_CQ | VMXNET3_TXD_EOP);
  826. /* setup the SOP desc */
  827. #ifdef __BIG_ENDIAN_BITFIELD
  828. gdesc = &tempTxDesc;
  829. gdesc->dword[2] = ctx.sop_txd->dword[2];
  830. gdesc->dword[3] = ctx.sop_txd->dword[3];
  831. #else
  832. gdesc = ctx.sop_txd;
  833. #endif
  834. if (ctx.mss) {
  835. gdesc->txd.hlen = ctx.eth_ip_hdr_size + ctx.l4_hdr_size;
  836. gdesc->txd.om = VMXNET3_OM_TSO;
  837. gdesc->txd.msscof = ctx.mss;
  838. le32_add_cpu(&tq->shared->txNumDeferred, (skb->len -
  839. gdesc->txd.hlen + ctx.mss - 1) / ctx.mss);
  840. } else {
  841. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  842. gdesc->txd.hlen = ctx.eth_ip_hdr_size;
  843. gdesc->txd.om = VMXNET3_OM_CSUM;
  844. gdesc->txd.msscof = ctx.eth_ip_hdr_size +
  845. skb->csum_offset;
  846. } else {
  847. gdesc->txd.om = 0;
  848. gdesc->txd.msscof = 0;
  849. }
  850. le32_add_cpu(&tq->shared->txNumDeferred, 1);
  851. }
  852. if (vlan_tx_tag_present(skb)) {
  853. gdesc->txd.ti = 1;
  854. gdesc->txd.tci = vlan_tx_tag_get(skb);
  855. }
  856. /* finally flips the GEN bit of the SOP desc. */
  857. gdesc->dword[2] = cpu_to_le32(le32_to_cpu(gdesc->dword[2]) ^
  858. VMXNET3_TXD_GEN);
  859. #ifdef __BIG_ENDIAN_BITFIELD
  860. /* Finished updating in bitfields of Tx Desc, so write them in original
  861. * place.
  862. */
  863. vmxnet3_TxDescToLe((struct Vmxnet3_TxDesc *)gdesc,
  864. (struct Vmxnet3_TxDesc *)ctx.sop_txd);
  865. gdesc = ctx.sop_txd;
  866. #endif
  867. dev_dbg(&adapter->netdev->dev,
  868. "txd[%u]: SOP 0x%Lx 0x%x 0x%x\n",
  869. (u32)((union Vmxnet3_GenericDesc *)ctx.sop_txd -
  870. tq->tx_ring.base), le64_to_cpu(gdesc->txd.addr),
  871. le32_to_cpu(gdesc->dword[2]), le32_to_cpu(gdesc->dword[3]));
  872. spin_unlock_irqrestore(&tq->tx_lock, flags);
  873. if (le32_to_cpu(tq->shared->txNumDeferred) >=
  874. le32_to_cpu(tq->shared->txThreshold)) {
  875. tq->shared->txNumDeferred = 0;
  876. VMXNET3_WRITE_BAR0_REG(adapter,
  877. VMXNET3_REG_TXPROD + tq->qid * 8,
  878. tq->tx_ring.next2fill);
  879. }
  880. return NETDEV_TX_OK;
  881. hdr_too_big:
  882. tq->stats.drop_oversized_hdr++;
  883. unlock_drop_pkt:
  884. spin_unlock_irqrestore(&tq->tx_lock, flags);
  885. drop_pkt:
  886. tq->stats.drop_total++;
  887. dev_kfree_skb(skb);
  888. return NETDEV_TX_OK;
  889. }
  890. static netdev_tx_t
  891. vmxnet3_xmit_frame(struct sk_buff *skb, struct net_device *netdev)
  892. {
  893. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  894. BUG_ON(skb->queue_mapping > adapter->num_tx_queues);
  895. return vmxnet3_tq_xmit(skb,
  896. &adapter->tx_queue[skb->queue_mapping],
  897. adapter, netdev);
  898. }
  899. static void
  900. vmxnet3_rx_csum(struct vmxnet3_adapter *adapter,
  901. struct sk_buff *skb,
  902. union Vmxnet3_GenericDesc *gdesc)
  903. {
  904. if (!gdesc->rcd.cnc && adapter->netdev->features & NETIF_F_RXCSUM) {
  905. /* typical case: TCP/UDP over IP and both csums are correct */
  906. if ((le32_to_cpu(gdesc->dword[3]) & VMXNET3_RCD_CSUM_OK) ==
  907. VMXNET3_RCD_CSUM_OK) {
  908. skb->ip_summed = CHECKSUM_UNNECESSARY;
  909. BUG_ON(!(gdesc->rcd.tcp || gdesc->rcd.udp));
  910. BUG_ON(!(gdesc->rcd.v4 || gdesc->rcd.v6));
  911. BUG_ON(gdesc->rcd.frg);
  912. } else {
  913. if (gdesc->rcd.csum) {
  914. skb->csum = htons(gdesc->rcd.csum);
  915. skb->ip_summed = CHECKSUM_PARTIAL;
  916. } else {
  917. skb_checksum_none_assert(skb);
  918. }
  919. }
  920. } else {
  921. skb_checksum_none_assert(skb);
  922. }
  923. }
  924. static void
  925. vmxnet3_rx_error(struct vmxnet3_rx_queue *rq, struct Vmxnet3_RxCompDesc *rcd,
  926. struct vmxnet3_rx_ctx *ctx, struct vmxnet3_adapter *adapter)
  927. {
  928. rq->stats.drop_err++;
  929. if (!rcd->fcs)
  930. rq->stats.drop_fcs++;
  931. rq->stats.drop_total++;
  932. /*
  933. * We do not unmap and chain the rx buffer to the skb.
  934. * We basically pretend this buffer is not used and will be recycled
  935. * by vmxnet3_rq_alloc_rx_buf()
  936. */
  937. /*
  938. * ctx->skb may be NULL if this is the first and the only one
  939. * desc for the pkt
  940. */
  941. if (ctx->skb)
  942. dev_kfree_skb_irq(ctx->skb);
  943. ctx->skb = NULL;
  944. }
  945. static int
  946. vmxnet3_rq_rx_complete(struct vmxnet3_rx_queue *rq,
  947. struct vmxnet3_adapter *adapter, int quota)
  948. {
  949. static const u32 rxprod_reg[2] = {
  950. VMXNET3_REG_RXPROD, VMXNET3_REG_RXPROD2
  951. };
  952. u32 num_rxd = 0;
  953. struct Vmxnet3_RxCompDesc *rcd;
  954. struct vmxnet3_rx_ctx *ctx = &rq->rx_ctx;
  955. #ifdef __BIG_ENDIAN_BITFIELD
  956. struct Vmxnet3_RxDesc rxCmdDesc;
  957. struct Vmxnet3_RxCompDesc rxComp;
  958. #endif
  959. vmxnet3_getRxComp(rcd, &rq->comp_ring.base[rq->comp_ring.next2proc].rcd,
  960. &rxComp);
  961. while (rcd->gen == rq->comp_ring.gen) {
  962. struct vmxnet3_rx_buf_info *rbi;
  963. struct sk_buff *skb;
  964. int num_to_alloc;
  965. struct Vmxnet3_RxDesc *rxd;
  966. u32 idx, ring_idx;
  967. if (num_rxd >= quota) {
  968. /* we may stop even before we see the EOP desc of
  969. * the current pkt
  970. */
  971. break;
  972. }
  973. num_rxd++;
  974. BUG_ON(rcd->rqID != rq->qid && rcd->rqID != rq->qid2);
  975. idx = rcd->rxdIdx;
  976. ring_idx = rcd->rqID < adapter->num_rx_queues ? 0 : 1;
  977. vmxnet3_getRxDesc(rxd, &rq->rx_ring[ring_idx].base[idx].rxd,
  978. &rxCmdDesc);
  979. rbi = rq->buf_info[ring_idx] + idx;
  980. BUG_ON(rxd->addr != rbi->dma_addr ||
  981. rxd->len != rbi->len);
  982. if (unlikely(rcd->eop && rcd->err)) {
  983. vmxnet3_rx_error(rq, rcd, ctx, adapter);
  984. goto rcd_done;
  985. }
  986. if (rcd->sop) { /* first buf of the pkt */
  987. BUG_ON(rxd->btype != VMXNET3_RXD_BTYPE_HEAD ||
  988. rcd->rqID != rq->qid);
  989. BUG_ON(rbi->buf_type != VMXNET3_RX_BUF_SKB);
  990. BUG_ON(ctx->skb != NULL || rbi->skb == NULL);
  991. if (unlikely(rcd->len == 0)) {
  992. /* Pretend the rx buffer is skipped. */
  993. BUG_ON(!(rcd->sop && rcd->eop));
  994. dev_dbg(&adapter->netdev->dev,
  995. "rxRing[%u][%u] 0 length\n",
  996. ring_idx, idx);
  997. goto rcd_done;
  998. }
  999. ctx->skb = rbi->skb;
  1000. rbi->skb = NULL;
  1001. pci_unmap_single(adapter->pdev, rbi->dma_addr, rbi->len,
  1002. PCI_DMA_FROMDEVICE);
  1003. skb_put(ctx->skb, rcd->len);
  1004. } else {
  1005. BUG_ON(ctx->skb == NULL);
  1006. /* non SOP buffer must be type 1 in most cases */
  1007. if (rbi->buf_type == VMXNET3_RX_BUF_PAGE) {
  1008. BUG_ON(rxd->btype != VMXNET3_RXD_BTYPE_BODY);
  1009. if (rcd->len) {
  1010. pci_unmap_page(adapter->pdev,
  1011. rbi->dma_addr, rbi->len,
  1012. PCI_DMA_FROMDEVICE);
  1013. vmxnet3_append_frag(ctx->skb, rcd, rbi);
  1014. rbi->page = NULL;
  1015. }
  1016. } else {
  1017. /*
  1018. * The only time a non-SOP buffer is type 0 is
  1019. * when it's EOP and error flag is raised, which
  1020. * has already been handled.
  1021. */
  1022. BUG_ON(true);
  1023. }
  1024. }
  1025. skb = ctx->skb;
  1026. if (rcd->eop) {
  1027. skb->len += skb->data_len;
  1028. skb->truesize += skb->data_len;
  1029. vmxnet3_rx_csum(adapter, skb,
  1030. (union Vmxnet3_GenericDesc *)rcd);
  1031. skb->protocol = eth_type_trans(skb, adapter->netdev);
  1032. if (unlikely(adapter->vlan_grp && rcd->ts)) {
  1033. vlan_hwaccel_receive_skb(skb,
  1034. adapter->vlan_grp, rcd->tci);
  1035. } else {
  1036. netif_receive_skb(skb);
  1037. }
  1038. ctx->skb = NULL;
  1039. }
  1040. rcd_done:
  1041. /* device may skip some rx descs */
  1042. rq->rx_ring[ring_idx].next2comp = idx;
  1043. VMXNET3_INC_RING_IDX_ONLY(rq->rx_ring[ring_idx].next2comp,
  1044. rq->rx_ring[ring_idx].size);
  1045. /* refill rx buffers frequently to avoid starving the h/w */
  1046. num_to_alloc = vmxnet3_cmd_ring_desc_avail(rq->rx_ring +
  1047. ring_idx);
  1048. if (unlikely(num_to_alloc > VMXNET3_RX_ALLOC_THRESHOLD(rq,
  1049. ring_idx, adapter))) {
  1050. vmxnet3_rq_alloc_rx_buf(rq, ring_idx, num_to_alloc,
  1051. adapter);
  1052. /* if needed, update the register */
  1053. if (unlikely(rq->shared->updateRxProd)) {
  1054. VMXNET3_WRITE_BAR0_REG(adapter,
  1055. rxprod_reg[ring_idx] + rq->qid * 8,
  1056. rq->rx_ring[ring_idx].next2fill);
  1057. rq->uncommitted[ring_idx] = 0;
  1058. }
  1059. }
  1060. vmxnet3_comp_ring_adv_next2proc(&rq->comp_ring);
  1061. vmxnet3_getRxComp(rcd,
  1062. &rq->comp_ring.base[rq->comp_ring.next2proc].rcd, &rxComp);
  1063. }
  1064. return num_rxd;
  1065. }
  1066. static void
  1067. vmxnet3_rq_cleanup(struct vmxnet3_rx_queue *rq,
  1068. struct vmxnet3_adapter *adapter)
  1069. {
  1070. u32 i, ring_idx;
  1071. struct Vmxnet3_RxDesc *rxd;
  1072. for (ring_idx = 0; ring_idx < 2; ring_idx++) {
  1073. for (i = 0; i < rq->rx_ring[ring_idx].size; i++) {
  1074. #ifdef __BIG_ENDIAN_BITFIELD
  1075. struct Vmxnet3_RxDesc rxDesc;
  1076. #endif
  1077. vmxnet3_getRxDesc(rxd,
  1078. &rq->rx_ring[ring_idx].base[i].rxd, &rxDesc);
  1079. if (rxd->btype == VMXNET3_RXD_BTYPE_HEAD &&
  1080. rq->buf_info[ring_idx][i].skb) {
  1081. pci_unmap_single(adapter->pdev, rxd->addr,
  1082. rxd->len, PCI_DMA_FROMDEVICE);
  1083. dev_kfree_skb(rq->buf_info[ring_idx][i].skb);
  1084. rq->buf_info[ring_idx][i].skb = NULL;
  1085. } else if (rxd->btype == VMXNET3_RXD_BTYPE_BODY &&
  1086. rq->buf_info[ring_idx][i].page) {
  1087. pci_unmap_page(adapter->pdev, rxd->addr,
  1088. rxd->len, PCI_DMA_FROMDEVICE);
  1089. put_page(rq->buf_info[ring_idx][i].page);
  1090. rq->buf_info[ring_idx][i].page = NULL;
  1091. }
  1092. }
  1093. rq->rx_ring[ring_idx].gen = VMXNET3_INIT_GEN;
  1094. rq->rx_ring[ring_idx].next2fill =
  1095. rq->rx_ring[ring_idx].next2comp = 0;
  1096. rq->uncommitted[ring_idx] = 0;
  1097. }
  1098. rq->comp_ring.gen = VMXNET3_INIT_GEN;
  1099. rq->comp_ring.next2proc = 0;
  1100. }
  1101. static void
  1102. vmxnet3_rq_cleanup_all(struct vmxnet3_adapter *adapter)
  1103. {
  1104. int i;
  1105. for (i = 0; i < adapter->num_rx_queues; i++)
  1106. vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter);
  1107. }
  1108. void vmxnet3_rq_destroy(struct vmxnet3_rx_queue *rq,
  1109. struct vmxnet3_adapter *adapter)
  1110. {
  1111. int i;
  1112. int j;
  1113. /* all rx buffers must have already been freed */
  1114. for (i = 0; i < 2; i++) {
  1115. if (rq->buf_info[i]) {
  1116. for (j = 0; j < rq->rx_ring[i].size; j++)
  1117. BUG_ON(rq->buf_info[i][j].page != NULL);
  1118. }
  1119. }
  1120. kfree(rq->buf_info[0]);
  1121. for (i = 0; i < 2; i++) {
  1122. if (rq->rx_ring[i].base) {
  1123. pci_free_consistent(adapter->pdev, rq->rx_ring[i].size
  1124. * sizeof(struct Vmxnet3_RxDesc),
  1125. rq->rx_ring[i].base,
  1126. rq->rx_ring[i].basePA);
  1127. rq->rx_ring[i].base = NULL;
  1128. }
  1129. rq->buf_info[i] = NULL;
  1130. }
  1131. if (rq->comp_ring.base) {
  1132. pci_free_consistent(adapter->pdev, rq->comp_ring.size *
  1133. sizeof(struct Vmxnet3_RxCompDesc),
  1134. rq->comp_ring.base, rq->comp_ring.basePA);
  1135. rq->comp_ring.base = NULL;
  1136. }
  1137. }
  1138. static int
  1139. vmxnet3_rq_init(struct vmxnet3_rx_queue *rq,
  1140. struct vmxnet3_adapter *adapter)
  1141. {
  1142. int i;
  1143. /* initialize buf_info */
  1144. for (i = 0; i < rq->rx_ring[0].size; i++) {
  1145. /* 1st buf for a pkt is skbuff */
  1146. if (i % adapter->rx_buf_per_pkt == 0) {
  1147. rq->buf_info[0][i].buf_type = VMXNET3_RX_BUF_SKB;
  1148. rq->buf_info[0][i].len = adapter->skb_buf_size;
  1149. } else { /* subsequent bufs for a pkt is frag */
  1150. rq->buf_info[0][i].buf_type = VMXNET3_RX_BUF_PAGE;
  1151. rq->buf_info[0][i].len = PAGE_SIZE;
  1152. }
  1153. }
  1154. for (i = 0; i < rq->rx_ring[1].size; i++) {
  1155. rq->buf_info[1][i].buf_type = VMXNET3_RX_BUF_PAGE;
  1156. rq->buf_info[1][i].len = PAGE_SIZE;
  1157. }
  1158. /* reset internal state and allocate buffers for both rings */
  1159. for (i = 0; i < 2; i++) {
  1160. rq->rx_ring[i].next2fill = rq->rx_ring[i].next2comp = 0;
  1161. rq->uncommitted[i] = 0;
  1162. memset(rq->rx_ring[i].base, 0, rq->rx_ring[i].size *
  1163. sizeof(struct Vmxnet3_RxDesc));
  1164. rq->rx_ring[i].gen = VMXNET3_INIT_GEN;
  1165. }
  1166. if (vmxnet3_rq_alloc_rx_buf(rq, 0, rq->rx_ring[0].size - 1,
  1167. adapter) == 0) {
  1168. /* at least has 1 rx buffer for the 1st ring */
  1169. return -ENOMEM;
  1170. }
  1171. vmxnet3_rq_alloc_rx_buf(rq, 1, rq->rx_ring[1].size - 1, adapter);
  1172. /* reset the comp ring */
  1173. rq->comp_ring.next2proc = 0;
  1174. memset(rq->comp_ring.base, 0, rq->comp_ring.size *
  1175. sizeof(struct Vmxnet3_RxCompDesc));
  1176. rq->comp_ring.gen = VMXNET3_INIT_GEN;
  1177. /* reset rxctx */
  1178. rq->rx_ctx.skb = NULL;
  1179. /* stats are not reset */
  1180. return 0;
  1181. }
  1182. static int
  1183. vmxnet3_rq_init_all(struct vmxnet3_adapter *adapter)
  1184. {
  1185. int i, err = 0;
  1186. for (i = 0; i < adapter->num_rx_queues; i++) {
  1187. err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter);
  1188. if (unlikely(err)) {
  1189. dev_err(&adapter->netdev->dev, "%s: failed to "
  1190. "initialize rx queue%i\n",
  1191. adapter->netdev->name, i);
  1192. break;
  1193. }
  1194. }
  1195. return err;
  1196. }
  1197. static int
  1198. vmxnet3_rq_create(struct vmxnet3_rx_queue *rq, struct vmxnet3_adapter *adapter)
  1199. {
  1200. int i;
  1201. size_t sz;
  1202. struct vmxnet3_rx_buf_info *bi;
  1203. for (i = 0; i < 2; i++) {
  1204. sz = rq->rx_ring[i].size * sizeof(struct Vmxnet3_RxDesc);
  1205. rq->rx_ring[i].base = pci_alloc_consistent(adapter->pdev, sz,
  1206. &rq->rx_ring[i].basePA);
  1207. if (!rq->rx_ring[i].base) {
  1208. printk(KERN_ERR "%s: failed to allocate rx ring %d\n",
  1209. adapter->netdev->name, i);
  1210. goto err;
  1211. }
  1212. }
  1213. sz = rq->comp_ring.size * sizeof(struct Vmxnet3_RxCompDesc);
  1214. rq->comp_ring.base = pci_alloc_consistent(adapter->pdev, sz,
  1215. &rq->comp_ring.basePA);
  1216. if (!rq->comp_ring.base) {
  1217. printk(KERN_ERR "%s: failed to allocate rx comp ring\n",
  1218. adapter->netdev->name);
  1219. goto err;
  1220. }
  1221. sz = sizeof(struct vmxnet3_rx_buf_info) * (rq->rx_ring[0].size +
  1222. rq->rx_ring[1].size);
  1223. bi = kzalloc(sz, GFP_KERNEL);
  1224. if (!bi) {
  1225. printk(KERN_ERR "%s: failed to allocate rx bufinfo\n",
  1226. adapter->netdev->name);
  1227. goto err;
  1228. }
  1229. rq->buf_info[0] = bi;
  1230. rq->buf_info[1] = bi + rq->rx_ring[0].size;
  1231. return 0;
  1232. err:
  1233. vmxnet3_rq_destroy(rq, adapter);
  1234. return -ENOMEM;
  1235. }
  1236. static int
  1237. vmxnet3_rq_create_all(struct vmxnet3_adapter *adapter)
  1238. {
  1239. int i, err = 0;
  1240. for (i = 0; i < adapter->num_rx_queues; i++) {
  1241. err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter);
  1242. if (unlikely(err)) {
  1243. dev_err(&adapter->netdev->dev,
  1244. "%s: failed to create rx queue%i\n",
  1245. adapter->netdev->name, i);
  1246. goto err_out;
  1247. }
  1248. }
  1249. return err;
  1250. err_out:
  1251. vmxnet3_rq_destroy_all(adapter);
  1252. return err;
  1253. }
  1254. /* Multiple queue aware polling function for tx and rx */
  1255. static int
  1256. vmxnet3_do_poll(struct vmxnet3_adapter *adapter, int budget)
  1257. {
  1258. int rcd_done = 0, i;
  1259. if (unlikely(adapter->shared->ecr))
  1260. vmxnet3_process_events(adapter);
  1261. for (i = 0; i < adapter->num_tx_queues; i++)
  1262. vmxnet3_tq_tx_complete(&adapter->tx_queue[i], adapter);
  1263. for (i = 0; i < adapter->num_rx_queues; i++)
  1264. rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i],
  1265. adapter, budget);
  1266. return rcd_done;
  1267. }
  1268. static int
  1269. vmxnet3_poll(struct napi_struct *napi, int budget)
  1270. {
  1271. struct vmxnet3_rx_queue *rx_queue = container_of(napi,
  1272. struct vmxnet3_rx_queue, napi);
  1273. int rxd_done;
  1274. rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget);
  1275. if (rxd_done < budget) {
  1276. napi_complete(napi);
  1277. vmxnet3_enable_all_intrs(rx_queue->adapter);
  1278. }
  1279. return rxd_done;
  1280. }
  1281. /*
  1282. * NAPI polling function for MSI-X mode with multiple Rx queues
  1283. * Returns the # of the NAPI credit consumed (# of rx descriptors processed)
  1284. */
  1285. static int
  1286. vmxnet3_poll_rx_only(struct napi_struct *napi, int budget)
  1287. {
  1288. struct vmxnet3_rx_queue *rq = container_of(napi,
  1289. struct vmxnet3_rx_queue, napi);
  1290. struct vmxnet3_adapter *adapter = rq->adapter;
  1291. int rxd_done;
  1292. /* When sharing interrupt with corresponding tx queue, process
  1293. * tx completions in that queue as well
  1294. */
  1295. if (adapter->share_intr == VMXNET3_INTR_BUDDYSHARE) {
  1296. struct vmxnet3_tx_queue *tq =
  1297. &adapter->tx_queue[rq - adapter->rx_queue];
  1298. vmxnet3_tq_tx_complete(tq, adapter);
  1299. }
  1300. rxd_done = vmxnet3_rq_rx_complete(rq, adapter, budget);
  1301. if (rxd_done < budget) {
  1302. napi_complete(napi);
  1303. vmxnet3_enable_intr(adapter, rq->comp_ring.intr_idx);
  1304. }
  1305. return rxd_done;
  1306. }
  1307. #ifdef CONFIG_PCI_MSI
  1308. /*
  1309. * Handle completion interrupts on tx queues
  1310. * Returns whether or not the intr is handled
  1311. */
  1312. static irqreturn_t
  1313. vmxnet3_msix_tx(int irq, void *data)
  1314. {
  1315. struct vmxnet3_tx_queue *tq = data;
  1316. struct vmxnet3_adapter *adapter = tq->adapter;
  1317. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1318. vmxnet3_disable_intr(adapter, tq->comp_ring.intr_idx);
  1319. /* Handle the case where only one irq is allocate for all tx queues */
  1320. if (adapter->share_intr == VMXNET3_INTR_TXSHARE) {
  1321. int i;
  1322. for (i = 0; i < adapter->num_tx_queues; i++) {
  1323. struct vmxnet3_tx_queue *txq = &adapter->tx_queue[i];
  1324. vmxnet3_tq_tx_complete(txq, adapter);
  1325. }
  1326. } else {
  1327. vmxnet3_tq_tx_complete(tq, adapter);
  1328. }
  1329. vmxnet3_enable_intr(adapter, tq->comp_ring.intr_idx);
  1330. return IRQ_HANDLED;
  1331. }
  1332. /*
  1333. * Handle completion interrupts on rx queues. Returns whether or not the
  1334. * intr is handled
  1335. */
  1336. static irqreturn_t
  1337. vmxnet3_msix_rx(int irq, void *data)
  1338. {
  1339. struct vmxnet3_rx_queue *rq = data;
  1340. struct vmxnet3_adapter *adapter = rq->adapter;
  1341. /* disable intr if needed */
  1342. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1343. vmxnet3_disable_intr(adapter, rq->comp_ring.intr_idx);
  1344. napi_schedule(&rq->napi);
  1345. return IRQ_HANDLED;
  1346. }
  1347. /*
  1348. *----------------------------------------------------------------------------
  1349. *
  1350. * vmxnet3_msix_event --
  1351. *
  1352. * vmxnet3 msix event intr handler
  1353. *
  1354. * Result:
  1355. * whether or not the intr is handled
  1356. *
  1357. *----------------------------------------------------------------------------
  1358. */
  1359. static irqreturn_t
  1360. vmxnet3_msix_event(int irq, void *data)
  1361. {
  1362. struct net_device *dev = data;
  1363. struct vmxnet3_adapter *adapter = netdev_priv(dev);
  1364. /* disable intr if needed */
  1365. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1366. vmxnet3_disable_intr(adapter, adapter->intr.event_intr_idx);
  1367. if (adapter->shared->ecr)
  1368. vmxnet3_process_events(adapter);
  1369. vmxnet3_enable_intr(adapter, adapter->intr.event_intr_idx);
  1370. return IRQ_HANDLED;
  1371. }
  1372. #endif /* CONFIG_PCI_MSI */
  1373. /* Interrupt handler for vmxnet3 */
  1374. static irqreturn_t
  1375. vmxnet3_intr(int irq, void *dev_id)
  1376. {
  1377. struct net_device *dev = dev_id;
  1378. struct vmxnet3_adapter *adapter = netdev_priv(dev);
  1379. if (adapter->intr.type == VMXNET3_IT_INTX) {
  1380. u32 icr = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_ICR);
  1381. if (unlikely(icr == 0))
  1382. /* not ours */
  1383. return IRQ_NONE;
  1384. }
  1385. /* disable intr if needed */
  1386. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1387. vmxnet3_disable_all_intrs(adapter);
  1388. napi_schedule(&adapter->rx_queue[0].napi);
  1389. return IRQ_HANDLED;
  1390. }
  1391. #ifdef CONFIG_NET_POLL_CONTROLLER
  1392. /* netpoll callback. */
  1393. static void
  1394. vmxnet3_netpoll(struct net_device *netdev)
  1395. {
  1396. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1397. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1398. vmxnet3_disable_all_intrs(adapter);
  1399. vmxnet3_do_poll(adapter, adapter->rx_queue[0].rx_ring[0].size);
  1400. vmxnet3_enable_all_intrs(adapter);
  1401. }
  1402. #endif /* CONFIG_NET_POLL_CONTROLLER */
  1403. static int
  1404. vmxnet3_request_irqs(struct vmxnet3_adapter *adapter)
  1405. {
  1406. struct vmxnet3_intr *intr = &adapter->intr;
  1407. int err = 0, i;
  1408. int vector = 0;
  1409. #ifdef CONFIG_PCI_MSI
  1410. if (adapter->intr.type == VMXNET3_IT_MSIX) {
  1411. for (i = 0; i < adapter->num_tx_queues; i++) {
  1412. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE) {
  1413. sprintf(adapter->tx_queue[i].name, "%s-tx-%d",
  1414. adapter->netdev->name, vector);
  1415. err = request_irq(
  1416. intr->msix_entries[vector].vector,
  1417. vmxnet3_msix_tx, 0,
  1418. adapter->tx_queue[i].name,
  1419. &adapter->tx_queue[i]);
  1420. } else {
  1421. sprintf(adapter->tx_queue[i].name, "%s-rxtx-%d",
  1422. adapter->netdev->name, vector);
  1423. }
  1424. if (err) {
  1425. dev_err(&adapter->netdev->dev,
  1426. "Failed to request irq for MSIX, %s, "
  1427. "error %d\n",
  1428. adapter->tx_queue[i].name, err);
  1429. return err;
  1430. }
  1431. /* Handle the case where only 1 MSIx was allocated for
  1432. * all tx queues */
  1433. if (adapter->share_intr == VMXNET3_INTR_TXSHARE) {
  1434. for (; i < adapter->num_tx_queues; i++)
  1435. adapter->tx_queue[i].comp_ring.intr_idx
  1436. = vector;
  1437. vector++;
  1438. break;
  1439. } else {
  1440. adapter->tx_queue[i].comp_ring.intr_idx
  1441. = vector++;
  1442. }
  1443. }
  1444. if (adapter->share_intr == VMXNET3_INTR_BUDDYSHARE)
  1445. vector = 0;
  1446. for (i = 0; i < adapter->num_rx_queues; i++) {
  1447. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE)
  1448. sprintf(adapter->rx_queue[i].name, "%s-rx-%d",
  1449. adapter->netdev->name, vector);
  1450. else
  1451. sprintf(adapter->rx_queue[i].name, "%s-rxtx-%d",
  1452. adapter->netdev->name, vector);
  1453. err = request_irq(intr->msix_entries[vector].vector,
  1454. vmxnet3_msix_rx, 0,
  1455. adapter->rx_queue[i].name,
  1456. &(adapter->rx_queue[i]));
  1457. if (err) {
  1458. printk(KERN_ERR "Failed to request irq for MSIX"
  1459. ", %s, error %d\n",
  1460. adapter->rx_queue[i].name, err);
  1461. return err;
  1462. }
  1463. adapter->rx_queue[i].comp_ring.intr_idx = vector++;
  1464. }
  1465. sprintf(intr->event_msi_vector_name, "%s-event-%d",
  1466. adapter->netdev->name, vector);
  1467. err = request_irq(intr->msix_entries[vector].vector,
  1468. vmxnet3_msix_event, 0,
  1469. intr->event_msi_vector_name, adapter->netdev);
  1470. intr->event_intr_idx = vector;
  1471. } else if (intr->type == VMXNET3_IT_MSI) {
  1472. adapter->num_rx_queues = 1;
  1473. err = request_irq(adapter->pdev->irq, vmxnet3_intr, 0,
  1474. adapter->netdev->name, adapter->netdev);
  1475. } else {
  1476. #endif
  1477. adapter->num_rx_queues = 1;
  1478. err = request_irq(adapter->pdev->irq, vmxnet3_intr,
  1479. IRQF_SHARED, adapter->netdev->name,
  1480. adapter->netdev);
  1481. #ifdef CONFIG_PCI_MSI
  1482. }
  1483. #endif
  1484. intr->num_intrs = vector + 1;
  1485. if (err) {
  1486. printk(KERN_ERR "Failed to request irq %s (intr type:%d), error"
  1487. ":%d\n", adapter->netdev->name, intr->type, err);
  1488. } else {
  1489. /* Number of rx queues will not change after this */
  1490. for (i = 0; i < adapter->num_rx_queues; i++) {
  1491. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  1492. rq->qid = i;
  1493. rq->qid2 = i + adapter->num_rx_queues;
  1494. }
  1495. /* init our intr settings */
  1496. for (i = 0; i < intr->num_intrs; i++)
  1497. intr->mod_levels[i] = UPT1_IML_ADAPTIVE;
  1498. if (adapter->intr.type != VMXNET3_IT_MSIX) {
  1499. adapter->intr.event_intr_idx = 0;
  1500. for (i = 0; i < adapter->num_tx_queues; i++)
  1501. adapter->tx_queue[i].comp_ring.intr_idx = 0;
  1502. adapter->rx_queue[0].comp_ring.intr_idx = 0;
  1503. }
  1504. printk(KERN_INFO "%s: intr type %u, mode %u, %u vectors "
  1505. "allocated\n", adapter->netdev->name, intr->type,
  1506. intr->mask_mode, intr->num_intrs);
  1507. }
  1508. return err;
  1509. }
  1510. static void
  1511. vmxnet3_free_irqs(struct vmxnet3_adapter *adapter)
  1512. {
  1513. struct vmxnet3_intr *intr = &adapter->intr;
  1514. BUG_ON(intr->type == VMXNET3_IT_AUTO || intr->num_intrs <= 0);
  1515. switch (intr->type) {
  1516. #ifdef CONFIG_PCI_MSI
  1517. case VMXNET3_IT_MSIX:
  1518. {
  1519. int i, vector = 0;
  1520. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE) {
  1521. for (i = 0; i < adapter->num_tx_queues; i++) {
  1522. free_irq(intr->msix_entries[vector++].vector,
  1523. &(adapter->tx_queue[i]));
  1524. if (adapter->share_intr == VMXNET3_INTR_TXSHARE)
  1525. break;
  1526. }
  1527. }
  1528. for (i = 0; i < adapter->num_rx_queues; i++) {
  1529. free_irq(intr->msix_entries[vector++].vector,
  1530. &(adapter->rx_queue[i]));
  1531. }
  1532. free_irq(intr->msix_entries[vector].vector,
  1533. adapter->netdev);
  1534. BUG_ON(vector >= intr->num_intrs);
  1535. break;
  1536. }
  1537. #endif
  1538. case VMXNET3_IT_MSI:
  1539. free_irq(adapter->pdev->irq, adapter->netdev);
  1540. break;
  1541. case VMXNET3_IT_INTX:
  1542. free_irq(adapter->pdev->irq, adapter->netdev);
  1543. break;
  1544. default:
  1545. BUG_ON(true);
  1546. }
  1547. }
  1548. static void
  1549. vmxnet3_vlan_rx_register(struct net_device *netdev, struct vlan_group *grp)
  1550. {
  1551. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1552. struct Vmxnet3_DriverShared *shared = adapter->shared;
  1553. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1554. unsigned long flags;
  1555. if (grp) {
  1556. /* add vlan rx stripping. */
  1557. if (adapter->netdev->features & NETIF_F_HW_VLAN_RX) {
  1558. int i;
  1559. adapter->vlan_grp = grp;
  1560. /*
  1561. * Clear entire vfTable; then enable untagged pkts.
  1562. * Note: setting one entry in vfTable to non-zero turns
  1563. * on VLAN rx filtering.
  1564. */
  1565. for (i = 0; i < VMXNET3_VFT_SIZE; i++)
  1566. vfTable[i] = 0;
  1567. VMXNET3_SET_VFTABLE_ENTRY(vfTable, 0);
  1568. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1569. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1570. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1571. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1572. } else {
  1573. printk(KERN_ERR "%s: vlan_rx_register when device has "
  1574. "no NETIF_F_HW_VLAN_RX\n", netdev->name);
  1575. }
  1576. } else {
  1577. /* remove vlan rx stripping. */
  1578. struct Vmxnet3_DSDevRead *devRead = &shared->devRead;
  1579. adapter->vlan_grp = NULL;
  1580. if (devRead->misc.uptFeatures & UPT1_F_RXVLAN) {
  1581. int i;
  1582. for (i = 0; i < VMXNET3_VFT_SIZE; i++) {
  1583. /* clear entire vfTable; this also disables
  1584. * VLAN rx filtering
  1585. */
  1586. vfTable[i] = 0;
  1587. }
  1588. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1589. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1590. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1591. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1592. }
  1593. }
  1594. }
  1595. static void
  1596. vmxnet3_restore_vlan(struct vmxnet3_adapter *adapter)
  1597. {
  1598. if (adapter->vlan_grp) {
  1599. u16 vid;
  1600. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1601. bool activeVlan = false;
  1602. for (vid = 0; vid < VLAN_N_VID; vid++) {
  1603. if (vlan_group_get_device(adapter->vlan_grp, vid)) {
  1604. VMXNET3_SET_VFTABLE_ENTRY(vfTable, vid);
  1605. activeVlan = true;
  1606. }
  1607. }
  1608. if (activeVlan) {
  1609. /* continue to allow untagged pkts */
  1610. VMXNET3_SET_VFTABLE_ENTRY(vfTable, 0);
  1611. }
  1612. }
  1613. }
  1614. static void
  1615. vmxnet3_vlan_rx_add_vid(struct net_device *netdev, u16 vid)
  1616. {
  1617. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1618. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1619. unsigned long flags;
  1620. VMXNET3_SET_VFTABLE_ENTRY(vfTable, vid);
  1621. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1622. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1623. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1624. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1625. }
  1626. static void
  1627. vmxnet3_vlan_rx_kill_vid(struct net_device *netdev, u16 vid)
  1628. {
  1629. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1630. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1631. unsigned long flags;
  1632. VMXNET3_CLEAR_VFTABLE_ENTRY(vfTable, vid);
  1633. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1634. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1635. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1636. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1637. }
  1638. static u8 *
  1639. vmxnet3_copy_mc(struct net_device *netdev)
  1640. {
  1641. u8 *buf = NULL;
  1642. u32 sz = netdev_mc_count(netdev) * ETH_ALEN;
  1643. /* struct Vmxnet3_RxFilterConf.mfTableLen is u16. */
  1644. if (sz <= 0xffff) {
  1645. /* We may be called with BH disabled */
  1646. buf = kmalloc(sz, GFP_ATOMIC);
  1647. if (buf) {
  1648. struct netdev_hw_addr *ha;
  1649. int i = 0;
  1650. netdev_for_each_mc_addr(ha, netdev)
  1651. memcpy(buf + i++ * ETH_ALEN, ha->addr,
  1652. ETH_ALEN);
  1653. }
  1654. }
  1655. return buf;
  1656. }
  1657. static void
  1658. vmxnet3_set_mc(struct net_device *netdev)
  1659. {
  1660. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1661. unsigned long flags;
  1662. struct Vmxnet3_RxFilterConf *rxConf =
  1663. &adapter->shared->devRead.rxFilterConf;
  1664. u8 *new_table = NULL;
  1665. u32 new_mode = VMXNET3_RXM_UCAST;
  1666. if (netdev->flags & IFF_PROMISC)
  1667. new_mode |= VMXNET3_RXM_PROMISC;
  1668. if (netdev->flags & IFF_BROADCAST)
  1669. new_mode |= VMXNET3_RXM_BCAST;
  1670. if (netdev->flags & IFF_ALLMULTI)
  1671. new_mode |= VMXNET3_RXM_ALL_MULTI;
  1672. else
  1673. if (!netdev_mc_empty(netdev)) {
  1674. new_table = vmxnet3_copy_mc(netdev);
  1675. if (new_table) {
  1676. new_mode |= VMXNET3_RXM_MCAST;
  1677. rxConf->mfTableLen = cpu_to_le16(
  1678. netdev_mc_count(netdev) * ETH_ALEN);
  1679. rxConf->mfTablePA = cpu_to_le64(virt_to_phys(
  1680. new_table));
  1681. } else {
  1682. printk(KERN_INFO "%s: failed to copy mcast list"
  1683. ", setting ALL_MULTI\n", netdev->name);
  1684. new_mode |= VMXNET3_RXM_ALL_MULTI;
  1685. }
  1686. }
  1687. if (!(new_mode & VMXNET3_RXM_MCAST)) {
  1688. rxConf->mfTableLen = 0;
  1689. rxConf->mfTablePA = 0;
  1690. }
  1691. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1692. if (new_mode != rxConf->rxMode) {
  1693. rxConf->rxMode = cpu_to_le32(new_mode);
  1694. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1695. VMXNET3_CMD_UPDATE_RX_MODE);
  1696. }
  1697. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1698. VMXNET3_CMD_UPDATE_MAC_FILTERS);
  1699. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1700. kfree(new_table);
  1701. }
  1702. void
  1703. vmxnet3_rq_destroy_all(struct vmxnet3_adapter *adapter)
  1704. {
  1705. int i;
  1706. for (i = 0; i < adapter->num_rx_queues; i++)
  1707. vmxnet3_rq_destroy(&adapter->rx_queue[i], adapter);
  1708. }
  1709. /*
  1710. * Set up driver_shared based on settings in adapter.
  1711. */
  1712. static void
  1713. vmxnet3_setup_driver_shared(struct vmxnet3_adapter *adapter)
  1714. {
  1715. struct Vmxnet3_DriverShared *shared = adapter->shared;
  1716. struct Vmxnet3_DSDevRead *devRead = &shared->devRead;
  1717. struct Vmxnet3_TxQueueConf *tqc;
  1718. struct Vmxnet3_RxQueueConf *rqc;
  1719. int i;
  1720. memset(shared, 0, sizeof(*shared));
  1721. /* driver settings */
  1722. shared->magic = cpu_to_le32(VMXNET3_REV1_MAGIC);
  1723. devRead->misc.driverInfo.version = cpu_to_le32(
  1724. VMXNET3_DRIVER_VERSION_NUM);
  1725. devRead->misc.driverInfo.gos.gosBits = (sizeof(void *) == 4 ?
  1726. VMXNET3_GOS_BITS_32 : VMXNET3_GOS_BITS_64);
  1727. devRead->misc.driverInfo.gos.gosType = VMXNET3_GOS_TYPE_LINUX;
  1728. *((u32 *)&devRead->misc.driverInfo.gos) = cpu_to_le32(
  1729. *((u32 *)&devRead->misc.driverInfo.gos));
  1730. devRead->misc.driverInfo.vmxnet3RevSpt = cpu_to_le32(1);
  1731. devRead->misc.driverInfo.uptVerSpt = cpu_to_le32(1);
  1732. devRead->misc.ddPA = cpu_to_le64(virt_to_phys(adapter));
  1733. devRead->misc.ddLen = cpu_to_le32(sizeof(struct vmxnet3_adapter));
  1734. /* set up feature flags */
  1735. if (adapter->netdev->features & NETIF_F_RXCSUM)
  1736. devRead->misc.uptFeatures |= UPT1_F_RXCSUM;
  1737. if (adapter->netdev->features & NETIF_F_LRO) {
  1738. devRead->misc.uptFeatures |= UPT1_F_LRO;
  1739. devRead->misc.maxNumRxSG = cpu_to_le16(1 + MAX_SKB_FRAGS);
  1740. }
  1741. if (adapter->netdev->features & NETIF_F_HW_VLAN_RX)
  1742. devRead->misc.uptFeatures |= UPT1_F_RXVLAN;
  1743. devRead->misc.mtu = cpu_to_le32(adapter->netdev->mtu);
  1744. devRead->misc.queueDescPA = cpu_to_le64(adapter->queue_desc_pa);
  1745. devRead->misc.queueDescLen = cpu_to_le32(
  1746. adapter->num_tx_queues * sizeof(struct Vmxnet3_TxQueueDesc) +
  1747. adapter->num_rx_queues * sizeof(struct Vmxnet3_RxQueueDesc));
  1748. /* tx queue settings */
  1749. devRead->misc.numTxQueues = adapter->num_tx_queues;
  1750. for (i = 0; i < adapter->num_tx_queues; i++) {
  1751. struct vmxnet3_tx_queue *tq = &adapter->tx_queue[i];
  1752. BUG_ON(adapter->tx_queue[i].tx_ring.base == NULL);
  1753. tqc = &adapter->tqd_start[i].conf;
  1754. tqc->txRingBasePA = cpu_to_le64(tq->tx_ring.basePA);
  1755. tqc->dataRingBasePA = cpu_to_le64(tq->data_ring.basePA);
  1756. tqc->compRingBasePA = cpu_to_le64(tq->comp_ring.basePA);
  1757. tqc->ddPA = cpu_to_le64(virt_to_phys(tq->buf_info));
  1758. tqc->txRingSize = cpu_to_le32(tq->tx_ring.size);
  1759. tqc->dataRingSize = cpu_to_le32(tq->data_ring.size);
  1760. tqc->compRingSize = cpu_to_le32(tq->comp_ring.size);
  1761. tqc->ddLen = cpu_to_le32(
  1762. sizeof(struct vmxnet3_tx_buf_info) *
  1763. tqc->txRingSize);
  1764. tqc->intrIdx = tq->comp_ring.intr_idx;
  1765. }
  1766. /* rx queue settings */
  1767. devRead->misc.numRxQueues = adapter->num_rx_queues;
  1768. for (i = 0; i < adapter->num_rx_queues; i++) {
  1769. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  1770. rqc = &adapter->rqd_start[i].conf;
  1771. rqc->rxRingBasePA[0] = cpu_to_le64(rq->rx_ring[0].basePA);
  1772. rqc->rxRingBasePA[1] = cpu_to_le64(rq->rx_ring[1].basePA);
  1773. rqc->compRingBasePA = cpu_to_le64(rq->comp_ring.basePA);
  1774. rqc->ddPA = cpu_to_le64(virt_to_phys(
  1775. rq->buf_info));
  1776. rqc->rxRingSize[0] = cpu_to_le32(rq->rx_ring[0].size);
  1777. rqc->rxRingSize[1] = cpu_to_le32(rq->rx_ring[1].size);
  1778. rqc->compRingSize = cpu_to_le32(rq->comp_ring.size);
  1779. rqc->ddLen = cpu_to_le32(
  1780. sizeof(struct vmxnet3_rx_buf_info) *
  1781. (rqc->rxRingSize[0] +
  1782. rqc->rxRingSize[1]));
  1783. rqc->intrIdx = rq->comp_ring.intr_idx;
  1784. }
  1785. #ifdef VMXNET3_RSS
  1786. memset(adapter->rss_conf, 0, sizeof(*adapter->rss_conf));
  1787. if (adapter->rss) {
  1788. struct UPT1_RSSConf *rssConf = adapter->rss_conf;
  1789. devRead->misc.uptFeatures |= UPT1_F_RSS;
  1790. devRead->misc.numRxQueues = adapter->num_rx_queues;
  1791. rssConf->hashType = UPT1_RSS_HASH_TYPE_TCP_IPV4 |
  1792. UPT1_RSS_HASH_TYPE_IPV4 |
  1793. UPT1_RSS_HASH_TYPE_TCP_IPV6 |
  1794. UPT1_RSS_HASH_TYPE_IPV6;
  1795. rssConf->hashFunc = UPT1_RSS_HASH_FUNC_TOEPLITZ;
  1796. rssConf->hashKeySize = UPT1_RSS_MAX_KEY_SIZE;
  1797. rssConf->indTableSize = VMXNET3_RSS_IND_TABLE_SIZE;
  1798. get_random_bytes(&rssConf->hashKey[0], rssConf->hashKeySize);
  1799. for (i = 0; i < rssConf->indTableSize; i++)
  1800. rssConf->indTable[i] = i % adapter->num_rx_queues;
  1801. devRead->rssConfDesc.confVer = 1;
  1802. devRead->rssConfDesc.confLen = sizeof(*rssConf);
  1803. devRead->rssConfDesc.confPA = virt_to_phys(rssConf);
  1804. }
  1805. #endif /* VMXNET3_RSS */
  1806. /* intr settings */
  1807. devRead->intrConf.autoMask = adapter->intr.mask_mode ==
  1808. VMXNET3_IMM_AUTO;
  1809. devRead->intrConf.numIntrs = adapter->intr.num_intrs;
  1810. for (i = 0; i < adapter->intr.num_intrs; i++)
  1811. devRead->intrConf.modLevels[i] = adapter->intr.mod_levels[i];
  1812. devRead->intrConf.eventIntrIdx = adapter->intr.event_intr_idx;
  1813. devRead->intrConf.intrCtrl |= cpu_to_le32(VMXNET3_IC_DISABLE_ALL);
  1814. /* rx filter settings */
  1815. devRead->rxFilterConf.rxMode = 0;
  1816. vmxnet3_restore_vlan(adapter);
  1817. vmxnet3_write_mac_addr(adapter, adapter->netdev->dev_addr);
  1818. /* the rest are already zeroed */
  1819. }
  1820. int
  1821. vmxnet3_activate_dev(struct vmxnet3_adapter *adapter)
  1822. {
  1823. int err, i;
  1824. u32 ret;
  1825. unsigned long flags;
  1826. dev_dbg(&adapter->netdev->dev, "%s: skb_buf_size %d, rx_buf_per_pkt %d,"
  1827. " ring sizes %u %u %u\n", adapter->netdev->name,
  1828. adapter->skb_buf_size, adapter->rx_buf_per_pkt,
  1829. adapter->tx_queue[0].tx_ring.size,
  1830. adapter->rx_queue[0].rx_ring[0].size,
  1831. adapter->rx_queue[0].rx_ring[1].size);
  1832. vmxnet3_tq_init_all(adapter);
  1833. err = vmxnet3_rq_init_all(adapter);
  1834. if (err) {
  1835. printk(KERN_ERR "Failed to init rx queue for %s: error %d\n",
  1836. adapter->netdev->name, err);
  1837. goto rq_err;
  1838. }
  1839. err = vmxnet3_request_irqs(adapter);
  1840. if (err) {
  1841. printk(KERN_ERR "Failed to setup irq for %s: error %d\n",
  1842. adapter->netdev->name, err);
  1843. goto irq_err;
  1844. }
  1845. vmxnet3_setup_driver_shared(adapter);
  1846. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAL, VMXNET3_GET_ADDR_LO(
  1847. adapter->shared_pa));
  1848. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAH, VMXNET3_GET_ADDR_HI(
  1849. adapter->shared_pa));
  1850. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1851. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1852. VMXNET3_CMD_ACTIVATE_DEV);
  1853. ret = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_CMD);
  1854. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1855. if (ret != 0) {
  1856. printk(KERN_ERR "Failed to activate dev %s: error %u\n",
  1857. adapter->netdev->name, ret);
  1858. err = -EINVAL;
  1859. goto activate_err;
  1860. }
  1861. for (i = 0; i < adapter->num_rx_queues; i++) {
  1862. VMXNET3_WRITE_BAR0_REG(adapter,
  1863. VMXNET3_REG_RXPROD + i * VMXNET3_REG_ALIGN,
  1864. adapter->rx_queue[i].rx_ring[0].next2fill);
  1865. VMXNET3_WRITE_BAR0_REG(adapter, (VMXNET3_REG_RXPROD2 +
  1866. (i * VMXNET3_REG_ALIGN)),
  1867. adapter->rx_queue[i].rx_ring[1].next2fill);
  1868. }
  1869. /* Apply the rx filter settins last. */
  1870. vmxnet3_set_mc(adapter->netdev);
  1871. /*
  1872. * Check link state when first activating device. It will start the
  1873. * tx queue if the link is up.
  1874. */
  1875. vmxnet3_check_link(adapter, true);
  1876. for (i = 0; i < adapter->num_rx_queues; i++)
  1877. napi_enable(&adapter->rx_queue[i].napi);
  1878. vmxnet3_enable_all_intrs(adapter);
  1879. clear_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state);
  1880. return 0;
  1881. activate_err:
  1882. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAL, 0);
  1883. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAH, 0);
  1884. vmxnet3_free_irqs(adapter);
  1885. irq_err:
  1886. rq_err:
  1887. /* free up buffers we allocated */
  1888. vmxnet3_rq_cleanup_all(adapter);
  1889. return err;
  1890. }
  1891. void
  1892. vmxnet3_reset_dev(struct vmxnet3_adapter *adapter)
  1893. {
  1894. unsigned long flags;
  1895. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1896. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD, VMXNET3_CMD_RESET_DEV);
  1897. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1898. }
  1899. int
  1900. vmxnet3_quiesce_dev(struct vmxnet3_adapter *adapter)
  1901. {
  1902. int i;
  1903. unsigned long flags;
  1904. if (test_and_set_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state))
  1905. return 0;
  1906. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1907. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1908. VMXNET3_CMD_QUIESCE_DEV);
  1909. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1910. vmxnet3_disable_all_intrs(adapter);
  1911. for (i = 0; i < adapter->num_rx_queues; i++)
  1912. napi_disable(&adapter->rx_queue[i].napi);
  1913. netif_tx_disable(adapter->netdev);
  1914. adapter->link_speed = 0;
  1915. netif_carrier_off(adapter->netdev);
  1916. vmxnet3_tq_cleanup_all(adapter);
  1917. vmxnet3_rq_cleanup_all(adapter);
  1918. vmxnet3_free_irqs(adapter);
  1919. return 0;
  1920. }
  1921. static void
  1922. vmxnet3_write_mac_addr(struct vmxnet3_adapter *adapter, u8 *mac)
  1923. {
  1924. u32 tmp;
  1925. tmp = *(u32 *)mac;
  1926. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_MACL, tmp);
  1927. tmp = (mac[5] << 8) | mac[4];
  1928. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_MACH, tmp);
  1929. }
  1930. static int
  1931. vmxnet3_set_mac_addr(struct net_device *netdev, void *p)
  1932. {
  1933. struct sockaddr *addr = p;
  1934. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1935. memcpy(netdev->dev_addr, addr->sa_data, netdev->addr_len);
  1936. vmxnet3_write_mac_addr(adapter, addr->sa_data);
  1937. return 0;
  1938. }
  1939. /* ==================== initialization and cleanup routines ============ */
  1940. static int
  1941. vmxnet3_alloc_pci_resources(struct vmxnet3_adapter *adapter, bool *dma64)
  1942. {
  1943. int err;
  1944. unsigned long mmio_start, mmio_len;
  1945. struct pci_dev *pdev = adapter->pdev;
  1946. err = pci_enable_device(pdev);
  1947. if (err) {
  1948. printk(KERN_ERR "Failed to enable adapter %s: error %d\n",
  1949. pci_name(pdev), err);
  1950. return err;
  1951. }
  1952. if (pci_set_dma_mask(pdev, DMA_BIT_MASK(64)) == 0) {
  1953. if (pci_set_consistent_dma_mask(pdev, DMA_BIT_MASK(64)) != 0) {
  1954. printk(KERN_ERR "pci_set_consistent_dma_mask failed "
  1955. "for adapter %s\n", pci_name(pdev));
  1956. err = -EIO;
  1957. goto err_set_mask;
  1958. }
  1959. *dma64 = true;
  1960. } else {
  1961. if (pci_set_dma_mask(pdev, DMA_BIT_MASK(32)) != 0) {
  1962. printk(KERN_ERR "pci_set_dma_mask failed for adapter "
  1963. "%s\n", pci_name(pdev));
  1964. err = -EIO;
  1965. goto err_set_mask;
  1966. }
  1967. *dma64 = false;
  1968. }
  1969. err = pci_request_selected_regions(pdev, (1 << 2) - 1,
  1970. vmxnet3_driver_name);
  1971. if (err) {
  1972. printk(KERN_ERR "Failed to request region for adapter %s: "
  1973. "error %d\n", pci_name(pdev), err);
  1974. goto err_set_mask;
  1975. }
  1976. pci_set_master(pdev);
  1977. mmio_start = pci_resource_start(pdev, 0);
  1978. mmio_len = pci_resource_len(pdev, 0);
  1979. adapter->hw_addr0 = ioremap(mmio_start, mmio_len);
  1980. if (!adapter->hw_addr0) {
  1981. printk(KERN_ERR "Failed to map bar0 for adapter %s\n",
  1982. pci_name(pdev));
  1983. err = -EIO;
  1984. goto err_ioremap;
  1985. }
  1986. mmio_start = pci_resource_start(pdev, 1);
  1987. mmio_len = pci_resource_len(pdev, 1);
  1988. adapter->hw_addr1 = ioremap(mmio_start, mmio_len);
  1989. if (!adapter->hw_addr1) {
  1990. printk(KERN_ERR "Failed to map bar1 for adapter %s\n",
  1991. pci_name(pdev));
  1992. err = -EIO;
  1993. goto err_bar1;
  1994. }
  1995. return 0;
  1996. err_bar1:
  1997. iounmap(adapter->hw_addr0);
  1998. err_ioremap:
  1999. pci_release_selected_regions(pdev, (1 << 2) - 1);
  2000. err_set_mask:
  2001. pci_disable_device(pdev);
  2002. return err;
  2003. }
  2004. static void
  2005. vmxnet3_free_pci_resources(struct vmxnet3_adapter *adapter)
  2006. {
  2007. BUG_ON(!adapter->pdev);
  2008. iounmap(adapter->hw_addr0);
  2009. iounmap(adapter->hw_addr1);
  2010. pci_release_selected_regions(adapter->pdev, (1 << 2) - 1);
  2011. pci_disable_device(adapter->pdev);
  2012. }
  2013. static void
  2014. vmxnet3_adjust_rx_ring_size(struct vmxnet3_adapter *adapter)
  2015. {
  2016. size_t sz, i, ring0_size, ring1_size, comp_size;
  2017. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[0];
  2018. if (adapter->netdev->mtu <= VMXNET3_MAX_SKB_BUF_SIZE -
  2019. VMXNET3_MAX_ETH_HDR_SIZE) {
  2020. adapter->skb_buf_size = adapter->netdev->mtu +
  2021. VMXNET3_MAX_ETH_HDR_SIZE;
  2022. if (adapter->skb_buf_size < VMXNET3_MIN_T0_BUF_SIZE)
  2023. adapter->skb_buf_size = VMXNET3_MIN_T0_BUF_SIZE;
  2024. adapter->rx_buf_per_pkt = 1;
  2025. } else {
  2026. adapter->skb_buf_size = VMXNET3_MAX_SKB_BUF_SIZE;
  2027. sz = adapter->netdev->mtu - VMXNET3_MAX_SKB_BUF_SIZE +
  2028. VMXNET3_MAX_ETH_HDR_SIZE;
  2029. adapter->rx_buf_per_pkt = 1 + (sz + PAGE_SIZE - 1) / PAGE_SIZE;
  2030. }
  2031. /*
  2032. * for simplicity, force the ring0 size to be a multiple of
  2033. * rx_buf_per_pkt * VMXNET3_RING_SIZE_ALIGN
  2034. */
  2035. sz = adapter->rx_buf_per_pkt * VMXNET3_RING_SIZE_ALIGN;
  2036. ring0_size = adapter->rx_queue[0].rx_ring[0].size;
  2037. ring0_size = (ring0_size + sz - 1) / sz * sz;
  2038. ring0_size = min_t(u32, ring0_size, VMXNET3_RX_RING_MAX_SIZE /
  2039. sz * sz);
  2040. ring1_size = adapter->rx_queue[0].rx_ring[1].size;
  2041. comp_size = ring0_size + ring1_size;
  2042. for (i = 0; i < adapter->num_rx_queues; i++) {
  2043. rq = &adapter->rx_queue[i];
  2044. rq->rx_ring[0].size = ring0_size;
  2045. rq->rx_ring[1].size = ring1_size;
  2046. rq->comp_ring.size = comp_size;
  2047. }
  2048. }
  2049. int
  2050. vmxnet3_create_queues(struct vmxnet3_adapter *adapter, u32 tx_ring_size,
  2051. u32 rx_ring_size, u32 rx_ring2_size)
  2052. {
  2053. int err = 0, i;
  2054. for (i = 0; i < adapter->num_tx_queues; i++) {
  2055. struct vmxnet3_tx_queue *tq = &adapter->tx_queue[i];
  2056. tq->tx_ring.size = tx_ring_size;
  2057. tq->data_ring.size = tx_ring_size;
  2058. tq->comp_ring.size = tx_ring_size;
  2059. tq->shared = &adapter->tqd_start[i].ctrl;
  2060. tq->stopped = true;
  2061. tq->adapter = adapter;
  2062. tq->qid = i;
  2063. err = vmxnet3_tq_create(tq, adapter);
  2064. /*
  2065. * Too late to change num_tx_queues. We cannot do away with
  2066. * lesser number of queues than what we asked for
  2067. */
  2068. if (err)
  2069. goto queue_err;
  2070. }
  2071. adapter->rx_queue[0].rx_ring[0].size = rx_ring_size;
  2072. adapter->rx_queue[0].rx_ring[1].size = rx_ring2_size;
  2073. vmxnet3_adjust_rx_ring_size(adapter);
  2074. for (i = 0; i < adapter->num_rx_queues; i++) {
  2075. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  2076. /* qid and qid2 for rx queues will be assigned later when num
  2077. * of rx queues is finalized after allocating intrs */
  2078. rq->shared = &adapter->rqd_start[i].ctrl;
  2079. rq->adapter = adapter;
  2080. err = vmxnet3_rq_create(rq, adapter);
  2081. if (err) {
  2082. if (i == 0) {
  2083. printk(KERN_ERR "Could not allocate any rx"
  2084. "queues. Aborting.\n");
  2085. goto queue_err;
  2086. } else {
  2087. printk(KERN_INFO "Number of rx queues changed "
  2088. "to : %d.\n", i);
  2089. adapter->num_rx_queues = i;
  2090. err = 0;
  2091. break;
  2092. }
  2093. }
  2094. }
  2095. return err;
  2096. queue_err:
  2097. vmxnet3_tq_destroy_all(adapter);
  2098. return err;
  2099. }
  2100. static int
  2101. vmxnet3_open(struct net_device *netdev)
  2102. {
  2103. struct vmxnet3_adapter *adapter;
  2104. int err, i;
  2105. adapter = netdev_priv(netdev);
  2106. for (i = 0; i < adapter->num_tx_queues; i++)
  2107. spin_lock_init(&adapter->tx_queue[i].tx_lock);
  2108. err = vmxnet3_create_queues(adapter, VMXNET3_DEF_TX_RING_SIZE,
  2109. VMXNET3_DEF_RX_RING_SIZE,
  2110. VMXNET3_DEF_RX_RING_SIZE);
  2111. if (err)
  2112. goto queue_err;
  2113. err = vmxnet3_activate_dev(adapter);
  2114. if (err)
  2115. goto activate_err;
  2116. return 0;
  2117. activate_err:
  2118. vmxnet3_rq_destroy_all(adapter);
  2119. vmxnet3_tq_destroy_all(adapter);
  2120. queue_err:
  2121. return err;
  2122. }
  2123. static int
  2124. vmxnet3_close(struct net_device *netdev)
  2125. {
  2126. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2127. /*
  2128. * Reset_work may be in the middle of resetting the device, wait for its
  2129. * completion.
  2130. */
  2131. while (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2132. msleep(1);
  2133. vmxnet3_quiesce_dev(adapter);
  2134. vmxnet3_rq_destroy_all(adapter);
  2135. vmxnet3_tq_destroy_all(adapter);
  2136. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2137. return 0;
  2138. }
  2139. void
  2140. vmxnet3_force_close(struct vmxnet3_adapter *adapter)
  2141. {
  2142. int i;
  2143. /*
  2144. * we must clear VMXNET3_STATE_BIT_RESETTING, otherwise
  2145. * vmxnet3_close() will deadlock.
  2146. */
  2147. BUG_ON(test_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state));
  2148. /* we need to enable NAPI, otherwise dev_close will deadlock */
  2149. for (i = 0; i < adapter->num_rx_queues; i++)
  2150. napi_enable(&adapter->rx_queue[i].napi);
  2151. dev_close(adapter->netdev);
  2152. }
  2153. static int
  2154. vmxnet3_change_mtu(struct net_device *netdev, int new_mtu)
  2155. {
  2156. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2157. int err = 0;
  2158. if (new_mtu < VMXNET3_MIN_MTU || new_mtu > VMXNET3_MAX_MTU)
  2159. return -EINVAL;
  2160. netdev->mtu = new_mtu;
  2161. /*
  2162. * Reset_work may be in the middle of resetting the device, wait for its
  2163. * completion.
  2164. */
  2165. while (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2166. msleep(1);
  2167. if (netif_running(netdev)) {
  2168. vmxnet3_quiesce_dev(adapter);
  2169. vmxnet3_reset_dev(adapter);
  2170. /* we need to re-create the rx queue based on the new mtu */
  2171. vmxnet3_rq_destroy_all(adapter);
  2172. vmxnet3_adjust_rx_ring_size(adapter);
  2173. err = vmxnet3_rq_create_all(adapter);
  2174. if (err) {
  2175. printk(KERN_ERR "%s: failed to re-create rx queues,"
  2176. " error %d. Closing it.\n", netdev->name, err);
  2177. goto out;
  2178. }
  2179. err = vmxnet3_activate_dev(adapter);
  2180. if (err) {
  2181. printk(KERN_ERR "%s: failed to re-activate, error %d. "
  2182. "Closing it\n", netdev->name, err);
  2183. goto out;
  2184. }
  2185. }
  2186. out:
  2187. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2188. if (err)
  2189. vmxnet3_force_close(adapter);
  2190. return err;
  2191. }
  2192. static void
  2193. vmxnet3_declare_features(struct vmxnet3_adapter *adapter, bool dma64)
  2194. {
  2195. struct net_device *netdev = adapter->netdev;
  2196. netdev->hw_features = NETIF_F_SG | NETIF_F_RXCSUM |
  2197. NETIF_F_HW_CSUM | NETIF_F_HW_VLAN_TX |
  2198. NETIF_F_TSO | NETIF_F_TSO6 | NETIF_F_LRO;
  2199. if (dma64)
  2200. netdev->features |= NETIF_F_HIGHDMA;
  2201. netdev->vlan_features = netdev->hw_features & ~NETIF_F_HW_VLAN_TX;
  2202. netdev->features = netdev->hw_features |
  2203. NETIF_F_HW_VLAN_RX | NETIF_F_HW_VLAN_FILTER;
  2204. netdev_info(adapter->netdev,
  2205. "features: sg csum vlan jf tso tsoIPv6 lro%s\n",
  2206. dma64 ? " highDMA" : "");
  2207. }
  2208. static void
  2209. vmxnet3_read_mac_addr(struct vmxnet3_adapter *adapter, u8 *mac)
  2210. {
  2211. u32 tmp;
  2212. tmp = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_MACL);
  2213. *(u32 *)mac = tmp;
  2214. tmp = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_MACH);
  2215. mac[4] = tmp & 0xff;
  2216. mac[5] = (tmp >> 8) & 0xff;
  2217. }
  2218. #ifdef CONFIG_PCI_MSI
  2219. /*
  2220. * Enable MSIx vectors.
  2221. * Returns :
  2222. * 0 on successful enabling of required vectors,
  2223. * VMXNET3_LINUX_MIN_MSIX_VECT when only minimum number of vectors required
  2224. * could be enabled.
  2225. * number of vectors which can be enabled otherwise (this number is smaller
  2226. * than VMXNET3_LINUX_MIN_MSIX_VECT)
  2227. */
  2228. static int
  2229. vmxnet3_acquire_msix_vectors(struct vmxnet3_adapter *adapter,
  2230. int vectors)
  2231. {
  2232. int err = 0, vector_threshold;
  2233. vector_threshold = VMXNET3_LINUX_MIN_MSIX_VECT;
  2234. while (vectors >= vector_threshold) {
  2235. err = pci_enable_msix(adapter->pdev, adapter->intr.msix_entries,
  2236. vectors);
  2237. if (!err) {
  2238. adapter->intr.num_intrs = vectors;
  2239. return 0;
  2240. } else if (err < 0) {
  2241. printk(KERN_ERR "Failed to enable MSI-X for %s, error"
  2242. " %d\n", adapter->netdev->name, err);
  2243. vectors = 0;
  2244. } else if (err < vector_threshold) {
  2245. break;
  2246. } else {
  2247. /* If fails to enable required number of MSI-x vectors
  2248. * try enabling minimum number of vectors required.
  2249. */
  2250. vectors = vector_threshold;
  2251. printk(KERN_ERR "Failed to enable %d MSI-X for %s, try"
  2252. " %d instead\n", vectors, adapter->netdev->name,
  2253. vector_threshold);
  2254. }
  2255. }
  2256. printk(KERN_INFO "Number of MSI-X interrupts which can be allocatedi"
  2257. " are lower than min threshold required.\n");
  2258. return err;
  2259. }
  2260. #endif /* CONFIG_PCI_MSI */
  2261. static void
  2262. vmxnet3_alloc_intr_resources(struct vmxnet3_adapter *adapter)
  2263. {
  2264. u32 cfg;
  2265. unsigned long flags;
  2266. /* intr settings */
  2267. spin_lock_irqsave(&adapter->cmd_lock, flags);
  2268. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  2269. VMXNET3_CMD_GET_CONF_INTR);
  2270. cfg = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_CMD);
  2271. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  2272. adapter->intr.type = cfg & 0x3;
  2273. adapter->intr.mask_mode = (cfg >> 2) & 0x3;
  2274. if (adapter->intr.type == VMXNET3_IT_AUTO) {
  2275. adapter->intr.type = VMXNET3_IT_MSIX;
  2276. }
  2277. #ifdef CONFIG_PCI_MSI
  2278. if (adapter->intr.type == VMXNET3_IT_MSIX) {
  2279. int vector, err = 0;
  2280. adapter->intr.num_intrs = (adapter->share_intr ==
  2281. VMXNET3_INTR_TXSHARE) ? 1 :
  2282. adapter->num_tx_queues;
  2283. adapter->intr.num_intrs += (adapter->share_intr ==
  2284. VMXNET3_INTR_BUDDYSHARE) ? 0 :
  2285. adapter->num_rx_queues;
  2286. adapter->intr.num_intrs += 1; /* for link event */
  2287. adapter->intr.num_intrs = (adapter->intr.num_intrs >
  2288. VMXNET3_LINUX_MIN_MSIX_VECT
  2289. ? adapter->intr.num_intrs :
  2290. VMXNET3_LINUX_MIN_MSIX_VECT);
  2291. for (vector = 0; vector < adapter->intr.num_intrs; vector++)
  2292. adapter->intr.msix_entries[vector].entry = vector;
  2293. err = vmxnet3_acquire_msix_vectors(adapter,
  2294. adapter->intr.num_intrs);
  2295. /* If we cannot allocate one MSIx vector per queue
  2296. * then limit the number of rx queues to 1
  2297. */
  2298. if (err == VMXNET3_LINUX_MIN_MSIX_VECT) {
  2299. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE
  2300. || adapter->num_rx_queues != 1) {
  2301. adapter->share_intr = VMXNET3_INTR_TXSHARE;
  2302. printk(KERN_ERR "Number of rx queues : 1\n");
  2303. adapter->num_rx_queues = 1;
  2304. adapter->intr.num_intrs =
  2305. VMXNET3_LINUX_MIN_MSIX_VECT;
  2306. }
  2307. return;
  2308. }
  2309. if (!err)
  2310. return;
  2311. /* If we cannot allocate MSIx vectors use only one rx queue */
  2312. printk(KERN_INFO "Failed to enable MSI-X for %s, error %d."
  2313. "#rx queues : 1, try MSI\n", adapter->netdev->name, err);
  2314. adapter->intr.type = VMXNET3_IT_MSI;
  2315. }
  2316. if (adapter->intr.type == VMXNET3_IT_MSI) {
  2317. int err;
  2318. err = pci_enable_msi(adapter->pdev);
  2319. if (!err) {
  2320. adapter->num_rx_queues = 1;
  2321. adapter->intr.num_intrs = 1;
  2322. return;
  2323. }
  2324. }
  2325. #endif /* CONFIG_PCI_MSI */
  2326. adapter->num_rx_queues = 1;
  2327. printk(KERN_INFO "Using INTx interrupt, #Rx queues: 1.\n");
  2328. adapter->intr.type = VMXNET3_IT_INTX;
  2329. /* INT-X related setting */
  2330. adapter->intr.num_intrs = 1;
  2331. }
  2332. static void
  2333. vmxnet3_free_intr_resources(struct vmxnet3_adapter *adapter)
  2334. {
  2335. if (adapter->intr.type == VMXNET3_IT_MSIX)
  2336. pci_disable_msix(adapter->pdev);
  2337. else if (adapter->intr.type == VMXNET3_IT_MSI)
  2338. pci_disable_msi(adapter->pdev);
  2339. else
  2340. BUG_ON(adapter->intr.type != VMXNET3_IT_INTX);
  2341. }
  2342. static void
  2343. vmxnet3_tx_timeout(struct net_device *netdev)
  2344. {
  2345. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2346. adapter->tx_timeout_count++;
  2347. printk(KERN_ERR "%s: tx hang\n", adapter->netdev->name);
  2348. schedule_work(&adapter->work);
  2349. netif_wake_queue(adapter->netdev);
  2350. }
  2351. static void
  2352. vmxnet3_reset_work(struct work_struct *data)
  2353. {
  2354. struct vmxnet3_adapter *adapter;
  2355. adapter = container_of(data, struct vmxnet3_adapter, work);
  2356. /* if another thread is resetting the device, no need to proceed */
  2357. if (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2358. return;
  2359. /* if the device is closed, we must leave it alone */
  2360. rtnl_lock();
  2361. if (netif_running(adapter->netdev)) {
  2362. printk(KERN_INFO "%s: resetting\n", adapter->netdev->name);
  2363. vmxnet3_quiesce_dev(adapter);
  2364. vmxnet3_reset_dev(adapter);
  2365. vmxnet3_activate_dev(adapter);
  2366. } else {
  2367. printk(KERN_INFO "%s: already closed\n", adapter->netdev->name);
  2368. }
  2369. rtnl_unlock();
  2370. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2371. }
  2372. static int __devinit
  2373. vmxnet3_probe_device(struct pci_dev *pdev,
  2374. const struct pci_device_id *id)
  2375. {
  2376. static const struct net_device_ops vmxnet3_netdev_ops = {
  2377. .ndo_open = vmxnet3_open,
  2378. .ndo_stop = vmxnet3_close,
  2379. .ndo_start_xmit = vmxnet3_xmit_frame,
  2380. .ndo_set_mac_address = vmxnet3_set_mac_addr,
  2381. .ndo_change_mtu = vmxnet3_change_mtu,
  2382. .ndo_set_features = vmxnet3_set_features,
  2383. .ndo_get_stats = vmxnet3_get_stats,
  2384. .ndo_tx_timeout = vmxnet3_tx_timeout,
  2385. .ndo_set_multicast_list = vmxnet3_set_mc,
  2386. .ndo_vlan_rx_register = vmxnet3_vlan_rx_register,
  2387. .ndo_vlan_rx_add_vid = vmxnet3_vlan_rx_add_vid,
  2388. .ndo_vlan_rx_kill_vid = vmxnet3_vlan_rx_kill_vid,
  2389. #ifdef CONFIG_NET_POLL_CONTROLLER
  2390. .ndo_poll_controller = vmxnet3_netpoll,
  2391. #endif
  2392. };
  2393. int err;
  2394. bool dma64 = false; /* stupid gcc */
  2395. u32 ver;
  2396. struct net_device *netdev;
  2397. struct vmxnet3_adapter *adapter;
  2398. u8 mac[ETH_ALEN];
  2399. int size;
  2400. int num_tx_queues;
  2401. int num_rx_queues;
  2402. if (!pci_msi_enabled())
  2403. enable_mq = 0;
  2404. #ifdef VMXNET3_RSS
  2405. if (enable_mq)
  2406. num_rx_queues = min(VMXNET3_DEVICE_MAX_RX_QUEUES,
  2407. (int)num_online_cpus());
  2408. else
  2409. #endif
  2410. num_rx_queues = 1;
  2411. if (enable_mq)
  2412. num_tx_queues = min(VMXNET3_DEVICE_MAX_TX_QUEUES,
  2413. (int)num_online_cpus());
  2414. else
  2415. num_tx_queues = 1;
  2416. netdev = alloc_etherdev_mq(sizeof(struct vmxnet3_adapter),
  2417. max(num_tx_queues, num_rx_queues));
  2418. printk(KERN_INFO "# of Tx queues : %d, # of Rx queues : %d\n",
  2419. num_tx_queues, num_rx_queues);
  2420. if (!netdev) {
  2421. printk(KERN_ERR "Failed to alloc ethernet device for adapter "
  2422. "%s\n", pci_name(pdev));
  2423. return -ENOMEM;
  2424. }
  2425. pci_set_drvdata(pdev, netdev);
  2426. adapter = netdev_priv(netdev);
  2427. adapter->netdev = netdev;
  2428. adapter->pdev = pdev;
  2429. spin_lock_init(&adapter->cmd_lock);
  2430. adapter->shared = pci_alloc_consistent(adapter->pdev,
  2431. sizeof(struct Vmxnet3_DriverShared),
  2432. &adapter->shared_pa);
  2433. if (!adapter->shared) {
  2434. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2435. pci_name(pdev));
  2436. err = -ENOMEM;
  2437. goto err_alloc_shared;
  2438. }
  2439. adapter->num_rx_queues = num_rx_queues;
  2440. adapter->num_tx_queues = num_tx_queues;
  2441. size = sizeof(struct Vmxnet3_TxQueueDesc) * adapter->num_tx_queues;
  2442. size += sizeof(struct Vmxnet3_RxQueueDesc) * adapter->num_rx_queues;
  2443. adapter->tqd_start = pci_alloc_consistent(adapter->pdev, size,
  2444. &adapter->queue_desc_pa);
  2445. if (!adapter->tqd_start) {
  2446. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2447. pci_name(pdev));
  2448. err = -ENOMEM;
  2449. goto err_alloc_queue_desc;
  2450. }
  2451. adapter->rqd_start = (struct Vmxnet3_RxQueueDesc *)(adapter->tqd_start +
  2452. adapter->num_tx_queues);
  2453. adapter->pm_conf = kmalloc(sizeof(struct Vmxnet3_PMConf), GFP_KERNEL);
  2454. if (adapter->pm_conf == NULL) {
  2455. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2456. pci_name(pdev));
  2457. err = -ENOMEM;
  2458. goto err_alloc_pm;
  2459. }
  2460. #ifdef VMXNET3_RSS
  2461. adapter->rss_conf = kmalloc(sizeof(struct UPT1_RSSConf), GFP_KERNEL);
  2462. if (adapter->rss_conf == NULL) {
  2463. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2464. pci_name(pdev));
  2465. err = -ENOMEM;
  2466. goto err_alloc_rss;
  2467. }
  2468. #endif /* VMXNET3_RSS */
  2469. err = vmxnet3_alloc_pci_resources(adapter, &dma64);
  2470. if (err < 0)
  2471. goto err_alloc_pci;
  2472. ver = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_VRRS);
  2473. if (ver & 1) {
  2474. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_VRRS, 1);
  2475. } else {
  2476. printk(KERN_ERR "Incompatible h/w version (0x%x) for adapter"
  2477. " %s\n", ver, pci_name(pdev));
  2478. err = -EBUSY;
  2479. goto err_ver;
  2480. }
  2481. ver = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_UVRS);
  2482. if (ver & 1) {
  2483. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_UVRS, 1);
  2484. } else {
  2485. printk(KERN_ERR "Incompatible upt version (0x%x) for "
  2486. "adapter %s\n", ver, pci_name(pdev));
  2487. err = -EBUSY;
  2488. goto err_ver;
  2489. }
  2490. vmxnet3_declare_features(adapter, dma64);
  2491. adapter->dev_number = atomic_read(&devices_found);
  2492. adapter->share_intr = irq_share_mode;
  2493. if (adapter->share_intr == VMXNET3_INTR_BUDDYSHARE &&
  2494. adapter->num_tx_queues != adapter->num_rx_queues)
  2495. adapter->share_intr = VMXNET3_INTR_DONTSHARE;
  2496. vmxnet3_alloc_intr_resources(adapter);
  2497. #ifdef VMXNET3_RSS
  2498. if (adapter->num_rx_queues > 1 &&
  2499. adapter->intr.type == VMXNET3_IT_MSIX) {
  2500. adapter->rss = true;
  2501. printk(KERN_INFO "RSS is enabled.\n");
  2502. } else {
  2503. adapter->rss = false;
  2504. }
  2505. #endif
  2506. vmxnet3_read_mac_addr(adapter, mac);
  2507. memcpy(netdev->dev_addr, mac, netdev->addr_len);
  2508. netdev->netdev_ops = &vmxnet3_netdev_ops;
  2509. vmxnet3_set_ethtool_ops(netdev);
  2510. netdev->watchdog_timeo = 5 * HZ;
  2511. INIT_WORK(&adapter->work, vmxnet3_reset_work);
  2512. if (adapter->intr.type == VMXNET3_IT_MSIX) {
  2513. int i;
  2514. for (i = 0; i < adapter->num_rx_queues; i++) {
  2515. netif_napi_add(adapter->netdev,
  2516. &adapter->rx_queue[i].napi,
  2517. vmxnet3_poll_rx_only, 64);
  2518. }
  2519. } else {
  2520. netif_napi_add(adapter->netdev, &adapter->rx_queue[0].napi,
  2521. vmxnet3_poll, 64);
  2522. }
  2523. netif_set_real_num_tx_queues(adapter->netdev, adapter->num_tx_queues);
  2524. netif_set_real_num_rx_queues(adapter->netdev, adapter->num_rx_queues);
  2525. SET_NETDEV_DEV(netdev, &pdev->dev);
  2526. err = register_netdev(netdev);
  2527. if (err) {
  2528. printk(KERN_ERR "Failed to register adapter %s\n",
  2529. pci_name(pdev));
  2530. goto err_register;
  2531. }
  2532. set_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state);
  2533. vmxnet3_check_link(adapter, false);
  2534. atomic_inc(&devices_found);
  2535. return 0;
  2536. err_register:
  2537. vmxnet3_free_intr_resources(adapter);
  2538. err_ver:
  2539. vmxnet3_free_pci_resources(adapter);
  2540. err_alloc_pci:
  2541. #ifdef VMXNET3_RSS
  2542. kfree(adapter->rss_conf);
  2543. err_alloc_rss:
  2544. #endif
  2545. kfree(adapter->pm_conf);
  2546. err_alloc_pm:
  2547. pci_free_consistent(adapter->pdev, size, adapter->tqd_start,
  2548. adapter->queue_desc_pa);
  2549. err_alloc_queue_desc:
  2550. pci_free_consistent(adapter->pdev, sizeof(struct Vmxnet3_DriverShared),
  2551. adapter->shared, adapter->shared_pa);
  2552. err_alloc_shared:
  2553. pci_set_drvdata(pdev, NULL);
  2554. free_netdev(netdev);
  2555. return err;
  2556. }
  2557. static void __devexit
  2558. vmxnet3_remove_device(struct pci_dev *pdev)
  2559. {
  2560. struct net_device *netdev = pci_get_drvdata(pdev);
  2561. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2562. int size = 0;
  2563. int num_rx_queues;
  2564. #ifdef VMXNET3_RSS
  2565. if (enable_mq)
  2566. num_rx_queues = min(VMXNET3_DEVICE_MAX_RX_QUEUES,
  2567. (int)num_online_cpus());
  2568. else
  2569. #endif
  2570. num_rx_queues = 1;
  2571. cancel_work_sync(&adapter->work);
  2572. unregister_netdev(netdev);
  2573. vmxnet3_free_intr_resources(adapter);
  2574. vmxnet3_free_pci_resources(adapter);
  2575. #ifdef VMXNET3_RSS
  2576. kfree(adapter->rss_conf);
  2577. #endif
  2578. kfree(adapter->pm_conf);
  2579. size = sizeof(struct Vmxnet3_TxQueueDesc) * adapter->num_tx_queues;
  2580. size += sizeof(struct Vmxnet3_RxQueueDesc) * num_rx_queues;
  2581. pci_free_consistent(adapter->pdev, size, adapter->tqd_start,
  2582. adapter->queue_desc_pa);
  2583. pci_free_consistent(adapter->pdev, sizeof(struct Vmxnet3_DriverShared),
  2584. adapter->shared, adapter->shared_pa);
  2585. free_netdev(netdev);
  2586. }
  2587. #ifdef CONFIG_PM
  2588. static int
  2589. vmxnet3_suspend(struct device *device)
  2590. {
  2591. struct pci_dev *pdev = to_pci_dev(device);
  2592. struct net_device *netdev = pci_get_drvdata(pdev);
  2593. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2594. struct Vmxnet3_PMConf *pmConf;
  2595. struct ethhdr *ehdr;
  2596. struct arphdr *ahdr;
  2597. u8 *arpreq;
  2598. struct in_device *in_dev;
  2599. struct in_ifaddr *ifa;
  2600. unsigned long flags;
  2601. int i = 0;
  2602. if (!netif_running(netdev))
  2603. return 0;
  2604. for (i = 0; i < adapter->num_rx_queues; i++)
  2605. napi_disable(&adapter->rx_queue[i].napi);
  2606. vmxnet3_disable_all_intrs(adapter);
  2607. vmxnet3_free_irqs(adapter);
  2608. vmxnet3_free_intr_resources(adapter);
  2609. netif_device_detach(netdev);
  2610. netif_tx_stop_all_queues(netdev);
  2611. /* Create wake-up filters. */
  2612. pmConf = adapter->pm_conf;
  2613. memset(pmConf, 0, sizeof(*pmConf));
  2614. if (adapter->wol & WAKE_UCAST) {
  2615. pmConf->filters[i].patternSize = ETH_ALEN;
  2616. pmConf->filters[i].maskSize = 1;
  2617. memcpy(pmConf->filters[i].pattern, netdev->dev_addr, ETH_ALEN);
  2618. pmConf->filters[i].mask[0] = 0x3F; /* LSB ETH_ALEN bits */
  2619. pmConf->wakeUpEvents |= VMXNET3_PM_WAKEUP_FILTER;
  2620. i++;
  2621. }
  2622. if (adapter->wol & WAKE_ARP) {
  2623. in_dev = in_dev_get(netdev);
  2624. if (!in_dev)
  2625. goto skip_arp;
  2626. ifa = (struct in_ifaddr *)in_dev->ifa_list;
  2627. if (!ifa)
  2628. goto skip_arp;
  2629. pmConf->filters[i].patternSize = ETH_HLEN + /* Ethernet header*/
  2630. sizeof(struct arphdr) + /* ARP header */
  2631. 2 * ETH_ALEN + /* 2 Ethernet addresses*/
  2632. 2 * sizeof(u32); /*2 IPv4 addresses */
  2633. pmConf->filters[i].maskSize =
  2634. (pmConf->filters[i].patternSize - 1) / 8 + 1;
  2635. /* ETH_P_ARP in Ethernet header. */
  2636. ehdr = (struct ethhdr *)pmConf->filters[i].pattern;
  2637. ehdr->h_proto = htons(ETH_P_ARP);
  2638. /* ARPOP_REQUEST in ARP header. */
  2639. ahdr = (struct arphdr *)&pmConf->filters[i].pattern[ETH_HLEN];
  2640. ahdr->ar_op = htons(ARPOP_REQUEST);
  2641. arpreq = (u8 *)(ahdr + 1);
  2642. /* The Unicast IPv4 address in 'tip' field. */
  2643. arpreq += 2 * ETH_ALEN + sizeof(u32);
  2644. *(u32 *)arpreq = ifa->ifa_address;
  2645. /* The mask for the relevant bits. */
  2646. pmConf->filters[i].mask[0] = 0x00;
  2647. pmConf->filters[i].mask[1] = 0x30; /* ETH_P_ARP */
  2648. pmConf->filters[i].mask[2] = 0x30; /* ARPOP_REQUEST */
  2649. pmConf->filters[i].mask[3] = 0x00;
  2650. pmConf->filters[i].mask[4] = 0xC0; /* IPv4 TIP */
  2651. pmConf->filters[i].mask[5] = 0x03; /* IPv4 TIP */
  2652. in_dev_put(in_dev);
  2653. pmConf->wakeUpEvents |= VMXNET3_PM_WAKEUP_FILTER;
  2654. i++;
  2655. }
  2656. skip_arp:
  2657. if (adapter->wol & WAKE_MAGIC)
  2658. pmConf->wakeUpEvents |= VMXNET3_PM_WAKEUP_MAGIC;
  2659. pmConf->numFilters = i;
  2660. adapter->shared->devRead.pmConfDesc.confVer = cpu_to_le32(1);
  2661. adapter->shared->devRead.pmConfDesc.confLen = cpu_to_le32(sizeof(
  2662. *pmConf));
  2663. adapter->shared->devRead.pmConfDesc.confPA = cpu_to_le64(virt_to_phys(
  2664. pmConf));
  2665. spin_lock_irqsave(&adapter->cmd_lock, flags);
  2666. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  2667. VMXNET3_CMD_UPDATE_PMCFG);
  2668. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  2669. pci_save_state(pdev);
  2670. pci_enable_wake(pdev, pci_choose_state(pdev, PMSG_SUSPEND),
  2671. adapter->wol);
  2672. pci_disable_device(pdev);
  2673. pci_set_power_state(pdev, pci_choose_state(pdev, PMSG_SUSPEND));
  2674. return 0;
  2675. }
  2676. static int
  2677. vmxnet3_resume(struct device *device)
  2678. {
  2679. int err, i = 0;
  2680. unsigned long flags;
  2681. struct pci_dev *pdev = to_pci_dev(device);
  2682. struct net_device *netdev = pci_get_drvdata(pdev);
  2683. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2684. struct Vmxnet3_PMConf *pmConf;
  2685. if (!netif_running(netdev))
  2686. return 0;
  2687. /* Destroy wake-up filters. */
  2688. pmConf = adapter->pm_conf;
  2689. memset(pmConf, 0, sizeof(*pmConf));
  2690. adapter->shared->devRead.pmConfDesc.confVer = cpu_to_le32(1);
  2691. adapter->shared->devRead.pmConfDesc.confLen = cpu_to_le32(sizeof(
  2692. *pmConf));
  2693. adapter->shared->devRead.pmConfDesc.confPA = cpu_to_le64(virt_to_phys(
  2694. pmConf));
  2695. netif_device_attach(netdev);
  2696. pci_set_power_state(pdev, PCI_D0);
  2697. pci_restore_state(pdev);
  2698. err = pci_enable_device_mem(pdev);
  2699. if (err != 0)
  2700. return err;
  2701. pci_enable_wake(pdev, PCI_D0, 0);
  2702. spin_lock_irqsave(&adapter->cmd_lock, flags);
  2703. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  2704. VMXNET3_CMD_UPDATE_PMCFG);
  2705. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  2706. vmxnet3_alloc_intr_resources(adapter);
  2707. vmxnet3_request_irqs(adapter);
  2708. for (i = 0; i < adapter->num_rx_queues; i++)
  2709. napi_enable(&adapter->rx_queue[i].napi);
  2710. vmxnet3_enable_all_intrs(adapter);
  2711. return 0;
  2712. }
  2713. static const struct dev_pm_ops vmxnet3_pm_ops = {
  2714. .suspend = vmxnet3_suspend,
  2715. .resume = vmxnet3_resume,
  2716. };
  2717. #endif
  2718. static struct pci_driver vmxnet3_driver = {
  2719. .name = vmxnet3_driver_name,
  2720. .id_table = vmxnet3_pciid_table,
  2721. .probe = vmxnet3_probe_device,
  2722. .remove = __devexit_p(vmxnet3_remove_device),
  2723. #ifdef CONFIG_PM
  2724. .driver.pm = &vmxnet3_pm_ops,
  2725. #endif
  2726. };
  2727. static int __init
  2728. vmxnet3_init_module(void)
  2729. {
  2730. printk(KERN_INFO "%s - version %s\n", VMXNET3_DRIVER_DESC,
  2731. VMXNET3_DRIVER_VERSION_REPORT);
  2732. return pci_register_driver(&vmxnet3_driver);
  2733. }
  2734. module_init(vmxnet3_init_module);
  2735. static void
  2736. vmxnet3_exit_module(void)
  2737. {
  2738. pci_unregister_driver(&vmxnet3_driver);
  2739. }
  2740. module_exit(vmxnet3_exit_module);
  2741. MODULE_AUTHOR("VMware, Inc.");
  2742. MODULE_DESCRIPTION(VMXNET3_DRIVER_DESC);
  2743. MODULE_LICENSE("GPL v2");
  2744. MODULE_VERSION(VMXNET3_DRIVER_VERSION_STRING);