lwp_syscall.c 126 KB

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