1
0

lwp_syscall.c 108 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846
  1. /*
  2. * Copyright (c) 2006-2023, RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2018-06-10 Bernard first version
  9. * 2021-02-03 lizhirui add limit condition for network syscall and add 64-bit arch support
  10. * 2021-02-06 lizhirui fix some bugs
  11. * 2021-02-12 lizhirui add 64-bit support for sys_brk
  12. * 2021-02-20 lizhirui fix some warnings
  13. */
  14. #define _GNU_SOURCE
  15. /* RT-Thread System call */
  16. #include <rtthread.h>
  17. #include <rthw.h>
  18. #include <board.h>
  19. #include <mm_aspace.h>
  20. #include <string.h>
  21. #include <lwp.h>
  22. #ifdef ARCH_MM_MMU
  23. #include <lwp_user_mm.h>
  24. #include <lwp_arch.h>
  25. #endif
  26. #include <fcntl.h>
  27. #ifdef RT_USING_DFS
  28. #include <poll.h>
  29. #include <sys/select.h>
  30. #include <dfs_file.h>
  31. #include <unistd.h>
  32. #include <stdio.h> /* rename() */
  33. #include <sys/stat.h>
  34. #include <sys/statfs.h> /* statfs() */
  35. #endif
  36. #include "syscall_data.h"
  37. #include "mqueue.h"
  38. #if (defined(RT_USING_SAL) && defined(SAL_USING_POSIX))
  39. #include <sys/socket.h>
  40. #define SYSCALL_NET(f) f
  41. #else
  42. #define SYSCALL_NET(f) SYSCALL_SIGN(sys_notimpl)
  43. #endif
  44. #if defined(RT_USING_DFS) && defined(ARCH_MM_MMU)
  45. #define SYSCALL_USPACE(f) f
  46. #else
  47. #define SYSCALL_USPACE(f) SYSCALL_SIGN(sys_notimpl)
  48. #endif
  49. #define DBG_TAG "SYSCALL"
  50. #define DBG_LVL DBG_INFO
  51. #include <rtdbg.h>
  52. #ifdef RT_USING_SAL
  53. #include <netdev_ipaddr.h>
  54. #include <netdev.h>
  55. #include <sal_netdb.h>
  56. #include <sal_socket.h>
  57. #include <sys/socket.h>
  58. #endif /* RT_USING_SAL */
  59. #include <tty.h>
  60. #include "lwp_ipc_internal.h"
  61. #include <sched.h>
  62. #ifndef GRND_NONBLOCK
  63. #define GRND_NONBLOCK 0x0001
  64. #endif /* GRND_NONBLOCK */
  65. #ifndef GRND_RANDOM
  66. #define GRND_RANDOM 0x0002
  67. #endif /*GRND_RANDOM */
  68. #ifndef RT_USING_POSIX_TIMER
  69. #error "No definition RT_USING_POSIX_TIMER"
  70. #endif
  71. #ifndef RT_USING_POSIX_CLOCK
  72. #error "No definition RT_USING_POSIX_CLOCK"
  73. #endif
  74. #define SET_ERRNO(no) rt_set_errno(-(no))
  75. #define GET_ERRNO() ((rt_get_errno() > 0) ? (-rt_get_errno()) : rt_get_errno())
  76. struct musl_sockaddr
  77. {
  78. uint16_t sa_family;
  79. char sa_data[14];
  80. };
  81. int sys_dup(int oldfd);
  82. int sys_dup2(int oldfd, int new);
  83. void lwp_cleanup(struct rt_thread *tid);
  84. #ifdef ARCH_MM_MMU
  85. #define ALLOC_KERNEL_STACK_SIZE 5120
  86. int sys_futex(int *uaddr, int op, int val, void *timeout, void *uaddr2, int val3);
  87. int sys_pmutex(void *umutex, int op, void *arg);
  88. int sys_cacheflush(void *addr, int len, int cache);
  89. static void *kmem_get(size_t size)
  90. {
  91. return rt_malloc(size);
  92. }
  93. static void kmem_put(void *kptr)
  94. {
  95. rt_free(kptr);
  96. }
  97. #else
  98. #define ALLOC_KERNEL_STACK_SIZE 1536
  99. #define ALLOC_KERNEL_STACK_SIZE_MIN 1024
  100. #define ALLOC_KERNEL_STACK_SIZE_MAX 4096
  101. extern void set_user_context(void *stack);
  102. #endif /* ARCH_MM_MMU */
  103. /* The same socket option is defined differently in the user interfaces and the
  104. * implementation. The options should be converted in the kernel. */
  105. /* socket levels */
  106. #define INTF_SOL_SOCKET 1
  107. #define IMPL_SOL_SOCKET 0xFFF
  108. #define INTF_IPPROTO_IP 0
  109. #define IMPL_IPPROTO_IP 0
  110. #define INTF_IPPROTO_TCP 6
  111. #define IMPL_IPPROTO_TCP 6
  112. #define INTF_IPPROTO_IPV6 41
  113. #define IMPL_IPPROTO_IPV6 41
  114. /* SOL_SOCKET option names */
  115. #define INTF_SO_BROADCAST 6
  116. #define INTF_SO_KEEPALIVE 9
  117. #define INTF_SO_REUSEADDR 2
  118. #define INTF_SO_TYPE 3
  119. #define INTF_SO_ERROR 4
  120. #define INTF_SO_SNDTIMEO 21
  121. #define INTF_SO_RCVTIMEO 20
  122. #define INTF_SO_RCVBUF 8
  123. #define INTF_SO_LINGER 13
  124. #define INTF_SO_NO_CHECK 11
  125. #define INTF_SO_ACCEPTCONN 30
  126. #define INTF_SO_DONTROUTE 5
  127. #define INTF_SO_OOBINLINE 10
  128. #define INTF_SO_REUSEPORT 15
  129. #define INTF_SO_SNDBUF 7
  130. #define INTF_SO_SNDLOWAT 19
  131. #define INTF_SO_RCVLOWAT 18
  132. #define IMPL_SO_BROADCAST 0x0020
  133. #define IMPL_SO_KEEPALIVE 0x0008
  134. #define IMPL_SO_REUSEADDR 0x0004
  135. #define IMPL_SO_TYPE 0x1008
  136. #define IMPL_SO_ERROR 0x1007
  137. #define IMPL_SO_SNDTIMEO 0x1005
  138. #define IMPL_SO_RCVTIMEO 0x1006
  139. #define IMPL_SO_RCVBUF 0x1002
  140. #define IMPL_SO_LINGER 0x0080
  141. #define IMPL_SO_NO_CHECK 0x100a
  142. #define IMPL_SO_ACCEPTCONN 0x0002
  143. #define IMPL_SO_DONTROUTE 0x0010
  144. #define IMPL_SO_OOBINLINE 0x0100
  145. #define IMPL_SO_REUSEPORT 0x0200
  146. #define IMPL_SO_SNDBUF 0x1001
  147. #define IMPL_SO_SNDLOWAT 0x1003
  148. #define IMPL_SO_RCVLOWAT 0x1004
  149. /* IPPROTO_IP option names */
  150. #define INTF_IP_TTL 2
  151. #define INTF_IP_TOS 1
  152. #define INTF_IP_MULTICAST_TTL 33
  153. #define INTF_IP_MULTICAST_IF 32
  154. #define INTF_IP_MULTICAST_LOOP 34
  155. #define INTF_IP_ADD_MEMBERSHIP 35
  156. #define INTF_IP_DROP_MEMBERSHIP 36
  157. #define IMPL_IP_TTL 2
  158. #define IMPL_IP_TOS 1
  159. #define IMPL_IP_MULTICAST_TTL 5
  160. #define IMPL_IP_MULTICAST_IF 6
  161. #define IMPL_IP_MULTICAST_LOOP 7
  162. #define IMPL_IP_ADD_MEMBERSHIP 3
  163. #define IMPL_IP_DROP_MEMBERSHIP 4
  164. /* IPPROTO_TCP option names */
  165. #define INTF_TCP_NODELAY 1
  166. #define INTF_TCP_KEEPALIVE 9
  167. #define INTF_TCP_KEEPIDLE 4
  168. #define INTF_TCP_KEEPINTVL 5
  169. #define INTF_TCP_KEEPCNT 6
  170. #define IMPL_TCP_NODELAY 0x01
  171. #define IMPL_TCP_KEEPALIVE 0x02
  172. #define IMPL_TCP_KEEPIDLE 0x03
  173. #define IMPL_TCP_KEEPINTVL 0x04
  174. #define IMPL_TCP_KEEPCNT 0x05
  175. /* IPPROTO_IPV6 option names */
  176. #define INTF_IPV6_V6ONLY 26
  177. #define IMPL_IPV6_V6ONLY 27
  178. #ifdef RT_USING_SAL
  179. static void convert_sockopt(int *level, int *optname)
  180. {
  181. if (*level == INTF_SOL_SOCKET)
  182. {
  183. *level = IMPL_SOL_SOCKET;
  184. switch (*optname)
  185. {
  186. case INTF_SO_REUSEADDR:
  187. *optname = IMPL_SO_REUSEADDR;
  188. break;
  189. case INTF_SO_KEEPALIVE:
  190. *optname = IMPL_SO_KEEPALIVE;
  191. break;
  192. case INTF_SO_BROADCAST:
  193. *optname = IMPL_SO_BROADCAST;
  194. break;
  195. case INTF_SO_ACCEPTCONN:
  196. *optname = IMPL_SO_ACCEPTCONN;
  197. break;
  198. case INTF_SO_DONTROUTE:
  199. *optname = IMPL_SO_DONTROUTE;
  200. break;
  201. case INTF_SO_LINGER:
  202. *optname = IMPL_SO_LINGER;
  203. break;
  204. case INTF_SO_OOBINLINE:
  205. *optname = IMPL_SO_OOBINLINE;
  206. break;
  207. case INTF_SO_REUSEPORT:
  208. *optname = IMPL_SO_REUSEPORT;
  209. break;
  210. case INTF_SO_SNDBUF:
  211. *optname = IMPL_SO_SNDBUF;
  212. break;
  213. case INTF_SO_RCVBUF:
  214. *optname = IMPL_SO_RCVBUF;
  215. break;
  216. case INTF_SO_SNDLOWAT:
  217. *optname = IMPL_SO_SNDLOWAT;
  218. break;
  219. case INTF_SO_RCVLOWAT:
  220. *optname = IMPL_SO_RCVLOWAT;
  221. break;
  222. case INTF_SO_SNDTIMEO:
  223. *optname = IMPL_SO_SNDTIMEO;
  224. break;
  225. case INTF_SO_RCVTIMEO:
  226. *optname = IMPL_SO_RCVTIMEO;
  227. break;
  228. case INTF_SO_ERROR:
  229. *optname = IMPL_SO_ERROR;
  230. break;
  231. case INTF_SO_TYPE:
  232. *optname = IMPL_SO_TYPE;
  233. break;
  234. case INTF_SO_NO_CHECK:
  235. *optname = IMPL_SO_NO_CHECK;
  236. break;
  237. /*
  238. * SO_DONTLINGER (*level = ((int)(~SO_LINGER))),
  239. * SO_USELOOPBACK (*level = 0x0040) and
  240. * SO_CONTIMEO (*level = 0x1009) are not supported for now.
  241. */
  242. default:
  243. *optname = 0;
  244. break;
  245. }
  246. return;
  247. }
  248. if (*level == INTF_IPPROTO_IP)
  249. {
  250. *level = IMPL_IPPROTO_IP;
  251. switch (*optname)
  252. {
  253. case INTF_IP_TTL:
  254. *optname = IMPL_IP_TTL;
  255. break;
  256. case INTF_IP_TOS:
  257. *optname = IMPL_IP_TOS;
  258. break;
  259. case INTF_IP_MULTICAST_TTL:
  260. *optname = IMPL_IP_MULTICAST_TTL;
  261. break;
  262. case INTF_IP_MULTICAST_IF:
  263. *optname = IMPL_IP_MULTICAST_IF;
  264. break;
  265. case INTF_IP_MULTICAST_LOOP:
  266. *optname = IMPL_IP_MULTICAST_LOOP;
  267. break;
  268. case INTF_IP_ADD_MEMBERSHIP:
  269. *optname = IMPL_IP_ADD_MEMBERSHIP;
  270. break;
  271. case INTF_IP_DROP_MEMBERSHIP:
  272. *optname = IMPL_IP_DROP_MEMBERSHIP;
  273. break;
  274. default:
  275. break;
  276. }
  277. }
  278. if (*level == INTF_IPPROTO_TCP)
  279. {
  280. *level = IMPL_IPPROTO_TCP;
  281. switch (*optname)
  282. {
  283. case INTF_TCP_NODELAY:
  284. *optname = IMPL_TCP_NODELAY;
  285. break;
  286. case INTF_TCP_KEEPALIVE:
  287. *optname = IMPL_TCP_KEEPALIVE;
  288. break;
  289. case INTF_TCP_KEEPIDLE:
  290. *optname = IMPL_TCP_KEEPIDLE;
  291. break;
  292. case INTF_TCP_KEEPINTVL:
  293. *optname = IMPL_TCP_KEEPINTVL;
  294. break;
  295. case INTF_TCP_KEEPCNT:
  296. *optname = IMPL_TCP_KEEPCNT;
  297. break;
  298. default:
  299. break;
  300. }
  301. return;
  302. }
  303. if (*level == INTF_IPPROTO_IPV6)
  304. {
  305. *level = IMPL_IPPROTO_IPV6;
  306. switch (*optname)
  307. {
  308. case INTF_IPV6_V6ONLY:
  309. *optname = IMPL_IPV6_V6ONLY;
  310. break;
  311. default:
  312. break;
  313. }
  314. return;
  315. }
  316. }
  317. #endif /* RT_USING_SAL */
  318. #if defined(RT_USING_LWIP) || defined(SAL_USING_UNET)
  319. static void sockaddr_tolwip(const struct musl_sockaddr *std, struct sockaddr *lwip)
  320. {
  321. if (std && lwip)
  322. {
  323. lwip->sa_len = sizeof(*lwip);
  324. lwip->sa_family = (sa_family_t) std->sa_family;
  325. memcpy(lwip->sa_data, std->sa_data, sizeof(lwip->sa_data));
  326. }
  327. }
  328. static void sockaddr_tomusl(const struct sockaddr *lwip, struct musl_sockaddr *std)
  329. {
  330. if (std && lwip)
  331. {
  332. std->sa_family = (uint16_t) lwip->sa_family;
  333. memcpy(std->sa_data, lwip->sa_data, sizeof(std->sa_data));
  334. }
  335. }
  336. #endif
  337. static void _crt_thread_entry(void *parameter)
  338. {
  339. rt_thread_t tid;
  340. rt_size_t user_stack;
  341. tid = rt_thread_self();
  342. user_stack = (rt_size_t)tid->user_stack + tid->user_stack_size;
  343. user_stack &= ~7; //align 8
  344. #ifdef ARCH_MM_MMU
  345. arch_crt_start_umode(parameter, tid->user_entry, (void *)user_stack, tid->stack_addr + tid->stack_size);
  346. #else
  347. set_user_context((void*)user_stack);
  348. arch_start_umode(parameter, tid->user_entry, ((struct rt_lwp *)tid->lwp)->data_entry, (void*)user_stack);
  349. #endif /* ARCH_MM_MMU */
  350. }
  351. /* thread/process */
  352. void sys_exit(int value)
  353. {
  354. rt_base_t level;
  355. rt_thread_t tid, main_thread;
  356. struct rt_lwp *lwp;
  357. LOG_D("thread/process exit.");
  358. tid = rt_thread_self();
  359. lwp = (struct rt_lwp *)tid->lwp;
  360. level = rt_hw_interrupt_disable();
  361. #ifdef ARCH_MM_MMU
  362. if (tid->clear_child_tid)
  363. {
  364. int t = 0;
  365. int *clear_child_tid = tid->clear_child_tid;
  366. tid->clear_child_tid = RT_NULL;
  367. lwp_put_to_user(clear_child_tid, &t, sizeof t);
  368. sys_futex(clear_child_tid, FUTEX_WAKE, 1, RT_NULL, RT_NULL, 0);
  369. }
  370. main_thread = rt_list_entry(lwp->t_grp.prev, struct rt_thread, sibling);
  371. if (main_thread == tid)
  372. {
  373. lwp_terminate(lwp);
  374. lwp_wait_subthread_exit();
  375. lwp->lwp_ret = value;
  376. }
  377. #else
  378. main_thread = rt_list_entry(lwp->t_grp.prev, struct rt_thread, sibling);
  379. if (main_thread == tid)
  380. {
  381. rt_thread_t sub_thread;
  382. rt_list_t *list;
  383. lwp_terminate(lwp);
  384. /* delete all subthread */
  385. while ((list = tid->sibling.prev) != &lwp->t_grp)
  386. {
  387. sub_thread = rt_list_entry(list, struct rt_thread, sibling);
  388. rt_list_remove(&sub_thread->sibling);
  389. rt_thread_delete(sub_thread);
  390. }
  391. lwp->lwp_ret = value;
  392. }
  393. #endif /* ARCH_MM_MMU */
  394. rt_thread_delete(tid);
  395. rt_schedule();
  396. rt_hw_interrupt_enable(level);
  397. return;
  398. }
  399. /* exit group */
  400. void sys_exit_group(int status)
  401. {
  402. return;
  403. }
  404. /* syscall: "read" ret: "ssize_t" args: "int" "void *" "size_t" */
  405. ssize_t sys_read(int fd, void *buf, size_t nbyte)
  406. {
  407. #ifdef ARCH_MM_MMU
  408. void *kmem = RT_NULL;
  409. ssize_t ret = -1;
  410. if (!nbyte)
  411. {
  412. return -EINVAL;
  413. }
  414. if (!lwp_user_accessable((void *)buf, nbyte))
  415. {
  416. return -EFAULT;
  417. }
  418. kmem = kmem_get(nbyte);
  419. if (!kmem)
  420. {
  421. return -ENOMEM;
  422. }
  423. ret = read(fd, kmem, nbyte);
  424. if (ret > 0)
  425. {
  426. lwp_put_to_user(buf, kmem, ret);
  427. }
  428. if (ret < 0)
  429. {
  430. ret = GET_ERRNO();
  431. }
  432. kmem_put(kmem);
  433. return ret;
  434. #else
  435. if (!lwp_user_accessable((void *)buf, nbyte))
  436. {
  437. return -EFAULT;
  438. }
  439. ssize_t ret = read(fd, buf, nbyte);
  440. return (ret < 0 ? GET_ERRNO() : ret);
  441. #endif
  442. }
  443. /* syscall: "write" ret: "ssize_t" args: "int" "const void *" "size_t" */
  444. ssize_t sys_write(int fd, const void *buf, size_t nbyte)
  445. {
  446. #ifdef ARCH_MM_MMU
  447. void *kmem = RT_NULL;
  448. ssize_t ret = -1;
  449. if (!nbyte)
  450. {
  451. return -EINVAL;
  452. }
  453. if (!lwp_user_accessable((void *)buf, nbyte))
  454. {
  455. return -EFAULT;
  456. }
  457. kmem = kmem_get(nbyte);
  458. if (!kmem)
  459. {
  460. return -ENOMEM;
  461. }
  462. lwp_get_from_user(kmem, (void *)buf, nbyte);
  463. ret = write(fd, kmem, nbyte);
  464. if (ret < 0)
  465. {
  466. ret = GET_ERRNO();
  467. }
  468. kmem_put(kmem);
  469. return ret;
  470. #else
  471. if (!lwp_user_accessable((void *)buf, nbyte))
  472. {
  473. return -EFAULT;
  474. }
  475. ssize_t ret = write(fd, buf, nbyte);
  476. return (ret < 0 ? GET_ERRNO() : ret);
  477. #endif
  478. }
  479. /* syscall: "lseek" ret: "off_t" args: "int" "off_t" "int" */
  480. off_t sys_lseek(int fd, off_t offset, int whence)
  481. {
  482. off_t ret = lseek(fd, offset, whence);
  483. return (ret < 0 ? GET_ERRNO() : ret);
  484. }
  485. /* syscall: "open" ret: "int" args: "const char *" "int" "..." */
  486. int sys_open(const char *name, int flag, ...)
  487. {
  488. #ifdef ARCH_MM_MMU
  489. int ret = -1;
  490. rt_size_t len = 0;
  491. char *kname = RT_NULL;
  492. if (!lwp_user_accessable((void *)name, 1))
  493. {
  494. return -EFAULT;
  495. }
  496. len = rt_strlen(name);
  497. if (!len)
  498. {
  499. return -EINVAL;
  500. }
  501. kname = (char *)kmem_get(len + 1);
  502. if (!kname)
  503. {
  504. return -ENOMEM;
  505. }
  506. lwp_get_from_user(kname, (void *)name, len + 1);
  507. ret = open(kname, flag, 0);
  508. if (ret < 0)
  509. {
  510. ret = GET_ERRNO();
  511. }
  512. kmem_put(kname);
  513. return ret;
  514. #else
  515. if (!lwp_user_accessable((void *)name, 1))
  516. {
  517. return -EFAULT;
  518. }
  519. int ret = open(name, flag, 0);
  520. return (ret < 0 ? GET_ERRNO() : ret);
  521. #endif
  522. }
  523. /* syscall: "close" ret: "int" args: "int" */
  524. int sys_close(int fd)
  525. {
  526. int ret = close(fd);
  527. return (ret < 0 ? GET_ERRNO() : ret);
  528. }
  529. /* syscall: "ioctl" ret: "int" args: "int" "u_long" "..." */
  530. int sys_ioctl(int fd, unsigned long cmd, void* data)
  531. {
  532. int ret = ioctl(fd, cmd, data);
  533. return (ret < 0 ? GET_ERRNO() : ret);
  534. }
  535. int sys_fstat(int file, struct stat *buf)
  536. {
  537. #ifdef ARCH_MM_MMU
  538. int ret = -1;
  539. struct stat statbuff = {0};
  540. if (!lwp_user_accessable((void *)buf, sizeof(struct stat)))
  541. {
  542. return -EFAULT;
  543. }
  544. else
  545. {
  546. ret = fstat(file, &statbuff);
  547. if (ret == 0)
  548. {
  549. lwp_put_to_user(buf, &statbuff, sizeof statbuff);
  550. }
  551. else
  552. {
  553. ret = GET_ERRNO();
  554. }
  555. return ret;
  556. }
  557. #else
  558. if (!lwp_user_accessable((void *)buf, sizeof(struct stat)))
  559. {
  560. return -EFAULT;
  561. }
  562. int ret = fstat(file, buf);
  563. return (ret < 0 ? GET_ERRNO() : ret);
  564. #endif
  565. }
  566. /* DFS and lwip definitions */
  567. #define IMPL_POLLIN (0x01)
  568. #define IMPL_POLLOUT (0x02)
  569. #define IMPL_POLLERR (0x04)
  570. #define IMPL_POLLHUP (0x08)
  571. #define IMPL_POLLNVAL (0x10)
  572. /* musl definitions */
  573. #define INTF_POLLIN 0x001
  574. #define INTF_POLLPRI 0x002
  575. #define INTF_POLLOUT 0x004
  576. #define INTF_POLLERR 0x008
  577. #define INTF_POLLHUP 0x010
  578. #define INTF_POLLNVAL 0x020
  579. #define INTF_POLLRDNORM 0x040
  580. #define INTF_POLLRDBAND 0x080
  581. #define INTF_POLLWRNORM 0x100
  582. #define INTF_POLLWRBAND 0x200
  583. #define INTF_POLLMSG 0x400
  584. #define INTF_POLLRDHUP 0x2000
  585. #define INTF_POLLIN_MASK (INTF_POLLIN | INTF_POLLRDNORM | INTF_POLLRDBAND | INTF_POLLPRI)
  586. #define INTF_POLLOUT_MASK (INTF_POLLOUT | INTF_POLLWRNORM | INTF_POLLWRBAND)
  587. static void musl2dfs_events(short *events)
  588. {
  589. short origin_e = *events;
  590. short result_e = 0;
  591. if (origin_e & INTF_POLLIN_MASK)
  592. {
  593. result_e |= IMPL_POLLIN;
  594. }
  595. if (origin_e & INTF_POLLOUT_MASK)
  596. {
  597. result_e |= IMPL_POLLOUT;
  598. }
  599. if (origin_e & INTF_POLLERR)
  600. {
  601. result_e |= IMPL_POLLERR;
  602. }
  603. if (origin_e & INTF_POLLHUP)
  604. {
  605. result_e |= IMPL_POLLHUP;
  606. }
  607. if (origin_e & INTF_POLLNVAL)
  608. {
  609. result_e |= IMPL_POLLNVAL;
  610. }
  611. *events = result_e;
  612. }
  613. static void dfs2musl_events(short *events)
  614. {
  615. short origin_e = *events;
  616. short result_e = 0;
  617. if (origin_e & IMPL_POLLIN)
  618. {
  619. result_e |= INTF_POLLIN_MASK;
  620. }
  621. if (origin_e & IMPL_POLLOUT)
  622. {
  623. result_e |= INTF_POLLOUT_MASK;
  624. }
  625. if (origin_e & IMPL_POLLERR)
  626. {
  627. result_e |= INTF_POLLERR;
  628. }
  629. if (origin_e & IMPL_POLLHUP)
  630. {
  631. result_e |= INTF_POLLHUP;
  632. }
  633. if (origin_e & IMPL_POLLNVAL)
  634. {
  635. result_e |= INTF_POLLNVAL;
  636. }
  637. *events = result_e;
  638. }
  639. int sys_poll(struct pollfd *fds, nfds_t nfds, int timeout)
  640. {
  641. int ret = -1;
  642. int i = 0;
  643. #ifdef ARCH_MM_MMU
  644. struct pollfd *kfds = RT_NULL;
  645. if (!lwp_user_accessable((void *)fds, nfds * sizeof *fds))
  646. {
  647. return -EFAULT;
  648. }
  649. kfds = (struct pollfd *)kmem_get(nfds * sizeof *kfds);
  650. if (!kfds)
  651. {
  652. return -ENOMEM;
  653. }
  654. lwp_get_from_user(kfds, fds, nfds * sizeof *kfds);
  655. for (i = 0; i < nfds; i++)
  656. {
  657. musl2dfs_events(&kfds[i].events);
  658. }
  659. ret = poll(kfds, nfds, timeout);
  660. if (ret > 0)
  661. {
  662. for (i = 0; i < nfds; i++)
  663. {
  664. dfs2musl_events(&kfds->revents);
  665. }
  666. lwp_put_to_user(fds, kfds, nfds * sizeof *kfds);
  667. }
  668. kmem_put(kfds);
  669. return ret;
  670. #else
  671. #ifdef RT_USING_MUSL
  672. for (i = 0; i < nfds; i++)
  673. {
  674. musl2dfs_events(&fds->events);
  675. }
  676. #endif /* RT_USING_MUSL */
  677. if (!lwp_user_accessable((void *)fds, nfds * sizeof *fds))
  678. {
  679. return -EFAULT;
  680. }
  681. ret = poll(fds, nfds, timeout);
  682. #ifdef RT_USING_MUSL
  683. if (ret > 0)
  684. {
  685. for (i = 0; i < nfds; i++)
  686. {
  687. dfs2musl_events(&fds->revents);
  688. }
  689. }
  690. #endif /* RT_USING_MUSL */
  691. return ret;
  692. #endif /* ARCH_MM_MMU */
  693. }
  694. int sys_select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout)
  695. {
  696. #ifdef ARCH_MM_MMU
  697. int ret = -1;
  698. fd_set *kreadfds = RT_NULL, *kwritefds = RT_NULL, *kexceptfds = RT_NULL;
  699. if (readfds)
  700. {
  701. if (!lwp_user_accessable((void *)readfds, sizeof *readfds))
  702. {
  703. SET_ERRNO(EFAULT);
  704. goto quit;
  705. }
  706. kreadfds = (fd_set *)kmem_get(sizeof *kreadfds);
  707. if (!kreadfds)
  708. {
  709. SET_ERRNO(ENOMEM);
  710. goto quit;
  711. }
  712. lwp_get_from_user(kreadfds, readfds, sizeof *kreadfds);
  713. }
  714. if (writefds)
  715. {
  716. if (!lwp_user_accessable((void *)writefds, sizeof *writefds))
  717. {
  718. SET_ERRNO(EFAULT);
  719. goto quit;
  720. }
  721. kwritefds = (fd_set *)kmem_get(sizeof *kwritefds);
  722. if (!kwritefds)
  723. {
  724. SET_ERRNO(ENOMEM);
  725. goto quit;
  726. }
  727. lwp_get_from_user(kwritefds, writefds, sizeof *kwritefds);
  728. }
  729. if (exceptfds)
  730. {
  731. if (!lwp_user_accessable((void *)exceptfds, sizeof *exceptfds))
  732. {
  733. SET_ERRNO(EFAULT);
  734. goto quit;
  735. }
  736. kexceptfds = (fd_set *)kmem_get(sizeof *kexceptfds);
  737. if (!kexceptfds)
  738. {
  739. SET_ERRNO(EINVAL);
  740. goto quit;
  741. }
  742. lwp_get_from_user(kexceptfds, exceptfds, sizeof *kexceptfds);
  743. }
  744. ret = select(nfds, kreadfds, kwritefds, kexceptfds, timeout);
  745. if (kreadfds)
  746. {
  747. lwp_put_to_user(readfds, kreadfds, sizeof *kreadfds);
  748. }
  749. if (kwritefds)
  750. {
  751. lwp_put_to_user(writefds, kwritefds, sizeof *kwritefds);
  752. }
  753. if (kexceptfds)
  754. {
  755. lwp_put_to_user(exceptfds, kexceptfds, sizeof *kexceptfds);
  756. }
  757. quit:
  758. if (ret < 0)
  759. {
  760. ret = GET_ERRNO();
  761. }
  762. if (kreadfds)
  763. {
  764. kmem_put(kreadfds);
  765. }
  766. if (kwritefds)
  767. {
  768. kmem_put(kwritefds);
  769. }
  770. if (kexceptfds)
  771. {
  772. kmem_put(kexceptfds);
  773. }
  774. return ret;
  775. #else
  776. int ret;
  777. if (!lwp_user_accessable((void *)readfds, sizeof *readfds))
  778. {
  779. return -EFAULT;
  780. }
  781. if (!lwp_user_accessable((void *)writefds, sizeof *writefds))
  782. {
  783. return -EFAULT;
  784. }
  785. if (!lwp_user_accessable((void *)exceptfds, sizeof *exceptfds))
  786. {
  787. return -EFAULT;
  788. }
  789. ret = select(nfds, readfds, writefds, exceptfds, timeout);
  790. return (ret < 0 ? GET_ERRNO() : ret);
  791. #endif
  792. }
  793. int sys_unlink(const char *pathname)
  794. {
  795. #ifdef ARCH_MM_MMU
  796. int ret = -1;
  797. rt_size_t len = 0;
  798. char *kname = RT_NULL;
  799. int a_err = 0;
  800. lwp_user_strlen(pathname, &a_err);
  801. if (a_err)
  802. {
  803. return -EFAULT;
  804. }
  805. len = rt_strlen(pathname);
  806. if (!len)
  807. {
  808. return -EINVAL;
  809. }
  810. kname = (char *)kmem_get(len + 1);
  811. if (!kname)
  812. {
  813. return -ENOMEM;
  814. }
  815. lwp_get_from_user(kname, (void *)pathname, len + 1);
  816. ret = unlink(kname);
  817. if (ret < 0)
  818. {
  819. ret = GET_ERRNO();
  820. }
  821. kmem_put(kname);
  822. return ret;
  823. #else
  824. int ret = 0;
  825. ret = unlink(pathname);
  826. return (ret < 0 ? GET_ERRNO() : ret);
  827. #endif
  828. }
  829. /* syscall: "nanosleep" ret: "int" args: "const struct timespec *" "struct timespec *" */
  830. int sys_nanosleep(const struct timespec *rqtp, struct timespec *rmtp)
  831. {
  832. int ret = 0;
  833. dbg_log(DBG_LOG, "sys_nanosleep\n");
  834. if (!lwp_user_accessable((void *)rqtp, sizeof *rqtp))
  835. return -EFAULT;
  836. #ifdef ARCH_MM_MMU
  837. struct timespec rqtp_k;
  838. struct timespec rmtp_k;
  839. lwp_get_from_user(&rqtp_k, (void *)rqtp, sizeof rqtp_k);
  840. ret = nanosleep(&rqtp_k, &rmtp_k);
  841. if ((ret != -1 || rt_get_errno() == EINTR) && rmtp && lwp_user_accessable((void *)rmtp, sizeof *rmtp))
  842. {
  843. lwp_put_to_user(rmtp, (void *)&rmtp_k, sizeof rmtp_k);
  844. if(ret != 0)
  845. return -EINTR;
  846. }
  847. #else
  848. if (rmtp)
  849. {
  850. if (!lwp_user_accessable((void *)rmtp, sizeof *rmtp))
  851. return -EFAULT;
  852. ret = nanosleep(rqtp, rmtp);
  853. }
  854. #endif
  855. return (ret < 0 ? GET_ERRNO() : ret);
  856. }
  857. /* syscall: "gettimeofday" ret: "int" args: "struct timeval *" "struct timezone *" */
  858. int sys_gettimeofday(struct timeval *tp, struct timezone *tzp)
  859. {
  860. #ifdef ARCH_MM_MMU
  861. struct timeval t_k;
  862. if (tp)
  863. {
  864. if (!lwp_user_accessable((void *)tp, sizeof *tp))
  865. {
  866. return -EFAULT;
  867. }
  868. t_k.tv_sec = rt_tick_get() / RT_TICK_PER_SECOND;
  869. t_k.tv_usec = (rt_tick_get() % RT_TICK_PER_SECOND) * (1000000 / RT_TICK_PER_SECOND);
  870. lwp_put_to_user(tp, (void *)&t_k, sizeof t_k);
  871. }
  872. #else
  873. if (tp)
  874. {
  875. if (!lwp_user_accessable((void *)tp, sizeof *tp))
  876. {
  877. return -EFAULT;
  878. }
  879. tp->tv_sec = rt_tick_get() / RT_TICK_PER_SECOND;
  880. tp->tv_usec = (rt_tick_get() % RT_TICK_PER_SECOND) * (1000000 / RT_TICK_PER_SECOND);
  881. }
  882. #endif
  883. return 0;
  884. }
  885. int sys_settimeofday(const struct timeval *tv, const struct timezone *tzp)
  886. {
  887. return 0;
  888. }
  889. int sys_exec(char *filename, int argc, char **argv, char **envp)
  890. {
  891. return lwp_execve(filename, 0, argc, argv, envp);
  892. }
  893. int sys_kill(int pid, int sig)
  894. {
  895. int ret = 0;
  896. ret = lwp_kill(pid, sig);
  897. return (ret < 0 ? GET_ERRNO() : ret);
  898. }
  899. int sys_getpid(void)
  900. {
  901. return lwp_getpid();
  902. }
  903. /* syscall: "getpriority" ret: "int" args: "int" "id_t" */
  904. int sys_getpriority(int which, id_t who)
  905. {
  906. if (which == PRIO_PROCESS)
  907. {
  908. rt_thread_t tid;
  909. tid = rt_thread_self();
  910. if (who == (id_t)(rt_size_t)tid || who == 0xff)
  911. {
  912. return tid->current_priority;
  913. }
  914. }
  915. return 0xff;
  916. }
  917. /* syscall: "setpriority" ret: "int" args: "int" "id_t" "int" */
  918. int sys_setpriority(int which, id_t who, int prio)
  919. {
  920. if (which == PRIO_PROCESS)
  921. {
  922. rt_thread_t tid;
  923. tid = rt_thread_self();
  924. if ((who == (id_t)(rt_size_t)tid || who == 0xff) && (prio >= 0 && prio < RT_THREAD_PRIORITY_MAX))
  925. {
  926. rt_thread_control(tid, RT_THREAD_CTRL_CHANGE_PRIORITY, &prio);
  927. return 0;
  928. }
  929. }
  930. return -1;
  931. }
  932. rt_sem_t sys_sem_create(const char *name, rt_uint32_t value, rt_uint8_t flag)
  933. {
  934. rt_sem_t sem = rt_sem_create(name, value, flag);
  935. if (lwp_user_object_add(lwp_self(), (rt_object_t)sem) != 0)
  936. {
  937. rt_sem_delete(sem);
  938. sem = NULL;
  939. }
  940. return sem;
  941. }
  942. rt_err_t sys_sem_delete(rt_sem_t sem)
  943. {
  944. return lwp_user_object_delete(lwp_self(), (rt_object_t)sem);
  945. }
  946. rt_err_t sys_sem_take(rt_sem_t sem, rt_int32_t time)
  947. {
  948. return rt_sem_take_interruptible(sem, time);
  949. }
  950. rt_err_t sys_sem_release(rt_sem_t sem)
  951. {
  952. return rt_sem_release(sem);
  953. }
  954. rt_mutex_t sys_mutex_create(const char *name, rt_uint8_t flag)
  955. {
  956. rt_mutex_t mutex = rt_mutex_create(name, flag);
  957. if (lwp_user_object_add(lwp_self(), (rt_object_t)mutex) != 0)
  958. {
  959. rt_mutex_delete(mutex);
  960. mutex = NULL;
  961. }
  962. return mutex;
  963. }
  964. rt_err_t sys_mutex_delete(rt_mutex_t mutex)
  965. {
  966. return lwp_user_object_delete(lwp_self(), (rt_object_t)mutex);
  967. }
  968. rt_err_t sys_mutex_take(rt_mutex_t mutex, rt_int32_t time)
  969. {
  970. return rt_mutex_take_interruptible(mutex, time);
  971. }
  972. rt_err_t sys_mutex_release(rt_mutex_t mutex)
  973. {
  974. return rt_mutex_release(mutex);
  975. }
  976. #ifdef ARCH_MM_MMU
  977. /* memory allocation */
  978. rt_base_t sys_brk(void *addr)
  979. {
  980. return lwp_brk(addr);
  981. }
  982. void *sys_mmap2(void *addr, size_t length, int prot,
  983. int flags, int fd, off_t pgoffset)
  984. {
  985. return lwp_mmap2(addr, length, prot, flags, fd, pgoffset);
  986. }
  987. int sys_munmap(void *addr, size_t length)
  988. {
  989. return lwp_munmap(addr);
  990. }
  991. void *sys_mremap(void *old_address, size_t old_size,
  992. size_t new_size, int flags, void *new_address)
  993. {
  994. return (void *)-1;
  995. }
  996. int sys_madvise(void *addr, size_t len, int behav)
  997. {
  998. return -ENOSYS;
  999. }
  1000. #endif
  1001. rt_event_t sys_event_create(const char *name, rt_uint8_t flag)
  1002. {
  1003. rt_event_t event = rt_event_create(name, flag);
  1004. if (lwp_user_object_add(lwp_self(), (rt_object_t)event) != 0)
  1005. {
  1006. rt_event_delete(event);
  1007. event = NULL;
  1008. }
  1009. return event;
  1010. }
  1011. rt_err_t sys_event_delete(rt_event_t event)
  1012. {
  1013. return lwp_user_object_delete(lwp_self(), (rt_object_t)event);
  1014. }
  1015. rt_err_t sys_event_send(rt_event_t event, rt_uint32_t set)
  1016. {
  1017. return rt_event_send(event, set);
  1018. }
  1019. rt_err_t sys_event_recv(rt_event_t event,
  1020. rt_uint32_t set,
  1021. rt_uint8_t opt,
  1022. rt_int32_t timeout,
  1023. rt_uint32_t *recved)
  1024. {
  1025. if ((recved != NULL) && !lwp_user_accessable((void *)recved, sizeof(rt_uint32_t *)))
  1026. {
  1027. return -EFAULT;
  1028. }
  1029. return rt_event_recv(event, set, opt, timeout, recved);
  1030. }
  1031. rt_mailbox_t sys_mb_create(const char *name, rt_size_t size, rt_uint8_t flag)
  1032. {
  1033. rt_mailbox_t mb = rt_mb_create(name, size, flag);
  1034. if (lwp_user_object_add(lwp_self(), (rt_object_t)mb) != 0)
  1035. {
  1036. rt_mb_delete(mb);
  1037. mb = NULL;
  1038. }
  1039. return mb;
  1040. }
  1041. rt_err_t sys_mb_delete(rt_mailbox_t mb)
  1042. {
  1043. return lwp_user_object_delete(lwp_self(), (rt_object_t)mb);
  1044. }
  1045. rt_err_t sys_mb_send(rt_mailbox_t mb, rt_ubase_t value)
  1046. {
  1047. return rt_mb_send(mb, value);
  1048. }
  1049. rt_err_t sys_mb_send_wait(rt_mailbox_t mb,
  1050. rt_ubase_t value,
  1051. rt_int32_t timeout)
  1052. {
  1053. return rt_mb_send_wait(mb, value, timeout);
  1054. }
  1055. rt_err_t sys_mb_recv(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout)
  1056. {
  1057. if (!lwp_user_accessable((void *)value, sizeof(rt_ubase_t *)))
  1058. {
  1059. return -EFAULT;
  1060. }
  1061. return rt_mb_recv(mb, (rt_ubase_t *)value, timeout);
  1062. }
  1063. rt_mq_t sys_mq_create(const char *name,
  1064. rt_size_t msg_size,
  1065. rt_size_t max_msgs,
  1066. rt_uint8_t flag)
  1067. {
  1068. rt_mq_t mq = rt_mq_create(name, msg_size, max_msgs, flag);
  1069. if (lwp_user_object_add(lwp_self(), (rt_object_t)mq) != 0)
  1070. {
  1071. rt_mq_delete(mq);
  1072. mq = NULL;
  1073. }
  1074. return mq;
  1075. }
  1076. rt_err_t sys_mq_delete(rt_mq_t mq)
  1077. {
  1078. return lwp_user_object_delete(lwp_self(), (rt_object_t)mq);
  1079. }
  1080. rt_err_t sys_mq_send(rt_mq_t mq, void *buffer, rt_size_t size)
  1081. {
  1082. if (!lwp_user_accessable((void *)buffer, size))
  1083. {
  1084. return -EFAULT;
  1085. }
  1086. return rt_mq_send(mq, buffer, size);
  1087. }
  1088. rt_err_t sys_mq_urgent(rt_mq_t mq, void *buffer, rt_size_t size)
  1089. {
  1090. if (!lwp_user_accessable((void *)buffer, size))
  1091. {
  1092. return -EFAULT;
  1093. }
  1094. return rt_mq_urgent(mq, buffer, size);
  1095. }
  1096. rt_err_t sys_mq_recv(rt_mq_t mq,
  1097. void *buffer,
  1098. rt_size_t size,
  1099. rt_int32_t timeout)
  1100. {
  1101. if (!lwp_user_accessable((void *)buffer, size))
  1102. {
  1103. return -EFAULT;
  1104. }
  1105. return rt_mq_recv(mq, buffer, size, timeout);
  1106. }
  1107. static void timer_timeout_callback(void *parameter)
  1108. {
  1109. rt_sem_t sem = (rt_sem_t)parameter;
  1110. rt_sem_release(sem);
  1111. }
  1112. rt_timer_t sys_rt_timer_create(const char *name,
  1113. void *data,
  1114. rt_tick_t time,
  1115. rt_uint8_t flag)
  1116. {
  1117. rt_timer_t timer = rt_timer_create(name, timer_timeout_callback, (void *)data, time, flag);
  1118. if (lwp_user_object_add(lwp_self(), (rt_object_t)timer) != 0)
  1119. {
  1120. rt_timer_delete(timer);
  1121. timer = NULL;
  1122. }
  1123. return timer;
  1124. }
  1125. rt_err_t sys_rt_timer_delete(rt_timer_t timer)
  1126. {
  1127. return lwp_user_object_delete(lwp_self(), (rt_object_t)timer);
  1128. }
  1129. rt_err_t sys_rt_timer_start(rt_timer_t timer)
  1130. {
  1131. return rt_timer_start(timer);
  1132. }
  1133. rt_err_t sys_rt_timer_stop(rt_timer_t timer)
  1134. {
  1135. return rt_timer_stop(timer);
  1136. }
  1137. rt_err_t sys_rt_timer_control(rt_timer_t timer, int cmd, void *arg)
  1138. {
  1139. return rt_timer_control(timer, cmd, arg);
  1140. }
  1141. rt_err_t sys_timer_create(clockid_t clockid, struct sigevent *restrict sevp, timer_t *restrict timerid)
  1142. {
  1143. int ret = 0;
  1144. #ifdef ARCH_MM_MMU
  1145. struct sigevent sevp_k;
  1146. timer_t timerid_k;
  1147. if (sevp == NULL)
  1148. {
  1149. sevp_k.sigev_notify = SIGEV_SIGNAL;
  1150. sevp_k.sigev_signo = SIGALRM;
  1151. sevp = &sevp_k;
  1152. }
  1153. else
  1154. lwp_get_from_user(&sevp_k, (void *)sevp, sizeof sevp_k);
  1155. lwp_get_from_user(&timerid_k, (void *)timerid, sizeof timerid_k);
  1156. ret = timer_create(clockid, &sevp_k, &timerid_k);
  1157. if (ret != -RT_ERROR){
  1158. lwp_put_to_user(sevp, (void *)&sevp_k, sizeof sevp_k);
  1159. lwp_put_to_user(timerid, (void *)&timerid_k, sizeof timerid_k);
  1160. }
  1161. #else
  1162. ret = timer_create(clockid, sevp, timerid);
  1163. #endif
  1164. return (ret < 0 ? GET_ERRNO() : ret);
  1165. }
  1166. rt_err_t sys_timer_delete(timer_t timerid)
  1167. {
  1168. int ret = timer_delete(timerid);
  1169. return (ret < 0 ? GET_ERRNO() : ret);
  1170. }
  1171. rt_err_t sys_timer_settime(timer_t timerid, int flags,
  1172. const struct itimerspec *restrict new_value,
  1173. struct itimerspec *restrict old_value)
  1174. {
  1175. int ret = 0;
  1176. #ifdef ARCH_MM_MMU
  1177. struct itimerspec new_value_k;
  1178. struct itimerspec old_value_k;
  1179. lwp_get_from_user(&new_value_k, (void *)new_value, sizeof new_value_k);
  1180. lwp_get_from_user(&old_value_k, (void *)timerid, sizeof old_value_k);
  1181. ret = timer_settime(timerid, flags, &new_value_k, &old_value_k);
  1182. lwp_put_to_user(old_value, (void *)&old_value_k, sizeof old_value_k);
  1183. #else
  1184. ret = timer_settime(timerid, flags, new_value, old_value);
  1185. #endif
  1186. return (ret < 0 ? GET_ERRNO() : ret);
  1187. }
  1188. rt_err_t sys_timer_gettime(timer_t timerid, struct itimerspec *curr_value)
  1189. {
  1190. int ret = 0;
  1191. #ifdef ARCH_MM_MMU
  1192. struct itimerspec curr_value_k;
  1193. lwp_get_from_user(&curr_value_k, (void *)curr_value, sizeof curr_value_k);
  1194. ret = timer_gettime(timerid, &curr_value_k);
  1195. lwp_put_to_user(curr_value, (void *)&curr_value_k, sizeof curr_value_k);
  1196. #else
  1197. ret = timer_gettime(timerid, curr_value);
  1198. #endif
  1199. return (ret < 0 ? GET_ERRNO() : ret);
  1200. }
  1201. rt_err_t sys_timer_getoverrun(timer_t timerid)
  1202. {
  1203. int ret = 0;
  1204. ret = timer_getoverrun(timerid);
  1205. return (ret < 0 ? GET_ERRNO() : ret);
  1206. }
  1207. rt_thread_t sys_thread_create(void *arg[])
  1208. {
  1209. rt_base_t level = 0;
  1210. void *user_stack = 0;
  1211. struct rt_lwp *lwp = 0;
  1212. rt_thread_t thread = RT_NULL;
  1213. int tid = 0;
  1214. lwp = rt_thread_self()->lwp;
  1215. lwp_ref_inc(lwp);
  1216. #ifdef ARCH_MM_MMU
  1217. user_stack = lwp_map_user(lwp, 0, (size_t)arg[3], 0);
  1218. if (!user_stack)
  1219. {
  1220. goto fail;
  1221. }
  1222. if ((tid = lwp_tid_get()) == 0)
  1223. {
  1224. goto fail;
  1225. }
  1226. thread = rt_thread_create((const char *)arg[0],
  1227. _crt_thread_entry,
  1228. (void *)arg[2],
  1229. ALLOC_KERNEL_STACK_SIZE,
  1230. (rt_uint8_t)(size_t)arg[4],
  1231. (rt_uint32_t)(rt_size_t)arg[5]);
  1232. if (!thread)
  1233. {
  1234. goto fail;
  1235. }
  1236. #ifdef RT_USING_SMP
  1237. thread->bind_cpu = lwp->bind_cpu;
  1238. #endif
  1239. thread->cleanup = lwp_cleanup;
  1240. thread->user_entry = (void (*)(void *))arg[1];
  1241. thread->user_stack = (void *)user_stack;
  1242. thread->user_stack_size = (rt_size_t)arg[3];
  1243. #else
  1244. rt_uint32_t kstack_size = (rt_uint32_t)arg[7];
  1245. if (kstack_size < ALLOC_KERNEL_STACK_SIZE_MIN)
  1246. {
  1247. /* When kstack size is 0, the default size of the kernel stack is used */
  1248. kstack_size = kstack_size ? ALLOC_KERNEL_STACK_SIZE_MIN : ALLOC_KERNEL_STACK_SIZE;
  1249. }
  1250. else if (kstack_size > ALLOC_KERNEL_STACK_SIZE_MAX)
  1251. {
  1252. kstack_size = ALLOC_KERNEL_STACK_SIZE_MAX;
  1253. }
  1254. user_stack = (void *)arg[3];
  1255. if ((!user_stack) || ((rt_uint32_t)arg[6] == RT_NULL))
  1256. {
  1257. goto fail;
  1258. }
  1259. if ((tid = lwp_tid_get()) == 0)
  1260. {
  1261. goto fail;
  1262. }
  1263. thread = rt_thread_create((const char *)arg[0], _crt_thread_entry, (void *)arg[2], kstack_size, (rt_uint8_t)(size_t)arg[5], (rt_uint32_t)arg[6]);
  1264. if (!thread)
  1265. {
  1266. goto fail;
  1267. }
  1268. thread->cleanup = lwp_cleanup;
  1269. thread->user_entry = (void (*)(void *))arg[1];
  1270. thread->user_stack = (void *)user_stack;
  1271. thread->user_stack_size = (uint32_t)arg[4];
  1272. rt_memset(thread->user_stack, '#', thread->user_stack_size);
  1273. #endif /* ARCH_MM_MMU */
  1274. thread->lwp = (void*)lwp;
  1275. thread->tid = tid;
  1276. lwp_tid_set_thread(tid, thread);
  1277. if (lwp->debug)
  1278. {
  1279. rt_thread_control(thread, RT_THREAD_CTRL_BIND_CPU, (void*)0);
  1280. }
  1281. level = rt_hw_interrupt_disable();
  1282. rt_list_insert_after(&lwp->t_grp, &thread->sibling);
  1283. rt_hw_interrupt_enable(level);
  1284. return thread;
  1285. fail:
  1286. lwp_tid_put(tid);
  1287. if (lwp)
  1288. {
  1289. lwp_ref_dec(lwp);
  1290. }
  1291. return RT_NULL;
  1292. }
  1293. #ifdef ARCH_MM_MMU
  1294. #define CLONE_VM 0x00000100
  1295. #define CLONE_FS 0x00000200
  1296. #define CLONE_FILES 0x00000400
  1297. #define CLONE_SIGHAND 0x00000800
  1298. #define CLONE_PTRACE 0x00002000
  1299. #define CLONE_VFORK 0x00004000
  1300. #define CLONE_PARENT 0x00008000
  1301. #define CLONE_THREAD 0x00010000
  1302. #define CLONE_NEWNS 0x00020000
  1303. #define CLONE_SYSVSEM 0x00040000
  1304. #define CLONE_SETTLS 0x00080000
  1305. #define CLONE_PARENT_SETTID 0x00100000
  1306. #define CLONE_CHILD_CLEARTID 0x00200000
  1307. #define CLONE_DETACHED 0x00400000
  1308. #define CLONE_UNTRACED 0x00800000
  1309. #define CLONE_CHILD_SETTID 0x01000000
  1310. #define CLONE_NEWCGROUP 0x02000000
  1311. #define CLONE_NEWUTS 0x04000000
  1312. #define CLONE_NEWIPC 0x08000000
  1313. #define CLONE_NEWUSER 0x10000000
  1314. #define CLONE_NEWPID 0x20000000
  1315. #define CLONE_NEWNET 0x40000000
  1316. #define CLONE_IO 0x80000000
  1317. /* arg[] -> flags
  1318. * stack
  1319. * new_tid
  1320. * tls
  1321. * set_clear_tid_address
  1322. * quit_func
  1323. * start_args
  1324. * */
  1325. #define SYS_CLONE_ARGS_NR 7
  1326. long _sys_clone(void *arg[])
  1327. {
  1328. rt_base_t level = 0;
  1329. struct rt_lwp *lwp = 0;
  1330. rt_thread_t thread = RT_NULL;
  1331. rt_thread_t self = RT_NULL;
  1332. int tid = 0;
  1333. unsigned long flags = 0;
  1334. void *user_stack = RT_NULL;
  1335. int *new_tid = RT_NULL;
  1336. void *tls = RT_NULL;
  1337. /*
  1338. musl call flags (CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND
  1339. | CLONE_THREAD | CLONE_SYSVSEM | CLONE_SETTLS
  1340. | CLONE_PARENT_SETTID | CLONE_CHILD_CLEARTID | CLONE_DETACHED);
  1341. */
  1342. /* check args */
  1343. if (!lwp_user_accessable(arg, sizeof(void *[SYS_CLONE_ARGS_NR])))
  1344. {
  1345. return -EFAULT;
  1346. }
  1347. flags = (unsigned long)(size_t)arg[0];
  1348. if ((flags & (CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_THREAD | CLONE_SYSVSEM))
  1349. != (CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_THREAD | CLONE_SYSVSEM))
  1350. {
  1351. return -EINVAL;
  1352. }
  1353. user_stack = arg[1];
  1354. new_tid = (int *)arg[2];
  1355. tls = (void *)arg[3];
  1356. if ((flags & CLONE_PARENT_SETTID) == CLONE_PARENT_SETTID)
  1357. {
  1358. if (!lwp_user_accessable(new_tid, sizeof(int)))
  1359. {
  1360. return -EFAULT;
  1361. }
  1362. }
  1363. self = rt_thread_self();
  1364. lwp = self->lwp;
  1365. lwp_ref_inc(lwp);
  1366. if (!user_stack)
  1367. {
  1368. SET_ERRNO(EINVAL);
  1369. goto fail;
  1370. }
  1371. if ((tid = lwp_tid_get()) == 0)
  1372. {
  1373. SET_ERRNO(ENOMEM);
  1374. goto fail;
  1375. }
  1376. thread = rt_thread_create(self->name,
  1377. RT_NULL,
  1378. RT_NULL,
  1379. self->stack_size,
  1380. self->init_priority,
  1381. self->init_tick);
  1382. if (!thread)
  1383. {
  1384. goto fail;
  1385. }
  1386. #ifdef RT_USING_SMP
  1387. thread->bind_cpu = lwp->bind_cpu;
  1388. #endif
  1389. thread->cleanup = lwp_cleanup;
  1390. thread->user_entry = RT_NULL;
  1391. thread->user_stack = RT_NULL;
  1392. thread->user_stack_size = 0;
  1393. thread->lwp = (void *)lwp;
  1394. thread->tid = tid;
  1395. if ((flags & CLONE_SETTLS) == CLONE_SETTLS)
  1396. {
  1397. thread->thread_idr = tls;
  1398. }
  1399. if ((flags & CLONE_PARENT_SETTID) == CLONE_PARENT_SETTID)
  1400. {
  1401. *new_tid = (int)(tid);
  1402. }
  1403. if ((flags & CLONE_CHILD_CLEARTID) == CLONE_CHILD_CLEARTID)
  1404. {
  1405. thread->clear_child_tid = (int *)arg[4];
  1406. }
  1407. if (lwp->debug)
  1408. {
  1409. rt_thread_control(thread, RT_THREAD_CTRL_BIND_CPU, (void*)0);
  1410. }
  1411. level = rt_hw_interrupt_disable();
  1412. rt_list_insert_after(&lwp->t_grp, &thread->sibling);
  1413. rt_hw_interrupt_enable(level);
  1414. /* copy origin stack */
  1415. rt_memcpy(thread->stack_addr, self->stack_addr, thread->stack_size);
  1416. lwp_tid_set_thread(tid, thread);
  1417. arch_set_thread_context(arch_clone_exit,
  1418. (void *)((char *)thread->stack_addr + thread->stack_size),
  1419. user_stack, &thread->sp);
  1420. /* new thread never reach there */
  1421. rt_thread_startup(thread);
  1422. return (long)tid;
  1423. fail:
  1424. lwp_tid_put(tid);
  1425. if (lwp)
  1426. {
  1427. lwp_ref_dec(lwp);
  1428. }
  1429. return GET_ERRNO();
  1430. }
  1431. rt_weak long sys_clone(void *arg[])
  1432. {
  1433. return _sys_clone(arg);
  1434. }
  1435. int lwp_dup_user(rt_varea_t varea, void *arg);
  1436. static int _copy_process(struct rt_lwp *dest_lwp, struct rt_lwp *src_lwp)
  1437. {
  1438. int err;
  1439. dest_lwp->lwp_obj->source = src_lwp->aspace;
  1440. err = rt_aspace_traversal(src_lwp->aspace, lwp_dup_user, dest_lwp);
  1441. dest_lwp->lwp_obj->source = NULL;
  1442. return err;
  1443. }
  1444. static void lwp_struct_copy(struct rt_lwp *dst, struct rt_lwp *src)
  1445. {
  1446. #ifdef ARCH_MM_MMU
  1447. dst->end_heap = src->end_heap;
  1448. #endif
  1449. dst->lwp_type = src->lwp_type;
  1450. dst->text_entry = src->text_entry;
  1451. dst->text_size = src->text_size;
  1452. dst->data_entry = src->data_entry;
  1453. dst->data_size = src->data_size;
  1454. dst->args = src->args;
  1455. dst->leader = 0;
  1456. dst->session = src->session;
  1457. dst->tty_old_pgrp = 0;
  1458. dst->__pgrp = src->__pgrp;
  1459. dst->tty = src->tty;
  1460. rt_memcpy(dst->cmd, src->cmd, RT_NAME_MAX);
  1461. dst->sa_flags = src->sa_flags;
  1462. dst->signal_mask = src->signal_mask;
  1463. rt_memcpy(dst->signal_handler, src->signal_handler, sizeof dst->signal_handler);
  1464. }
  1465. static int lwp_copy_files(struct rt_lwp *dst, struct rt_lwp *src)
  1466. {
  1467. struct dfs_fdtable *dst_fdt;
  1468. struct dfs_fdtable *src_fdt;
  1469. src_fdt = &src->fdt;
  1470. dst_fdt = &dst->fdt;
  1471. /* init fds */
  1472. dst_fdt->fds = rt_calloc(src_fdt->maxfd, sizeof(void *));
  1473. if (dst_fdt->fds)
  1474. {
  1475. struct dfs_fd *d_s;
  1476. int i;
  1477. dst_fdt->maxfd = src_fdt->maxfd;
  1478. dfs_fd_lock();
  1479. /* dup files */
  1480. for (i = 0; i < src_fdt->maxfd; i++)
  1481. {
  1482. d_s = fdt_fd_get(src_fdt, i);
  1483. if (d_s)
  1484. {
  1485. dst_fdt->fds[i] = d_s;
  1486. d_s->ref_count++;
  1487. }
  1488. }
  1489. dfs_fd_unlock();
  1490. return 0;
  1491. }
  1492. return -RT_ERROR;
  1493. }
  1494. int _sys_fork(void)
  1495. {
  1496. rt_base_t level;
  1497. int tid = 0;
  1498. rt_err_t falival = 0;
  1499. struct rt_lwp *lwp = RT_NULL;
  1500. struct rt_lwp *self_lwp = RT_NULL;
  1501. rt_thread_t thread = RT_NULL;
  1502. rt_thread_t self_thread = RT_NULL;
  1503. void *user_stack = RT_NULL;
  1504. /* new lwp */
  1505. lwp = lwp_new();
  1506. if (!lwp)
  1507. {
  1508. SET_ERRNO(ENOMEM);
  1509. goto fail;
  1510. }
  1511. /* new tid */
  1512. if ((tid = lwp_tid_get()) == 0)
  1513. {
  1514. SET_ERRNO(ENOMEM);
  1515. goto fail;
  1516. }
  1517. /* user space init */
  1518. if (lwp_user_space_init(lwp, 1) != 0)
  1519. {
  1520. SET_ERRNO(ENOMEM);
  1521. goto fail;
  1522. }
  1523. self_lwp = lwp_self();
  1524. /* copy process */
  1525. if (_copy_process(lwp, self_lwp) != 0)
  1526. {
  1527. SET_ERRNO(ENOMEM);
  1528. goto fail;
  1529. }
  1530. /* copy lwp struct data */
  1531. lwp_struct_copy(lwp, self_lwp);
  1532. /* copy files */
  1533. if (lwp_copy_files(lwp, self_lwp) != 0)
  1534. {
  1535. SET_ERRNO(ENOMEM);
  1536. goto fail;
  1537. }
  1538. /* create thread */
  1539. self_thread = rt_thread_self();
  1540. thread = rt_thread_create(self_thread->name,
  1541. RT_NULL,
  1542. RT_NULL,
  1543. self_thread->stack_size,
  1544. self_thread->init_priority,
  1545. self_thread->init_tick);
  1546. if (!thread)
  1547. {
  1548. SET_ERRNO(ENOMEM);
  1549. goto fail;
  1550. }
  1551. thread->cleanup = self_thread->cleanup;
  1552. thread->user_entry = self_thread->user_entry;
  1553. thread->user_stack = self_thread->user_stack;
  1554. thread->user_stack_size = self_thread->user_stack_size;
  1555. thread->signal_mask = self_thread->signal_mask;
  1556. thread->thread_idr = self_thread->thread_idr;
  1557. thread->lwp = (void *)lwp;
  1558. thread->tid = tid;
  1559. level = rt_hw_interrupt_disable();
  1560. /* add thread to lwp process */
  1561. rt_list_insert_after(&lwp->t_grp, &thread->sibling);
  1562. /* lwp add to children link */
  1563. lwp->sibling = self_lwp->first_child;
  1564. self_lwp->first_child = lwp;
  1565. lwp->parent = self_lwp;
  1566. rt_hw_interrupt_enable(level);
  1567. /* copy origin stack */
  1568. rt_memcpy(thread->stack_addr, self_thread->stack_addr, self_thread->stack_size);
  1569. lwp_tid_set_thread(tid, thread);
  1570. /* duplicate user objects */
  1571. lwp_user_object_dup(lwp, self_lwp);
  1572. level = rt_hw_interrupt_disable();
  1573. user_stack = arch_get_user_sp();
  1574. rt_hw_interrupt_enable(level);
  1575. arch_set_thread_context(arch_fork_exit,
  1576. (void *)((char *)thread->stack_addr + thread->stack_size),
  1577. user_stack, &thread->sp);
  1578. /* new thread never reach there */
  1579. level = rt_hw_interrupt_disable();
  1580. if (lwp->tty != RT_NULL)
  1581. {
  1582. int ret;
  1583. struct rt_lwp *old_lwp;
  1584. old_lwp = lwp->tty->foreground;
  1585. rt_mutex_take(&lwp->tty->lock, RT_WAITING_FOREVER);
  1586. ret = tty_push(&lwp->tty->head, old_lwp);
  1587. rt_mutex_release(&lwp->tty->lock);
  1588. if (ret < 0)
  1589. {
  1590. LOG_E("malloc fail!\n");
  1591. SET_ERRNO(ENOMEM);
  1592. goto fail;
  1593. }
  1594. lwp->tty->foreground = lwp;
  1595. }
  1596. rt_hw_interrupt_enable(level);
  1597. rt_thread_startup(thread);
  1598. return lwp_to_pid(lwp);
  1599. fail:
  1600. falival = GET_ERRNO();
  1601. if (tid != 0)
  1602. {
  1603. lwp_tid_put(tid);
  1604. }
  1605. if (lwp)
  1606. {
  1607. lwp_ref_dec(lwp);
  1608. }
  1609. return falival;
  1610. }
  1611. size_t lwp_user_strlen(const char *s, int *err)
  1612. {
  1613. size_t len = 0;
  1614. while (1)
  1615. {
  1616. if (!lwp_user_accessable((void *)(s + len), sizeof(char)))
  1617. {
  1618. if (err)
  1619. {
  1620. *err = 1;
  1621. }
  1622. return 0;
  1623. }
  1624. if (s[len] == '\0')
  1625. {
  1626. if (err)
  1627. {
  1628. *err = 0;
  1629. }
  1630. return len;
  1631. }
  1632. len++;
  1633. }
  1634. }
  1635. /* arm needs to wrap fork/clone call to preserved lr & caller saved regs */
  1636. rt_weak int sys_fork(void)
  1637. {
  1638. return _sys_fork();
  1639. }
  1640. rt_weak int sys_vfork(void)
  1641. {
  1642. return sys_fork();
  1643. }
  1644. struct process_aux *lwp_argscopy(struct rt_lwp *lwp, int argc, char **argv, char **envp);
  1645. int lwp_load(const char *filename, struct rt_lwp *lwp, uint8_t *load_addr, size_t addr_size, struct process_aux *aux);
  1646. void lwp_user_obj_free(struct rt_lwp *lwp);
  1647. #define _swap_lwp_data(lwp_used, lwp_new, type, member) \
  1648. do {\
  1649. type tmp;\
  1650. tmp = lwp_used->member;\
  1651. lwp_used->member = lwp_new->member;\
  1652. lwp_new->member = tmp;\
  1653. } while (0)
  1654. static char *_insert_args(int new_argc, char *new_argv[], struct lwp_args_info *args)
  1655. {
  1656. void *page = NULL;
  1657. int err = 0;
  1658. char **nargv;
  1659. char **nenvp;
  1660. char *p;
  1661. int i, len;
  1662. int nsize;
  1663. if (new_argc == 0)
  1664. {
  1665. goto quit;
  1666. }
  1667. page = rt_pages_alloc(0); /* 1 page */
  1668. if (!page)
  1669. {
  1670. goto quit;
  1671. }
  1672. nsize = new_argc * sizeof(char *);
  1673. for (i = 0; i < new_argc; i++)
  1674. {
  1675. nsize += rt_strlen(new_argv[i]) + 1;
  1676. }
  1677. if (nsize + args->size > ARCH_PAGE_SIZE)
  1678. {
  1679. err = 1;
  1680. goto quit;
  1681. }
  1682. nargv = (char **)page;
  1683. nenvp = nargv + args->argc + new_argc + 1;
  1684. p = (char *)(nenvp + args->envc + 1);
  1685. /* insert argv */
  1686. for (i = 0; i < new_argc; i++)
  1687. {
  1688. nargv[i] = p;
  1689. len = rt_strlen(new_argv[i]) + 1;
  1690. rt_memcpy(p, new_argv[i], len);
  1691. p += len;
  1692. }
  1693. /* copy argv */
  1694. nargv += new_argc;
  1695. for (i = 0; i < args->argc; i++)
  1696. {
  1697. nargv[i] = p;
  1698. len = rt_strlen(args->argv[i]) + 1;
  1699. rt_memcpy(p, args->argv[i], len);
  1700. p += len;
  1701. }
  1702. nargv[i] = NULL;
  1703. /* copy envp */
  1704. for (i = 0; i < args->envc; i++)
  1705. {
  1706. nenvp[i] = p;
  1707. len = rt_strlen(args->envp[i]) + 1;
  1708. rt_memcpy(p, args->envp[i], len);
  1709. p += len;
  1710. }
  1711. nenvp[i] = NULL;
  1712. /* update args */
  1713. args->argv = (char **)page;
  1714. args->argc = args->argc + new_argc;
  1715. args->envp = args->argv + args->argc + 1;
  1716. /* args->envc no change */
  1717. args->size = args->size + nsize;
  1718. quit:
  1719. if (err && page)
  1720. {
  1721. rt_pages_free(page, 0);
  1722. page = NULL;
  1723. }
  1724. return page;
  1725. }
  1726. #define INTERP_BUF_SIZE 128
  1727. static char *_load_script(const char *filename, struct lwp_args_info *args)
  1728. {
  1729. void *page = NULL;
  1730. char *new_page;
  1731. int fd = -RT_ERROR;
  1732. int len;
  1733. char interp[INTERP_BUF_SIZE];
  1734. char *cp;
  1735. char *i_name;
  1736. char *i_arg;
  1737. fd = open(filename, O_BINARY | O_RDONLY, 0);
  1738. if (fd < 0)
  1739. {
  1740. goto quit;
  1741. }
  1742. len = read(fd, interp, INTERP_BUF_SIZE);
  1743. if (len < 2)
  1744. {
  1745. goto quit;
  1746. }
  1747. if ((interp[0] != '#') || (interp[1] != '!'))
  1748. {
  1749. goto quit;
  1750. }
  1751. if (len == INTERP_BUF_SIZE)
  1752. {
  1753. len--;
  1754. }
  1755. interp[len] = '\0';
  1756. if ((cp = strchr(interp, '\n')) == NULL)
  1757. {
  1758. cp = interp + INTERP_BUF_SIZE - 1;
  1759. }
  1760. *cp = '\0';
  1761. while (cp > interp)
  1762. {
  1763. cp--;
  1764. if ((*cp == ' ') || (*cp == '\t'))
  1765. {
  1766. *cp = '\0';
  1767. }
  1768. else
  1769. {
  1770. break;
  1771. }
  1772. }
  1773. for (cp = interp + 2; (*cp == ' ') || (*cp == '\t'); cp++)
  1774. {
  1775. /* nothing */
  1776. }
  1777. if (*cp == '\0')
  1778. {
  1779. goto quit; /* No interpreter name found */
  1780. }
  1781. i_name = cp;
  1782. i_arg = NULL;
  1783. for (; *cp && (*cp != ' ') && (*cp != '\t'); cp++)
  1784. {
  1785. /* nothing */
  1786. }
  1787. while ((*cp == ' ') || (*cp == '\t'))
  1788. {
  1789. *cp++ = '\0';
  1790. }
  1791. if (*cp)
  1792. {
  1793. i_arg = cp;
  1794. }
  1795. if (i_arg)
  1796. {
  1797. new_page = _insert_args(1, &i_arg, args);
  1798. rt_pages_free(page, 0);
  1799. page = new_page;
  1800. if (!page)
  1801. {
  1802. goto quit;
  1803. }
  1804. }
  1805. new_page = _insert_args(1, &i_name, args);
  1806. rt_pages_free(page, 0);
  1807. page = new_page;
  1808. quit:
  1809. if (fd >= 0)
  1810. {
  1811. close(fd);
  1812. }
  1813. return page;
  1814. }
  1815. int load_ldso(struct rt_lwp *lwp, char *exec_name, char *const argv[], char *const envp[])
  1816. {
  1817. int ret = -1;
  1818. int i;
  1819. void *page;
  1820. void *new_page;
  1821. int argc = 0;
  1822. int envc = 0;
  1823. int size;
  1824. char **kargv;
  1825. char **kenvp;
  1826. size_t len;
  1827. char *p;
  1828. char *i_arg;
  1829. struct lwp_args_info args_info;
  1830. struct process_aux *aux;
  1831. size = sizeof(char *);
  1832. if (argv)
  1833. {
  1834. while (1)
  1835. {
  1836. if (!argv[argc])
  1837. {
  1838. break;
  1839. }
  1840. len = rt_strlen((const char *)argv[argc]);
  1841. size += sizeof(char *) + len + 1;
  1842. argc++;
  1843. }
  1844. }
  1845. if (envp)
  1846. {
  1847. while (1)
  1848. {
  1849. if (!envp[envc])
  1850. {
  1851. break;
  1852. }
  1853. len = rt_strlen((const char *)envp[envc]);
  1854. size += sizeof(char *) + len + 1;
  1855. envc++;
  1856. }
  1857. }
  1858. page = rt_pages_alloc(0); /* 1 page */
  1859. if (!page)
  1860. {
  1861. SET_ERRNO(ENOMEM);
  1862. goto quit;
  1863. }
  1864. kargv = (char **)page;
  1865. kenvp = kargv + argc + 1;
  1866. p = (char *)(kenvp + envc + 1);
  1867. /* copy argv */
  1868. if (argv)
  1869. {
  1870. for (i = 0; i < argc; i++)
  1871. {
  1872. kargv[i] = p;
  1873. len = rt_strlen(argv[i]) + 1;
  1874. rt_memcpy(p, argv[i], len);
  1875. p += len;
  1876. }
  1877. kargv[i] = NULL;
  1878. }
  1879. /* copy envp */
  1880. if (envp)
  1881. {
  1882. for (i = 0; i < envc; i++)
  1883. {
  1884. kenvp[i] = p;
  1885. len = rt_strlen(envp[i]) + 1;
  1886. rt_memcpy(p, envp[i], len);
  1887. p += len;
  1888. }
  1889. kenvp[i] = NULL;
  1890. }
  1891. args_info.argc = argc;
  1892. args_info.argv = kargv;
  1893. args_info.envc = envc;
  1894. args_info.envp = kenvp;
  1895. args_info.size = size;
  1896. new_page = _insert_args(1, &exec_name, &args_info);
  1897. rt_pages_free(page, 0);
  1898. page = new_page;
  1899. if (!page)
  1900. {
  1901. SET_ERRNO(ENOMEM);
  1902. goto quit;
  1903. }
  1904. i_arg = "-e";
  1905. new_page = _insert_args(1, &i_arg, &args_info);
  1906. rt_pages_free(page, 0);
  1907. page = new_page;
  1908. if (!page)
  1909. {
  1910. SET_ERRNO(ENOMEM);
  1911. goto quit;
  1912. }
  1913. i_arg = "ld.so";
  1914. new_page = _insert_args(1, &i_arg, &args_info);
  1915. rt_pages_free(page, 0);
  1916. page = new_page;
  1917. if (!page)
  1918. {
  1919. SET_ERRNO(ENOMEM);
  1920. goto quit;
  1921. }
  1922. if ((aux = lwp_argscopy(lwp, args_info.argc, args_info.argv, args_info.envp)) == NULL)
  1923. {
  1924. SET_ERRNO(ENOMEM);
  1925. goto quit;
  1926. }
  1927. ret = lwp_load("/lib/ld.so", lwp, RT_NULL, 0, aux);
  1928. rt_strncpy(lwp->cmd, exec_name, RT_NAME_MAX);
  1929. quit:
  1930. if (page)
  1931. {
  1932. rt_pages_free(page, 0);
  1933. }
  1934. return (ret < 0 ? GET_ERRNO() : ret);
  1935. }
  1936. int sys_execve(const char *path, char *const argv[], char *const envp[])
  1937. {
  1938. int ret = -1;
  1939. int argc = 0;
  1940. int envc = 0;
  1941. void *page = NULL;
  1942. void *new_page;
  1943. int size = 0;
  1944. size_t len;
  1945. int access_err;
  1946. char **kargv;
  1947. char **kenvp;
  1948. char *p;
  1949. struct rt_lwp *new_lwp = NULL;
  1950. struct rt_lwp *lwp;
  1951. rt_base_t level;
  1952. int uni_thread;
  1953. rt_thread_t thread;
  1954. struct process_aux *aux;
  1955. int i;
  1956. struct lwp_args_info args_info;
  1957. lwp = lwp_self();
  1958. thread = rt_thread_self();
  1959. uni_thread = 1;
  1960. level = rt_hw_interrupt_disable();
  1961. if (lwp->t_grp.prev != &thread->sibling)
  1962. {
  1963. uni_thread = 0;
  1964. }
  1965. if (lwp->t_grp.next != &thread->sibling)
  1966. {
  1967. uni_thread = 0;
  1968. }
  1969. rt_hw_interrupt_enable(level);
  1970. if (!uni_thread)
  1971. {
  1972. SET_ERRNO(EINVAL);
  1973. goto quit;
  1974. }
  1975. len = lwp_user_strlen(path, &access_err);
  1976. if (access_err)
  1977. {
  1978. SET_ERRNO(EFAULT);
  1979. goto quit;
  1980. }
  1981. size += sizeof(char *);
  1982. if (argv)
  1983. {
  1984. while (1)
  1985. {
  1986. if (!lwp_user_accessable((void *)(argv + argc), sizeof(char *)))
  1987. {
  1988. SET_ERRNO(EFAULT);
  1989. goto quit;
  1990. }
  1991. if (!argv[argc])
  1992. {
  1993. break;
  1994. }
  1995. len = lwp_user_strlen((const char *)argv[argc], &access_err);
  1996. if (access_err)
  1997. {
  1998. SET_ERRNO(EFAULT);
  1999. goto quit;
  2000. }
  2001. size += sizeof(char *) + len + 1;
  2002. argc++;
  2003. }
  2004. }
  2005. size += sizeof(char *);
  2006. if (envp)
  2007. {
  2008. while (1)
  2009. {
  2010. if (!lwp_user_accessable((void *)(envp + envc), sizeof(char *)))
  2011. {
  2012. SET_ERRNO(EFAULT);
  2013. goto quit;
  2014. }
  2015. if (!envp[envc])
  2016. {
  2017. break;
  2018. }
  2019. len = lwp_user_strlen((const char *)envp[envc], &access_err);
  2020. if (access_err)
  2021. {
  2022. SET_ERRNO(EFAULT);
  2023. goto quit;
  2024. }
  2025. size += sizeof(char *) + len + 1;
  2026. envc++;
  2027. }
  2028. }
  2029. if (size > ARCH_PAGE_SIZE)
  2030. {
  2031. SET_ERRNO(EINVAL);
  2032. goto quit;
  2033. }
  2034. page = rt_pages_alloc(0); /* 1 page */
  2035. if (!page)
  2036. {
  2037. SET_ERRNO(ENOMEM);
  2038. goto quit;
  2039. }
  2040. kargv = (char **)page;
  2041. kenvp = kargv + argc + 1;
  2042. p = (char *)(kenvp + envc + 1);
  2043. /* copy argv */
  2044. if (argv)
  2045. {
  2046. for (i = 0; i < argc; i++)
  2047. {
  2048. kargv[i] = p;
  2049. len = rt_strlen(argv[i]) + 1;
  2050. rt_memcpy(p, argv[i], len);
  2051. p += len;
  2052. }
  2053. kargv[i] = NULL;
  2054. }
  2055. /* copy envp */
  2056. if (envp)
  2057. {
  2058. for (i = 0; i < envc; i++)
  2059. {
  2060. kenvp[i] = p;
  2061. len = rt_strlen(envp[i]) + 1;
  2062. rt_memcpy(p, envp[i], len);
  2063. p += len;
  2064. }
  2065. kenvp[i] = NULL;
  2066. }
  2067. /* alloc new lwp to operation */
  2068. new_lwp = (struct rt_lwp *)rt_malloc(sizeof(struct rt_lwp));
  2069. if (!new_lwp)
  2070. {
  2071. SET_ERRNO(ENOMEM);
  2072. goto quit;
  2073. }
  2074. rt_memset(new_lwp, 0, sizeof(struct rt_lwp));
  2075. new_lwp->ref = 1;
  2076. lwp_user_object_lock_init(new_lwp);
  2077. ret = lwp_user_space_init(new_lwp, 0);
  2078. if (ret != 0)
  2079. {
  2080. SET_ERRNO(ENOMEM);
  2081. goto quit;
  2082. }
  2083. /* file is a script ? */
  2084. args_info.argc = argc;
  2085. args_info.argv = kargv;
  2086. args_info.envc = envc;
  2087. args_info.envp = kenvp;
  2088. args_info.size = size;
  2089. while (1)
  2090. {
  2091. new_page = _load_script(path, &args_info);
  2092. if (!new_page)
  2093. {
  2094. break;
  2095. }
  2096. rt_pages_free(page, 0);
  2097. page = new_page;
  2098. path = args_info.argv[0];
  2099. }
  2100. /* now load elf */
  2101. if ((aux = lwp_argscopy(new_lwp, args_info.argc, args_info.argv, args_info.envp)) == NULL)
  2102. {
  2103. SET_ERRNO(ENOMEM);
  2104. goto quit;
  2105. }
  2106. ret = lwp_load(path, new_lwp, RT_NULL, 0, aux);
  2107. if (ret == 1)
  2108. {
  2109. /* dynamic */
  2110. lwp_unmap_user(new_lwp, (void *)(USER_VADDR_TOP - ARCH_PAGE_SIZE));
  2111. ret = load_ldso(new_lwp, (char *)path, args_info.argv, args_info.envp);
  2112. }
  2113. if (ret == RT_EOK)
  2114. {
  2115. int off = 0;
  2116. int last_backslash = 0;
  2117. char *run_name = args_info.argv[0];
  2118. /* clear all user objects */
  2119. lwp_user_object_clear(lwp);
  2120. /* find last \ or / */
  2121. while (1)
  2122. {
  2123. char c = run_name[off++];
  2124. if (c == '\0')
  2125. {
  2126. break;
  2127. }
  2128. if (c == '\\' || c == '/')
  2129. {
  2130. last_backslash = off;
  2131. }
  2132. }
  2133. /* load ok, now set thread name and swap the data of lwp and new_lwp */
  2134. level = rt_hw_interrupt_disable();
  2135. rt_strncpy(thread->name, run_name + last_backslash, RT_NAME_MAX);
  2136. rt_pages_free(page, 0);
  2137. #ifdef ARCH_MM_MMU
  2138. _swap_lwp_data(lwp, new_lwp, struct rt_aspace *, aspace);
  2139. _swap_lwp_data(lwp, new_lwp, struct rt_lwp_objs *, lwp_obj);
  2140. _swap_lwp_data(lwp, new_lwp, size_t, end_heap);
  2141. #endif
  2142. _swap_lwp_data(lwp, new_lwp, uint8_t, lwp_type);
  2143. _swap_lwp_data(lwp, new_lwp, void *, text_entry);
  2144. _swap_lwp_data(lwp, new_lwp, uint32_t, text_size);
  2145. _swap_lwp_data(lwp, new_lwp, void *, data_entry);
  2146. _swap_lwp_data(lwp, new_lwp, uint32_t, data_size);
  2147. _swap_lwp_data(lwp, new_lwp, void *, args);
  2148. rt_memset(&thread->signal_mask, 0, sizeof(thread->signal_mask));
  2149. rt_memset(&thread->signal_mask_bak, 0, sizeof(thread->signal_mask_bak));
  2150. lwp->sa_flags = 0;
  2151. rt_memset(&lwp->signal_mask, 0, sizeof(lwp->signal_mask));
  2152. rt_memset(&lwp->signal_mask_bak, 0, sizeof(lwp->signal_mask_bak));
  2153. rt_memset(lwp->signal_handler, 0, sizeof(lwp->signal_handler));
  2154. /* to do: clsoe files with flag CLOEXEC */
  2155. lwp_aspace_switch(thread);
  2156. rt_hw_interrupt_enable(level);
  2157. lwp_ref_dec(new_lwp);
  2158. arch_start_umode(lwp->args,
  2159. lwp->text_entry,
  2160. (void*)USER_STACK_VEND,
  2161. thread->stack_addr + thread->stack_size);
  2162. /* never reach here */
  2163. }
  2164. return -EINVAL;
  2165. quit:
  2166. if (page)
  2167. {
  2168. rt_pages_free(page, 0);
  2169. }
  2170. if (new_lwp)
  2171. {
  2172. lwp_ref_dec(new_lwp);
  2173. }
  2174. return (ret < 0 ? GET_ERRNO() : ret);
  2175. }
  2176. #endif /* ARCH_MM_MMU */
  2177. rt_err_t sys_thread_delete(rt_thread_t thread)
  2178. {
  2179. #ifdef ARCH_MM_MMU
  2180. return rt_thread_delete(thread);
  2181. #else
  2182. rt_err_t ret = 0;
  2183. if(thread->type != RT_Object_Class_Thread)
  2184. {
  2185. ret = -EINVAL;
  2186. goto __exit;
  2187. }
  2188. ret = rt_thread_delete(thread);
  2189. if (rt_thread_self() == thread)
  2190. {
  2191. rt_schedule();
  2192. }
  2193. __exit:
  2194. return ret;
  2195. #endif
  2196. }
  2197. rt_err_t sys_thread_startup(rt_thread_t thread)
  2198. {
  2199. return rt_thread_startup(thread);
  2200. }
  2201. rt_thread_t sys_thread_self(void)
  2202. {
  2203. return rt_thread_self();
  2204. }
  2205. /* sys channel */
  2206. int sys_channel_open(const char *name, int flags)
  2207. {
  2208. return lwp_channel_open(FDT_TYPE_LWP, name, flags);
  2209. }
  2210. rt_err_t sys_channel_close(int fd)
  2211. {
  2212. return lwp_channel_close(FDT_TYPE_LWP, fd);
  2213. }
  2214. rt_err_t sys_channel_send(int fd, rt_channel_msg_t data)
  2215. {
  2216. return lwp_channel_send(FDT_TYPE_LWP, fd, data);
  2217. }
  2218. rt_err_t sys_channel_send_recv_timeout(int fd, rt_channel_msg_t data, rt_channel_msg_t data_ret, rt_int32_t time)
  2219. {
  2220. return lwp_channel_send_recv_timeout(FDT_TYPE_LWP, fd, data, data_ret, time);
  2221. }
  2222. rt_err_t sys_channel_reply(int fd, rt_channel_msg_t data)
  2223. {
  2224. return lwp_channel_reply(FDT_TYPE_LWP, fd, data);
  2225. }
  2226. rt_err_t sys_channel_recv_timeout(int fd, rt_channel_msg_t data, rt_int32_t time)
  2227. {
  2228. return lwp_channel_recv_timeout(FDT_TYPE_LWP, fd, data, time);
  2229. }
  2230. static struct rt_semaphore critical_lock;
  2231. static int critical_init(void)
  2232. {
  2233. rt_sem_init(&critical_lock, "ct_lock", 1, RT_IPC_FLAG_FIFO);
  2234. return 0;
  2235. }
  2236. INIT_DEVICE_EXPORT(critical_init);
  2237. void sys_enter_critical(void)
  2238. {
  2239. rt_sem_take(&critical_lock, RT_WAITING_FOREVER);
  2240. }
  2241. void sys_exit_critical(void)
  2242. {
  2243. rt_sem_release(&critical_lock);
  2244. }
  2245. /* syscall: "sys_log" ret: "int" args: "const char*" "size" */
  2246. static int __sys_log_enable = 0;
  2247. static int sys_log_enable(int argc, char** argv)
  2248. {
  2249. if (argc == 1)
  2250. {
  2251. rt_kprintf("sys_log = %d\n", __sys_log_enable);
  2252. return 0;
  2253. }
  2254. else
  2255. {
  2256. __sys_log_enable = atoi(argv[1]);
  2257. }
  2258. return 0;
  2259. }
  2260. MSH_CMD_EXPORT_ALIAS(sys_log_enable, sys_log, sys_log 1(enable)/0(disable));
  2261. int sys_log(const char* log, int size)
  2262. {
  2263. rt_device_t console = rt_console_get_device();
  2264. if (console && __sys_log_enable)
  2265. {
  2266. rt_device_write(console, -1, log, size);
  2267. }
  2268. return 0;
  2269. }
  2270. int sys_stat(const char *file, struct stat *buf)
  2271. {
  2272. int ret = 0;
  2273. int err;
  2274. size_t len;
  2275. size_t copy_len;
  2276. char *copy_path;
  2277. struct stat statbuff = {0};
  2278. if (!lwp_user_accessable((void *)buf, sizeof(struct stat)))
  2279. {
  2280. return -EFAULT;
  2281. }
  2282. len = lwp_user_strlen(file, &err);
  2283. if (err)
  2284. {
  2285. return -EFAULT;
  2286. }
  2287. copy_path = (char*)rt_malloc(len + 1);
  2288. if (!copy_path)
  2289. {
  2290. return -ENOMEM;
  2291. }
  2292. copy_len = lwp_get_from_user(copy_path, (void*)file, len);
  2293. if (copy_len == 0)
  2294. {
  2295. rt_free(copy_path);
  2296. return -EFAULT;
  2297. }
  2298. copy_path[copy_len] = '\0';
  2299. ret = stat(copy_path, &statbuff);
  2300. rt_free(copy_path);
  2301. if (ret == 0)
  2302. {
  2303. lwp_put_to_user(buf, &statbuff, sizeof statbuff);
  2304. }
  2305. return (ret < 0 ? GET_ERRNO() : ret);
  2306. }
  2307. int sys_notimpl(void)
  2308. {
  2309. return -ENOSYS;
  2310. }
  2311. uint32_t sys_hw_interrupt_disable(void)
  2312. {
  2313. return rt_hw_interrupt_disable();
  2314. }
  2315. void sys_hw_interrupt_enable(uint32_t level)
  2316. {
  2317. rt_hw_interrupt_enable(level);
  2318. }
  2319. #ifdef ARCH_MM_MMU
  2320. int sys_shmget(size_t key, size_t size, int create)
  2321. {
  2322. return lwp_shmget(key, size, create);
  2323. }
  2324. int sys_shmrm(int id)
  2325. {
  2326. return lwp_shmrm(id);
  2327. }
  2328. void* sys_shmat(int id, void* shm_vaddr)
  2329. {
  2330. return lwp_shmat(id, shm_vaddr);
  2331. }
  2332. int sys_shmdt(void* shm_vaddr)
  2333. {
  2334. return lwp_shmdt(shm_vaddr);
  2335. }
  2336. #elif defined RT_LWP_USING_SHM
  2337. void *sys_shm_alloc(int size)
  2338. {
  2339. if (size < 0)
  2340. {
  2341. return RT_NULL;
  2342. }
  2343. return lwp_shm_alloc((rt_size_t)size);
  2344. }
  2345. void *sys_shm_retain(void *mem)
  2346. {
  2347. if (!lwp_user_accessable(mem, sizeof (void *)))
  2348. {
  2349. return RT_NULL;
  2350. }
  2351. return lwp_shm_retain(mem);
  2352. }
  2353. int sys_shm_free(void *mem)
  2354. {
  2355. if (!lwp_user_accessable(mem, sizeof (void *)))
  2356. {
  2357. return -EFAULT;
  2358. }
  2359. lwp_shm_free(mem);
  2360. return 0;
  2361. }
  2362. #endif
  2363. /* device interfaces */
  2364. rt_err_t sys_device_init(rt_device_t dev)
  2365. {
  2366. return rt_device_init(dev);
  2367. }
  2368. rt_err_t sys_device_register(rt_device_t dev, const char *name, rt_uint16_t flags)
  2369. {
  2370. return rt_device_register(dev, name, flags);
  2371. }
  2372. rt_err_t sys_device_control(rt_device_t dev, int cmd, void *arg)
  2373. {
  2374. return rt_device_control(dev, cmd, arg);
  2375. }
  2376. rt_device_t sys_device_find(const char* name)
  2377. {
  2378. return rt_device_find(name);
  2379. }
  2380. rt_err_t sys_device_open(rt_device_t dev, rt_uint16_t oflag)
  2381. {
  2382. return rt_device_open(dev, oflag);
  2383. }
  2384. rt_err_t sys_device_close(rt_device_t dev)
  2385. {
  2386. return rt_device_close(dev);
  2387. }
  2388. rt_ssize_t sys_device_read(rt_device_t dev, rt_off_t pos, void *buffer, rt_size_t size)
  2389. {
  2390. return rt_device_read(dev, pos, buffer, size);
  2391. }
  2392. rt_ssize_t sys_device_write(rt_device_t dev, rt_off_t pos, const void *buffer, rt_size_t size)
  2393. {
  2394. return rt_device_write(dev, pos, buffer, size);
  2395. }
  2396. #ifdef RT_USING_SAL
  2397. /* network interfaces */
  2398. int sys_accept(int socket, struct musl_sockaddr *addr, socklen_t *addrlen)
  2399. {
  2400. int ret = -1;
  2401. struct sockaddr ksa;
  2402. struct musl_sockaddr kmusladdr;
  2403. socklen_t uaddrlen;
  2404. socklen_t kaddrlen;
  2405. if (addr)
  2406. {
  2407. if (!lwp_user_accessable(addrlen, sizeof (socklen_t)))
  2408. {
  2409. return -EFAULT;
  2410. }
  2411. lwp_get_from_user(&uaddrlen, addrlen, sizeof (socklen_t));
  2412. if (!uaddrlen)
  2413. {
  2414. return -EINVAL;
  2415. }
  2416. if (!lwp_user_accessable(addr, uaddrlen))
  2417. {
  2418. return -EFAULT;
  2419. }
  2420. }
  2421. kaddrlen = sizeof(struct sockaddr);
  2422. ret = accept(socket, &ksa, &kaddrlen);
  2423. if (ret >= 0)
  2424. {
  2425. if (addr)
  2426. {
  2427. sockaddr_tomusl(&ksa, &kmusladdr);
  2428. if (uaddrlen > sizeof(struct musl_sockaddr))
  2429. {
  2430. uaddrlen = sizeof(struct musl_sockaddr);
  2431. }
  2432. lwp_put_to_user(addr, &kmusladdr, uaddrlen);
  2433. lwp_put_to_user(addrlen, &uaddrlen, sizeof (socklen_t));
  2434. }
  2435. }
  2436. return ret;
  2437. }
  2438. int sys_bind(int socket, const struct musl_sockaddr *name, socklen_t namelen)
  2439. {
  2440. struct sockaddr sa;
  2441. struct musl_sockaddr kname;
  2442. if (!lwp_user_accessable((void *)name, namelen))
  2443. {
  2444. return -EFAULT;
  2445. }
  2446. #ifdef SAL_USING_AF_UNIX
  2447. if (name->sa_family == AF_UNIX)
  2448. {
  2449. namelen = sizeof(struct sockaddr);
  2450. }
  2451. #endif /* SAL_USING_AF_UNIX */
  2452. lwp_get_from_user(&kname, (void *)name, namelen);
  2453. sockaddr_tolwip(&kname, &sa);
  2454. return bind(socket, &sa, namelen);
  2455. }
  2456. int sys_shutdown(int socket, int how)
  2457. {
  2458. return shutdown(socket, how);
  2459. }
  2460. int sys_getpeername (int socket, struct musl_sockaddr *name, socklen_t *namelen)
  2461. {
  2462. int ret = -1;
  2463. struct sockaddr sa;
  2464. struct musl_sockaddr kname;
  2465. socklen_t unamelen;
  2466. socklen_t knamelen;
  2467. if (!lwp_user_accessable(namelen, sizeof (socklen_t *)))
  2468. {
  2469. return -EFAULT;
  2470. }
  2471. lwp_get_from_user(&unamelen, namelen, sizeof (socklen_t *));
  2472. if (!unamelen)
  2473. {
  2474. return -EINVAL;
  2475. }
  2476. if (!lwp_user_accessable(name, unamelen))
  2477. {
  2478. return -EFAULT;
  2479. }
  2480. knamelen = sizeof(struct sockaddr);
  2481. ret = getpeername(socket, &sa, &knamelen);
  2482. if (ret == 0)
  2483. {
  2484. sockaddr_tomusl(&sa, &kname);
  2485. if (unamelen > sizeof(struct musl_sockaddr))
  2486. {
  2487. unamelen = sizeof(struct musl_sockaddr);
  2488. }
  2489. lwp_put_to_user(name, &kname, unamelen);
  2490. lwp_put_to_user(namelen, &unamelen, sizeof (socklen_t *));
  2491. }
  2492. else
  2493. {
  2494. ret = GET_ERRNO();
  2495. }
  2496. return ret;
  2497. }
  2498. int sys_getsockname (int socket, struct musl_sockaddr *name, socklen_t *namelen)
  2499. {
  2500. int ret = -1;
  2501. struct sockaddr sa;
  2502. struct musl_sockaddr kname;
  2503. socklen_t unamelen;
  2504. socklen_t knamelen;
  2505. if (!lwp_user_accessable(namelen, sizeof (socklen_t *)))
  2506. {
  2507. return -EFAULT;
  2508. }
  2509. lwp_get_from_user(&unamelen, namelen, sizeof (socklen_t *));
  2510. if (!unamelen)
  2511. {
  2512. return -EINVAL;
  2513. }
  2514. if (!lwp_user_accessable(name, unamelen))
  2515. {
  2516. return -EFAULT;
  2517. }
  2518. knamelen = sizeof(struct sockaddr);
  2519. ret = getsockname(socket, &sa, &knamelen);
  2520. if (ret == 0)
  2521. {
  2522. sockaddr_tomusl(&sa, &kname);
  2523. if (unamelen > sizeof(struct musl_sockaddr))
  2524. {
  2525. unamelen = sizeof(struct musl_sockaddr);
  2526. }
  2527. lwp_put_to_user(name, &kname, unamelen);
  2528. lwp_put_to_user(namelen, &unamelen, sizeof(socklen_t *));
  2529. }
  2530. else
  2531. {
  2532. ret = GET_ERRNO();
  2533. }
  2534. return ret;
  2535. }
  2536. int sys_getsockopt(int socket, int level, int optname, void *optval, socklen_t *optlen)
  2537. {
  2538. int ret;
  2539. convert_sockopt(&level, &optname);
  2540. ret = getsockopt(socket, level, optname, optval, optlen);
  2541. return (ret < 0 ? GET_ERRNO() : ret);
  2542. }
  2543. int sys_setsockopt(int socket, int level, int optname, const void *optval, socklen_t optlen)
  2544. {
  2545. int ret;
  2546. convert_sockopt(&level, &optname);
  2547. ret = setsockopt(socket, level, optname, optval, optlen);
  2548. return (ret < 0 ? GET_ERRNO() : ret);
  2549. }
  2550. int sys_connect(int socket, const struct musl_sockaddr *name, socklen_t namelen)
  2551. {
  2552. int ret;
  2553. struct sockaddr sa;
  2554. struct musl_sockaddr kname;
  2555. if (!lwp_user_accessable((void *)name, namelen))
  2556. {
  2557. return -EFAULT;
  2558. }
  2559. #ifdef SAL_USING_AF_UNIX
  2560. if (name->sa_family == AF_UNIX)
  2561. {
  2562. namelen = sizeof(struct sockaddr);
  2563. }
  2564. #endif /* SAL_USING_AF_UNIX */
  2565. lwp_get_from_user(&kname, (void *)name, namelen);
  2566. sockaddr_tolwip(&kname, &sa);
  2567. ret = connect(socket, &sa, namelen);
  2568. return (ret < 0 ? GET_ERRNO() : ret);
  2569. }
  2570. int sys_listen(int socket, int backlog)
  2571. {
  2572. return listen(socket, backlog);
  2573. }
  2574. #define MUSLC_MSG_OOB 0x0001
  2575. #define MUSLC_MSG_PEEK 0x0002
  2576. #define MUSLC_MSG_DONTWAIT 0x0040
  2577. #define MUSLC_MSG_WAITALL 0x0100
  2578. #define MUSLC_MSG_MORE 0x8000
  2579. static int netflags_muslc_2_lwip(int flags)
  2580. {
  2581. int flgs = 0;
  2582. if (flags & MUSLC_MSG_PEEK)
  2583. {
  2584. flgs |= MSG_PEEK;
  2585. }
  2586. if (flags & MUSLC_MSG_WAITALL)
  2587. {
  2588. flgs |= MSG_WAITALL;
  2589. }
  2590. if (flags & MUSLC_MSG_OOB)
  2591. {
  2592. flgs |= MSG_OOB;
  2593. }
  2594. if (flags & MUSLC_MSG_DONTWAIT)
  2595. {
  2596. flgs |= MSG_DONTWAIT;
  2597. }
  2598. if (flags & MUSLC_MSG_MORE)
  2599. {
  2600. flgs |= MSG_MORE;
  2601. }
  2602. return flgs;
  2603. }
  2604. int sys_recvfrom(int socket, void *mem, size_t len, int flags,
  2605. struct musl_sockaddr *from, socklen_t *fromlen)
  2606. {
  2607. int flgs = 0;
  2608. #ifdef ARCH_MM_MMU
  2609. int ret = -1;
  2610. void *kmem = RT_NULL;
  2611. #endif
  2612. flgs = netflags_muslc_2_lwip(flags);
  2613. #ifdef ARCH_MM_MMU
  2614. if (!len)
  2615. {
  2616. return -EINVAL;
  2617. }
  2618. if (!lwp_user_accessable((void *)mem, len))
  2619. {
  2620. return -EFAULT;
  2621. }
  2622. kmem = kmem_get(len);
  2623. if (!kmem)
  2624. {
  2625. return -ENOMEM;
  2626. }
  2627. if (flags == 0x2)
  2628. {
  2629. flags = 0x1;
  2630. }
  2631. if (from)
  2632. {
  2633. struct sockaddr sa;
  2634. ret = recvfrom(socket, kmem, len, flgs, &sa, fromlen);
  2635. sockaddr_tomusl(&sa, from);
  2636. }
  2637. else
  2638. {
  2639. ret = recvfrom(socket, kmem, len, flgs, NULL, NULL);
  2640. }
  2641. if (ret > 0)
  2642. {
  2643. lwp_put_to_user(mem, kmem, len);
  2644. }
  2645. if (ret < 0)
  2646. {
  2647. ret = GET_ERRNO();
  2648. }
  2649. kmem_put(kmem);
  2650. return ret;
  2651. #else
  2652. int ret = -1;
  2653. if (from)
  2654. {
  2655. struct sockaddr sa = {0};
  2656. ret = recvfrom(socket, mem, len, flgs, &sa, fromlen);
  2657. sockaddr_tomusl(&sa, from);
  2658. }
  2659. else
  2660. {
  2661. ret = recvfrom(socket, mem, len, flags, NULL, NULL);
  2662. }
  2663. return (ret < 0 ? GET_ERRNO() : ret);
  2664. #endif
  2665. }
  2666. int sys_recv(int socket, void *mem, size_t len, int flags)
  2667. {
  2668. int flgs = 0;
  2669. int ret;
  2670. flgs = netflags_muslc_2_lwip(flags);
  2671. ret = recvfrom(socket, mem, len, flgs, NULL, NULL);
  2672. return (ret < 0 ? GET_ERRNO() : ret);
  2673. }
  2674. int sys_sendto(int socket, const void *dataptr, size_t size, int flags,
  2675. const struct musl_sockaddr *to, socklen_t tolen)
  2676. {
  2677. int flgs = 0;
  2678. #ifdef ARCH_MM_MMU
  2679. int ret = -1;
  2680. void *kmem = RT_NULL;
  2681. #endif
  2682. flgs = netflags_muslc_2_lwip(flags);
  2683. #ifdef ARCH_MM_MMU
  2684. if (!size)
  2685. {
  2686. return -EINVAL;
  2687. }
  2688. if (!lwp_user_accessable((void *)dataptr, size))
  2689. {
  2690. return -EFAULT;
  2691. }
  2692. kmem = kmem_get(size);
  2693. if (!kmem)
  2694. {
  2695. return -ENOMEM;
  2696. }
  2697. lwp_get_from_user(kmem, (void *)dataptr, size);
  2698. if (to)
  2699. {
  2700. struct sockaddr sa;
  2701. sockaddr_tolwip(to, &sa);
  2702. ret = sendto(socket, kmem, size, flgs, &sa, tolen);
  2703. }
  2704. else
  2705. {
  2706. ret = sendto(socket, kmem, size, flgs, NULL, tolen);
  2707. }
  2708. if (ret < 0)
  2709. {
  2710. ret = GET_ERRNO();
  2711. }
  2712. kmem_put(kmem);
  2713. return ret;
  2714. #else
  2715. int ret;
  2716. if (to)
  2717. {
  2718. struct sockaddr sa;
  2719. sockaddr_tolwip(to, &sa);
  2720. ret = sendto(socket, dataptr, size, flgs, &sa, tolen);
  2721. }
  2722. else
  2723. {
  2724. ret = sendto(socket, dataptr, size, flgs, NULL, tolen);
  2725. }
  2726. return (ret < 0 ? GET_ERRNO() : ret);
  2727. #endif
  2728. }
  2729. int sys_send(int socket, const void *dataptr, size_t size, int flags)
  2730. {
  2731. int ret;
  2732. int flgs = 0;
  2733. flgs = netflags_muslc_2_lwip(flags);
  2734. ret = sendto(socket, dataptr, size, flgs, NULL, 0);
  2735. return (ret < 0 ? GET_ERRNO() : ret);
  2736. }
  2737. int sys_socket(int domain, int type, int protocol)
  2738. {
  2739. int fd = -1;
  2740. int nonblock = 0;
  2741. /* not support SOCK_CLOEXEC type */
  2742. if (type & SOCK_CLOEXEC)
  2743. {
  2744. type &= ~SOCK_CLOEXEC;
  2745. }
  2746. if (type & SOCK_NONBLOCK)
  2747. {
  2748. nonblock = 1;
  2749. type &= ~SOCK_NONBLOCK;
  2750. }
  2751. fd = socket(domain, type, protocol);
  2752. if (fd < 0)
  2753. {
  2754. goto out;
  2755. }
  2756. if (nonblock)
  2757. {
  2758. fcntl(fd, F_SETFL, O_NONBLOCK);
  2759. }
  2760. out:
  2761. return (fd < 0 ? GET_ERRNO() : fd);
  2762. }
  2763. int sys_closesocket(int socket)
  2764. {
  2765. return closesocket(socket);
  2766. }
  2767. #endif
  2768. rt_thread_t sys_thread_find(char *name)
  2769. {
  2770. return rt_thread_find(name);
  2771. }
  2772. rt_tick_t sys_tick_get(void)
  2773. {
  2774. return rt_tick_get();
  2775. }
  2776. rt_err_t sys_thread_mdelay(rt_int32_t ms)
  2777. {
  2778. return rt_thread_mdelay(ms);
  2779. }
  2780. struct k_sigaction {
  2781. void (*handler)(int);
  2782. unsigned long flags;
  2783. void (*restorer)(void);
  2784. unsigned mask[2];
  2785. };
  2786. int sys_sigaction(int sig, const struct k_sigaction *act,
  2787. struct k_sigaction *oact, size_t sigsetsize)
  2788. {
  2789. int ret = -RT_EINVAL;
  2790. struct lwp_sigaction kact, *pkact = RT_NULL;
  2791. struct lwp_sigaction koact, *pkoact = RT_NULL;
  2792. if (!sigsetsize)
  2793. {
  2794. SET_ERRNO(EINVAL);
  2795. goto out;
  2796. }
  2797. if (sigsetsize > sizeof(lwp_sigset_t))
  2798. {
  2799. sigsetsize = sizeof(lwp_sigset_t);
  2800. }
  2801. if (!act && !oact)
  2802. {
  2803. SET_ERRNO(EINVAL);
  2804. goto out;
  2805. }
  2806. if (oact)
  2807. {
  2808. if (!lwp_user_accessable((void *)oact, sizeof(*oact)))
  2809. {
  2810. SET_ERRNO(EFAULT);
  2811. goto out;
  2812. }
  2813. pkoact = &koact;
  2814. }
  2815. if (act)
  2816. {
  2817. if (!lwp_user_accessable((void *)act, sizeof(*act)))
  2818. {
  2819. SET_ERRNO(EFAULT);
  2820. goto out;
  2821. }
  2822. kact.sa_flags = act->flags;
  2823. kact.__sa_handler._sa_handler = act->handler;
  2824. memcpy(&kact.sa_mask, &act->mask, sigsetsize);
  2825. kact.sa_restorer = act->restorer;
  2826. pkact = &kact;
  2827. }
  2828. ret = lwp_sigaction(sig, pkact, pkoact, sigsetsize);
  2829. #ifdef ARCH_MM_MMU
  2830. if (ret == 0 && oact)
  2831. {
  2832. lwp_put_to_user(&oact->handler, &pkoact->__sa_handler._sa_handler, sizeof(void (*)(int)));
  2833. lwp_put_to_user(&oact->mask, &pkoact->sa_mask, sigsetsize);
  2834. lwp_put_to_user(&oact->flags, &pkoact->sa_flags, sizeof(int));
  2835. lwp_put_to_user(&oact->restorer, &pkoact->sa_restorer, sizeof(void (*)(void)));
  2836. }
  2837. #endif /* ARCH_MM_MMU */
  2838. out:
  2839. return (ret < 0 ? GET_ERRNO() : ret);
  2840. }
  2841. int sys_sigprocmask(int how, const sigset_t *sigset, sigset_t *oset, size_t size)
  2842. {
  2843. int ret = -1;
  2844. lwp_sigset_t *pnewset = RT_NULL, *poldset = RT_NULL;
  2845. #ifdef ARCH_MM_MMU
  2846. lwp_sigset_t newset, oldset;
  2847. #endif /* ARCH_MM_MMU*/
  2848. if (!size)
  2849. {
  2850. return -EINVAL;
  2851. }
  2852. if (!oset && !sigset)
  2853. {
  2854. return -EINVAL;
  2855. }
  2856. if (size > sizeof(lwp_sigset_t))
  2857. {
  2858. size = sizeof(lwp_sigset_t);
  2859. }
  2860. if (oset)
  2861. {
  2862. #ifdef ARCH_MM_MMU
  2863. if (!lwp_user_accessable((void *)oset, size))
  2864. {
  2865. return -EFAULT;
  2866. }
  2867. poldset = &oldset;
  2868. #else
  2869. if (!lwp_user_accessable((void *)oset, size))
  2870. {
  2871. return -EFAULT;
  2872. }
  2873. poldset = (lwp_sigset_t *)oset;
  2874. #endif
  2875. }
  2876. if (sigset)
  2877. {
  2878. #ifdef ARCH_MM_MMU
  2879. if (!lwp_user_accessable((void *)sigset, size))
  2880. {
  2881. return -EFAULT;
  2882. }
  2883. lwp_get_from_user(&newset, (void *)sigset, size);
  2884. pnewset = &newset;
  2885. #else
  2886. if (!lwp_user_accessable((void *)sigset, size))
  2887. {
  2888. return -EFAULT;
  2889. }
  2890. pnewset = (lwp_sigset_t *)sigset;
  2891. #endif /* ARCH_MM_MMU */
  2892. }
  2893. ret = lwp_sigprocmask(how, pnewset, poldset);
  2894. #ifdef ARCH_MM_MMU
  2895. if (ret < 0)
  2896. {
  2897. return ret;
  2898. }
  2899. if (oset)
  2900. {
  2901. lwp_put_to_user(oset, poldset, size);
  2902. }
  2903. #endif /* ARCH_MM_MMU */
  2904. return (ret < 0 ? -EFAULT: ret);
  2905. }
  2906. int sys_tkill(int tid, int sig)
  2907. {
  2908. #ifdef ARCH_MM_MMU
  2909. rt_base_t level;
  2910. rt_thread_t thread;
  2911. int ret;
  2912. level = rt_hw_interrupt_disable();
  2913. thread = lwp_tid_get_thread(tid);
  2914. ret = lwp_thread_kill(thread, sig);
  2915. rt_hw_interrupt_enable(level);
  2916. return ret;
  2917. #else
  2918. return lwp_thread_kill((rt_thread_t)tid, sig);
  2919. #endif
  2920. }
  2921. int sys_thread_sigprocmask(int how, const lwp_sigset_t *sigset, lwp_sigset_t *oset, size_t size)
  2922. {
  2923. int ret = -1;
  2924. lwp_sigset_t *pnewset = RT_NULL, *poldset = RT_NULL;
  2925. #ifdef ARCH_MM_MMU
  2926. lwp_sigset_t newset, oldset;
  2927. #endif /* ARCH_MM_MMU */
  2928. if (!size)
  2929. {
  2930. return -EINVAL;
  2931. }
  2932. if (!oset && !sigset)
  2933. {
  2934. return -EINVAL;
  2935. }
  2936. if (size != sizeof(lwp_sigset_t))
  2937. {
  2938. return -EINVAL;
  2939. }
  2940. if (oset)
  2941. {
  2942. #ifdef ARCH_MM_MMU
  2943. if (!lwp_user_accessable((void *)oset, size))
  2944. {
  2945. return -EFAULT;
  2946. }
  2947. poldset = &oldset;
  2948. #else
  2949. if (!lwp_user_accessable((void *)oset, size))
  2950. {
  2951. return -EFAULT;
  2952. }
  2953. poldset = oset;
  2954. #endif
  2955. }
  2956. if (sigset)
  2957. {
  2958. #ifdef ARCH_MM_MMU
  2959. if (!lwp_user_accessable((void *)sigset, size))
  2960. {
  2961. return -EFAULT;
  2962. }
  2963. lwp_get_from_user(&newset, (void *)sigset, sizeof(lwp_sigset_t));
  2964. pnewset = &newset;
  2965. #else
  2966. if (!lwp_user_accessable((void *)sigset, size))
  2967. {
  2968. return -EFAULT;
  2969. }
  2970. pnewset = (lwp_sigset_t *)sigset;
  2971. #endif
  2972. }
  2973. ret = lwp_thread_sigprocmask(how, pnewset, poldset);
  2974. if (ret < 0)
  2975. {
  2976. return ret;
  2977. }
  2978. #ifdef ARCH_MM_MMU
  2979. if (oset)
  2980. {
  2981. lwp_put_to_user(oset, poldset, sizeof(lwp_sigset_t));
  2982. }
  2983. #endif
  2984. return (ret < 0 ? -EFAULT: ret);
  2985. }
  2986. #ifndef ARCH_MM_MMU
  2987. int sys_lwp_sighandler_set(int sig, lwp_sighandler_t func)
  2988. {
  2989. if (!lwp_user_accessable((void *)func, sizeof(lwp_sighandler_t)))
  2990. {
  2991. return -EFAULT;
  2992. }
  2993. lwp_sighandler_set(sig, func);
  2994. return 0;
  2995. }
  2996. int sys_thread_sighandler_set(int sig, lwp_sighandler_t func)
  2997. {
  2998. if (!lwp_user_accessable((void *)func, sizeof(lwp_sighandler_t)))
  2999. {
  3000. return -EFAULT;
  3001. }
  3002. lwp_thread_sighandler_set(sig, func);
  3003. return 0;
  3004. }
  3005. #endif /* not defined ARCH_MM_MMU */
  3006. int32_t sys_waitpid(int32_t pid, int *status, int options)
  3007. {
  3008. int ret = -1;
  3009. #ifdef ARCH_MM_MMU
  3010. if (!lwp_user_accessable((void *)status, sizeof(int)))
  3011. {
  3012. return -EFAULT;
  3013. }
  3014. else
  3015. {
  3016. ret = waitpid(pid, status, options);
  3017. }
  3018. #else
  3019. if (!lwp_user_accessable((void *)status, sizeof(int)))
  3020. {
  3021. return -EFAULT;
  3022. }
  3023. ret = waitpid(pid, status, options);
  3024. #endif
  3025. return ret;
  3026. }
  3027. #if defined(RT_USING_SAL) && defined(SAL_USING_POSIX)
  3028. struct musl_addrinfo
  3029. {
  3030. int ai_flags;
  3031. int ai_family;
  3032. int ai_socktype;
  3033. int ai_protocol;
  3034. socklen_t ai_addrlen;
  3035. struct musl_sockaddr *ai_addr;
  3036. char *ai_canonname;
  3037. struct musl_addrinfo *ai_next;
  3038. };
  3039. int sys_getaddrinfo(const char *nodename,
  3040. const char *servname,
  3041. const struct musl_addrinfo *hints,
  3042. struct musl_addrinfo *res)
  3043. {
  3044. int ret = -1;
  3045. struct addrinfo *k_res = NULL;
  3046. char *k_nodename = NULL;
  3047. char *k_servname = NULL;
  3048. struct addrinfo *k_hints = NULL;
  3049. #ifdef ARCH_MM_MMU
  3050. int err;
  3051. #endif
  3052. #ifdef ARCH_MM_MMU
  3053. if (!lwp_user_accessable((void *)res, sizeof(*res)))
  3054. {
  3055. SET_ERRNO(EFAULT);
  3056. goto exit;
  3057. }
  3058. #endif
  3059. if (nodename)
  3060. {
  3061. #ifdef ARCH_MM_MMU
  3062. lwp_user_strlen(nodename, &err);
  3063. if (err)
  3064. {
  3065. SET_ERRNO(EFAULT);
  3066. goto exit;
  3067. }
  3068. #endif
  3069. k_nodename = rt_strdup(nodename);
  3070. if (!k_nodename)
  3071. {
  3072. SET_ERRNO(ENOMEM);
  3073. goto exit;
  3074. }
  3075. }
  3076. if (servname)
  3077. {
  3078. #ifdef ARCH_MM_MMU
  3079. lwp_user_strlen(servname, &err);
  3080. if (err)
  3081. {
  3082. SET_ERRNO(EFAULT);
  3083. goto exit;
  3084. }
  3085. #endif
  3086. k_servname = rt_strdup(servname);
  3087. if (!k_servname)
  3088. {
  3089. SET_ERRNO(ENOMEM);
  3090. goto exit;
  3091. }
  3092. }
  3093. if (hints)
  3094. {
  3095. #ifdef ARCH_MM_MMU
  3096. if (!lwp_user_accessable((void *)hints, sizeof(*hints)))
  3097. {
  3098. SET_ERRNO(EFAULT);
  3099. goto exit;
  3100. }
  3101. #endif
  3102. k_hints = (struct addrinfo *) rt_malloc(sizeof *hints);
  3103. if (!k_hints)
  3104. {
  3105. SET_ERRNO(ENOMEM);
  3106. goto exit;
  3107. }
  3108. rt_memset(k_hints, 0x0, sizeof(struct addrinfo));
  3109. k_hints->ai_flags = hints->ai_flags;
  3110. k_hints->ai_family = hints->ai_family;
  3111. k_hints->ai_socktype = hints->ai_socktype;
  3112. k_hints->ai_protocol = hints->ai_protocol;
  3113. k_hints->ai_addrlen = hints->ai_addrlen;
  3114. }
  3115. ret = sal_getaddrinfo(k_nodename, k_servname, k_hints, &k_res);
  3116. if (ret == 0)
  3117. {
  3118. /* set sockaddr */
  3119. sockaddr_tomusl(k_res->ai_addr, res->ai_addr);
  3120. res->ai_addrlen = k_res->ai_addrlen;
  3121. /* set up addrinfo */
  3122. res->ai_family = k_res->ai_family;
  3123. res->ai_flags = k_res->ai_flags;
  3124. res->ai_next = NULL;
  3125. if (hints != NULL)
  3126. {
  3127. /* copy socktype & protocol from hints if specified */
  3128. res->ai_socktype = hints->ai_socktype;
  3129. res->ai_protocol = hints->ai_protocol;
  3130. }
  3131. sal_freeaddrinfo(k_res);
  3132. k_res = NULL;
  3133. }
  3134. exit:
  3135. if (ret < 0)
  3136. {
  3137. ret = GET_ERRNO();
  3138. }
  3139. if (k_nodename)
  3140. {
  3141. rt_free(k_nodename);
  3142. }
  3143. if (k_servname)
  3144. {
  3145. rt_free(k_servname);
  3146. }
  3147. if (k_hints)
  3148. {
  3149. rt_free(k_hints);
  3150. }
  3151. return ret;
  3152. }
  3153. #define HOSTENT_BUFSZ 512
  3154. int sys_gethostbyname2_r(const char *name, int af, struct hostent *ret,
  3155. char *buf, size_t buflen,
  3156. struct hostent **result, int *err)
  3157. {
  3158. int ret_val = -1;
  3159. int sal_ret = -1 , sal_err = -1;
  3160. struct hostent sal_he;
  3161. struct hostent *sal_result = NULL;
  3162. char *sal_buf = NULL;
  3163. char *k_name = NULL;
  3164. int a_err = 0;
  3165. #ifdef ARCH_MM_MMU
  3166. if (!lwp_user_accessable((void *)err, sizeof(*err)))
  3167. {
  3168. SET_ERRNO(EFAULT);
  3169. goto __exit;
  3170. }
  3171. if (!lwp_user_accessable((void *)result, sizeof(*result))
  3172. || !lwp_user_accessable((void *)ret, sizeof(*ret))
  3173. || !lwp_user_accessable((void *)buf, buflen))
  3174. {
  3175. /* not all arguments given */
  3176. *err = EFAULT;
  3177. SET_ERRNO(EFAULT);
  3178. goto __exit;
  3179. }
  3180. lwp_user_strlen(name, &a_err);
  3181. if (a_err)
  3182. {
  3183. *err = EFAULT;
  3184. SET_ERRNO(EFAULT);
  3185. goto __exit;
  3186. }
  3187. #endif
  3188. *result = ret;
  3189. sal_buf = (char *)malloc(HOSTENT_BUFSZ);
  3190. if (sal_buf == NULL)
  3191. {
  3192. SET_ERRNO(ENOMEM);
  3193. goto __exit;
  3194. }
  3195. k_name = rt_strdup(name);
  3196. if (k_name == NULL)
  3197. {
  3198. SET_ERRNO(ENOMEM);
  3199. goto __exit;
  3200. }
  3201. /* get host by name in SAL */
  3202. sal_ret = sal_gethostbyname_r(k_name, &sal_he, sal_buf, HOSTENT_BUFSZ, &sal_result, &sal_err);
  3203. if (sal_ret == 0)
  3204. {
  3205. int index = 0, cnt = 0;
  3206. char *ptr = buf;
  3207. /* get counter */
  3208. index = 0;
  3209. while (sal_he.h_addr_list[index] != NULL)
  3210. {
  3211. index++;
  3212. }
  3213. cnt = index + 1;
  3214. /* update user space hostent */
  3215. ret->h_addrtype = sal_he.h_addrtype;
  3216. ret->h_length = sal_he.h_length;
  3217. rt_strncpy(ptr, k_name, buflen - (ptr - buf));
  3218. ret->h_name = ptr;
  3219. ptr += rt_strlen(k_name);
  3220. ret->h_addr_list = (char**)ptr;
  3221. ptr += cnt * sizeof(char *);
  3222. index = 0;
  3223. while (sal_he.h_addr_list[index] != NULL)
  3224. {
  3225. ret->h_addr_list[index] = ptr;
  3226. rt_memcpy(ptr, sal_he.h_addr_list[index], sal_he.h_length);
  3227. ptr += sal_he.h_length;
  3228. index++;
  3229. }
  3230. ret->h_addr_list[index] = NULL;
  3231. }
  3232. ret_val = 0;
  3233. __exit:
  3234. if (ret_val < 0)
  3235. {
  3236. ret_val = GET_ERRNO();
  3237. }
  3238. /* release buffer */
  3239. if (sal_buf)
  3240. {
  3241. free(sal_buf);
  3242. }
  3243. if (k_name)
  3244. {
  3245. free(k_name);
  3246. }
  3247. return ret_val;
  3248. }
  3249. #endif
  3250. char *sys_getcwd(char *buf, size_t size)
  3251. {
  3252. if (!lwp_user_accessable((void *)buf, size))
  3253. {
  3254. return RT_NULL;
  3255. }
  3256. getcwd(buf, size);
  3257. return (char *)strlen(buf);
  3258. }
  3259. int sys_chdir(const char *path)
  3260. {
  3261. #ifdef ARCH_MM_MMU
  3262. int err = 0;
  3263. lwp_user_strlen(path, &err);
  3264. if (err)
  3265. {
  3266. return -EFAULT;
  3267. }
  3268. err = chdir(path);
  3269. return (err < 0 ? GET_ERRNO() : err);
  3270. #else
  3271. int ret = chdir(path);
  3272. return (ret < 0 ? GET_ERRNO() : ret);
  3273. #endif
  3274. }
  3275. int sys_mkdir(const char *path, mode_t mode)
  3276. {
  3277. #ifdef ARCH_MM_MMU
  3278. int err = 0;
  3279. lwp_user_strlen(path, &err);
  3280. if (err)
  3281. {
  3282. return -EFAULT;
  3283. }
  3284. err = mkdir(path, mode);
  3285. return (err < 0 ? GET_ERRNO() : err);
  3286. #else
  3287. int ret = mkdir(path, mode);
  3288. return (ret < 0 ? GET_ERRNO() : ret);
  3289. #endif
  3290. }
  3291. int sys_rmdir(const char *path)
  3292. {
  3293. #ifdef ARCH_MM_MMU
  3294. int err = 0;
  3295. lwp_user_strlen(path, &err);
  3296. if (err)
  3297. {
  3298. return -EFAULT;
  3299. }
  3300. err = unlink(path);
  3301. return (err < 0 ? GET_ERRNO() : err);
  3302. #else
  3303. int ret = unlink(path);
  3304. return (ret < 0 ? GET_ERRNO() : ret);
  3305. #endif
  3306. }
  3307. #ifdef RT_USING_MUSL
  3308. typedef uint64_t ino_t;
  3309. #endif
  3310. struct libc_dirent {
  3311. ino_t d_ino;
  3312. off_t d_off;
  3313. unsigned short d_reclen;
  3314. unsigned char d_type;
  3315. char d_name[256];
  3316. };
  3317. int sys_getdents(int fd, struct libc_dirent *dirp, size_t nbytes)
  3318. {
  3319. int ret = -1;
  3320. struct dfs_fd *dfs_fd;
  3321. size_t cnt = (nbytes / sizeof(struct libc_dirent));
  3322. size_t rtt_nbytes = 0;
  3323. struct dirent *rtt_dirp;
  3324. #ifdef ARCH_MM_MMU
  3325. if (!lwp_user_accessable((void *)dirp, sizeof(struct libc_dirent)))
  3326. {
  3327. return -EFAULT;
  3328. }
  3329. #endif
  3330. if (cnt == 0)
  3331. {
  3332. return -EINVAL;
  3333. }
  3334. rtt_nbytes = cnt * sizeof(struct dirent);
  3335. rtt_dirp = (struct dirent *)rt_malloc(rtt_nbytes);
  3336. if (!rtt_dirp)
  3337. {
  3338. return -ENOMEM;
  3339. }
  3340. dfs_fd = fd_get(fd);
  3341. ret = dfs_file_getdents(dfs_fd, rtt_dirp, rtt_nbytes);
  3342. if (ret > 0)
  3343. {
  3344. size_t i = 0;
  3345. cnt = ret / sizeof(struct dirent);
  3346. for (i = 0; i < cnt; i++)
  3347. {
  3348. dirp[i].d_ino = 0;
  3349. dirp[i].d_off = i*sizeof(struct libc_dirent);
  3350. dirp[i].d_type = rtt_dirp[i].d_type;
  3351. dirp[i].d_reclen = sizeof(struct libc_dirent);
  3352. strcpy(dirp[i].d_name, rtt_dirp[i].d_name);
  3353. }
  3354. ret = cnt * sizeof(struct libc_dirent);
  3355. }
  3356. if (ret < 0)
  3357. {
  3358. ret = GET_ERRNO();
  3359. }
  3360. rt_free(rtt_dirp);
  3361. return ret;
  3362. }
  3363. rt_err_t sys_get_errno(void)
  3364. {
  3365. return rt_get_errno();
  3366. }
  3367. #ifdef ARCH_MM_MMU
  3368. int sys_set_thread_area(void *p)
  3369. {
  3370. rt_thread_t thread;
  3371. thread = rt_thread_self();
  3372. thread->thread_idr = p;
  3373. arch_set_thread_area(p);
  3374. return 0;
  3375. }
  3376. int sys_set_tid_address(int *tidptr)
  3377. {
  3378. rt_thread_t thread;
  3379. #ifdef ARCH_MM_MMU
  3380. if (!lwp_user_accessable((void *)tidptr, sizeof(int)))
  3381. {
  3382. return -EFAULT;
  3383. }
  3384. #endif
  3385. thread = rt_thread_self();
  3386. thread->clear_child_tid = tidptr;
  3387. return thread->tid;
  3388. }
  3389. #endif /* ARCH_MM_MMU */
  3390. int sys_gettid(void)
  3391. {
  3392. return rt_thread_self()->tid;
  3393. }
  3394. int sys_access(const char *filename, int mode)
  3395. {
  3396. int ret = 0;
  3397. #ifdef ARCH_MM_MMU
  3398. rt_size_t len = 0;
  3399. char *kname = RT_NULL;
  3400. int a_err = 0;
  3401. lwp_user_strlen(filename, &a_err);
  3402. if (a_err)
  3403. {
  3404. return -EFAULT;
  3405. }
  3406. len = rt_strlen(filename);
  3407. if (!len)
  3408. {
  3409. return -EINVAL;
  3410. }
  3411. kname = (char *)kmem_get(len + 1);
  3412. if (!kname)
  3413. {
  3414. return -ENOMEM;
  3415. }
  3416. lwp_get_from_user(kname, (void *)filename, len + 1);
  3417. ret = access(kname, mode);
  3418. if (ret < 0)
  3419. {
  3420. ret = GET_ERRNO();
  3421. }
  3422. kmem_put(kname);
  3423. return ret;
  3424. #else
  3425. ret = access(filename, mode);
  3426. return (ret < 0 ? GET_ERRNO() : ret);
  3427. #endif
  3428. }
  3429. int sys_pipe(int fd[2])
  3430. {
  3431. int ret;
  3432. if (!lwp_user_accessable((void *)fd, sizeof(int[2])))
  3433. {
  3434. return -EFAULT;
  3435. }
  3436. ret = pipe(fd);
  3437. return (ret < 0 ? GET_ERRNO() : ret);
  3438. }
  3439. int sys_clock_settime(clockid_t clk, const struct timespec *ts)
  3440. {
  3441. int ret = 0;
  3442. #ifdef ARCH_MM_MMU
  3443. size_t size = sizeof(struct timespec);
  3444. struct timespec *kts = NULL;
  3445. if (!lwp_user_accessable((void *)ts, size))
  3446. {
  3447. return -EFAULT;
  3448. }
  3449. kts = kmem_get(size);
  3450. if (!kts)
  3451. {
  3452. return -ENOMEM;
  3453. }
  3454. lwp_get_from_user(kts, (void *)ts, size);
  3455. ret = clock_settime(clk, kts);
  3456. if (ret < 0)
  3457. {
  3458. ret = GET_ERRNO();
  3459. }
  3460. kmem_put(kts);
  3461. return ret;
  3462. #else
  3463. if (!lwp_user_accessable((void *)ts, sizeof(struct timespec)))
  3464. {
  3465. return -EFAULT;
  3466. }
  3467. ret = clock_settime(clk, ts);
  3468. return (ret < 0 ? GET_ERRNO() : ret);
  3469. #endif
  3470. }
  3471. int sys_clock_gettime(clockid_t clk, struct timespec *ts)
  3472. {
  3473. int ret = 0;
  3474. #ifdef ARCH_MM_MMU
  3475. size_t size = sizeof(struct timespec);
  3476. struct timespec *kts = NULL;
  3477. if (!lwp_user_accessable((void *)ts, size))
  3478. {
  3479. return -EFAULT;
  3480. }
  3481. kts = kmem_get(size);
  3482. if (!kts)
  3483. {
  3484. return -ENOMEM;
  3485. }
  3486. ret = clock_gettime(clk, kts);
  3487. if (ret != -1)
  3488. lwp_put_to_user(ts, kts, size);
  3489. if (ret < 0)
  3490. {
  3491. ret = GET_ERRNO();
  3492. }
  3493. kmem_put(kts);
  3494. return ret;
  3495. #else
  3496. if (!lwp_user_accessable((void *)ts, sizeof(struct timespec)))
  3497. {
  3498. return -EFAULT;
  3499. }
  3500. ret = clock_gettime(clk, ts);
  3501. return (ret < 0 ? GET_ERRNO() : ret);
  3502. #endif
  3503. }
  3504. int sys_clock_nanosleep(clockid_t clk, int flags, const struct timespec *rqtp, struct timespec *rmtp)
  3505. {
  3506. int ret = 0;
  3507. dbg_log(DBG_LOG, "sys_nanosleep\n");
  3508. if (!lwp_user_accessable((void *)rqtp, sizeof *rqtp))
  3509. return -EFAULT;
  3510. #ifdef ARCH_MM_MMU
  3511. struct timespec rqtp_k;
  3512. struct timespec rmtp_k;
  3513. lwp_get_from_user(&rqtp_k, (void *)rqtp, sizeof rqtp_k);
  3514. ret = clock_nanosleep(clk, flags, &rqtp_k, &rmtp_k);
  3515. if ((ret != -1 || rt_get_errno() == EINTR) && rmtp && lwp_user_accessable((void *)rmtp, sizeof *rmtp))
  3516. {
  3517. lwp_put_to_user(rmtp, (void *)&rmtp_k, sizeof rmtp_k);
  3518. if(ret != 0)
  3519. return -EINTR;
  3520. }
  3521. #else
  3522. if (rmtp)
  3523. {
  3524. if (!lwp_user_accessable((void *)rmtp, sizeof *rmtp))
  3525. return -EFAULT;
  3526. ret = clock_nanosleep(clk, flags, rqtp, rmtp);
  3527. }
  3528. #endif
  3529. return (ret < 0 ? GET_ERRNO() : ret);
  3530. }
  3531. int sys_clock_getres(clockid_t clk, struct timespec *ts)
  3532. {
  3533. int ret = 0;
  3534. #ifdef ARCH_MM_MMU
  3535. struct timespec kts;
  3536. size_t size = sizeof(struct timespec);
  3537. if (!lwp_user_accessable((void *)ts, size))
  3538. {
  3539. return -EFAULT;
  3540. }
  3541. ret = clock_getres(clk, &kts);
  3542. if (ret != -1)
  3543. lwp_put_to_user(ts, &kts, size);
  3544. #else
  3545. if (!lwp_user_accessable((void *)ts, sizeof(struct timespec)))
  3546. {
  3547. return -EFAULT;
  3548. }
  3549. ret = clock_getres(clk, ts);
  3550. #endif
  3551. return (ret < 0 ? GET_ERRNO() : ret);
  3552. }
  3553. int sys_rename(const char *oldpath, const char *newpath)
  3554. {
  3555. int ret = -1;
  3556. #ifdef ARCH_MM_MMU
  3557. int err;
  3558. lwp_user_strlen(oldpath, &err);
  3559. if (err)
  3560. {
  3561. return -EFAULT;
  3562. }
  3563. lwp_user_strlen(newpath, &err);
  3564. if (err)
  3565. {
  3566. return -EFAULT;
  3567. }
  3568. #endif
  3569. ret = rename(oldpath, newpath);
  3570. return (ret < 0 ? GET_ERRNO() : ret);
  3571. }
  3572. typedef unsigned long long rlim_t;
  3573. struct rlimit {
  3574. rlim_t rlim_cur;
  3575. rlim_t rlim_max;
  3576. };
  3577. #define RLIMIT_CPU 0
  3578. #define RLIMIT_FSIZE 1
  3579. #define RLIMIT_DATA 2
  3580. #define RLIMIT_STACK 3
  3581. #define RLIMIT_CORE 4
  3582. #define RLIMIT_RSS 5
  3583. #define RLIMIT_NPROC 6
  3584. #define RLIMIT_NOFILE 7
  3585. #define RLIMIT_MEMLOCK 8
  3586. #define RLIMIT_AS 9
  3587. int sys_prlimit64(pid_t pid,
  3588. unsigned int resource,
  3589. const struct rlimit *new_rlim,
  3590. struct rlimit *old_rlim)
  3591. {
  3592. return -ENOSYS;
  3593. }
  3594. int sys_getrlimit(unsigned int resource, unsigned long rlim[2])
  3595. {
  3596. int ret = -1;
  3597. if (!lwp_user_accessable((void *)rlim, sizeof(unsigned long [2])))
  3598. {
  3599. return -EFAULT;
  3600. }
  3601. switch (resource)
  3602. {
  3603. case RLIMIT_NOFILE:
  3604. {
  3605. struct dfs_fdtable *fdt = dfs_fdtable_get();
  3606. dfs_fd_lock();
  3607. rlim[0] = fdt->maxfd;
  3608. dfs_fd_unlock();
  3609. rlim[1] = DFS_FD_MAX;
  3610. ret = 0;
  3611. }
  3612. break;
  3613. default:
  3614. return -EINVAL;
  3615. break;
  3616. }
  3617. return (ret < 0 ? GET_ERRNO() : ret);
  3618. }
  3619. int sys_setrlimit(unsigned int resource, struct rlimit *rlim)
  3620. {
  3621. return -ENOSYS;
  3622. }
  3623. int sys_setsid(void)
  3624. {
  3625. int ret = 0;
  3626. ret = setsid();
  3627. return (ret < 0 ? GET_ERRNO() : ret);
  3628. }
  3629. int sys_getrandom(void *buf, size_t buflen, unsigned int flags)
  3630. {
  3631. int ret = -1;
  3632. int count = 0;
  3633. void *kmem = RT_NULL;
  3634. rt_device_t rd_dev = RT_NULL;
  3635. if (flags & GRND_RANDOM)
  3636. rd_dev = rt_device_find("random");
  3637. else
  3638. rd_dev = rt_device_find("urandom");
  3639. if (rd_dev == RT_NULL)
  3640. {
  3641. return -EFAULT;
  3642. }
  3643. if (rt_device_open(rd_dev, RT_DEVICE_OFLAG_RDONLY) != RT_EOK)
  3644. {
  3645. return -EFAULT;
  3646. }
  3647. if (!lwp_user_accessable(buf, buflen))
  3648. {
  3649. rt_device_close(rd_dev);
  3650. return -EFAULT;
  3651. }
  3652. #ifdef ARCH_MM_MMU
  3653. kmem = kmem_get(buflen);
  3654. if (!kmem)
  3655. {
  3656. rt_device_close(rd_dev);
  3657. return -ENOMEM;
  3658. }
  3659. while (count < buflen)
  3660. {
  3661. ret = rt_device_read(rd_dev, count, (char *)kmem + count, buflen - count);
  3662. if (ret <= 0)
  3663. break;
  3664. count += ret;
  3665. }
  3666. rt_device_close(rd_dev);
  3667. ret = count;
  3668. if (count > 0)
  3669. {
  3670. ret = lwp_put_to_user(buf, kmem, count);
  3671. }
  3672. kmem_put(kmem);
  3673. #else
  3674. while (count < buflen)
  3675. {
  3676. ret = rt_device_read(rd_dev, count, (char *)kmem + count, buflen - count);
  3677. if (ret <= 0)
  3678. break;
  3679. count += ret;
  3680. }
  3681. rt_device_close(rd_dev);
  3682. ret = count;
  3683. #endif
  3684. return ret;
  3685. }
  3686. ssize_t sys_readlink(char* path, char *buf, size_t bufsz)
  3687. {
  3688. size_t len, copy_len;
  3689. int err;
  3690. int fd = -1;
  3691. struct dfs_fd *d;
  3692. char *copy_path;
  3693. len = lwp_user_strlen(path, &err);
  3694. if (err)
  3695. {
  3696. return -EFAULT;
  3697. }
  3698. if (!lwp_user_accessable(buf, bufsz))
  3699. {
  3700. return -EINVAL;
  3701. }
  3702. copy_path = (char*)rt_malloc(len + 1);
  3703. if (!copy_path)
  3704. {
  3705. return -ENOMEM;
  3706. }
  3707. copy_len = lwp_get_from_user(copy_path, path, len);
  3708. copy_path[copy_len] = '\0';
  3709. /* musl __procfdname */
  3710. err = sscanf(copy_path, "/proc/self/fd/%d", &fd);
  3711. rt_free(copy_path);
  3712. if (err != 1)
  3713. {
  3714. LOG_E("readlink: path not is /proc/self/fd/* , call by musl __procfdname()?");
  3715. return -EINVAL;
  3716. }
  3717. d = fd_get(fd);
  3718. if (!d)
  3719. {
  3720. return -EBADF;
  3721. }
  3722. if (!d->vnode)
  3723. {
  3724. return -EBADF;
  3725. }
  3726. copy_len = strlen(d->vnode->fullpath);
  3727. if (copy_len > bufsz)
  3728. {
  3729. copy_len = bufsz;
  3730. }
  3731. bufsz = lwp_put_to_user(buf, d->vnode->fullpath, copy_len);
  3732. return bufsz;
  3733. }
  3734. int sys_setaffinity(pid_t pid, size_t size, void *set)
  3735. {
  3736. if (!lwp_user_accessable(set, sizeof(cpu_set_t)))
  3737. {
  3738. return -EFAULT;
  3739. }
  3740. for (int i = 0;i < size * 8; i++)
  3741. {
  3742. if (CPU_ISSET(i, (cpu_set_t *)set))
  3743. {
  3744. return lwp_setaffinity(pid, i);
  3745. }
  3746. }
  3747. return -1;
  3748. }
  3749. int sys_sched_setparam(pid_t pid, void *param)
  3750. {
  3751. struct sched_param *sched_param = (struct sched_param *)param;
  3752. struct rt_lwp *lwp = NULL;
  3753. rt_thread_t main_thread;
  3754. int ret = -1;
  3755. if (!lwp_user_accessable(param, sizeof(struct sched_param)))
  3756. {
  3757. return -EFAULT;
  3758. }
  3759. if (pid > 0)
  3760. {
  3761. lwp = lwp_from_pid(pid);
  3762. }
  3763. else if (pid == 0)
  3764. {
  3765. lwp = lwp_self();
  3766. }
  3767. if (lwp)
  3768. {
  3769. main_thread = rt_list_entry(lwp->t_grp.prev, struct rt_thread, sibling);
  3770. return rt_thread_control(main_thread, RT_THREAD_CTRL_CHANGE_PRIORITY, (void *)&sched_param->sched_priority);
  3771. }
  3772. return ret;
  3773. }
  3774. int sys_sched_getparam(pid_t pid, void *param)
  3775. {
  3776. struct sched_param *sched_param = (struct sched_param *)param;
  3777. struct rt_lwp *lwp = NULL;
  3778. rt_thread_t main_thread;
  3779. int ret = -1;
  3780. if (!lwp_user_accessable(param, sizeof(struct sched_param)))
  3781. {
  3782. return -EFAULT;
  3783. }
  3784. if (pid > 0)
  3785. {
  3786. lwp = lwp_from_pid(pid);
  3787. }
  3788. else if (pid == 0)
  3789. {
  3790. lwp = lwp_self();
  3791. }
  3792. if (lwp)
  3793. {
  3794. main_thread = rt_list_entry(lwp->t_grp.prev, struct rt_thread, sibling);
  3795. sched_param->sched_priority = main_thread->current_priority;
  3796. ret = 0;
  3797. }
  3798. return ret;
  3799. }
  3800. int sys_sched_get_priority_max(int policy)
  3801. {
  3802. if(policy < 0)
  3803. {
  3804. rt_set_errno(EINVAL);
  3805. return -rt_get_errno();
  3806. }
  3807. return RT_THREAD_PRIORITY_MAX;
  3808. }
  3809. int sys_sched_get_priority_min(int policy)
  3810. {
  3811. if(policy < 0)
  3812. {
  3813. rt_set_errno(EINVAL);
  3814. return -rt_get_errno();
  3815. }
  3816. return 0;
  3817. }
  3818. int sys_sched_setscheduler(int tid, int policy, void *param)
  3819. {
  3820. struct sched_param *sched_param = (struct sched_param *)param;
  3821. rt_thread_t thread = lwp_tid_get_thread(tid);
  3822. if (!lwp_user_accessable(param, sizeof(struct sched_param)))
  3823. {
  3824. return -EFAULT;
  3825. }
  3826. return rt_thread_control(thread, RT_THREAD_CTRL_CHANGE_PRIORITY, (void *)&sched_param->sched_priority);
  3827. return 0;
  3828. }
  3829. int sys_sched_getscheduler(int tid, int *policy, void *param)
  3830. {
  3831. struct sched_param *sched_param = (struct sched_param *)param;
  3832. rt_thread_t thread = lwp_tid_get_thread(tid);
  3833. if (!lwp_user_accessable(sched_param, sizeof(struct sched_param)))
  3834. {
  3835. return -EFAULT;
  3836. }
  3837. sched_param->sched_priority = thread->current_priority;
  3838. *policy = 0;
  3839. return 0;
  3840. }
  3841. int sys_fsync(int fd)
  3842. {
  3843. int res = fsync(fd);
  3844. if (res < 0)
  3845. res = rt_get_errno();
  3846. return res;
  3847. }
  3848. mqd_t sys_mq_open(const char *name, int flags, mode_t mode, struct mq_attr *attr)
  3849. {
  3850. mqd_t mqdes;
  3851. rt_err_t ret = 0;
  3852. #ifdef ARCH_MM_MMU
  3853. char *kname = RT_NULL;
  3854. int a_err = 0;
  3855. rt_size_t len = 0;
  3856. struct mq_attr attr_k;
  3857. lwp_user_strlen(name, &a_err);
  3858. if (a_err)
  3859. return (mqd_t)-EFAULT;
  3860. len = rt_strlen(name);
  3861. if (!len)
  3862. return (mqd_t)-EINVAL;
  3863. kname = (char *)kmem_get(len + 1);
  3864. if (!kname)
  3865. return (mqd_t)-ENOMEM;
  3866. lwp_get_from_user(&attr_k, (void *)attr, sizeof(struct mq_attr));
  3867. lwp_get_from_user(kname, (void *)name, len + 1);
  3868. mqdes = mq_open(kname, flags, mode, &attr_k);
  3869. if (mqdes == RT_NULL)
  3870. {
  3871. ret = GET_ERRNO();
  3872. }
  3873. lwp_put_to_user(attr, &attr_k, sizeof(struct mq_attr));
  3874. kmem_put(kname);
  3875. #else
  3876. mqdes = mq_open(name, flags, mode, attr);
  3877. #endif
  3878. if (mqdes == RT_NULL)
  3879. return (mqd_t)ret;
  3880. else
  3881. return mqdes;
  3882. }
  3883. int sys_mq_unlink(const char *name)
  3884. {
  3885. int ret = 0;
  3886. #ifdef ARCH_MM_MMU
  3887. char *kname = RT_NULL;
  3888. int a_err = 0;
  3889. rt_size_t len = 0;
  3890. lwp_user_strlen(name, &a_err);
  3891. if (a_err)
  3892. return -EFAULT;
  3893. len = rt_strlen(name);
  3894. if (!len)
  3895. return -EINVAL;
  3896. kname = (char *)kmem_get(len + 1);
  3897. if (!kname)
  3898. return -ENOMEM;
  3899. lwp_get_from_user(kname, (void *)name, len + 1);
  3900. ret = mq_unlink(kname);
  3901. if (ret < 0)
  3902. {
  3903. ret = GET_ERRNO();
  3904. }
  3905. kmem_put(kname);
  3906. return ret;
  3907. #else
  3908. ret = mq_unlink(name);
  3909. return (ret < 0 ? GET_ERRNO() : ret);
  3910. #endif
  3911. }
  3912. int sys_mq_timedsend(mqd_t mqd, const char *msg, size_t len, unsigned prio, const struct timespec *at)
  3913. {
  3914. int ret = 0;
  3915. #ifdef ARCH_MM_MMU
  3916. char *kmsg = RT_NULL;
  3917. int a_err = 0;
  3918. struct timespec at_k;
  3919. lwp_user_strlen(msg, &a_err);
  3920. if (a_err)
  3921. return -EFAULT;
  3922. kmsg = (char *)kmem_get(len + 1);
  3923. if (!kmsg)
  3924. return -ENOMEM;
  3925. lwp_get_from_user(&at_k, (void *)at, sizeof(struct timespec));
  3926. lwp_get_from_user(kmsg, (void *)msg, len + 1);
  3927. ret = mq_timedsend(mqd, kmsg, len, prio, &at_k);
  3928. if (ret < 0)
  3929. {
  3930. ret = GET_ERRNO();
  3931. }
  3932. kmem_put(kmsg);
  3933. return ret;
  3934. #else
  3935. ret = mq_timedsend(mqd, msg, len, prio, at);
  3936. return (ret < 0 ? GET_ERRNO() : ret);
  3937. #endif
  3938. }
  3939. int sys_mq_timedreceive(mqd_t mqd, char *restrict msg, size_t len, unsigned *restrict prio, const struct timespec *restrict at)
  3940. {
  3941. int ret = 0;
  3942. #ifdef ARCH_MM_MMU
  3943. char *restrict kmsg = RT_NULL;
  3944. int a_err = 0;
  3945. struct timespec at_k;
  3946. lwp_user_strlen(msg, &a_err);
  3947. if (a_err)
  3948. return -EFAULT;
  3949. kmsg = (char *restrict)kmem_get(len + 1);
  3950. if (!kmsg)
  3951. return -ENOMEM;
  3952. lwp_get_from_user(&at_k, (void *)at, sizeof(struct timespec));
  3953. lwp_get_from_user(kmsg, (void *)msg, len + 1);
  3954. ret = mq_timedreceive(mqd, kmsg, len, prio, &at_k);
  3955. if (ret > 0)
  3956. lwp_put_to_user(msg, kmsg, len + 1);
  3957. if (ret < 0)
  3958. {
  3959. ret = GET_ERRNO();
  3960. }
  3961. kmem_put(kmsg);
  3962. return ret;
  3963. #else
  3964. ret = mq_timedreceive(mqd, msg, len, prio, at);
  3965. return (ret < 0 ? GET_ERRNO() : ret);
  3966. #endif
  3967. }
  3968. int sys_mq_notify(mqd_t mqd, const struct sigevent *sev)
  3969. {
  3970. int ret = 0;
  3971. #ifdef ARCH_MM_MMU
  3972. struct sigevent sev_k;
  3973. lwp_get_from_user(&sev_k, (void *)sev, sizeof(struct timespec));
  3974. ret = mq_notify(mqd, &sev_k);
  3975. #else
  3976. ret = mq_notify(mqd, sev);
  3977. #endif
  3978. return (ret < 0 ? GET_ERRNO() : ret);
  3979. }
  3980. int sys_mq_getsetattr(mqd_t mqd, const struct mq_attr *restrict new, struct mq_attr *restrict old)
  3981. {
  3982. int ret = 0;
  3983. #ifdef ARCH_MM_MMU
  3984. size_t size = sizeof(struct mq_attr);
  3985. struct mq_attr *restrict knew = NULL;
  3986. struct mq_attr *restrict kold = NULL;
  3987. if (new != RT_NULL)
  3988. {
  3989. if (!lwp_user_accessable((void *)new, size))
  3990. return -EFAULT;
  3991. knew = kmem_get(size);
  3992. if (!knew)
  3993. return -ENOMEM;
  3994. lwp_get_from_user(knew, (void *)new, size);
  3995. }
  3996. if (!lwp_user_accessable((void *)old, size))
  3997. return -EFAULT;
  3998. kold = kmem_get(size);
  3999. if (!kold)
  4000. return -ENOMEM;
  4001. lwp_get_from_user(kold, (void *)old, size);
  4002. ret = mq_setattr(mqd, knew, kold);
  4003. if (ret != -1)
  4004. lwp_put_to_user(old, kold, size);
  4005. if (ret < 0)
  4006. {
  4007. ret = GET_ERRNO();
  4008. }
  4009. kmem_put(kold);
  4010. if (new != RT_NULL)
  4011. kmem_put(knew);
  4012. return ret;
  4013. #else
  4014. ret = mq_setattr(mqd, new, old);
  4015. return (ret < 0 ? GET_ERRNO() : ret);
  4016. #endif
  4017. }
  4018. int sys_mq_close(mqd_t mqd)
  4019. {
  4020. int ret = 0;
  4021. #ifdef ARCH_MM_MMU
  4022. ret = mq_close(mqd);
  4023. #else
  4024. ret = mq_close(mqd);
  4025. #endif
  4026. return (ret < 0 ? GET_ERRNO() : ret);
  4027. }
  4028. const static void* func_table[] =
  4029. {
  4030. SYSCALL_SIGN(sys_exit), /* 01 */
  4031. SYSCALL_SIGN(sys_read),
  4032. SYSCALL_SIGN(sys_write),
  4033. SYSCALL_SIGN(sys_lseek),
  4034. SYSCALL_SIGN(sys_open), /* 05 */
  4035. SYSCALL_SIGN(sys_close),
  4036. SYSCALL_SIGN(sys_ioctl),
  4037. SYSCALL_SIGN(sys_fstat),
  4038. SYSCALL_SIGN(sys_poll),
  4039. SYSCALL_SIGN(sys_nanosleep), /* 10 */
  4040. SYSCALL_SIGN(sys_gettimeofday),
  4041. SYSCALL_SIGN(sys_settimeofday),
  4042. SYSCALL_SIGN(sys_exec),
  4043. SYSCALL_SIGN(sys_kill),
  4044. SYSCALL_SIGN(sys_getpid), /* 15 */
  4045. SYSCALL_SIGN(sys_getpriority),
  4046. SYSCALL_SIGN(sys_setpriority),
  4047. SYSCALL_SIGN(sys_sem_create),
  4048. SYSCALL_SIGN(sys_sem_delete),
  4049. SYSCALL_SIGN(sys_sem_take), /* 20 */
  4050. SYSCALL_SIGN(sys_sem_release),
  4051. SYSCALL_SIGN(sys_mutex_create),
  4052. SYSCALL_SIGN(sys_mutex_delete),
  4053. SYSCALL_SIGN(sys_mutex_take),
  4054. SYSCALL_SIGN(sys_mutex_release), /* 25 */
  4055. SYSCALL_SIGN(sys_event_create),
  4056. SYSCALL_SIGN(sys_event_delete),
  4057. SYSCALL_SIGN(sys_event_send),
  4058. SYSCALL_SIGN(sys_event_recv),
  4059. SYSCALL_SIGN(sys_mb_create), /* 30 */
  4060. SYSCALL_SIGN(sys_mb_delete),
  4061. SYSCALL_SIGN(sys_mb_send),
  4062. SYSCALL_SIGN(sys_mb_send_wait),
  4063. SYSCALL_SIGN(sys_mb_recv),
  4064. SYSCALL_SIGN(sys_mq_create), /* 35 */
  4065. SYSCALL_SIGN(sys_mq_delete),
  4066. SYSCALL_SIGN(sys_mq_send),
  4067. SYSCALL_SIGN(sys_mq_urgent),
  4068. SYSCALL_SIGN(sys_mq_recv),
  4069. SYSCALL_SIGN(sys_thread_create), /* 40 */
  4070. SYSCALL_SIGN(sys_thread_delete),
  4071. SYSCALL_SIGN(sys_thread_startup),
  4072. SYSCALL_SIGN(sys_thread_self),
  4073. SYSCALL_SIGN(sys_channel_open),
  4074. SYSCALL_SIGN(sys_channel_close), /* 45 */
  4075. SYSCALL_SIGN(sys_channel_send),
  4076. SYSCALL_SIGN(sys_channel_send_recv_timeout),
  4077. SYSCALL_SIGN(sys_channel_reply),
  4078. SYSCALL_SIGN(sys_channel_recv_timeout),
  4079. SYSCALL_SIGN(sys_enter_critical), /* 50 */
  4080. SYSCALL_SIGN(sys_exit_critical),
  4081. SYSCALL_USPACE(SYSCALL_SIGN(sys_brk)),
  4082. SYSCALL_USPACE(SYSCALL_SIGN(sys_mmap2)),
  4083. SYSCALL_USPACE(SYSCALL_SIGN(sys_munmap)),
  4084. #ifdef ARCH_MM_MMU
  4085. SYSCALL_USPACE(SYSCALL_SIGN(sys_shmget)), /* 55 */
  4086. SYSCALL_USPACE(SYSCALL_SIGN(sys_shmrm)),
  4087. SYSCALL_USPACE(SYSCALL_SIGN(sys_shmat)),
  4088. SYSCALL_USPACE(SYSCALL_SIGN(sys_shmdt)),
  4089. #else
  4090. #ifdef RT_LWP_USING_SHM
  4091. SYSCALL_SIGN(sys_shm_alloc), /* 55 */
  4092. SYSCALL_SIGN(sys_shm_free),
  4093. SYSCALL_SIGN(sys_shm_retain),
  4094. SYSCALL_SIGN(sys_notimpl),
  4095. #else
  4096. SYSCALL_SIGN(sys_notimpl), /* 55 */
  4097. SYSCALL_SIGN(sys_notimpl),
  4098. SYSCALL_SIGN(sys_notimpl),
  4099. SYSCALL_SIGN(sys_notimpl),
  4100. #endif /* RT_LWP_USING_SHM */
  4101. #endif /* ARCH_MM_MMU */
  4102. SYSCALL_SIGN(sys_device_init),
  4103. SYSCALL_SIGN(sys_device_register), /* 60 */
  4104. SYSCALL_SIGN(sys_device_control),
  4105. SYSCALL_SIGN(sys_device_find),
  4106. SYSCALL_SIGN(sys_device_open),
  4107. SYSCALL_SIGN(sys_device_close),
  4108. SYSCALL_SIGN(sys_device_read), /* 65 */
  4109. SYSCALL_SIGN(sys_device_write),
  4110. SYSCALL_SIGN(sys_stat),
  4111. SYSCALL_SIGN(sys_thread_find),
  4112. SYSCALL_NET(SYSCALL_SIGN(sys_accept)),
  4113. SYSCALL_NET(SYSCALL_SIGN(sys_bind)), /* 70 */
  4114. SYSCALL_NET(SYSCALL_SIGN(sys_shutdown)),
  4115. SYSCALL_NET(SYSCALL_SIGN(sys_getpeername)),
  4116. SYSCALL_NET(SYSCALL_SIGN(sys_getsockname)),
  4117. SYSCALL_NET(SYSCALL_SIGN(sys_getsockopt)),
  4118. SYSCALL_NET(SYSCALL_SIGN(sys_setsockopt)), /* 75 */
  4119. SYSCALL_NET(SYSCALL_SIGN(sys_connect)),
  4120. SYSCALL_NET(SYSCALL_SIGN(sys_listen)),
  4121. SYSCALL_NET(SYSCALL_SIGN(sys_recv)),
  4122. SYSCALL_NET(SYSCALL_SIGN(sys_recvfrom)),
  4123. SYSCALL_NET(SYSCALL_SIGN(sys_send)), /* 80 */
  4124. SYSCALL_NET(SYSCALL_SIGN(sys_sendto)),
  4125. SYSCALL_NET(SYSCALL_SIGN(sys_socket)),
  4126. SYSCALL_NET(SYSCALL_SIGN(sys_closesocket)),
  4127. SYSCALL_NET(SYSCALL_SIGN(sys_getaddrinfo)),
  4128. SYSCALL_NET(SYSCALL_SIGN(sys_gethostbyname2_r)), /* 85 */
  4129. SYSCALL_SIGN(sys_notimpl), //network,
  4130. SYSCALL_SIGN(sys_notimpl), //network,
  4131. SYSCALL_SIGN(sys_notimpl), //network,
  4132. SYSCALL_SIGN(sys_notimpl), //network,
  4133. SYSCALL_SIGN(sys_notimpl), //network, /* 90 */
  4134. SYSCALL_SIGN(sys_notimpl), //network,
  4135. SYSCALL_SIGN(sys_notimpl), //network,
  4136. SYSCALL_SIGN(sys_notimpl), //network,
  4137. #ifdef RT_USING_DFS
  4138. SYSCALL_SIGN(sys_select),
  4139. #else
  4140. SYSCALL_SIGN(sys_notimpl),
  4141. #endif
  4142. SYSCALL_SIGN(sys_notimpl), //SYSCALL_SIGN(sys_hw_interrupt_disable), /* 95 */
  4143. SYSCALL_SIGN(sys_notimpl), //SYSCALL_SIGN(sys_hw_interrupt_enable),
  4144. SYSCALL_SIGN(sys_tick_get),
  4145. SYSCALL_SIGN(sys_exit_group),
  4146. SYSCALL_SIGN(sys_notimpl), //rt_delayed_work_init,
  4147. SYSCALL_SIGN(sys_notimpl), //rt_work_submit, /* 100 */
  4148. SYSCALL_SIGN(sys_notimpl), //rt_wqueue_wakeup,
  4149. SYSCALL_SIGN(sys_thread_mdelay),
  4150. SYSCALL_SIGN(sys_sigaction),
  4151. SYSCALL_SIGN(sys_sigprocmask),
  4152. SYSCALL_SIGN(sys_tkill), /* 105 */
  4153. SYSCALL_SIGN(sys_thread_sigprocmask),
  4154. #ifdef ARCH_MM_MMU
  4155. SYSCALL_SIGN(sys_cacheflush),
  4156. SYSCALL_SIGN(sys_notimpl),
  4157. SYSCALL_SIGN(sys_notimpl),
  4158. #else
  4159. SYSCALL_SIGN(sys_notimpl),
  4160. SYSCALL_SIGN(sys_lwp_sighandler_set),
  4161. SYSCALL_SIGN(sys_thread_sighandler_set),
  4162. #endif
  4163. SYSCALL_SIGN(sys_waitpid), /* 110 */
  4164. SYSCALL_SIGN(sys_rt_timer_create),
  4165. SYSCALL_SIGN(sys_rt_timer_delete),
  4166. SYSCALL_SIGN(sys_rt_timer_start),
  4167. SYSCALL_SIGN(sys_rt_timer_stop),
  4168. SYSCALL_SIGN(sys_rt_timer_control), /* 115 */
  4169. SYSCALL_SIGN(sys_getcwd),
  4170. SYSCALL_SIGN(sys_chdir),
  4171. SYSCALL_SIGN(sys_unlink),
  4172. SYSCALL_SIGN(sys_mkdir),
  4173. SYSCALL_SIGN(sys_rmdir), /* 120 */
  4174. SYSCALL_SIGN(sys_getdents),
  4175. SYSCALL_SIGN(sys_get_errno),
  4176. #ifdef ARCH_MM_MMU
  4177. SYSCALL_SIGN(sys_set_thread_area),
  4178. SYSCALL_SIGN(sys_set_tid_address),
  4179. #else
  4180. SYSCALL_SIGN(sys_notimpl),
  4181. SYSCALL_SIGN(sys_notimpl),
  4182. #endif
  4183. SYSCALL_SIGN(sys_access), /* 125 */
  4184. SYSCALL_SIGN(sys_pipe),
  4185. SYSCALL_SIGN(sys_clock_settime),
  4186. SYSCALL_SIGN(sys_clock_gettime),
  4187. SYSCALL_SIGN(sys_clock_getres),
  4188. SYSCALL_USPACE(SYSCALL_SIGN(sys_clone)), /* 130 */
  4189. SYSCALL_USPACE(SYSCALL_SIGN(sys_futex)),
  4190. SYSCALL_USPACE(SYSCALL_SIGN(sys_pmutex)),
  4191. SYSCALL_SIGN(sys_dup),
  4192. SYSCALL_SIGN(sys_dup2),
  4193. SYSCALL_SIGN(sys_rename), /* 135 */
  4194. SYSCALL_USPACE(SYSCALL_SIGN(sys_fork)),
  4195. SYSCALL_USPACE(SYSCALL_SIGN(sys_execve)),
  4196. SYSCALL_USPACE(SYSCALL_SIGN(sys_vfork)),
  4197. SYSCALL_SIGN(sys_gettid),
  4198. SYSCALL_SIGN(sys_prlimit64), /* 140 */
  4199. SYSCALL_SIGN(sys_getrlimit),
  4200. SYSCALL_SIGN(sys_setrlimit),
  4201. SYSCALL_SIGN(sys_setsid),
  4202. SYSCALL_SIGN(sys_getrandom),
  4203. SYSCALL_SIGN(sys_readlink), // SYSCALL_SIGN(sys_readlink) /* 145 */
  4204. SYSCALL_USPACE(SYSCALL_SIGN(sys_mremap)),
  4205. SYSCALL_USPACE(SYSCALL_SIGN(sys_madvise)),
  4206. SYSCALL_SIGN(sys_sched_setparam),
  4207. SYSCALL_SIGN(sys_sched_getparam),
  4208. SYSCALL_SIGN(sys_sched_get_priority_max), /* 150 */
  4209. SYSCALL_SIGN(sys_sched_get_priority_min),
  4210. SYSCALL_SIGN(sys_sched_setscheduler),
  4211. SYSCALL_SIGN(sys_sched_getscheduler),
  4212. SYSCALL_SIGN(sys_setaffinity),
  4213. SYSCALL_SIGN(sys_fsync), /* 155 */
  4214. SYSCALL_SIGN(sys_clock_nanosleep),
  4215. SYSCALL_SIGN(sys_timer_create),
  4216. SYSCALL_SIGN(sys_timer_delete),
  4217. SYSCALL_SIGN(sys_timer_settime),
  4218. SYSCALL_SIGN(sys_timer_gettime), /* 160 */
  4219. SYSCALL_SIGN(sys_timer_getoverrun),
  4220. SYSCALL_SIGN(sys_mq_open),
  4221. SYSCALL_SIGN(sys_mq_unlink),
  4222. SYSCALL_SIGN(sys_mq_timedsend),
  4223. SYSCALL_SIGN(sys_mq_timedreceive),
  4224. SYSCALL_SIGN(sys_mq_notify),
  4225. SYSCALL_SIGN(sys_mq_getsetattr),
  4226. SYSCALL_SIGN(sys_mq_close),
  4227. };
  4228. const void *lwp_get_sys_api(rt_uint32_t number)
  4229. {
  4230. const void *func = (const void *)sys_notimpl;
  4231. if (number == 0xff)
  4232. {
  4233. func = (void *)sys_log;
  4234. }
  4235. else
  4236. {
  4237. number -= 1;
  4238. if (number < sizeof(func_table) / sizeof(func_table[0]) / 2)
  4239. {
  4240. func = func_table[number << 1];
  4241. }
  4242. }
  4243. return func;
  4244. }
  4245. const char *lwp_get_syscall_name(rt_uint32_t number)
  4246. {
  4247. const char *name = "sys_notimpl";
  4248. if (number == 0xff)
  4249. {
  4250. name = "sys_log";
  4251. }
  4252. else
  4253. {
  4254. number -= 1;
  4255. if (number < sizeof(func_table) / sizeof(func_table[0]) / 2)
  4256. {
  4257. name = (char*)func_table[(number << 1) + 1];
  4258. }
  4259. }
  4260. // skip sys_
  4261. return name + 4;
  4262. }