vmxnet3_drv.c 87 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313
  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. tbi = tq->buf_info + tq->tx_ring.next2comp;
  336. vmxnet3_unmap_tx_buf(tbi, adapter->pdev);
  337. if (tbi->skb) {
  338. dev_kfree_skb_any(tbi->skb);
  339. tbi->skb = NULL;
  340. }
  341. vmxnet3_cmd_ring_adv_next2comp(&tq->tx_ring);
  342. }
  343. /* sanity check, verify all buffers are indeed unmapped and freed */
  344. for (i = 0; i < tq->tx_ring.size; i++) {
  345. BUG_ON(tq->buf_info[i].skb != NULL ||
  346. tq->buf_info[i].map_type != VMXNET3_MAP_NONE);
  347. }
  348. tq->tx_ring.gen = VMXNET3_INIT_GEN;
  349. tq->tx_ring.next2fill = tq->tx_ring.next2comp = 0;
  350. tq->comp_ring.gen = VMXNET3_INIT_GEN;
  351. tq->comp_ring.next2proc = 0;
  352. }
  353. static void
  354. vmxnet3_tq_destroy(struct vmxnet3_tx_queue *tq,
  355. struct vmxnet3_adapter *adapter)
  356. {
  357. if (tq->tx_ring.base) {
  358. pci_free_consistent(adapter->pdev, tq->tx_ring.size *
  359. sizeof(struct Vmxnet3_TxDesc),
  360. tq->tx_ring.base, tq->tx_ring.basePA);
  361. tq->tx_ring.base = NULL;
  362. }
  363. if (tq->data_ring.base) {
  364. pci_free_consistent(adapter->pdev, tq->data_ring.size *
  365. sizeof(struct Vmxnet3_TxDataDesc),
  366. tq->data_ring.base, tq->data_ring.basePA);
  367. tq->data_ring.base = NULL;
  368. }
  369. if (tq->comp_ring.base) {
  370. pci_free_consistent(adapter->pdev, tq->comp_ring.size *
  371. sizeof(struct Vmxnet3_TxCompDesc),
  372. tq->comp_ring.base, tq->comp_ring.basePA);
  373. tq->comp_ring.base = NULL;
  374. }
  375. kfree(tq->buf_info);
  376. tq->buf_info = NULL;
  377. }
  378. /* Destroy all tx queues */
  379. void
  380. vmxnet3_tq_destroy_all(struct vmxnet3_adapter *adapter)
  381. {
  382. int i;
  383. for (i = 0; i < adapter->num_tx_queues; i++)
  384. vmxnet3_tq_destroy(&adapter->tx_queue[i], adapter);
  385. }
  386. static void
  387. vmxnet3_tq_init(struct vmxnet3_tx_queue *tq,
  388. struct vmxnet3_adapter *adapter)
  389. {
  390. int i;
  391. /* reset the tx ring contents to 0 and reset the tx ring states */
  392. memset(tq->tx_ring.base, 0, tq->tx_ring.size *
  393. sizeof(struct Vmxnet3_TxDesc));
  394. tq->tx_ring.next2fill = tq->tx_ring.next2comp = 0;
  395. tq->tx_ring.gen = VMXNET3_INIT_GEN;
  396. memset(tq->data_ring.base, 0, tq->data_ring.size *
  397. sizeof(struct Vmxnet3_TxDataDesc));
  398. /* reset the tx comp ring contents to 0 and reset comp ring states */
  399. memset(tq->comp_ring.base, 0, tq->comp_ring.size *
  400. sizeof(struct Vmxnet3_TxCompDesc));
  401. tq->comp_ring.next2proc = 0;
  402. tq->comp_ring.gen = VMXNET3_INIT_GEN;
  403. /* reset the bookkeeping data */
  404. memset(tq->buf_info, 0, sizeof(tq->buf_info[0]) * tq->tx_ring.size);
  405. for (i = 0; i < tq->tx_ring.size; i++)
  406. tq->buf_info[i].map_type = VMXNET3_MAP_NONE;
  407. /* stats are not reset */
  408. }
  409. static int
  410. vmxnet3_tq_create(struct vmxnet3_tx_queue *tq,
  411. struct vmxnet3_adapter *adapter)
  412. {
  413. BUG_ON(tq->tx_ring.base || tq->data_ring.base ||
  414. tq->comp_ring.base || tq->buf_info);
  415. tq->tx_ring.base = pci_alloc_consistent(adapter->pdev, tq->tx_ring.size
  416. * sizeof(struct Vmxnet3_TxDesc),
  417. &tq->tx_ring.basePA);
  418. if (!tq->tx_ring.base) {
  419. printk(KERN_ERR "%s: failed to allocate tx ring\n",
  420. adapter->netdev->name);
  421. goto err;
  422. }
  423. tq->data_ring.base = pci_alloc_consistent(adapter->pdev,
  424. tq->data_ring.size *
  425. sizeof(struct Vmxnet3_TxDataDesc),
  426. &tq->data_ring.basePA);
  427. if (!tq->data_ring.base) {
  428. printk(KERN_ERR "%s: failed to allocate data ring\n",
  429. adapter->netdev->name);
  430. goto err;
  431. }
  432. tq->comp_ring.base = pci_alloc_consistent(adapter->pdev,
  433. tq->comp_ring.size *
  434. sizeof(struct Vmxnet3_TxCompDesc),
  435. &tq->comp_ring.basePA);
  436. if (!tq->comp_ring.base) {
  437. printk(KERN_ERR "%s: failed to allocate tx comp ring\n",
  438. adapter->netdev->name);
  439. goto err;
  440. }
  441. tq->buf_info = kcalloc(tq->tx_ring.size, sizeof(tq->buf_info[0]),
  442. GFP_KERNEL);
  443. if (!tq->buf_info) {
  444. printk(KERN_ERR "%s: failed to allocate tx bufinfo\n",
  445. adapter->netdev->name);
  446. goto err;
  447. }
  448. return 0;
  449. err:
  450. vmxnet3_tq_destroy(tq, adapter);
  451. return -ENOMEM;
  452. }
  453. static void
  454. vmxnet3_tq_cleanup_all(struct vmxnet3_adapter *adapter)
  455. {
  456. int i;
  457. for (i = 0; i < adapter->num_tx_queues; i++)
  458. vmxnet3_tq_cleanup(&adapter->tx_queue[i], adapter);
  459. }
  460. /*
  461. * starting from ring->next2fill, allocate rx buffers for the given ring
  462. * of the rx queue and update the rx desc. stop after @num_to_alloc buffers
  463. * are allocated or allocation fails
  464. */
  465. static int
  466. vmxnet3_rq_alloc_rx_buf(struct vmxnet3_rx_queue *rq, u32 ring_idx,
  467. int num_to_alloc, struct vmxnet3_adapter *adapter)
  468. {
  469. int num_allocated = 0;
  470. struct vmxnet3_rx_buf_info *rbi_base = rq->buf_info[ring_idx];
  471. struct vmxnet3_cmd_ring *ring = &rq->rx_ring[ring_idx];
  472. u32 val;
  473. while (num_allocated <= num_to_alloc) {
  474. struct vmxnet3_rx_buf_info *rbi;
  475. union Vmxnet3_GenericDesc *gd;
  476. rbi = rbi_base + ring->next2fill;
  477. gd = ring->base + ring->next2fill;
  478. if (rbi->buf_type == VMXNET3_RX_BUF_SKB) {
  479. if (rbi->skb == NULL) {
  480. rbi->skb = dev_alloc_skb(rbi->len +
  481. NET_IP_ALIGN);
  482. if (unlikely(rbi->skb == NULL)) {
  483. rq->stats.rx_buf_alloc_failure++;
  484. break;
  485. }
  486. rbi->skb->dev = adapter->netdev;
  487. skb_reserve(rbi->skb, NET_IP_ALIGN);
  488. rbi->dma_addr = pci_map_single(adapter->pdev,
  489. rbi->skb->data, rbi->len,
  490. PCI_DMA_FROMDEVICE);
  491. } else {
  492. /* rx buffer skipped by the device */
  493. }
  494. val = VMXNET3_RXD_BTYPE_HEAD << VMXNET3_RXD_BTYPE_SHIFT;
  495. } else {
  496. BUG_ON(rbi->buf_type != VMXNET3_RX_BUF_PAGE ||
  497. rbi->len != PAGE_SIZE);
  498. if (rbi->page == NULL) {
  499. rbi->page = alloc_page(GFP_ATOMIC);
  500. if (unlikely(rbi->page == NULL)) {
  501. rq->stats.rx_buf_alloc_failure++;
  502. break;
  503. }
  504. rbi->dma_addr = pci_map_page(adapter->pdev,
  505. rbi->page, 0, PAGE_SIZE,
  506. PCI_DMA_FROMDEVICE);
  507. } else {
  508. /* rx buffers skipped by the device */
  509. }
  510. val = VMXNET3_RXD_BTYPE_BODY << VMXNET3_RXD_BTYPE_SHIFT;
  511. }
  512. BUG_ON(rbi->dma_addr == 0);
  513. gd->rxd.addr = cpu_to_le64(rbi->dma_addr);
  514. gd->dword[2] = cpu_to_le32((!ring->gen << VMXNET3_RXD_GEN_SHIFT)
  515. | val | rbi->len);
  516. /* Fill the last buffer but dont mark it ready, or else the
  517. * device will think that the queue is full */
  518. if (num_allocated == num_to_alloc)
  519. break;
  520. gd->dword[2] |= cpu_to_le32(ring->gen << VMXNET3_RXD_GEN_SHIFT);
  521. num_allocated++;
  522. vmxnet3_cmd_ring_adv_next2fill(ring);
  523. }
  524. rq->uncommitted[ring_idx] += num_allocated;
  525. dev_dbg(&adapter->netdev->dev,
  526. "alloc_rx_buf: %d allocated, next2fill %u, next2comp "
  527. "%u, uncommited %u\n", num_allocated, ring->next2fill,
  528. ring->next2comp, rq->uncommitted[ring_idx]);
  529. /* so that the device can distinguish a full ring and an empty ring */
  530. BUG_ON(num_allocated != 0 && ring->next2fill == ring->next2comp);
  531. return num_allocated;
  532. }
  533. static void
  534. vmxnet3_append_frag(struct sk_buff *skb, struct Vmxnet3_RxCompDesc *rcd,
  535. struct vmxnet3_rx_buf_info *rbi)
  536. {
  537. struct skb_frag_struct *frag = skb_shinfo(skb)->frags +
  538. skb_shinfo(skb)->nr_frags;
  539. BUG_ON(skb_shinfo(skb)->nr_frags >= MAX_SKB_FRAGS);
  540. frag->page = rbi->page;
  541. frag->page_offset = 0;
  542. frag->size = rcd->len;
  543. skb->data_len += frag->size;
  544. skb_shinfo(skb)->nr_frags++;
  545. }
  546. static void
  547. vmxnet3_map_pkt(struct sk_buff *skb, struct vmxnet3_tx_ctx *ctx,
  548. struct vmxnet3_tx_queue *tq, struct pci_dev *pdev,
  549. struct vmxnet3_adapter *adapter)
  550. {
  551. u32 dw2, len;
  552. unsigned long buf_offset;
  553. int i;
  554. union Vmxnet3_GenericDesc *gdesc;
  555. struct vmxnet3_tx_buf_info *tbi = NULL;
  556. BUG_ON(ctx->copy_size > skb_headlen(skb));
  557. /* use the previous gen bit for the SOP desc */
  558. dw2 = (tq->tx_ring.gen ^ 0x1) << VMXNET3_TXD_GEN_SHIFT;
  559. ctx->sop_txd = tq->tx_ring.base + tq->tx_ring.next2fill;
  560. gdesc = ctx->sop_txd; /* both loops below can be skipped */
  561. /* no need to map the buffer if headers are copied */
  562. if (ctx->copy_size) {
  563. ctx->sop_txd->txd.addr = cpu_to_le64(tq->data_ring.basePA +
  564. tq->tx_ring.next2fill *
  565. sizeof(struct Vmxnet3_TxDataDesc));
  566. ctx->sop_txd->dword[2] = cpu_to_le32(dw2 | ctx->copy_size);
  567. ctx->sop_txd->dword[3] = 0;
  568. tbi = tq->buf_info + tq->tx_ring.next2fill;
  569. tbi->map_type = VMXNET3_MAP_NONE;
  570. dev_dbg(&adapter->netdev->dev,
  571. "txd[%u]: 0x%Lx 0x%x 0x%x\n",
  572. tq->tx_ring.next2fill,
  573. le64_to_cpu(ctx->sop_txd->txd.addr),
  574. ctx->sop_txd->dword[2], ctx->sop_txd->dword[3]);
  575. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  576. /* use the right gen for non-SOP desc */
  577. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  578. }
  579. /* linear part can use multiple tx desc if it's big */
  580. len = skb_headlen(skb) - ctx->copy_size;
  581. buf_offset = ctx->copy_size;
  582. while (len) {
  583. u32 buf_size;
  584. if (len < VMXNET3_MAX_TX_BUF_SIZE) {
  585. buf_size = len;
  586. dw2 |= len;
  587. } else {
  588. buf_size = VMXNET3_MAX_TX_BUF_SIZE;
  589. /* spec says that for TxDesc.len, 0 == 2^14 */
  590. }
  591. tbi = tq->buf_info + tq->tx_ring.next2fill;
  592. tbi->map_type = VMXNET3_MAP_SINGLE;
  593. tbi->dma_addr = pci_map_single(adapter->pdev,
  594. skb->data + buf_offset, buf_size,
  595. PCI_DMA_TODEVICE);
  596. tbi->len = buf_size;
  597. gdesc = tq->tx_ring.base + tq->tx_ring.next2fill;
  598. BUG_ON(gdesc->txd.gen == tq->tx_ring.gen);
  599. gdesc->txd.addr = cpu_to_le64(tbi->dma_addr);
  600. gdesc->dword[2] = cpu_to_le32(dw2);
  601. gdesc->dword[3] = 0;
  602. dev_dbg(&adapter->netdev->dev,
  603. "txd[%u]: 0x%Lx 0x%x 0x%x\n",
  604. tq->tx_ring.next2fill, le64_to_cpu(gdesc->txd.addr),
  605. le32_to_cpu(gdesc->dword[2]), gdesc->dword[3]);
  606. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  607. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  608. len -= buf_size;
  609. buf_offset += buf_size;
  610. }
  611. for (i = 0; i < skb_shinfo(skb)->nr_frags; i++) {
  612. struct skb_frag_struct *frag = &skb_shinfo(skb)->frags[i];
  613. tbi = tq->buf_info + tq->tx_ring.next2fill;
  614. tbi->map_type = VMXNET3_MAP_PAGE;
  615. tbi->dma_addr = pci_map_page(adapter->pdev, frag->page,
  616. frag->page_offset, frag->size,
  617. PCI_DMA_TODEVICE);
  618. tbi->len = frag->size;
  619. gdesc = tq->tx_ring.base + tq->tx_ring.next2fill;
  620. BUG_ON(gdesc->txd.gen == tq->tx_ring.gen);
  621. gdesc->txd.addr = cpu_to_le64(tbi->dma_addr);
  622. gdesc->dword[2] = cpu_to_le32(dw2 | frag->size);
  623. gdesc->dword[3] = 0;
  624. dev_dbg(&adapter->netdev->dev,
  625. "txd[%u]: 0x%llu %u %u\n",
  626. tq->tx_ring.next2fill, le64_to_cpu(gdesc->txd.addr),
  627. le32_to_cpu(gdesc->dword[2]), gdesc->dword[3]);
  628. vmxnet3_cmd_ring_adv_next2fill(&tq->tx_ring);
  629. dw2 = tq->tx_ring.gen << VMXNET3_TXD_GEN_SHIFT;
  630. }
  631. ctx->eop_txd = gdesc;
  632. /* set the last buf_info for the pkt */
  633. tbi->skb = skb;
  634. tbi->sop_idx = ctx->sop_txd - tq->tx_ring.base;
  635. }
  636. /* Init all tx queues */
  637. static void
  638. vmxnet3_tq_init_all(struct vmxnet3_adapter *adapter)
  639. {
  640. int i;
  641. for (i = 0; i < adapter->num_tx_queues; i++)
  642. vmxnet3_tq_init(&adapter->tx_queue[i], adapter);
  643. }
  644. /*
  645. * parse and copy relevant protocol headers:
  646. * For a tso pkt, relevant headers are L2/3/4 including options
  647. * For a pkt requesting csum offloading, they are L2/3 and may include L4
  648. * if it's a TCP/UDP pkt
  649. *
  650. * Returns:
  651. * -1: error happens during parsing
  652. * 0: protocol headers parsed, but too big to be copied
  653. * 1: protocol headers parsed and copied
  654. *
  655. * Other effects:
  656. * 1. related *ctx fields are updated.
  657. * 2. ctx->copy_size is # of bytes copied
  658. * 3. the portion copied is guaranteed to be in the linear part
  659. *
  660. */
  661. static int
  662. vmxnet3_parse_and_copy_hdr(struct sk_buff *skb, struct vmxnet3_tx_queue *tq,
  663. struct vmxnet3_tx_ctx *ctx,
  664. struct vmxnet3_adapter *adapter)
  665. {
  666. struct Vmxnet3_TxDataDesc *tdd;
  667. if (ctx->mss) { /* TSO */
  668. ctx->eth_ip_hdr_size = skb_transport_offset(skb);
  669. ctx->l4_hdr_size = ((struct tcphdr *)
  670. skb_transport_header(skb))->doff * 4;
  671. ctx->copy_size = ctx->eth_ip_hdr_size + ctx->l4_hdr_size;
  672. } else {
  673. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  674. ctx->eth_ip_hdr_size = skb_checksum_start_offset(skb);
  675. if (ctx->ipv4) {
  676. struct iphdr *iph = (struct iphdr *)
  677. skb_network_header(skb);
  678. if (iph->protocol == IPPROTO_TCP)
  679. ctx->l4_hdr_size = ((struct tcphdr *)
  680. skb_transport_header(skb))->doff * 4;
  681. else if (iph->protocol == IPPROTO_UDP)
  682. /*
  683. * Use tcp header size so that bytes to
  684. * be copied are more than required by
  685. * the device.
  686. */
  687. ctx->l4_hdr_size =
  688. sizeof(struct tcphdr);
  689. else
  690. ctx->l4_hdr_size = 0;
  691. } else {
  692. /* for simplicity, don't copy L4 headers */
  693. ctx->l4_hdr_size = 0;
  694. }
  695. ctx->copy_size = ctx->eth_ip_hdr_size +
  696. ctx->l4_hdr_size;
  697. } else {
  698. ctx->eth_ip_hdr_size = 0;
  699. ctx->l4_hdr_size = 0;
  700. /* copy as much as allowed */
  701. ctx->copy_size = min((unsigned int)VMXNET3_HDR_COPY_SIZE
  702. , skb_headlen(skb));
  703. }
  704. /* make sure headers are accessible directly */
  705. if (unlikely(!pskb_may_pull(skb, ctx->copy_size)))
  706. goto err;
  707. }
  708. if (unlikely(ctx->copy_size > VMXNET3_HDR_COPY_SIZE)) {
  709. tq->stats.oversized_hdr++;
  710. ctx->copy_size = 0;
  711. return 0;
  712. }
  713. tdd = tq->data_ring.base + tq->tx_ring.next2fill;
  714. memcpy(tdd->data, skb->data, ctx->copy_size);
  715. dev_dbg(&adapter->netdev->dev,
  716. "copy %u bytes to dataRing[%u]\n",
  717. ctx->copy_size, tq->tx_ring.next2fill);
  718. return 1;
  719. err:
  720. return -1;
  721. }
  722. static void
  723. vmxnet3_prepare_tso(struct sk_buff *skb,
  724. struct vmxnet3_tx_ctx *ctx)
  725. {
  726. struct tcphdr *tcph = (struct tcphdr *)skb_transport_header(skb);
  727. if (ctx->ipv4) {
  728. struct iphdr *iph = (struct iphdr *)skb_network_header(skb);
  729. iph->check = 0;
  730. tcph->check = ~csum_tcpudp_magic(iph->saddr, iph->daddr, 0,
  731. IPPROTO_TCP, 0);
  732. } else {
  733. struct ipv6hdr *iph = (struct ipv6hdr *)skb_network_header(skb);
  734. tcph->check = ~csum_ipv6_magic(&iph->saddr, &iph->daddr, 0,
  735. IPPROTO_TCP, 0);
  736. }
  737. }
  738. /*
  739. * Transmits a pkt thru a given tq
  740. * Returns:
  741. * NETDEV_TX_OK: descriptors are setup successfully
  742. * NETDEV_TX_OK: error occurred, the pkt is dropped
  743. * NETDEV_TX_BUSY: tx ring is full, queue is stopped
  744. *
  745. * Side-effects:
  746. * 1. tx ring may be changed
  747. * 2. tq stats may be updated accordingly
  748. * 3. shared->txNumDeferred may be updated
  749. */
  750. static int
  751. vmxnet3_tq_xmit(struct sk_buff *skb, struct vmxnet3_tx_queue *tq,
  752. struct vmxnet3_adapter *adapter, struct net_device *netdev)
  753. {
  754. int ret;
  755. u32 count;
  756. unsigned long flags;
  757. struct vmxnet3_tx_ctx ctx;
  758. union Vmxnet3_GenericDesc *gdesc;
  759. #ifdef __BIG_ENDIAN_BITFIELD
  760. /* Use temporary descriptor to avoid touching bits multiple times */
  761. union Vmxnet3_GenericDesc tempTxDesc;
  762. #endif
  763. /* conservatively estimate # of descriptors to use */
  764. count = VMXNET3_TXD_NEEDED(skb_headlen(skb)) +
  765. skb_shinfo(skb)->nr_frags + 1;
  766. ctx.ipv4 = (vlan_get_protocol(skb) == cpu_to_be16(ETH_P_IP));
  767. ctx.mss = skb_shinfo(skb)->gso_size;
  768. if (ctx.mss) {
  769. if (skb_header_cloned(skb)) {
  770. if (unlikely(pskb_expand_head(skb, 0, 0,
  771. GFP_ATOMIC) != 0)) {
  772. tq->stats.drop_tso++;
  773. goto drop_pkt;
  774. }
  775. tq->stats.copy_skb_header++;
  776. }
  777. vmxnet3_prepare_tso(skb, &ctx);
  778. } else {
  779. if (unlikely(count > VMXNET3_MAX_TXD_PER_PKT)) {
  780. /* non-tso pkts must not use more than
  781. * VMXNET3_MAX_TXD_PER_PKT entries
  782. */
  783. if (skb_linearize(skb) != 0) {
  784. tq->stats.drop_too_many_frags++;
  785. goto drop_pkt;
  786. }
  787. tq->stats.linearized++;
  788. /* recalculate the # of descriptors to use */
  789. count = VMXNET3_TXD_NEEDED(skb_headlen(skb)) + 1;
  790. }
  791. }
  792. spin_lock_irqsave(&tq->tx_lock, flags);
  793. if (count > vmxnet3_cmd_ring_desc_avail(&tq->tx_ring)) {
  794. tq->stats.tx_ring_full++;
  795. dev_dbg(&adapter->netdev->dev,
  796. "tx queue stopped on %s, next2comp %u"
  797. " next2fill %u\n", adapter->netdev->name,
  798. tq->tx_ring.next2comp, tq->tx_ring.next2fill);
  799. vmxnet3_tq_stop(tq, adapter);
  800. spin_unlock_irqrestore(&tq->tx_lock, flags);
  801. return NETDEV_TX_BUSY;
  802. }
  803. ret = vmxnet3_parse_and_copy_hdr(skb, tq, &ctx, adapter);
  804. if (ret >= 0) {
  805. BUG_ON(ret <= 0 && ctx.copy_size != 0);
  806. /* hdrs parsed, check against other limits */
  807. if (ctx.mss) {
  808. if (unlikely(ctx.eth_ip_hdr_size + ctx.l4_hdr_size >
  809. VMXNET3_MAX_TX_BUF_SIZE)) {
  810. goto hdr_too_big;
  811. }
  812. } else {
  813. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  814. if (unlikely(ctx.eth_ip_hdr_size +
  815. skb->csum_offset >
  816. VMXNET3_MAX_CSUM_OFFSET)) {
  817. goto hdr_too_big;
  818. }
  819. }
  820. }
  821. } else {
  822. tq->stats.drop_hdr_inspect_err++;
  823. goto unlock_drop_pkt;
  824. }
  825. /* fill tx descs related to addr & len */
  826. vmxnet3_map_pkt(skb, &ctx, tq, adapter->pdev, adapter);
  827. /* setup the EOP desc */
  828. ctx.eop_txd->dword[3] = cpu_to_le32(VMXNET3_TXD_CQ | VMXNET3_TXD_EOP);
  829. /* setup the SOP desc */
  830. #ifdef __BIG_ENDIAN_BITFIELD
  831. gdesc = &tempTxDesc;
  832. gdesc->dword[2] = ctx.sop_txd->dword[2];
  833. gdesc->dword[3] = ctx.sop_txd->dword[3];
  834. #else
  835. gdesc = ctx.sop_txd;
  836. #endif
  837. if (ctx.mss) {
  838. gdesc->txd.hlen = ctx.eth_ip_hdr_size + ctx.l4_hdr_size;
  839. gdesc->txd.om = VMXNET3_OM_TSO;
  840. gdesc->txd.msscof = ctx.mss;
  841. le32_add_cpu(&tq->shared->txNumDeferred, (skb->len -
  842. gdesc->txd.hlen + ctx.mss - 1) / ctx.mss);
  843. } else {
  844. if (skb->ip_summed == CHECKSUM_PARTIAL) {
  845. gdesc->txd.hlen = ctx.eth_ip_hdr_size;
  846. gdesc->txd.om = VMXNET3_OM_CSUM;
  847. gdesc->txd.msscof = ctx.eth_ip_hdr_size +
  848. skb->csum_offset;
  849. } else {
  850. gdesc->txd.om = 0;
  851. gdesc->txd.msscof = 0;
  852. }
  853. le32_add_cpu(&tq->shared->txNumDeferred, 1);
  854. }
  855. if (vlan_tx_tag_present(skb)) {
  856. gdesc->txd.ti = 1;
  857. gdesc->txd.tci = vlan_tx_tag_get(skb);
  858. }
  859. /* finally flips the GEN bit of the SOP desc. */
  860. gdesc->dword[2] = cpu_to_le32(le32_to_cpu(gdesc->dword[2]) ^
  861. VMXNET3_TXD_GEN);
  862. #ifdef __BIG_ENDIAN_BITFIELD
  863. /* Finished updating in bitfields of Tx Desc, so write them in original
  864. * place.
  865. */
  866. vmxnet3_TxDescToLe((struct Vmxnet3_TxDesc *)gdesc,
  867. (struct Vmxnet3_TxDesc *)ctx.sop_txd);
  868. gdesc = ctx.sop_txd;
  869. #endif
  870. dev_dbg(&adapter->netdev->dev,
  871. "txd[%u]: SOP 0x%Lx 0x%x 0x%x\n",
  872. (u32)((union Vmxnet3_GenericDesc *)ctx.sop_txd -
  873. tq->tx_ring.base), le64_to_cpu(gdesc->txd.addr),
  874. le32_to_cpu(gdesc->dword[2]), le32_to_cpu(gdesc->dword[3]));
  875. spin_unlock_irqrestore(&tq->tx_lock, flags);
  876. if (le32_to_cpu(tq->shared->txNumDeferred) >=
  877. le32_to_cpu(tq->shared->txThreshold)) {
  878. tq->shared->txNumDeferred = 0;
  879. VMXNET3_WRITE_BAR0_REG(adapter,
  880. VMXNET3_REG_TXPROD + tq->qid * 8,
  881. tq->tx_ring.next2fill);
  882. }
  883. return NETDEV_TX_OK;
  884. hdr_too_big:
  885. tq->stats.drop_oversized_hdr++;
  886. unlock_drop_pkt:
  887. spin_unlock_irqrestore(&tq->tx_lock, flags);
  888. drop_pkt:
  889. tq->stats.drop_total++;
  890. dev_kfree_skb(skb);
  891. return NETDEV_TX_OK;
  892. }
  893. static netdev_tx_t
  894. vmxnet3_xmit_frame(struct sk_buff *skb, struct net_device *netdev)
  895. {
  896. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  897. BUG_ON(skb->queue_mapping > adapter->num_tx_queues);
  898. return vmxnet3_tq_xmit(skb,
  899. &adapter->tx_queue[skb->queue_mapping],
  900. adapter, netdev);
  901. }
  902. static void
  903. vmxnet3_rx_csum(struct vmxnet3_adapter *adapter,
  904. struct sk_buff *skb,
  905. union Vmxnet3_GenericDesc *gdesc)
  906. {
  907. if (!gdesc->rcd.cnc && adapter->netdev->features & NETIF_F_RXCSUM) {
  908. /* typical case: TCP/UDP over IP and both csums are correct */
  909. if ((le32_to_cpu(gdesc->dword[3]) & VMXNET3_RCD_CSUM_OK) ==
  910. VMXNET3_RCD_CSUM_OK) {
  911. skb->ip_summed = CHECKSUM_UNNECESSARY;
  912. BUG_ON(!(gdesc->rcd.tcp || gdesc->rcd.udp));
  913. BUG_ON(!(gdesc->rcd.v4 || gdesc->rcd.v6));
  914. BUG_ON(gdesc->rcd.frg);
  915. } else {
  916. if (gdesc->rcd.csum) {
  917. skb->csum = htons(gdesc->rcd.csum);
  918. skb->ip_summed = CHECKSUM_PARTIAL;
  919. } else {
  920. skb_checksum_none_assert(skb);
  921. }
  922. }
  923. } else {
  924. skb_checksum_none_assert(skb);
  925. }
  926. }
  927. static void
  928. vmxnet3_rx_error(struct vmxnet3_rx_queue *rq, struct Vmxnet3_RxCompDesc *rcd,
  929. struct vmxnet3_rx_ctx *ctx, struct vmxnet3_adapter *adapter)
  930. {
  931. rq->stats.drop_err++;
  932. if (!rcd->fcs)
  933. rq->stats.drop_fcs++;
  934. rq->stats.drop_total++;
  935. /*
  936. * We do not unmap and chain the rx buffer to the skb.
  937. * We basically pretend this buffer is not used and will be recycled
  938. * by vmxnet3_rq_alloc_rx_buf()
  939. */
  940. /*
  941. * ctx->skb may be NULL if this is the first and the only one
  942. * desc for the pkt
  943. */
  944. if (ctx->skb)
  945. dev_kfree_skb_irq(ctx->skb);
  946. ctx->skb = NULL;
  947. }
  948. static int
  949. vmxnet3_rq_rx_complete(struct vmxnet3_rx_queue *rq,
  950. struct vmxnet3_adapter *adapter, int quota)
  951. {
  952. static const u32 rxprod_reg[2] = {
  953. VMXNET3_REG_RXPROD, VMXNET3_REG_RXPROD2
  954. };
  955. u32 num_rxd = 0;
  956. bool skip_page_frags = false;
  957. struct Vmxnet3_RxCompDesc *rcd;
  958. struct vmxnet3_rx_ctx *ctx = &rq->rx_ctx;
  959. #ifdef __BIG_ENDIAN_BITFIELD
  960. struct Vmxnet3_RxDesc rxCmdDesc;
  961. struct Vmxnet3_RxCompDesc rxComp;
  962. #endif
  963. vmxnet3_getRxComp(rcd, &rq->comp_ring.base[rq->comp_ring.next2proc].rcd,
  964. &rxComp);
  965. while (rcd->gen == rq->comp_ring.gen) {
  966. struct vmxnet3_rx_buf_info *rbi;
  967. struct sk_buff *skb, *new_skb = NULL;
  968. struct page *new_page = NULL;
  969. int num_to_alloc;
  970. struct Vmxnet3_RxDesc *rxd;
  971. u32 idx, ring_idx;
  972. struct vmxnet3_cmd_ring *ring = NULL;
  973. if (num_rxd >= quota) {
  974. /* we may stop even before we see the EOP desc of
  975. * the current pkt
  976. */
  977. break;
  978. }
  979. num_rxd++;
  980. BUG_ON(rcd->rqID != rq->qid && rcd->rqID != rq->qid2);
  981. idx = rcd->rxdIdx;
  982. ring_idx = rcd->rqID < adapter->num_rx_queues ? 0 : 1;
  983. ring = rq->rx_ring + ring_idx;
  984. vmxnet3_getRxDesc(rxd, &rq->rx_ring[ring_idx].base[idx].rxd,
  985. &rxCmdDesc);
  986. rbi = rq->buf_info[ring_idx] + idx;
  987. BUG_ON(rxd->addr != rbi->dma_addr ||
  988. rxd->len != rbi->len);
  989. if (unlikely(rcd->eop && rcd->err)) {
  990. vmxnet3_rx_error(rq, rcd, ctx, adapter);
  991. goto rcd_done;
  992. }
  993. if (rcd->sop) { /* first buf of the pkt */
  994. BUG_ON(rxd->btype != VMXNET3_RXD_BTYPE_HEAD ||
  995. rcd->rqID != rq->qid);
  996. BUG_ON(rbi->buf_type != VMXNET3_RX_BUF_SKB);
  997. BUG_ON(ctx->skb != NULL || rbi->skb == NULL);
  998. if (unlikely(rcd->len == 0)) {
  999. /* Pretend the rx buffer is skipped. */
  1000. BUG_ON(!(rcd->sop && rcd->eop));
  1001. dev_dbg(&adapter->netdev->dev,
  1002. "rxRing[%u][%u] 0 length\n",
  1003. ring_idx, idx);
  1004. goto rcd_done;
  1005. }
  1006. skip_page_frags = false;
  1007. ctx->skb = rbi->skb;
  1008. new_skb = dev_alloc_skb(rbi->len + NET_IP_ALIGN);
  1009. if (new_skb == NULL) {
  1010. /* Skb allocation failed, do not handover this
  1011. * skb to stack. Reuse it. Drop the existing pkt
  1012. */
  1013. rq->stats.rx_buf_alloc_failure++;
  1014. ctx->skb = NULL;
  1015. rq->stats.drop_total++;
  1016. skip_page_frags = true;
  1017. goto rcd_done;
  1018. }
  1019. pci_unmap_single(adapter->pdev, rbi->dma_addr, rbi->len,
  1020. PCI_DMA_FROMDEVICE);
  1021. skb_put(ctx->skb, rcd->len);
  1022. /* Immediate refill */
  1023. new_skb->dev = adapter->netdev;
  1024. skb_reserve(new_skb, NET_IP_ALIGN);
  1025. rbi->skb = new_skb;
  1026. rbi->dma_addr = pci_map_single(adapter->pdev,
  1027. rbi->skb->data, rbi->len,
  1028. PCI_DMA_FROMDEVICE);
  1029. rxd->addr = cpu_to_le64(rbi->dma_addr);
  1030. rxd->len = rbi->len;
  1031. } else {
  1032. BUG_ON(ctx->skb == NULL && !skip_page_frags);
  1033. /* non SOP buffer must be type 1 in most cases */
  1034. BUG_ON(rbi->buf_type != VMXNET3_RX_BUF_PAGE);
  1035. BUG_ON(rxd->btype != VMXNET3_RXD_BTYPE_BODY);
  1036. /* If an sop buffer was dropped, skip all
  1037. * following non-sop fragments. They will be reused.
  1038. */
  1039. if (skip_page_frags)
  1040. goto rcd_done;
  1041. new_page = alloc_page(GFP_ATOMIC);
  1042. if (unlikely(new_page == NULL)) {
  1043. /* Replacement page frag could not be allocated.
  1044. * Reuse this page. Drop the pkt and free the
  1045. * skb which contained this page as a frag. Skip
  1046. * processing all the following non-sop frags.
  1047. */
  1048. rq->stats.rx_buf_alloc_failure++;
  1049. dev_kfree_skb(ctx->skb);
  1050. ctx->skb = NULL;
  1051. skip_page_frags = true;
  1052. goto rcd_done;
  1053. }
  1054. if (rcd->len) {
  1055. pci_unmap_page(adapter->pdev,
  1056. rbi->dma_addr, rbi->len,
  1057. PCI_DMA_FROMDEVICE);
  1058. vmxnet3_append_frag(ctx->skb, rcd, rbi);
  1059. }
  1060. /* Immediate refill */
  1061. rbi->page = new_page;
  1062. rbi->dma_addr = pci_map_page(adapter->pdev, rbi->page,
  1063. 0, PAGE_SIZE,
  1064. PCI_DMA_FROMDEVICE);
  1065. rxd->addr = cpu_to_le64(rbi->dma_addr);
  1066. rxd->len = rbi->len;
  1067. }
  1068. skb = ctx->skb;
  1069. if (rcd->eop) {
  1070. skb->len += skb->data_len;
  1071. skb->truesize += skb->data_len;
  1072. vmxnet3_rx_csum(adapter, skb,
  1073. (union Vmxnet3_GenericDesc *)rcd);
  1074. skb->protocol = eth_type_trans(skb, adapter->netdev);
  1075. if (unlikely(rcd->ts))
  1076. __vlan_hwaccel_put_tag(skb, rcd->tci);
  1077. if (adapter->netdev->features & NETIF_F_LRO)
  1078. netif_receive_skb(skb);
  1079. else
  1080. napi_gro_receive(&rq->napi, skb);
  1081. ctx->skb = NULL;
  1082. }
  1083. rcd_done:
  1084. /* device may have skipped some rx descs */
  1085. ring->next2comp = idx;
  1086. num_to_alloc = vmxnet3_cmd_ring_desc_avail(ring);
  1087. ring = rq->rx_ring + ring_idx;
  1088. while (num_to_alloc) {
  1089. vmxnet3_getRxDesc(rxd, &ring->base[ring->next2fill].rxd,
  1090. &rxCmdDesc);
  1091. BUG_ON(!rxd->addr);
  1092. /* Recv desc is ready to be used by the device */
  1093. rxd->gen = ring->gen;
  1094. vmxnet3_cmd_ring_adv_next2fill(ring);
  1095. num_to_alloc--;
  1096. }
  1097. /* if needed, update the register */
  1098. if (unlikely(rq->shared->updateRxProd)) {
  1099. VMXNET3_WRITE_BAR0_REG(adapter,
  1100. rxprod_reg[ring_idx] + rq->qid * 8,
  1101. ring->next2fill);
  1102. rq->uncommitted[ring_idx] = 0;
  1103. }
  1104. vmxnet3_comp_ring_adv_next2proc(&rq->comp_ring);
  1105. vmxnet3_getRxComp(rcd,
  1106. &rq->comp_ring.base[rq->comp_ring.next2proc].rcd, &rxComp);
  1107. }
  1108. return num_rxd;
  1109. }
  1110. static void
  1111. vmxnet3_rq_cleanup(struct vmxnet3_rx_queue *rq,
  1112. struct vmxnet3_adapter *adapter)
  1113. {
  1114. u32 i, ring_idx;
  1115. struct Vmxnet3_RxDesc *rxd;
  1116. for (ring_idx = 0; ring_idx < 2; ring_idx++) {
  1117. for (i = 0; i < rq->rx_ring[ring_idx].size; i++) {
  1118. #ifdef __BIG_ENDIAN_BITFIELD
  1119. struct Vmxnet3_RxDesc rxDesc;
  1120. #endif
  1121. vmxnet3_getRxDesc(rxd,
  1122. &rq->rx_ring[ring_idx].base[i].rxd, &rxDesc);
  1123. if (rxd->btype == VMXNET3_RXD_BTYPE_HEAD &&
  1124. rq->buf_info[ring_idx][i].skb) {
  1125. pci_unmap_single(adapter->pdev, rxd->addr,
  1126. rxd->len, PCI_DMA_FROMDEVICE);
  1127. dev_kfree_skb(rq->buf_info[ring_idx][i].skb);
  1128. rq->buf_info[ring_idx][i].skb = NULL;
  1129. } else if (rxd->btype == VMXNET3_RXD_BTYPE_BODY &&
  1130. rq->buf_info[ring_idx][i].page) {
  1131. pci_unmap_page(adapter->pdev, rxd->addr,
  1132. rxd->len, PCI_DMA_FROMDEVICE);
  1133. put_page(rq->buf_info[ring_idx][i].page);
  1134. rq->buf_info[ring_idx][i].page = NULL;
  1135. }
  1136. }
  1137. rq->rx_ring[ring_idx].gen = VMXNET3_INIT_GEN;
  1138. rq->rx_ring[ring_idx].next2fill =
  1139. rq->rx_ring[ring_idx].next2comp = 0;
  1140. rq->uncommitted[ring_idx] = 0;
  1141. }
  1142. rq->comp_ring.gen = VMXNET3_INIT_GEN;
  1143. rq->comp_ring.next2proc = 0;
  1144. }
  1145. static void
  1146. vmxnet3_rq_cleanup_all(struct vmxnet3_adapter *adapter)
  1147. {
  1148. int i;
  1149. for (i = 0; i < adapter->num_rx_queues; i++)
  1150. vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter);
  1151. }
  1152. void vmxnet3_rq_destroy(struct vmxnet3_rx_queue *rq,
  1153. struct vmxnet3_adapter *adapter)
  1154. {
  1155. int i;
  1156. int j;
  1157. /* all rx buffers must have already been freed */
  1158. for (i = 0; i < 2; i++) {
  1159. if (rq->buf_info[i]) {
  1160. for (j = 0; j < rq->rx_ring[i].size; j++)
  1161. BUG_ON(rq->buf_info[i][j].page != NULL);
  1162. }
  1163. }
  1164. kfree(rq->buf_info[0]);
  1165. for (i = 0; i < 2; i++) {
  1166. if (rq->rx_ring[i].base) {
  1167. pci_free_consistent(adapter->pdev, rq->rx_ring[i].size
  1168. * sizeof(struct Vmxnet3_RxDesc),
  1169. rq->rx_ring[i].base,
  1170. rq->rx_ring[i].basePA);
  1171. rq->rx_ring[i].base = NULL;
  1172. }
  1173. rq->buf_info[i] = NULL;
  1174. }
  1175. if (rq->comp_ring.base) {
  1176. pci_free_consistent(adapter->pdev, rq->comp_ring.size *
  1177. sizeof(struct Vmxnet3_RxCompDesc),
  1178. rq->comp_ring.base, rq->comp_ring.basePA);
  1179. rq->comp_ring.base = NULL;
  1180. }
  1181. }
  1182. static int
  1183. vmxnet3_rq_init(struct vmxnet3_rx_queue *rq,
  1184. struct vmxnet3_adapter *adapter)
  1185. {
  1186. int i;
  1187. /* initialize buf_info */
  1188. for (i = 0; i < rq->rx_ring[0].size; i++) {
  1189. /* 1st buf for a pkt is skbuff */
  1190. if (i % adapter->rx_buf_per_pkt == 0) {
  1191. rq->buf_info[0][i].buf_type = VMXNET3_RX_BUF_SKB;
  1192. rq->buf_info[0][i].len = adapter->skb_buf_size;
  1193. } else { /* subsequent bufs for a pkt is frag */
  1194. rq->buf_info[0][i].buf_type = VMXNET3_RX_BUF_PAGE;
  1195. rq->buf_info[0][i].len = PAGE_SIZE;
  1196. }
  1197. }
  1198. for (i = 0; i < rq->rx_ring[1].size; i++) {
  1199. rq->buf_info[1][i].buf_type = VMXNET3_RX_BUF_PAGE;
  1200. rq->buf_info[1][i].len = PAGE_SIZE;
  1201. }
  1202. /* reset internal state and allocate buffers for both rings */
  1203. for (i = 0; i < 2; i++) {
  1204. rq->rx_ring[i].next2fill = rq->rx_ring[i].next2comp = 0;
  1205. rq->uncommitted[i] = 0;
  1206. memset(rq->rx_ring[i].base, 0, rq->rx_ring[i].size *
  1207. sizeof(struct Vmxnet3_RxDesc));
  1208. rq->rx_ring[i].gen = VMXNET3_INIT_GEN;
  1209. }
  1210. if (vmxnet3_rq_alloc_rx_buf(rq, 0, rq->rx_ring[0].size - 1,
  1211. adapter) == 0) {
  1212. /* at least has 1 rx buffer for the 1st ring */
  1213. return -ENOMEM;
  1214. }
  1215. vmxnet3_rq_alloc_rx_buf(rq, 1, rq->rx_ring[1].size - 1, adapter);
  1216. /* reset the comp ring */
  1217. rq->comp_ring.next2proc = 0;
  1218. memset(rq->comp_ring.base, 0, rq->comp_ring.size *
  1219. sizeof(struct Vmxnet3_RxCompDesc));
  1220. rq->comp_ring.gen = VMXNET3_INIT_GEN;
  1221. /* reset rxctx */
  1222. rq->rx_ctx.skb = NULL;
  1223. /* stats are not reset */
  1224. return 0;
  1225. }
  1226. static int
  1227. vmxnet3_rq_init_all(struct vmxnet3_adapter *adapter)
  1228. {
  1229. int i, err = 0;
  1230. for (i = 0; i < adapter->num_rx_queues; i++) {
  1231. err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter);
  1232. if (unlikely(err)) {
  1233. dev_err(&adapter->netdev->dev, "%s: failed to "
  1234. "initialize rx queue%i\n",
  1235. adapter->netdev->name, i);
  1236. break;
  1237. }
  1238. }
  1239. return err;
  1240. }
  1241. static int
  1242. vmxnet3_rq_create(struct vmxnet3_rx_queue *rq, struct vmxnet3_adapter *adapter)
  1243. {
  1244. int i;
  1245. size_t sz;
  1246. struct vmxnet3_rx_buf_info *bi;
  1247. for (i = 0; i < 2; i++) {
  1248. sz = rq->rx_ring[i].size * sizeof(struct Vmxnet3_RxDesc);
  1249. rq->rx_ring[i].base = pci_alloc_consistent(adapter->pdev, sz,
  1250. &rq->rx_ring[i].basePA);
  1251. if (!rq->rx_ring[i].base) {
  1252. printk(KERN_ERR "%s: failed to allocate rx ring %d\n",
  1253. adapter->netdev->name, i);
  1254. goto err;
  1255. }
  1256. }
  1257. sz = rq->comp_ring.size * sizeof(struct Vmxnet3_RxCompDesc);
  1258. rq->comp_ring.base = pci_alloc_consistent(adapter->pdev, sz,
  1259. &rq->comp_ring.basePA);
  1260. if (!rq->comp_ring.base) {
  1261. printk(KERN_ERR "%s: failed to allocate rx comp ring\n",
  1262. adapter->netdev->name);
  1263. goto err;
  1264. }
  1265. sz = sizeof(struct vmxnet3_rx_buf_info) * (rq->rx_ring[0].size +
  1266. rq->rx_ring[1].size);
  1267. bi = kzalloc(sz, GFP_KERNEL);
  1268. if (!bi) {
  1269. printk(KERN_ERR "%s: failed to allocate rx bufinfo\n",
  1270. adapter->netdev->name);
  1271. goto err;
  1272. }
  1273. rq->buf_info[0] = bi;
  1274. rq->buf_info[1] = bi + rq->rx_ring[0].size;
  1275. return 0;
  1276. err:
  1277. vmxnet3_rq_destroy(rq, adapter);
  1278. return -ENOMEM;
  1279. }
  1280. static int
  1281. vmxnet3_rq_create_all(struct vmxnet3_adapter *adapter)
  1282. {
  1283. int i, err = 0;
  1284. for (i = 0; i < adapter->num_rx_queues; i++) {
  1285. err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter);
  1286. if (unlikely(err)) {
  1287. dev_err(&adapter->netdev->dev,
  1288. "%s: failed to create rx queue%i\n",
  1289. adapter->netdev->name, i);
  1290. goto err_out;
  1291. }
  1292. }
  1293. return err;
  1294. err_out:
  1295. vmxnet3_rq_destroy_all(adapter);
  1296. return err;
  1297. }
  1298. /* Multiple queue aware polling function for tx and rx */
  1299. static int
  1300. vmxnet3_do_poll(struct vmxnet3_adapter *adapter, int budget)
  1301. {
  1302. int rcd_done = 0, i;
  1303. if (unlikely(adapter->shared->ecr))
  1304. vmxnet3_process_events(adapter);
  1305. for (i = 0; i < adapter->num_tx_queues; i++)
  1306. vmxnet3_tq_tx_complete(&adapter->tx_queue[i], adapter);
  1307. for (i = 0; i < adapter->num_rx_queues; i++)
  1308. rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i],
  1309. adapter, budget);
  1310. return rcd_done;
  1311. }
  1312. static int
  1313. vmxnet3_poll(struct napi_struct *napi, int budget)
  1314. {
  1315. struct vmxnet3_rx_queue *rx_queue = container_of(napi,
  1316. struct vmxnet3_rx_queue, napi);
  1317. int rxd_done;
  1318. rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget);
  1319. if (rxd_done < budget) {
  1320. napi_complete(napi);
  1321. vmxnet3_enable_all_intrs(rx_queue->adapter);
  1322. }
  1323. return rxd_done;
  1324. }
  1325. /*
  1326. * NAPI polling function for MSI-X mode with multiple Rx queues
  1327. * Returns the # of the NAPI credit consumed (# of rx descriptors processed)
  1328. */
  1329. static int
  1330. vmxnet3_poll_rx_only(struct napi_struct *napi, int budget)
  1331. {
  1332. struct vmxnet3_rx_queue *rq = container_of(napi,
  1333. struct vmxnet3_rx_queue, napi);
  1334. struct vmxnet3_adapter *adapter = rq->adapter;
  1335. int rxd_done;
  1336. /* When sharing interrupt with corresponding tx queue, process
  1337. * tx completions in that queue as well
  1338. */
  1339. if (adapter->share_intr == VMXNET3_INTR_BUDDYSHARE) {
  1340. struct vmxnet3_tx_queue *tq =
  1341. &adapter->tx_queue[rq - adapter->rx_queue];
  1342. vmxnet3_tq_tx_complete(tq, adapter);
  1343. }
  1344. rxd_done = vmxnet3_rq_rx_complete(rq, adapter, budget);
  1345. if (rxd_done < budget) {
  1346. napi_complete(napi);
  1347. vmxnet3_enable_intr(adapter, rq->comp_ring.intr_idx);
  1348. }
  1349. return rxd_done;
  1350. }
  1351. #ifdef CONFIG_PCI_MSI
  1352. /*
  1353. * Handle completion interrupts on tx queues
  1354. * Returns whether or not the intr is handled
  1355. */
  1356. static irqreturn_t
  1357. vmxnet3_msix_tx(int irq, void *data)
  1358. {
  1359. struct vmxnet3_tx_queue *tq = data;
  1360. struct vmxnet3_adapter *adapter = tq->adapter;
  1361. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1362. vmxnet3_disable_intr(adapter, tq->comp_ring.intr_idx);
  1363. /* Handle the case where only one irq is allocate for all tx queues */
  1364. if (adapter->share_intr == VMXNET3_INTR_TXSHARE) {
  1365. int i;
  1366. for (i = 0; i < adapter->num_tx_queues; i++) {
  1367. struct vmxnet3_tx_queue *txq = &adapter->tx_queue[i];
  1368. vmxnet3_tq_tx_complete(txq, adapter);
  1369. }
  1370. } else {
  1371. vmxnet3_tq_tx_complete(tq, adapter);
  1372. }
  1373. vmxnet3_enable_intr(adapter, tq->comp_ring.intr_idx);
  1374. return IRQ_HANDLED;
  1375. }
  1376. /*
  1377. * Handle completion interrupts on rx queues. Returns whether or not the
  1378. * intr is handled
  1379. */
  1380. static irqreturn_t
  1381. vmxnet3_msix_rx(int irq, void *data)
  1382. {
  1383. struct vmxnet3_rx_queue *rq = data;
  1384. struct vmxnet3_adapter *adapter = rq->adapter;
  1385. /* disable intr if needed */
  1386. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1387. vmxnet3_disable_intr(adapter, rq->comp_ring.intr_idx);
  1388. napi_schedule(&rq->napi);
  1389. return IRQ_HANDLED;
  1390. }
  1391. /*
  1392. *----------------------------------------------------------------------------
  1393. *
  1394. * vmxnet3_msix_event --
  1395. *
  1396. * vmxnet3 msix event intr handler
  1397. *
  1398. * Result:
  1399. * whether or not the intr is handled
  1400. *
  1401. *----------------------------------------------------------------------------
  1402. */
  1403. static irqreturn_t
  1404. vmxnet3_msix_event(int irq, void *data)
  1405. {
  1406. struct net_device *dev = data;
  1407. struct vmxnet3_adapter *adapter = netdev_priv(dev);
  1408. /* disable intr if needed */
  1409. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1410. vmxnet3_disable_intr(adapter, adapter->intr.event_intr_idx);
  1411. if (adapter->shared->ecr)
  1412. vmxnet3_process_events(adapter);
  1413. vmxnet3_enable_intr(adapter, adapter->intr.event_intr_idx);
  1414. return IRQ_HANDLED;
  1415. }
  1416. #endif /* CONFIG_PCI_MSI */
  1417. /* Interrupt handler for vmxnet3 */
  1418. static irqreturn_t
  1419. vmxnet3_intr(int irq, void *dev_id)
  1420. {
  1421. struct net_device *dev = dev_id;
  1422. struct vmxnet3_adapter *adapter = netdev_priv(dev);
  1423. if (adapter->intr.type == VMXNET3_IT_INTX) {
  1424. u32 icr = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_ICR);
  1425. if (unlikely(icr == 0))
  1426. /* not ours */
  1427. return IRQ_NONE;
  1428. }
  1429. /* disable intr if needed */
  1430. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1431. vmxnet3_disable_all_intrs(adapter);
  1432. napi_schedule(&adapter->rx_queue[0].napi);
  1433. return IRQ_HANDLED;
  1434. }
  1435. #ifdef CONFIG_NET_POLL_CONTROLLER
  1436. /* netpoll callback. */
  1437. static void
  1438. vmxnet3_netpoll(struct net_device *netdev)
  1439. {
  1440. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1441. if (adapter->intr.mask_mode == VMXNET3_IMM_ACTIVE)
  1442. vmxnet3_disable_all_intrs(adapter);
  1443. vmxnet3_do_poll(adapter, adapter->rx_queue[0].rx_ring[0].size);
  1444. vmxnet3_enable_all_intrs(adapter);
  1445. }
  1446. #endif /* CONFIG_NET_POLL_CONTROLLER */
  1447. static int
  1448. vmxnet3_request_irqs(struct vmxnet3_adapter *adapter)
  1449. {
  1450. struct vmxnet3_intr *intr = &adapter->intr;
  1451. int err = 0, i;
  1452. int vector = 0;
  1453. #ifdef CONFIG_PCI_MSI
  1454. if (adapter->intr.type == VMXNET3_IT_MSIX) {
  1455. for (i = 0; i < adapter->num_tx_queues; i++) {
  1456. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE) {
  1457. sprintf(adapter->tx_queue[i].name, "%s-tx-%d",
  1458. adapter->netdev->name, vector);
  1459. err = request_irq(
  1460. intr->msix_entries[vector].vector,
  1461. vmxnet3_msix_tx, 0,
  1462. adapter->tx_queue[i].name,
  1463. &adapter->tx_queue[i]);
  1464. } else {
  1465. sprintf(adapter->tx_queue[i].name, "%s-rxtx-%d",
  1466. adapter->netdev->name, vector);
  1467. }
  1468. if (err) {
  1469. dev_err(&adapter->netdev->dev,
  1470. "Failed to request irq for MSIX, %s, "
  1471. "error %d\n",
  1472. adapter->tx_queue[i].name, err);
  1473. return err;
  1474. }
  1475. /* Handle the case where only 1 MSIx was allocated for
  1476. * all tx queues */
  1477. if (adapter->share_intr == VMXNET3_INTR_TXSHARE) {
  1478. for (; i < adapter->num_tx_queues; i++)
  1479. adapter->tx_queue[i].comp_ring.intr_idx
  1480. = vector;
  1481. vector++;
  1482. break;
  1483. } else {
  1484. adapter->tx_queue[i].comp_ring.intr_idx
  1485. = vector++;
  1486. }
  1487. }
  1488. if (adapter->share_intr == VMXNET3_INTR_BUDDYSHARE)
  1489. vector = 0;
  1490. for (i = 0; i < adapter->num_rx_queues; i++) {
  1491. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE)
  1492. sprintf(adapter->rx_queue[i].name, "%s-rx-%d",
  1493. adapter->netdev->name, vector);
  1494. else
  1495. sprintf(adapter->rx_queue[i].name, "%s-rxtx-%d",
  1496. adapter->netdev->name, vector);
  1497. err = request_irq(intr->msix_entries[vector].vector,
  1498. vmxnet3_msix_rx, 0,
  1499. adapter->rx_queue[i].name,
  1500. &(adapter->rx_queue[i]));
  1501. if (err) {
  1502. printk(KERN_ERR "Failed to request irq for MSIX"
  1503. ", %s, error %d\n",
  1504. adapter->rx_queue[i].name, err);
  1505. return err;
  1506. }
  1507. adapter->rx_queue[i].comp_ring.intr_idx = vector++;
  1508. }
  1509. sprintf(intr->event_msi_vector_name, "%s-event-%d",
  1510. adapter->netdev->name, vector);
  1511. err = request_irq(intr->msix_entries[vector].vector,
  1512. vmxnet3_msix_event, 0,
  1513. intr->event_msi_vector_name, adapter->netdev);
  1514. intr->event_intr_idx = vector;
  1515. } else if (intr->type == VMXNET3_IT_MSI) {
  1516. adapter->num_rx_queues = 1;
  1517. err = request_irq(adapter->pdev->irq, vmxnet3_intr, 0,
  1518. adapter->netdev->name, adapter->netdev);
  1519. } else {
  1520. #endif
  1521. adapter->num_rx_queues = 1;
  1522. err = request_irq(adapter->pdev->irq, vmxnet3_intr,
  1523. IRQF_SHARED, adapter->netdev->name,
  1524. adapter->netdev);
  1525. #ifdef CONFIG_PCI_MSI
  1526. }
  1527. #endif
  1528. intr->num_intrs = vector + 1;
  1529. if (err) {
  1530. printk(KERN_ERR "Failed to request irq %s (intr type:%d), error"
  1531. ":%d\n", adapter->netdev->name, intr->type, err);
  1532. } else {
  1533. /* Number of rx queues will not change after this */
  1534. for (i = 0; i < adapter->num_rx_queues; i++) {
  1535. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  1536. rq->qid = i;
  1537. rq->qid2 = i + adapter->num_rx_queues;
  1538. }
  1539. /* init our intr settings */
  1540. for (i = 0; i < intr->num_intrs; i++)
  1541. intr->mod_levels[i] = UPT1_IML_ADAPTIVE;
  1542. if (adapter->intr.type != VMXNET3_IT_MSIX) {
  1543. adapter->intr.event_intr_idx = 0;
  1544. for (i = 0; i < adapter->num_tx_queues; i++)
  1545. adapter->tx_queue[i].comp_ring.intr_idx = 0;
  1546. adapter->rx_queue[0].comp_ring.intr_idx = 0;
  1547. }
  1548. printk(KERN_INFO "%s: intr type %u, mode %u, %u vectors "
  1549. "allocated\n", adapter->netdev->name, intr->type,
  1550. intr->mask_mode, intr->num_intrs);
  1551. }
  1552. return err;
  1553. }
  1554. static void
  1555. vmxnet3_free_irqs(struct vmxnet3_adapter *adapter)
  1556. {
  1557. struct vmxnet3_intr *intr = &adapter->intr;
  1558. BUG_ON(intr->type == VMXNET3_IT_AUTO || intr->num_intrs <= 0);
  1559. switch (intr->type) {
  1560. #ifdef CONFIG_PCI_MSI
  1561. case VMXNET3_IT_MSIX:
  1562. {
  1563. int i, vector = 0;
  1564. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE) {
  1565. for (i = 0; i < adapter->num_tx_queues; i++) {
  1566. free_irq(intr->msix_entries[vector++].vector,
  1567. &(adapter->tx_queue[i]));
  1568. if (adapter->share_intr == VMXNET3_INTR_TXSHARE)
  1569. break;
  1570. }
  1571. }
  1572. for (i = 0; i < adapter->num_rx_queues; i++) {
  1573. free_irq(intr->msix_entries[vector++].vector,
  1574. &(adapter->rx_queue[i]));
  1575. }
  1576. free_irq(intr->msix_entries[vector].vector,
  1577. adapter->netdev);
  1578. BUG_ON(vector >= intr->num_intrs);
  1579. break;
  1580. }
  1581. #endif
  1582. case VMXNET3_IT_MSI:
  1583. free_irq(adapter->pdev->irq, adapter->netdev);
  1584. break;
  1585. case VMXNET3_IT_INTX:
  1586. free_irq(adapter->pdev->irq, adapter->netdev);
  1587. break;
  1588. default:
  1589. BUG_ON(true);
  1590. }
  1591. }
  1592. static void
  1593. vmxnet3_restore_vlan(struct vmxnet3_adapter *adapter)
  1594. {
  1595. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1596. u16 vid;
  1597. /* allow untagged pkts */
  1598. VMXNET3_SET_VFTABLE_ENTRY(vfTable, 0);
  1599. for_each_set_bit(vid, adapter->active_vlans, VLAN_N_VID)
  1600. VMXNET3_SET_VFTABLE_ENTRY(vfTable, vid);
  1601. }
  1602. static void
  1603. vmxnet3_vlan_rx_add_vid(struct net_device *netdev, u16 vid)
  1604. {
  1605. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1606. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1607. unsigned long flags;
  1608. VMXNET3_SET_VFTABLE_ENTRY(vfTable, vid);
  1609. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1610. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1611. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1612. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1613. set_bit(vid, adapter->active_vlans);
  1614. }
  1615. static void
  1616. vmxnet3_vlan_rx_kill_vid(struct net_device *netdev, u16 vid)
  1617. {
  1618. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1619. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1620. unsigned long flags;
  1621. VMXNET3_CLEAR_VFTABLE_ENTRY(vfTable, vid);
  1622. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1623. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1624. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1625. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1626. clear_bit(vid, adapter->active_vlans);
  1627. }
  1628. static u8 *
  1629. vmxnet3_copy_mc(struct net_device *netdev)
  1630. {
  1631. u8 *buf = NULL;
  1632. u32 sz = netdev_mc_count(netdev) * ETH_ALEN;
  1633. /* struct Vmxnet3_RxFilterConf.mfTableLen is u16. */
  1634. if (sz <= 0xffff) {
  1635. /* We may be called with BH disabled */
  1636. buf = kmalloc(sz, GFP_ATOMIC);
  1637. if (buf) {
  1638. struct netdev_hw_addr *ha;
  1639. int i = 0;
  1640. netdev_for_each_mc_addr(ha, netdev)
  1641. memcpy(buf + i++ * ETH_ALEN, ha->addr,
  1642. ETH_ALEN);
  1643. }
  1644. }
  1645. return buf;
  1646. }
  1647. static void
  1648. vmxnet3_set_mc(struct net_device *netdev)
  1649. {
  1650. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1651. unsigned long flags;
  1652. struct Vmxnet3_RxFilterConf *rxConf =
  1653. &adapter->shared->devRead.rxFilterConf;
  1654. u8 *new_table = NULL;
  1655. u32 new_mode = VMXNET3_RXM_UCAST;
  1656. if (netdev->flags & IFF_PROMISC) {
  1657. u32 *vfTable = adapter->shared->devRead.rxFilterConf.vfTable;
  1658. memset(vfTable, 0, VMXNET3_VFT_SIZE * sizeof(*vfTable));
  1659. new_mode |= VMXNET3_RXM_PROMISC;
  1660. } else {
  1661. vmxnet3_restore_vlan(adapter);
  1662. }
  1663. if (netdev->flags & IFF_BROADCAST)
  1664. new_mode |= VMXNET3_RXM_BCAST;
  1665. if (netdev->flags & IFF_ALLMULTI)
  1666. new_mode |= VMXNET3_RXM_ALL_MULTI;
  1667. else
  1668. if (!netdev_mc_empty(netdev)) {
  1669. new_table = vmxnet3_copy_mc(netdev);
  1670. if (new_table) {
  1671. new_mode |= VMXNET3_RXM_MCAST;
  1672. rxConf->mfTableLen = cpu_to_le16(
  1673. netdev_mc_count(netdev) * ETH_ALEN);
  1674. rxConf->mfTablePA = cpu_to_le64(virt_to_phys(
  1675. new_table));
  1676. } else {
  1677. printk(KERN_INFO "%s: failed to copy mcast list"
  1678. ", setting ALL_MULTI\n", netdev->name);
  1679. new_mode |= VMXNET3_RXM_ALL_MULTI;
  1680. }
  1681. }
  1682. if (!(new_mode & VMXNET3_RXM_MCAST)) {
  1683. rxConf->mfTableLen = 0;
  1684. rxConf->mfTablePA = 0;
  1685. }
  1686. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1687. if (new_mode != rxConf->rxMode) {
  1688. rxConf->rxMode = cpu_to_le32(new_mode);
  1689. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1690. VMXNET3_CMD_UPDATE_RX_MODE);
  1691. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1692. VMXNET3_CMD_UPDATE_VLAN_FILTERS);
  1693. }
  1694. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1695. VMXNET3_CMD_UPDATE_MAC_FILTERS);
  1696. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1697. kfree(new_table);
  1698. }
  1699. void
  1700. vmxnet3_rq_destroy_all(struct vmxnet3_adapter *adapter)
  1701. {
  1702. int i;
  1703. for (i = 0; i < adapter->num_rx_queues; i++)
  1704. vmxnet3_rq_destroy(&adapter->rx_queue[i], adapter);
  1705. }
  1706. /*
  1707. * Set up driver_shared based on settings in adapter.
  1708. */
  1709. static void
  1710. vmxnet3_setup_driver_shared(struct vmxnet3_adapter *adapter)
  1711. {
  1712. struct Vmxnet3_DriverShared *shared = adapter->shared;
  1713. struct Vmxnet3_DSDevRead *devRead = &shared->devRead;
  1714. struct Vmxnet3_TxQueueConf *tqc;
  1715. struct Vmxnet3_RxQueueConf *rqc;
  1716. int i;
  1717. memset(shared, 0, sizeof(*shared));
  1718. /* driver settings */
  1719. shared->magic = cpu_to_le32(VMXNET3_REV1_MAGIC);
  1720. devRead->misc.driverInfo.version = cpu_to_le32(
  1721. VMXNET3_DRIVER_VERSION_NUM);
  1722. devRead->misc.driverInfo.gos.gosBits = (sizeof(void *) == 4 ?
  1723. VMXNET3_GOS_BITS_32 : VMXNET3_GOS_BITS_64);
  1724. devRead->misc.driverInfo.gos.gosType = VMXNET3_GOS_TYPE_LINUX;
  1725. *((u32 *)&devRead->misc.driverInfo.gos) = cpu_to_le32(
  1726. *((u32 *)&devRead->misc.driverInfo.gos));
  1727. devRead->misc.driverInfo.vmxnet3RevSpt = cpu_to_le32(1);
  1728. devRead->misc.driverInfo.uptVerSpt = cpu_to_le32(1);
  1729. devRead->misc.ddPA = cpu_to_le64(virt_to_phys(adapter));
  1730. devRead->misc.ddLen = cpu_to_le32(sizeof(struct vmxnet3_adapter));
  1731. /* set up feature flags */
  1732. if (adapter->netdev->features & NETIF_F_RXCSUM)
  1733. devRead->misc.uptFeatures |= UPT1_F_RXCSUM;
  1734. if (adapter->netdev->features & NETIF_F_LRO) {
  1735. devRead->misc.uptFeatures |= UPT1_F_LRO;
  1736. devRead->misc.maxNumRxSG = cpu_to_le16(1 + MAX_SKB_FRAGS);
  1737. }
  1738. if (adapter->netdev->features & NETIF_F_HW_VLAN_RX)
  1739. devRead->misc.uptFeatures |= UPT1_F_RXVLAN;
  1740. devRead->misc.mtu = cpu_to_le32(adapter->netdev->mtu);
  1741. devRead->misc.queueDescPA = cpu_to_le64(adapter->queue_desc_pa);
  1742. devRead->misc.queueDescLen = cpu_to_le32(
  1743. adapter->num_tx_queues * sizeof(struct Vmxnet3_TxQueueDesc) +
  1744. adapter->num_rx_queues * sizeof(struct Vmxnet3_RxQueueDesc));
  1745. /* tx queue settings */
  1746. devRead->misc.numTxQueues = adapter->num_tx_queues;
  1747. for (i = 0; i < adapter->num_tx_queues; i++) {
  1748. struct vmxnet3_tx_queue *tq = &adapter->tx_queue[i];
  1749. BUG_ON(adapter->tx_queue[i].tx_ring.base == NULL);
  1750. tqc = &adapter->tqd_start[i].conf;
  1751. tqc->txRingBasePA = cpu_to_le64(tq->tx_ring.basePA);
  1752. tqc->dataRingBasePA = cpu_to_le64(tq->data_ring.basePA);
  1753. tqc->compRingBasePA = cpu_to_le64(tq->comp_ring.basePA);
  1754. tqc->ddPA = cpu_to_le64(virt_to_phys(tq->buf_info));
  1755. tqc->txRingSize = cpu_to_le32(tq->tx_ring.size);
  1756. tqc->dataRingSize = cpu_to_le32(tq->data_ring.size);
  1757. tqc->compRingSize = cpu_to_le32(tq->comp_ring.size);
  1758. tqc->ddLen = cpu_to_le32(
  1759. sizeof(struct vmxnet3_tx_buf_info) *
  1760. tqc->txRingSize);
  1761. tqc->intrIdx = tq->comp_ring.intr_idx;
  1762. }
  1763. /* rx queue settings */
  1764. devRead->misc.numRxQueues = adapter->num_rx_queues;
  1765. for (i = 0; i < adapter->num_rx_queues; i++) {
  1766. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  1767. rqc = &adapter->rqd_start[i].conf;
  1768. rqc->rxRingBasePA[0] = cpu_to_le64(rq->rx_ring[0].basePA);
  1769. rqc->rxRingBasePA[1] = cpu_to_le64(rq->rx_ring[1].basePA);
  1770. rqc->compRingBasePA = cpu_to_le64(rq->comp_ring.basePA);
  1771. rqc->ddPA = cpu_to_le64(virt_to_phys(
  1772. rq->buf_info));
  1773. rqc->rxRingSize[0] = cpu_to_le32(rq->rx_ring[0].size);
  1774. rqc->rxRingSize[1] = cpu_to_le32(rq->rx_ring[1].size);
  1775. rqc->compRingSize = cpu_to_le32(rq->comp_ring.size);
  1776. rqc->ddLen = cpu_to_le32(
  1777. sizeof(struct vmxnet3_rx_buf_info) *
  1778. (rqc->rxRingSize[0] +
  1779. rqc->rxRingSize[1]));
  1780. rqc->intrIdx = rq->comp_ring.intr_idx;
  1781. }
  1782. #ifdef VMXNET3_RSS
  1783. memset(adapter->rss_conf, 0, sizeof(*adapter->rss_conf));
  1784. if (adapter->rss) {
  1785. struct UPT1_RSSConf *rssConf = adapter->rss_conf;
  1786. devRead->misc.uptFeatures |= UPT1_F_RSS;
  1787. devRead->misc.numRxQueues = adapter->num_rx_queues;
  1788. rssConf->hashType = UPT1_RSS_HASH_TYPE_TCP_IPV4 |
  1789. UPT1_RSS_HASH_TYPE_IPV4 |
  1790. UPT1_RSS_HASH_TYPE_TCP_IPV6 |
  1791. UPT1_RSS_HASH_TYPE_IPV6;
  1792. rssConf->hashFunc = UPT1_RSS_HASH_FUNC_TOEPLITZ;
  1793. rssConf->hashKeySize = UPT1_RSS_MAX_KEY_SIZE;
  1794. rssConf->indTableSize = VMXNET3_RSS_IND_TABLE_SIZE;
  1795. get_random_bytes(&rssConf->hashKey[0], rssConf->hashKeySize);
  1796. for (i = 0; i < rssConf->indTableSize; i++)
  1797. rssConf->indTable[i] = i % adapter->num_rx_queues;
  1798. devRead->rssConfDesc.confVer = 1;
  1799. devRead->rssConfDesc.confLen = sizeof(*rssConf);
  1800. devRead->rssConfDesc.confPA = virt_to_phys(rssConf);
  1801. }
  1802. #endif /* VMXNET3_RSS */
  1803. /* intr settings */
  1804. devRead->intrConf.autoMask = adapter->intr.mask_mode ==
  1805. VMXNET3_IMM_AUTO;
  1806. devRead->intrConf.numIntrs = adapter->intr.num_intrs;
  1807. for (i = 0; i < adapter->intr.num_intrs; i++)
  1808. devRead->intrConf.modLevels[i] = adapter->intr.mod_levels[i];
  1809. devRead->intrConf.eventIntrIdx = adapter->intr.event_intr_idx;
  1810. devRead->intrConf.intrCtrl |= cpu_to_le32(VMXNET3_IC_DISABLE_ALL);
  1811. /* rx filter settings */
  1812. devRead->rxFilterConf.rxMode = 0;
  1813. vmxnet3_restore_vlan(adapter);
  1814. vmxnet3_write_mac_addr(adapter, adapter->netdev->dev_addr);
  1815. /* the rest are already zeroed */
  1816. }
  1817. int
  1818. vmxnet3_activate_dev(struct vmxnet3_adapter *adapter)
  1819. {
  1820. int err, i;
  1821. u32 ret;
  1822. unsigned long flags;
  1823. dev_dbg(&adapter->netdev->dev, "%s: skb_buf_size %d, rx_buf_per_pkt %d,"
  1824. " ring sizes %u %u %u\n", adapter->netdev->name,
  1825. adapter->skb_buf_size, adapter->rx_buf_per_pkt,
  1826. adapter->tx_queue[0].tx_ring.size,
  1827. adapter->rx_queue[0].rx_ring[0].size,
  1828. adapter->rx_queue[0].rx_ring[1].size);
  1829. vmxnet3_tq_init_all(adapter);
  1830. err = vmxnet3_rq_init_all(adapter);
  1831. if (err) {
  1832. printk(KERN_ERR "Failed to init rx queue for %s: error %d\n",
  1833. adapter->netdev->name, err);
  1834. goto rq_err;
  1835. }
  1836. err = vmxnet3_request_irqs(adapter);
  1837. if (err) {
  1838. printk(KERN_ERR "Failed to setup irq for %s: error %d\n",
  1839. adapter->netdev->name, err);
  1840. goto irq_err;
  1841. }
  1842. vmxnet3_setup_driver_shared(adapter);
  1843. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAL, VMXNET3_GET_ADDR_LO(
  1844. adapter->shared_pa));
  1845. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAH, VMXNET3_GET_ADDR_HI(
  1846. adapter->shared_pa));
  1847. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1848. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1849. VMXNET3_CMD_ACTIVATE_DEV);
  1850. ret = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_CMD);
  1851. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1852. if (ret != 0) {
  1853. printk(KERN_ERR "Failed to activate dev %s: error %u\n",
  1854. adapter->netdev->name, ret);
  1855. err = -EINVAL;
  1856. goto activate_err;
  1857. }
  1858. for (i = 0; i < adapter->num_rx_queues; i++) {
  1859. VMXNET3_WRITE_BAR0_REG(adapter,
  1860. VMXNET3_REG_RXPROD + i * VMXNET3_REG_ALIGN,
  1861. adapter->rx_queue[i].rx_ring[0].next2fill);
  1862. VMXNET3_WRITE_BAR0_REG(adapter, (VMXNET3_REG_RXPROD2 +
  1863. (i * VMXNET3_REG_ALIGN)),
  1864. adapter->rx_queue[i].rx_ring[1].next2fill);
  1865. }
  1866. /* Apply the rx filter settins last. */
  1867. vmxnet3_set_mc(adapter->netdev);
  1868. /*
  1869. * Check link state when first activating device. It will start the
  1870. * tx queue if the link is up.
  1871. */
  1872. vmxnet3_check_link(adapter, true);
  1873. for (i = 0; i < adapter->num_rx_queues; i++)
  1874. napi_enable(&adapter->rx_queue[i].napi);
  1875. vmxnet3_enable_all_intrs(adapter);
  1876. clear_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state);
  1877. return 0;
  1878. activate_err:
  1879. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAL, 0);
  1880. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_DSAH, 0);
  1881. vmxnet3_free_irqs(adapter);
  1882. irq_err:
  1883. rq_err:
  1884. /* free up buffers we allocated */
  1885. vmxnet3_rq_cleanup_all(adapter);
  1886. return err;
  1887. }
  1888. void
  1889. vmxnet3_reset_dev(struct vmxnet3_adapter *adapter)
  1890. {
  1891. unsigned long flags;
  1892. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1893. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD, VMXNET3_CMD_RESET_DEV);
  1894. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1895. }
  1896. int
  1897. vmxnet3_quiesce_dev(struct vmxnet3_adapter *adapter)
  1898. {
  1899. int i;
  1900. unsigned long flags;
  1901. if (test_and_set_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state))
  1902. return 0;
  1903. spin_lock_irqsave(&adapter->cmd_lock, flags);
  1904. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  1905. VMXNET3_CMD_QUIESCE_DEV);
  1906. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  1907. vmxnet3_disable_all_intrs(adapter);
  1908. for (i = 0; i < adapter->num_rx_queues; i++)
  1909. napi_disable(&adapter->rx_queue[i].napi);
  1910. netif_tx_disable(adapter->netdev);
  1911. adapter->link_speed = 0;
  1912. netif_carrier_off(adapter->netdev);
  1913. vmxnet3_tq_cleanup_all(adapter);
  1914. vmxnet3_rq_cleanup_all(adapter);
  1915. vmxnet3_free_irqs(adapter);
  1916. return 0;
  1917. }
  1918. static void
  1919. vmxnet3_write_mac_addr(struct vmxnet3_adapter *adapter, u8 *mac)
  1920. {
  1921. u32 tmp;
  1922. tmp = *(u32 *)mac;
  1923. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_MACL, tmp);
  1924. tmp = (mac[5] << 8) | mac[4];
  1925. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_MACH, tmp);
  1926. }
  1927. static int
  1928. vmxnet3_set_mac_addr(struct net_device *netdev, void *p)
  1929. {
  1930. struct sockaddr *addr = p;
  1931. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  1932. memcpy(netdev->dev_addr, addr->sa_data, netdev->addr_len);
  1933. vmxnet3_write_mac_addr(adapter, addr->sa_data);
  1934. return 0;
  1935. }
  1936. /* ==================== initialization and cleanup routines ============ */
  1937. static int
  1938. vmxnet3_alloc_pci_resources(struct vmxnet3_adapter *adapter, bool *dma64)
  1939. {
  1940. int err;
  1941. unsigned long mmio_start, mmio_len;
  1942. struct pci_dev *pdev = adapter->pdev;
  1943. err = pci_enable_device(pdev);
  1944. if (err) {
  1945. printk(KERN_ERR "Failed to enable adapter %s: error %d\n",
  1946. pci_name(pdev), err);
  1947. return err;
  1948. }
  1949. if (pci_set_dma_mask(pdev, DMA_BIT_MASK(64)) == 0) {
  1950. if (pci_set_consistent_dma_mask(pdev, DMA_BIT_MASK(64)) != 0) {
  1951. printk(KERN_ERR "pci_set_consistent_dma_mask failed "
  1952. "for adapter %s\n", pci_name(pdev));
  1953. err = -EIO;
  1954. goto err_set_mask;
  1955. }
  1956. *dma64 = true;
  1957. } else {
  1958. if (pci_set_dma_mask(pdev, DMA_BIT_MASK(32)) != 0) {
  1959. printk(KERN_ERR "pci_set_dma_mask failed for adapter "
  1960. "%s\n", pci_name(pdev));
  1961. err = -EIO;
  1962. goto err_set_mask;
  1963. }
  1964. *dma64 = false;
  1965. }
  1966. err = pci_request_selected_regions(pdev, (1 << 2) - 1,
  1967. vmxnet3_driver_name);
  1968. if (err) {
  1969. printk(KERN_ERR "Failed to request region for adapter %s: "
  1970. "error %d\n", pci_name(pdev), err);
  1971. goto err_set_mask;
  1972. }
  1973. pci_set_master(pdev);
  1974. mmio_start = pci_resource_start(pdev, 0);
  1975. mmio_len = pci_resource_len(pdev, 0);
  1976. adapter->hw_addr0 = ioremap(mmio_start, mmio_len);
  1977. if (!adapter->hw_addr0) {
  1978. printk(KERN_ERR "Failed to map bar0 for adapter %s\n",
  1979. pci_name(pdev));
  1980. err = -EIO;
  1981. goto err_ioremap;
  1982. }
  1983. mmio_start = pci_resource_start(pdev, 1);
  1984. mmio_len = pci_resource_len(pdev, 1);
  1985. adapter->hw_addr1 = ioremap(mmio_start, mmio_len);
  1986. if (!adapter->hw_addr1) {
  1987. printk(KERN_ERR "Failed to map bar1 for adapter %s\n",
  1988. pci_name(pdev));
  1989. err = -EIO;
  1990. goto err_bar1;
  1991. }
  1992. return 0;
  1993. err_bar1:
  1994. iounmap(adapter->hw_addr0);
  1995. err_ioremap:
  1996. pci_release_selected_regions(pdev, (1 << 2) - 1);
  1997. err_set_mask:
  1998. pci_disable_device(pdev);
  1999. return err;
  2000. }
  2001. static void
  2002. vmxnet3_free_pci_resources(struct vmxnet3_adapter *adapter)
  2003. {
  2004. BUG_ON(!adapter->pdev);
  2005. iounmap(adapter->hw_addr0);
  2006. iounmap(adapter->hw_addr1);
  2007. pci_release_selected_regions(adapter->pdev, (1 << 2) - 1);
  2008. pci_disable_device(adapter->pdev);
  2009. }
  2010. static void
  2011. vmxnet3_adjust_rx_ring_size(struct vmxnet3_adapter *adapter)
  2012. {
  2013. size_t sz, i, ring0_size, ring1_size, comp_size;
  2014. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[0];
  2015. if (adapter->netdev->mtu <= VMXNET3_MAX_SKB_BUF_SIZE -
  2016. VMXNET3_MAX_ETH_HDR_SIZE) {
  2017. adapter->skb_buf_size = adapter->netdev->mtu +
  2018. VMXNET3_MAX_ETH_HDR_SIZE;
  2019. if (adapter->skb_buf_size < VMXNET3_MIN_T0_BUF_SIZE)
  2020. adapter->skb_buf_size = VMXNET3_MIN_T0_BUF_SIZE;
  2021. adapter->rx_buf_per_pkt = 1;
  2022. } else {
  2023. adapter->skb_buf_size = VMXNET3_MAX_SKB_BUF_SIZE;
  2024. sz = adapter->netdev->mtu - VMXNET3_MAX_SKB_BUF_SIZE +
  2025. VMXNET3_MAX_ETH_HDR_SIZE;
  2026. adapter->rx_buf_per_pkt = 1 + (sz + PAGE_SIZE - 1) / PAGE_SIZE;
  2027. }
  2028. /*
  2029. * for simplicity, force the ring0 size to be a multiple of
  2030. * rx_buf_per_pkt * VMXNET3_RING_SIZE_ALIGN
  2031. */
  2032. sz = adapter->rx_buf_per_pkt * VMXNET3_RING_SIZE_ALIGN;
  2033. ring0_size = adapter->rx_queue[0].rx_ring[0].size;
  2034. ring0_size = (ring0_size + sz - 1) / sz * sz;
  2035. ring0_size = min_t(u32, ring0_size, VMXNET3_RX_RING_MAX_SIZE /
  2036. sz * sz);
  2037. ring1_size = adapter->rx_queue[0].rx_ring[1].size;
  2038. comp_size = ring0_size + ring1_size;
  2039. for (i = 0; i < adapter->num_rx_queues; i++) {
  2040. rq = &adapter->rx_queue[i];
  2041. rq->rx_ring[0].size = ring0_size;
  2042. rq->rx_ring[1].size = ring1_size;
  2043. rq->comp_ring.size = comp_size;
  2044. }
  2045. }
  2046. int
  2047. vmxnet3_create_queues(struct vmxnet3_adapter *adapter, u32 tx_ring_size,
  2048. u32 rx_ring_size, u32 rx_ring2_size)
  2049. {
  2050. int err = 0, i;
  2051. for (i = 0; i < adapter->num_tx_queues; i++) {
  2052. struct vmxnet3_tx_queue *tq = &adapter->tx_queue[i];
  2053. tq->tx_ring.size = tx_ring_size;
  2054. tq->data_ring.size = tx_ring_size;
  2055. tq->comp_ring.size = tx_ring_size;
  2056. tq->shared = &adapter->tqd_start[i].ctrl;
  2057. tq->stopped = true;
  2058. tq->adapter = adapter;
  2059. tq->qid = i;
  2060. err = vmxnet3_tq_create(tq, adapter);
  2061. /*
  2062. * Too late to change num_tx_queues. We cannot do away with
  2063. * lesser number of queues than what we asked for
  2064. */
  2065. if (err)
  2066. goto queue_err;
  2067. }
  2068. adapter->rx_queue[0].rx_ring[0].size = rx_ring_size;
  2069. adapter->rx_queue[0].rx_ring[1].size = rx_ring2_size;
  2070. vmxnet3_adjust_rx_ring_size(adapter);
  2071. for (i = 0; i < adapter->num_rx_queues; i++) {
  2072. struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
  2073. /* qid and qid2 for rx queues will be assigned later when num
  2074. * of rx queues is finalized after allocating intrs */
  2075. rq->shared = &adapter->rqd_start[i].ctrl;
  2076. rq->adapter = adapter;
  2077. err = vmxnet3_rq_create(rq, adapter);
  2078. if (err) {
  2079. if (i == 0) {
  2080. printk(KERN_ERR "Could not allocate any rx"
  2081. "queues. Aborting.\n");
  2082. goto queue_err;
  2083. } else {
  2084. printk(KERN_INFO "Number of rx queues changed "
  2085. "to : %d.\n", i);
  2086. adapter->num_rx_queues = i;
  2087. err = 0;
  2088. break;
  2089. }
  2090. }
  2091. }
  2092. return err;
  2093. queue_err:
  2094. vmxnet3_tq_destroy_all(adapter);
  2095. return err;
  2096. }
  2097. static int
  2098. vmxnet3_open(struct net_device *netdev)
  2099. {
  2100. struct vmxnet3_adapter *adapter;
  2101. int err, i;
  2102. adapter = netdev_priv(netdev);
  2103. for (i = 0; i < adapter->num_tx_queues; i++)
  2104. spin_lock_init(&adapter->tx_queue[i].tx_lock);
  2105. err = vmxnet3_create_queues(adapter, VMXNET3_DEF_TX_RING_SIZE,
  2106. VMXNET3_DEF_RX_RING_SIZE,
  2107. VMXNET3_DEF_RX_RING_SIZE);
  2108. if (err)
  2109. goto queue_err;
  2110. err = vmxnet3_activate_dev(adapter);
  2111. if (err)
  2112. goto activate_err;
  2113. return 0;
  2114. activate_err:
  2115. vmxnet3_rq_destroy_all(adapter);
  2116. vmxnet3_tq_destroy_all(adapter);
  2117. queue_err:
  2118. return err;
  2119. }
  2120. static int
  2121. vmxnet3_close(struct net_device *netdev)
  2122. {
  2123. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2124. /*
  2125. * Reset_work may be in the middle of resetting the device, wait for its
  2126. * completion.
  2127. */
  2128. while (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2129. msleep(1);
  2130. vmxnet3_quiesce_dev(adapter);
  2131. vmxnet3_rq_destroy_all(adapter);
  2132. vmxnet3_tq_destroy_all(adapter);
  2133. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2134. return 0;
  2135. }
  2136. void
  2137. vmxnet3_force_close(struct vmxnet3_adapter *adapter)
  2138. {
  2139. int i;
  2140. /*
  2141. * we must clear VMXNET3_STATE_BIT_RESETTING, otherwise
  2142. * vmxnet3_close() will deadlock.
  2143. */
  2144. BUG_ON(test_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state));
  2145. /* we need to enable NAPI, otherwise dev_close will deadlock */
  2146. for (i = 0; i < adapter->num_rx_queues; i++)
  2147. napi_enable(&adapter->rx_queue[i].napi);
  2148. dev_close(adapter->netdev);
  2149. }
  2150. static int
  2151. vmxnet3_change_mtu(struct net_device *netdev, int new_mtu)
  2152. {
  2153. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2154. int err = 0;
  2155. if (new_mtu < VMXNET3_MIN_MTU || new_mtu > VMXNET3_MAX_MTU)
  2156. return -EINVAL;
  2157. netdev->mtu = new_mtu;
  2158. /*
  2159. * Reset_work may be in the middle of resetting the device, wait for its
  2160. * completion.
  2161. */
  2162. while (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2163. msleep(1);
  2164. if (netif_running(netdev)) {
  2165. vmxnet3_quiesce_dev(adapter);
  2166. vmxnet3_reset_dev(adapter);
  2167. /* we need to re-create the rx queue based on the new mtu */
  2168. vmxnet3_rq_destroy_all(adapter);
  2169. vmxnet3_adjust_rx_ring_size(adapter);
  2170. err = vmxnet3_rq_create_all(adapter);
  2171. if (err) {
  2172. printk(KERN_ERR "%s: failed to re-create rx queues,"
  2173. " error %d. Closing it.\n", netdev->name, err);
  2174. goto out;
  2175. }
  2176. err = vmxnet3_activate_dev(adapter);
  2177. if (err) {
  2178. printk(KERN_ERR "%s: failed to re-activate, error %d. "
  2179. "Closing it\n", netdev->name, err);
  2180. goto out;
  2181. }
  2182. }
  2183. out:
  2184. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2185. if (err)
  2186. vmxnet3_force_close(adapter);
  2187. return err;
  2188. }
  2189. static void
  2190. vmxnet3_declare_features(struct vmxnet3_adapter *adapter, bool dma64)
  2191. {
  2192. struct net_device *netdev = adapter->netdev;
  2193. netdev->hw_features = NETIF_F_SG | NETIF_F_RXCSUM |
  2194. NETIF_F_HW_CSUM | NETIF_F_HW_VLAN_TX |
  2195. NETIF_F_HW_VLAN_RX | NETIF_F_TSO | NETIF_F_TSO6 |
  2196. NETIF_F_LRO;
  2197. if (dma64)
  2198. netdev->hw_features |= NETIF_F_HIGHDMA;
  2199. netdev->vlan_features = netdev->hw_features &
  2200. ~(NETIF_F_HW_VLAN_TX | NETIF_F_HW_VLAN_RX);
  2201. netdev->features = netdev->hw_features | NETIF_F_HW_VLAN_FILTER;
  2202. netdev_info(adapter->netdev,
  2203. "features: sg csum vlan jf tso tsoIPv6 lro%s\n",
  2204. dma64 ? " highDMA" : "");
  2205. }
  2206. static void
  2207. vmxnet3_read_mac_addr(struct vmxnet3_adapter *adapter, u8 *mac)
  2208. {
  2209. u32 tmp;
  2210. tmp = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_MACL);
  2211. *(u32 *)mac = tmp;
  2212. tmp = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_MACH);
  2213. mac[4] = tmp & 0xff;
  2214. mac[5] = (tmp >> 8) & 0xff;
  2215. }
  2216. #ifdef CONFIG_PCI_MSI
  2217. /*
  2218. * Enable MSIx vectors.
  2219. * Returns :
  2220. * 0 on successful enabling of required vectors,
  2221. * VMXNET3_LINUX_MIN_MSIX_VECT when only minimum number of vectors required
  2222. * could be enabled.
  2223. * number of vectors which can be enabled otherwise (this number is smaller
  2224. * than VMXNET3_LINUX_MIN_MSIX_VECT)
  2225. */
  2226. static int
  2227. vmxnet3_acquire_msix_vectors(struct vmxnet3_adapter *adapter,
  2228. int vectors)
  2229. {
  2230. int err = 0, vector_threshold;
  2231. vector_threshold = VMXNET3_LINUX_MIN_MSIX_VECT;
  2232. while (vectors >= vector_threshold) {
  2233. err = pci_enable_msix(adapter->pdev, adapter->intr.msix_entries,
  2234. vectors);
  2235. if (!err) {
  2236. adapter->intr.num_intrs = vectors;
  2237. return 0;
  2238. } else if (err < 0) {
  2239. printk(KERN_ERR "Failed to enable MSI-X for %s, error"
  2240. " %d\n", adapter->netdev->name, err);
  2241. vectors = 0;
  2242. } else if (err < vector_threshold) {
  2243. break;
  2244. } else {
  2245. /* If fails to enable required number of MSI-x vectors
  2246. * try enabling minimum number of vectors required.
  2247. */
  2248. vectors = vector_threshold;
  2249. printk(KERN_ERR "Failed to enable %d MSI-X for %s, try"
  2250. " %d instead\n", vectors, adapter->netdev->name,
  2251. vector_threshold);
  2252. }
  2253. }
  2254. printk(KERN_INFO "Number of MSI-X interrupts which can be allocatedi"
  2255. " are lower than min threshold required.\n");
  2256. return err;
  2257. }
  2258. #endif /* CONFIG_PCI_MSI */
  2259. static void
  2260. vmxnet3_alloc_intr_resources(struct vmxnet3_adapter *adapter)
  2261. {
  2262. u32 cfg;
  2263. unsigned long flags;
  2264. /* intr settings */
  2265. spin_lock_irqsave(&adapter->cmd_lock, flags);
  2266. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_CMD,
  2267. VMXNET3_CMD_GET_CONF_INTR);
  2268. cfg = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_CMD);
  2269. spin_unlock_irqrestore(&adapter->cmd_lock, flags);
  2270. adapter->intr.type = cfg & 0x3;
  2271. adapter->intr.mask_mode = (cfg >> 2) & 0x3;
  2272. if (adapter->intr.type == VMXNET3_IT_AUTO) {
  2273. adapter->intr.type = VMXNET3_IT_MSIX;
  2274. }
  2275. #ifdef CONFIG_PCI_MSI
  2276. if (adapter->intr.type == VMXNET3_IT_MSIX) {
  2277. int vector, err = 0;
  2278. adapter->intr.num_intrs = (adapter->share_intr ==
  2279. VMXNET3_INTR_TXSHARE) ? 1 :
  2280. adapter->num_tx_queues;
  2281. adapter->intr.num_intrs += (adapter->share_intr ==
  2282. VMXNET3_INTR_BUDDYSHARE) ? 0 :
  2283. adapter->num_rx_queues;
  2284. adapter->intr.num_intrs += 1; /* for link event */
  2285. adapter->intr.num_intrs = (adapter->intr.num_intrs >
  2286. VMXNET3_LINUX_MIN_MSIX_VECT
  2287. ? adapter->intr.num_intrs :
  2288. VMXNET3_LINUX_MIN_MSIX_VECT);
  2289. for (vector = 0; vector < adapter->intr.num_intrs; vector++)
  2290. adapter->intr.msix_entries[vector].entry = vector;
  2291. err = vmxnet3_acquire_msix_vectors(adapter,
  2292. adapter->intr.num_intrs);
  2293. /* If we cannot allocate one MSIx vector per queue
  2294. * then limit the number of rx queues to 1
  2295. */
  2296. if (err == VMXNET3_LINUX_MIN_MSIX_VECT) {
  2297. if (adapter->share_intr != VMXNET3_INTR_BUDDYSHARE
  2298. || adapter->num_rx_queues != 1) {
  2299. adapter->share_intr = VMXNET3_INTR_TXSHARE;
  2300. printk(KERN_ERR "Number of rx queues : 1\n");
  2301. adapter->num_rx_queues = 1;
  2302. adapter->intr.num_intrs =
  2303. VMXNET3_LINUX_MIN_MSIX_VECT;
  2304. }
  2305. return;
  2306. }
  2307. if (!err)
  2308. return;
  2309. /* If we cannot allocate MSIx vectors use only one rx queue */
  2310. printk(KERN_INFO "Failed to enable MSI-X for %s, error %d."
  2311. "#rx queues : 1, try MSI\n", adapter->netdev->name, err);
  2312. adapter->intr.type = VMXNET3_IT_MSI;
  2313. }
  2314. if (adapter->intr.type == VMXNET3_IT_MSI) {
  2315. int err;
  2316. err = pci_enable_msi(adapter->pdev);
  2317. if (!err) {
  2318. adapter->num_rx_queues = 1;
  2319. adapter->intr.num_intrs = 1;
  2320. return;
  2321. }
  2322. }
  2323. #endif /* CONFIG_PCI_MSI */
  2324. adapter->num_rx_queues = 1;
  2325. printk(KERN_INFO "Using INTx interrupt, #Rx queues: 1.\n");
  2326. adapter->intr.type = VMXNET3_IT_INTX;
  2327. /* INT-X related setting */
  2328. adapter->intr.num_intrs = 1;
  2329. }
  2330. static void
  2331. vmxnet3_free_intr_resources(struct vmxnet3_adapter *adapter)
  2332. {
  2333. if (adapter->intr.type == VMXNET3_IT_MSIX)
  2334. pci_disable_msix(adapter->pdev);
  2335. else if (adapter->intr.type == VMXNET3_IT_MSI)
  2336. pci_disable_msi(adapter->pdev);
  2337. else
  2338. BUG_ON(adapter->intr.type != VMXNET3_IT_INTX);
  2339. }
  2340. static void
  2341. vmxnet3_tx_timeout(struct net_device *netdev)
  2342. {
  2343. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2344. adapter->tx_timeout_count++;
  2345. printk(KERN_ERR "%s: tx hang\n", adapter->netdev->name);
  2346. schedule_work(&adapter->work);
  2347. netif_wake_queue(adapter->netdev);
  2348. }
  2349. static void
  2350. vmxnet3_reset_work(struct work_struct *data)
  2351. {
  2352. struct vmxnet3_adapter *adapter;
  2353. adapter = container_of(data, struct vmxnet3_adapter, work);
  2354. /* if another thread is resetting the device, no need to proceed */
  2355. if (test_and_set_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state))
  2356. return;
  2357. /* if the device is closed, we must leave it alone */
  2358. rtnl_lock();
  2359. if (netif_running(adapter->netdev)) {
  2360. printk(KERN_INFO "%s: resetting\n", adapter->netdev->name);
  2361. vmxnet3_quiesce_dev(adapter);
  2362. vmxnet3_reset_dev(adapter);
  2363. vmxnet3_activate_dev(adapter);
  2364. } else {
  2365. printk(KERN_INFO "%s: already closed\n", adapter->netdev->name);
  2366. }
  2367. rtnl_unlock();
  2368. clear_bit(VMXNET3_STATE_BIT_RESETTING, &adapter->state);
  2369. }
  2370. static int __devinit
  2371. vmxnet3_probe_device(struct pci_dev *pdev,
  2372. const struct pci_device_id *id)
  2373. {
  2374. static const struct net_device_ops vmxnet3_netdev_ops = {
  2375. .ndo_open = vmxnet3_open,
  2376. .ndo_stop = vmxnet3_close,
  2377. .ndo_start_xmit = vmxnet3_xmit_frame,
  2378. .ndo_set_mac_address = vmxnet3_set_mac_addr,
  2379. .ndo_change_mtu = vmxnet3_change_mtu,
  2380. .ndo_set_features = vmxnet3_set_features,
  2381. .ndo_get_stats64 = vmxnet3_get_stats64,
  2382. .ndo_tx_timeout = vmxnet3_tx_timeout,
  2383. .ndo_set_multicast_list = vmxnet3_set_mc,
  2384. .ndo_vlan_rx_add_vid = vmxnet3_vlan_rx_add_vid,
  2385. .ndo_vlan_rx_kill_vid = vmxnet3_vlan_rx_kill_vid,
  2386. #ifdef CONFIG_NET_POLL_CONTROLLER
  2387. .ndo_poll_controller = vmxnet3_netpoll,
  2388. #endif
  2389. };
  2390. int err;
  2391. bool dma64 = false; /* stupid gcc */
  2392. u32 ver;
  2393. struct net_device *netdev;
  2394. struct vmxnet3_adapter *adapter;
  2395. u8 mac[ETH_ALEN];
  2396. int size;
  2397. int num_tx_queues;
  2398. int num_rx_queues;
  2399. if (!pci_msi_enabled())
  2400. enable_mq = 0;
  2401. #ifdef VMXNET3_RSS
  2402. if (enable_mq)
  2403. num_rx_queues = min(VMXNET3_DEVICE_MAX_RX_QUEUES,
  2404. (int)num_online_cpus());
  2405. else
  2406. #endif
  2407. num_rx_queues = 1;
  2408. num_rx_queues = rounddown_pow_of_two(num_rx_queues);
  2409. if (enable_mq)
  2410. num_tx_queues = min(VMXNET3_DEVICE_MAX_TX_QUEUES,
  2411. (int)num_online_cpus());
  2412. else
  2413. num_tx_queues = 1;
  2414. num_tx_queues = rounddown_pow_of_two(num_tx_queues);
  2415. netdev = alloc_etherdev_mq(sizeof(struct vmxnet3_adapter),
  2416. max(num_tx_queues, num_rx_queues));
  2417. printk(KERN_INFO "# of Tx queues : %d, # of Rx queues : %d\n",
  2418. num_tx_queues, num_rx_queues);
  2419. if (!netdev) {
  2420. printk(KERN_ERR "Failed to alloc ethernet device for adapter "
  2421. "%s\n", pci_name(pdev));
  2422. return -ENOMEM;
  2423. }
  2424. pci_set_drvdata(pdev, netdev);
  2425. adapter = netdev_priv(netdev);
  2426. adapter->netdev = netdev;
  2427. adapter->pdev = pdev;
  2428. spin_lock_init(&adapter->cmd_lock);
  2429. adapter->shared = pci_alloc_consistent(adapter->pdev,
  2430. sizeof(struct Vmxnet3_DriverShared),
  2431. &adapter->shared_pa);
  2432. if (!adapter->shared) {
  2433. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2434. pci_name(pdev));
  2435. err = -ENOMEM;
  2436. goto err_alloc_shared;
  2437. }
  2438. adapter->num_rx_queues = num_rx_queues;
  2439. adapter->num_tx_queues = num_tx_queues;
  2440. size = sizeof(struct Vmxnet3_TxQueueDesc) * adapter->num_tx_queues;
  2441. size += sizeof(struct Vmxnet3_RxQueueDesc) * adapter->num_rx_queues;
  2442. adapter->tqd_start = pci_alloc_consistent(adapter->pdev, size,
  2443. &adapter->queue_desc_pa);
  2444. if (!adapter->tqd_start) {
  2445. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2446. pci_name(pdev));
  2447. err = -ENOMEM;
  2448. goto err_alloc_queue_desc;
  2449. }
  2450. adapter->rqd_start = (struct Vmxnet3_RxQueueDesc *)(adapter->tqd_start +
  2451. adapter->num_tx_queues);
  2452. adapter->pm_conf = kmalloc(sizeof(struct Vmxnet3_PMConf), GFP_KERNEL);
  2453. if (adapter->pm_conf == NULL) {
  2454. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2455. pci_name(pdev));
  2456. err = -ENOMEM;
  2457. goto err_alloc_pm;
  2458. }
  2459. #ifdef VMXNET3_RSS
  2460. adapter->rss_conf = kmalloc(sizeof(struct UPT1_RSSConf), GFP_KERNEL);
  2461. if (adapter->rss_conf == NULL) {
  2462. printk(KERN_ERR "Failed to allocate memory for %s\n",
  2463. pci_name(pdev));
  2464. err = -ENOMEM;
  2465. goto err_alloc_rss;
  2466. }
  2467. #endif /* VMXNET3_RSS */
  2468. err = vmxnet3_alloc_pci_resources(adapter, &dma64);
  2469. if (err < 0)
  2470. goto err_alloc_pci;
  2471. ver = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_VRRS);
  2472. if (ver & 1) {
  2473. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_VRRS, 1);
  2474. } else {
  2475. printk(KERN_ERR "Incompatible h/w version (0x%x) for adapter"
  2476. " %s\n", ver, pci_name(pdev));
  2477. err = -EBUSY;
  2478. goto err_ver;
  2479. }
  2480. ver = VMXNET3_READ_BAR1_REG(adapter, VMXNET3_REG_UVRS);
  2481. if (ver & 1) {
  2482. VMXNET3_WRITE_BAR1_REG(adapter, VMXNET3_REG_UVRS, 1);
  2483. } else {
  2484. printk(KERN_ERR "Incompatible upt version (0x%x) for "
  2485. "adapter %s\n", ver, pci_name(pdev));
  2486. err = -EBUSY;
  2487. goto err_ver;
  2488. }
  2489. SET_NETDEV_DEV(netdev, &pdev->dev);
  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. err = register_netdev(netdev);
  2526. if (err) {
  2527. printk(KERN_ERR "Failed to register adapter %s\n",
  2528. pci_name(pdev));
  2529. goto err_register;
  2530. }
  2531. set_bit(VMXNET3_STATE_BIT_QUIESCED, &adapter->state);
  2532. vmxnet3_check_link(adapter, false);
  2533. atomic_inc(&devices_found);
  2534. return 0;
  2535. err_register:
  2536. vmxnet3_free_intr_resources(adapter);
  2537. err_ver:
  2538. vmxnet3_free_pci_resources(adapter);
  2539. err_alloc_pci:
  2540. #ifdef VMXNET3_RSS
  2541. kfree(adapter->rss_conf);
  2542. err_alloc_rss:
  2543. #endif
  2544. kfree(adapter->pm_conf);
  2545. err_alloc_pm:
  2546. pci_free_consistent(adapter->pdev, size, adapter->tqd_start,
  2547. adapter->queue_desc_pa);
  2548. err_alloc_queue_desc:
  2549. pci_free_consistent(adapter->pdev, sizeof(struct Vmxnet3_DriverShared),
  2550. adapter->shared, adapter->shared_pa);
  2551. err_alloc_shared:
  2552. pci_set_drvdata(pdev, NULL);
  2553. free_netdev(netdev);
  2554. return err;
  2555. }
  2556. static void __devexit
  2557. vmxnet3_remove_device(struct pci_dev *pdev)
  2558. {
  2559. struct net_device *netdev = pci_get_drvdata(pdev);
  2560. struct vmxnet3_adapter *adapter = netdev_priv(netdev);
  2561. int size = 0;
  2562. int num_rx_queues;
  2563. #ifdef VMXNET3_RSS
  2564. if (enable_mq)
  2565. num_rx_queues = min(VMXNET3_DEVICE_MAX_RX_QUEUES,
  2566. (int)num_online_cpus());
  2567. else
  2568. #endif
  2569. num_rx_queues = 1;
  2570. num_rx_queues = rounddown_pow_of_two(num_rx_queues);
  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);