wayland_thread.cpp 137 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416
  1. /**************************************************************************/
  2. /* wayland_thread.cpp */
  3. /**************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* https://godotengine.org */
  7. /**************************************************************************/
  8. /* Copyright (c) 2014-present Godot Engine contributors (see AUTHORS.md). */
  9. /* Copyright (c) 2007-2014 Juan Linietsky, Ariel Manzur. */
  10. /* */
  11. /* Permission is hereby granted, free of charge, to any person obtaining */
  12. /* a copy of this software and associated documentation files (the */
  13. /* "Software"), to deal in the Software without restriction, including */
  14. /* without limitation the rights to use, copy, modify, merge, publish, */
  15. /* distribute, sublicense, and/or sell copies of the Software, and to */
  16. /* permit persons to whom the Software is furnished to do so, subject to */
  17. /* the following conditions: */
  18. /* */
  19. /* The above copyright notice and this permission notice shall be */
  20. /* included in all copies or substantial portions of the Software. */
  21. /* */
  22. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  23. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  24. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. */
  25. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  26. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  27. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  28. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  29. /**************************************************************************/
  30. #include "wayland_thread.h"
  31. #ifdef WAYLAND_ENABLED
  32. // FIXME: Does this cause issues with *BSDs?
  33. #include <linux/input-event-codes.h>
  34. // For the actual polling thread.
  35. #include <poll.h>
  36. // For shared memory buffer creation.
  37. #include <fcntl.h>
  38. #include <sys/mman.h>
  39. #include <unistd.h>
  40. // Fix the wl_array_for_each macro to work with C++. This is based on the
  41. // original from `wayland-util.h` in the Wayland client library.
  42. #undef wl_array_for_each
  43. #define wl_array_for_each(pos, array) \
  44. for (pos = (decltype(pos))(array)->data; (const char *)pos < ((const char *)(array)->data + (array)->size); (pos)++)
  45. #define WAYLAND_THREAD_DEBUG_LOGS_ENABLED
  46. #ifdef WAYLAND_THREAD_DEBUG_LOGS_ENABLED
  47. #define DEBUG_LOG_WAYLAND_THREAD(...) print_verbose(__VA_ARGS__)
  48. #else
  49. #define DEBUG_LOG_WAYLAND_THREAD(...)
  50. #endif
  51. // Read the content pointed by fd into a Vector<uint8_t>.
  52. Vector<uint8_t> WaylandThread::_read_fd(int fd) {
  53. // This is pretty much an arbitrary size.
  54. uint32_t chunk_size = 2048;
  55. LocalVector<uint8_t> data;
  56. data.resize(chunk_size);
  57. uint32_t bytes_read = 0;
  58. while (true) {
  59. ssize_t last_bytes_read = read(fd, data.ptr() + bytes_read, chunk_size);
  60. if (last_bytes_read < 0) {
  61. ERR_PRINT(vformat("Read error %d.", errno));
  62. data.clear();
  63. break;
  64. }
  65. if (last_bytes_read == 0) {
  66. // We're done, we've reached the EOF.
  67. DEBUG_LOG_WAYLAND_THREAD(vformat("Done reading %d bytes.", bytes_read));
  68. close(fd);
  69. data.resize(bytes_read);
  70. break;
  71. }
  72. DEBUG_LOG_WAYLAND_THREAD(vformat("Read chunk of %d bytes.", last_bytes_read));
  73. bytes_read += last_bytes_read;
  74. // Increase the buffer size by one chunk in preparation of the next read.
  75. data.resize(bytes_read + chunk_size);
  76. }
  77. return data;
  78. }
  79. // Based on the wayland book's shared memory boilerplate (PD/CC0).
  80. // See: https://wayland-book.com/surfaces/shared-memory.html
  81. int WaylandThread::_allocate_shm_file(size_t size) {
  82. int retries = 100;
  83. do {
  84. // Generate a random name.
  85. char name[] = "/wl_shm-godot-XXXXXX";
  86. for (long unsigned int i = sizeof(name) - 7; i < sizeof(name) - 1; i++) {
  87. name[i] = Math::random('A', 'Z');
  88. }
  89. // Try to open a shared memory object with that name.
  90. int fd = shm_open(name, O_RDWR | O_CREAT | O_EXCL, 0600);
  91. if (fd >= 0) {
  92. // Success, unlink its name as we just need the file descriptor.
  93. shm_unlink(name);
  94. // Resize the file to the requested length.
  95. int ret;
  96. do {
  97. ret = ftruncate(fd, size);
  98. } while (ret < 0 && errno == EINTR);
  99. if (ret < 0) {
  100. close(fd);
  101. return -1;
  102. }
  103. return fd;
  104. }
  105. retries--;
  106. } while (retries > 0 && errno == EEXIST);
  107. return -1;
  108. }
  109. // Return the content of a wl_data_offer.
  110. Vector<uint8_t> WaylandThread::_wl_data_offer_read(struct wl_display *p_display, const char *p_mime, struct wl_data_offer *p_offer) {
  111. if (!p_offer) {
  112. return Vector<uint8_t>();
  113. }
  114. int fds[2];
  115. if (pipe(fds) == 0) {
  116. wl_data_offer_receive(p_offer, p_mime, fds[1]);
  117. // Let the compositor know about the pipe.
  118. // NOTE: It's important to just flush and not roundtrip here as we would risk
  119. // running some cleanup event, like for example `wl_data_device::leave`. We're
  120. // going to wait for the message anyways as the read will probably block if
  121. // the compositor doesn't read from the other end of the pipe.
  122. wl_display_flush(p_display);
  123. // Close the write end of the pipe, which we don't need and would otherwise
  124. // just stall our next `read`s.
  125. close(fds[1]);
  126. return _read_fd(fds[0]);
  127. }
  128. return Vector<uint8_t>();
  129. }
  130. // Read the content of a wp_primary_selection_offer.
  131. Vector<uint8_t> WaylandThread::_wp_primary_selection_offer_read(struct wl_display *p_display, const char *p_mime, struct zwp_primary_selection_offer_v1 *p_offer) {
  132. if (!p_offer) {
  133. return Vector<uint8_t>();
  134. }
  135. int fds[2];
  136. if (pipe(fds) == 0) {
  137. zwp_primary_selection_offer_v1_receive(p_offer, p_mime, fds[1]);
  138. // NOTE: It's important to just flush and not roundtrip here as we would risk
  139. // running some cleanup event, like for example `wl_data_device::leave`. We're
  140. // going to wait for the message anyways as the read will probably block if
  141. // the compositor doesn't read from the other end of the pipe.
  142. wl_display_flush(p_display);
  143. // Close the write end of the pipe, which we don't need and would otherwise
  144. // just stall our next `read`s.
  145. close(fds[1]);
  146. return _read_fd(fds[0]);
  147. }
  148. return Vector<uint8_t>();
  149. }
  150. // Sets up an `InputEventKey` and returns whether it has any meaningful value.
  151. bool WaylandThread::_seat_state_configure_key_event(SeatState &p_ss, Ref<InputEventKey> p_event, xkb_keycode_t p_keycode, bool p_pressed) {
  152. // TODO: Handle keys that release multiple symbols?
  153. Key keycode = KeyMappingXKB::get_keycode(xkb_state_key_get_one_sym(p_ss.xkb_state, p_keycode));
  154. Key physical_keycode = KeyMappingXKB::get_scancode(p_keycode);
  155. KeyLocation key_location = KeyMappingXKB::get_location(p_keycode);
  156. if (physical_keycode == Key::NONE) {
  157. return false;
  158. }
  159. if (keycode == Key::NONE) {
  160. keycode = physical_keycode;
  161. }
  162. if (keycode >= Key::A + 32 && keycode <= Key::Z + 32) {
  163. keycode -= 'a' - 'A';
  164. }
  165. p_event->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  166. // Set all pressed modifiers.
  167. p_event->set_shift_pressed(p_ss.shift_pressed);
  168. p_event->set_ctrl_pressed(p_ss.ctrl_pressed);
  169. p_event->set_alt_pressed(p_ss.alt_pressed);
  170. p_event->set_meta_pressed(p_ss.meta_pressed);
  171. p_event->set_pressed(p_pressed);
  172. p_event->set_keycode(keycode);
  173. p_event->set_physical_keycode(physical_keycode);
  174. p_event->set_location(key_location);
  175. uint32_t unicode = xkb_state_key_get_utf32(p_ss.xkb_state, p_keycode);
  176. if (unicode != 0) {
  177. p_event->set_key_label(fix_key_label(unicode, keycode));
  178. } else {
  179. p_event->set_key_label(keycode);
  180. }
  181. if (p_pressed) {
  182. p_event->set_unicode(fix_unicode(unicode));
  183. }
  184. // Taken from DisplayServerX11.
  185. if (p_event->get_keycode() == Key::BACKTAB) {
  186. // Make it consistent across platforms.
  187. p_event->set_keycode(Key::TAB);
  188. p_event->set_physical_keycode(Key::TAB);
  189. p_event->set_shift_pressed(true);
  190. }
  191. return true;
  192. }
  193. void WaylandThread::_set_current_seat(struct wl_seat *p_seat) {
  194. if (p_seat == wl_seat_current) {
  195. return;
  196. }
  197. SeatState *old_state = wl_seat_get_seat_state(wl_seat_current);
  198. if (old_state) {
  199. seat_state_unlock_pointer(old_state);
  200. }
  201. SeatState *new_state = wl_seat_get_seat_state(p_seat);
  202. seat_state_unlock_pointer(new_state);
  203. wl_seat_current = p_seat;
  204. pointer_set_constraint(pointer_constraint);
  205. }
  206. // Returns whether it loaded the theme or not.
  207. bool WaylandThread::_load_cursor_theme(int p_cursor_size) {
  208. if (wl_cursor_theme) {
  209. wl_cursor_theme_destroy(wl_cursor_theme);
  210. wl_cursor_theme = nullptr;
  211. current_wl_cursor = nullptr;
  212. }
  213. if (cursor_theme_name.is_empty()) {
  214. cursor_theme_name = "default";
  215. }
  216. print_verbose(vformat("Loading cursor theme \"%s\" size %d.", cursor_theme_name, p_cursor_size));
  217. wl_cursor_theme = wl_cursor_theme_load(cursor_theme_name.utf8().get_data(), p_cursor_size, registry.wl_shm);
  218. ERR_FAIL_NULL_V_MSG(wl_cursor_theme, false, "Can't load any cursor theme.");
  219. static const char *cursor_names[] = {
  220. "left_ptr",
  221. "xterm",
  222. "hand2",
  223. "cross",
  224. "watch",
  225. "left_ptr_watch",
  226. "fleur",
  227. "dnd-move",
  228. "crossed_circle",
  229. "v_double_arrow",
  230. "h_double_arrow",
  231. "size_bdiag",
  232. "size_fdiag",
  233. "move",
  234. "row_resize",
  235. "col_resize",
  236. "question_arrow"
  237. };
  238. static const char *cursor_names_fallback[] = {
  239. nullptr,
  240. nullptr,
  241. "pointer",
  242. "cross",
  243. "wait",
  244. "progress",
  245. "grabbing",
  246. "hand1",
  247. "forbidden",
  248. "ns-resize",
  249. "ew-resize",
  250. "fd_double_arrow",
  251. "bd_double_arrow",
  252. "fleur",
  253. "sb_v_double_arrow",
  254. "sb_h_double_arrow",
  255. "help"
  256. };
  257. for (int i = 0; i < DisplayServer::CURSOR_MAX; i++) {
  258. struct wl_cursor *cursor = wl_cursor_theme_get_cursor(wl_cursor_theme, cursor_names[i]);
  259. if (!cursor && cursor_names_fallback[i]) {
  260. cursor = wl_cursor_theme_get_cursor(wl_cursor_theme, cursor_names_fallback[i]);
  261. }
  262. if (cursor && cursor->image_count > 0) {
  263. wl_cursors[i] = cursor;
  264. } else {
  265. wl_cursors[i] = nullptr;
  266. print_verbose("Failed loading cursor: " + String(cursor_names[i]));
  267. }
  268. }
  269. return true;
  270. }
  271. void WaylandThread::_update_scale(int p_scale) {
  272. if (p_scale <= cursor_scale) {
  273. return;
  274. }
  275. print_verbose(vformat("Bumping cursor scale to %d", p_scale));
  276. // There's some display that's bigger than the cache, let's update it.
  277. cursor_scale = p_scale;
  278. if (wl_cursor_theme == nullptr) {
  279. // Ugh. Either we're still initializing (this must've been called from the
  280. // first roundtrips) or we had some error while doing so. We'll trust that it
  281. // will be updated for us if needed.
  282. return;
  283. }
  284. int cursor_size = unscaled_cursor_size * p_scale;
  285. if (_load_cursor_theme(cursor_size)) {
  286. cursor_set_shape(last_cursor_shape);
  287. }
  288. }
  289. void WaylandThread::_wl_registry_on_global(void *data, struct wl_registry *wl_registry, uint32_t name, const char *interface, uint32_t version) {
  290. RegistryState *registry = (RegistryState *)data;
  291. ERR_FAIL_NULL(registry);
  292. if (strcmp(interface, wl_shm_interface.name) == 0) {
  293. registry->wl_shm = (struct wl_shm *)wl_registry_bind(wl_registry, name, &wl_shm_interface, 1);
  294. registry->wl_shm_name = name;
  295. return;
  296. }
  297. if (strcmp(interface, zxdg_exporter_v1_interface.name) == 0) {
  298. registry->xdg_exporter = (struct zxdg_exporter_v1 *)wl_registry_bind(wl_registry, name, &zxdg_exporter_v1_interface, 1);
  299. registry->xdg_exporter_name = name;
  300. return;
  301. }
  302. if (strcmp(interface, wl_compositor_interface.name) == 0) {
  303. registry->wl_compositor = (struct wl_compositor *)wl_registry_bind(wl_registry, name, &wl_compositor_interface, CLAMP((int)version, 1, 6));
  304. registry->wl_compositor_name = name;
  305. return;
  306. }
  307. if (strcmp(interface, wl_data_device_manager_interface.name) == 0) {
  308. registry->wl_data_device_manager = (struct wl_data_device_manager *)wl_registry_bind(wl_registry, name, &wl_data_device_manager_interface, CLAMP((int)version, 1, 3));
  309. registry->wl_data_device_manager_name = name;
  310. // This global creates some seat data. Let's do that for the ones already available.
  311. for (struct wl_seat *wl_seat : registry->wl_seats) {
  312. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  313. ERR_FAIL_NULL(ss);
  314. if (ss->wl_data_device == nullptr) {
  315. ss->wl_data_device = wl_data_device_manager_get_data_device(registry->wl_data_device_manager, wl_seat);
  316. wl_data_device_add_listener(ss->wl_data_device, &wl_data_device_listener, ss);
  317. }
  318. }
  319. return;
  320. }
  321. if (strcmp(interface, wl_output_interface.name) == 0) {
  322. struct wl_output *wl_output = (struct wl_output *)wl_registry_bind(wl_registry, name, &wl_output_interface, CLAMP((int)version, 1, 4));
  323. wl_proxy_tag_godot((struct wl_proxy *)wl_output);
  324. registry->wl_outputs.push_back(wl_output);
  325. ScreenState *ss = memnew(ScreenState);
  326. ss->wl_output_name = name;
  327. ss->wayland_thread = registry->wayland_thread;
  328. wl_proxy_tag_godot((struct wl_proxy *)wl_output);
  329. wl_output_add_listener(wl_output, &wl_output_listener, ss);
  330. return;
  331. }
  332. if (strcmp(interface, wl_seat_interface.name) == 0) {
  333. struct wl_seat *wl_seat = (struct wl_seat *)wl_registry_bind(wl_registry, name, &wl_seat_interface, CLAMP((int)version, 1, 9));
  334. wl_proxy_tag_godot((struct wl_proxy *)wl_seat);
  335. SeatState *ss = memnew(SeatState);
  336. ss->wl_seat = wl_seat;
  337. ss->wl_seat_name = name;
  338. ss->registry = registry;
  339. ss->wayland_thread = registry->wayland_thread;
  340. // Some extra stuff depends on other globals. We'll initialize them if the
  341. // globals are already there, otherwise we'll have to do that once and if they
  342. // get announced.
  343. //
  344. // NOTE: Don't forget to also bind/destroy with the respective global.
  345. if (!ss->wl_data_device && registry->wl_data_device_manager) {
  346. // Clipboard & DnD.
  347. ss->wl_data_device = wl_data_device_manager_get_data_device(registry->wl_data_device_manager, wl_seat);
  348. wl_data_device_add_listener(ss->wl_data_device, &wl_data_device_listener, ss);
  349. }
  350. if (!ss->wp_primary_selection_device && registry->wp_primary_selection_device_manager) {
  351. // Primary selection.
  352. ss->wp_primary_selection_device = zwp_primary_selection_device_manager_v1_get_device(registry->wp_primary_selection_device_manager, wl_seat);
  353. zwp_primary_selection_device_v1_add_listener(ss->wp_primary_selection_device, &wp_primary_selection_device_listener, ss);
  354. }
  355. if (!ss->wp_tablet_seat && registry->wp_tablet_manager) {
  356. // Tablet.
  357. ss->wp_tablet_seat = zwp_tablet_manager_v2_get_tablet_seat(registry->wp_tablet_manager, wl_seat);
  358. zwp_tablet_seat_v2_add_listener(ss->wp_tablet_seat, &wp_tablet_seat_listener, ss);
  359. }
  360. if (!ss->wp_text_input && registry->wp_text_input_manager) {
  361. // IME.
  362. ss->wp_text_input = zwp_text_input_manager_v3_get_text_input(registry->wp_text_input_manager, wl_seat);
  363. zwp_text_input_v3_add_listener(ss->wp_text_input, &wp_text_input_listener, ss);
  364. }
  365. registry->wl_seats.push_back(wl_seat);
  366. wl_seat_add_listener(wl_seat, &wl_seat_listener, ss);
  367. if (registry->wayland_thread->wl_seat_current == nullptr) {
  368. registry->wayland_thread->_set_current_seat(wl_seat);
  369. }
  370. return;
  371. }
  372. if (strcmp(interface, xdg_wm_base_interface.name) == 0) {
  373. registry->xdg_wm_base = (struct xdg_wm_base *)wl_registry_bind(wl_registry, name, &xdg_wm_base_interface, CLAMP((int)version, 1, 6));
  374. registry->xdg_wm_base_name = name;
  375. xdg_wm_base_add_listener(registry->xdg_wm_base, &xdg_wm_base_listener, nullptr);
  376. return;
  377. }
  378. if (strcmp(interface, wp_viewporter_interface.name) == 0) {
  379. registry->wp_viewporter = (struct wp_viewporter *)wl_registry_bind(wl_registry, name, &wp_viewporter_interface, 1);
  380. registry->wp_viewporter_name = name;
  381. }
  382. if (strcmp(interface, wp_fractional_scale_manager_v1_interface.name) == 0) {
  383. registry->wp_fractional_scale_manager = (struct wp_fractional_scale_manager_v1 *)wl_registry_bind(wl_registry, name, &wp_fractional_scale_manager_v1_interface, 1);
  384. registry->wp_fractional_scale_manager_name = name;
  385. // NOTE: We're not mapping the fractional scale object here because this is
  386. // supposed to be a "startup global". If for some reason this isn't true (who
  387. // knows), add a conditional branch for creating the add-on object.
  388. }
  389. if (strcmp(interface, zxdg_decoration_manager_v1_interface.name) == 0) {
  390. registry->xdg_decoration_manager = (struct zxdg_decoration_manager_v1 *)wl_registry_bind(wl_registry, name, &zxdg_decoration_manager_v1_interface, 1);
  391. registry->xdg_decoration_manager_name = name;
  392. return;
  393. }
  394. if (strcmp(interface, xdg_activation_v1_interface.name) == 0) {
  395. registry->xdg_activation = (struct xdg_activation_v1 *)wl_registry_bind(wl_registry, name, &xdg_activation_v1_interface, 1);
  396. registry->xdg_activation_name = name;
  397. return;
  398. }
  399. if (strcmp(interface, zwp_primary_selection_device_manager_v1_interface.name) == 0) {
  400. registry->wp_primary_selection_device_manager = (struct zwp_primary_selection_device_manager_v1 *)wl_registry_bind(wl_registry, name, &zwp_primary_selection_device_manager_v1_interface, 1);
  401. // This global creates some seat data. Let's do that for the ones already available.
  402. for (struct wl_seat *wl_seat : registry->wl_seats) {
  403. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  404. ERR_FAIL_NULL(ss);
  405. if (!ss->wp_primary_selection_device && registry->wp_primary_selection_device_manager) {
  406. ss->wp_primary_selection_device = zwp_primary_selection_device_manager_v1_get_device(registry->wp_primary_selection_device_manager, wl_seat);
  407. zwp_primary_selection_device_v1_add_listener(ss->wp_primary_selection_device, &wp_primary_selection_device_listener, ss);
  408. }
  409. }
  410. }
  411. if (strcmp(interface, zwp_relative_pointer_manager_v1_interface.name) == 0) {
  412. registry->wp_relative_pointer_manager = (struct zwp_relative_pointer_manager_v1 *)wl_registry_bind(wl_registry, name, &zwp_relative_pointer_manager_v1_interface, 1);
  413. registry->wp_relative_pointer_manager_name = name;
  414. return;
  415. }
  416. if (strcmp(interface, zwp_pointer_constraints_v1_interface.name) == 0) {
  417. registry->wp_pointer_constraints = (struct zwp_pointer_constraints_v1 *)wl_registry_bind(wl_registry, name, &zwp_pointer_constraints_v1_interface, 1);
  418. registry->wp_pointer_constraints_name = name;
  419. return;
  420. }
  421. if (strcmp(interface, zwp_pointer_gestures_v1_interface.name) == 0) {
  422. registry->wp_pointer_gestures = (struct zwp_pointer_gestures_v1 *)wl_registry_bind(wl_registry, name, &zwp_pointer_gestures_v1_interface, 1);
  423. registry->wp_pointer_gestures_name = name;
  424. return;
  425. }
  426. if (strcmp(interface, zwp_idle_inhibit_manager_v1_interface.name) == 0) {
  427. registry->wp_idle_inhibit_manager = (struct zwp_idle_inhibit_manager_v1 *)wl_registry_bind(wl_registry, name, &zwp_idle_inhibit_manager_v1_interface, 1);
  428. registry->wp_idle_inhibit_manager_name = name;
  429. return;
  430. }
  431. if (strcmp(interface, zwp_tablet_manager_v2_interface.name) == 0) {
  432. registry->wp_tablet_manager = (struct zwp_tablet_manager_v2 *)wl_registry_bind(wl_registry, name, &zwp_tablet_manager_v2_interface, 1);
  433. registry->wp_tablet_manager_name = name;
  434. // This global creates some seat data. Let's do that for the ones already available.
  435. for (struct wl_seat *wl_seat : registry->wl_seats) {
  436. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  437. ERR_FAIL_NULL(ss);
  438. ss->wp_tablet_seat = zwp_tablet_manager_v2_get_tablet_seat(registry->wp_tablet_manager, wl_seat);
  439. zwp_tablet_seat_v2_add_listener(ss->wp_tablet_seat, &wp_tablet_seat_listener, ss);
  440. }
  441. return;
  442. }
  443. if (strcmp(interface, zwp_text_input_manager_v3_interface.name) == 0) {
  444. registry->wp_text_input_manager = (struct zwp_text_input_manager_v3 *)wl_registry_bind(wl_registry, name, &zwp_text_input_manager_v3_interface, 1);
  445. registry->wp_text_input_manager_name = name;
  446. // This global creates some seat data. Let's do that for the ones already available.
  447. for (struct wl_seat *wl_seat : registry->wl_seats) {
  448. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  449. ERR_FAIL_NULL(ss);
  450. ss->wp_text_input = zwp_text_input_manager_v3_get_text_input(registry->wp_text_input_manager, wl_seat);
  451. zwp_text_input_v3_add_listener(ss->wp_text_input, &wp_text_input_listener, ss);
  452. }
  453. return;
  454. }
  455. }
  456. void WaylandThread::_wl_registry_on_global_remove(void *data, struct wl_registry *wl_registry, uint32_t name) {
  457. RegistryState *registry = (RegistryState *)data;
  458. ERR_FAIL_NULL(registry);
  459. if (name == registry->wl_shm_name) {
  460. if (registry->wl_shm) {
  461. wl_shm_destroy(registry->wl_shm);
  462. registry->wl_shm = nullptr;
  463. }
  464. registry->wl_shm_name = 0;
  465. return;
  466. }
  467. if (name == registry->xdg_exporter_name) {
  468. if (registry->xdg_exporter) {
  469. zxdg_exporter_v1_destroy(registry->xdg_exporter);
  470. registry->xdg_exporter = nullptr;
  471. }
  472. registry->xdg_exporter_name = 0;
  473. return;
  474. }
  475. if (name == registry->wl_compositor_name) {
  476. if (registry->wl_compositor) {
  477. wl_compositor_destroy(registry->wl_compositor);
  478. registry->wl_compositor = nullptr;
  479. }
  480. registry->wl_compositor_name = 0;
  481. return;
  482. }
  483. if (name == registry->wl_data_device_manager_name) {
  484. if (registry->wl_data_device_manager) {
  485. wl_data_device_manager_destroy(registry->wl_data_device_manager);
  486. registry->wl_data_device_manager = nullptr;
  487. }
  488. registry->wl_data_device_manager_name = 0;
  489. // This global is used to create some seat data. Let's clean it.
  490. for (struct wl_seat *wl_seat : registry->wl_seats) {
  491. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  492. ERR_FAIL_NULL(ss);
  493. if (ss->wl_data_device) {
  494. wl_data_device_destroy(ss->wl_data_device);
  495. ss->wl_data_device = nullptr;
  496. }
  497. ss->wl_data_device = nullptr;
  498. }
  499. return;
  500. }
  501. if (name == registry->xdg_wm_base_name) {
  502. if (registry->xdg_wm_base) {
  503. xdg_wm_base_destroy(registry->xdg_wm_base);
  504. registry->xdg_wm_base = nullptr;
  505. }
  506. registry->xdg_wm_base_name = 0;
  507. return;
  508. }
  509. if (name == registry->wp_viewporter_name) {
  510. WindowState *ws = &registry->wayland_thread->main_window;
  511. if (registry->wp_viewporter) {
  512. wp_viewporter_destroy(registry->wp_viewporter);
  513. registry->wp_viewporter = nullptr;
  514. }
  515. if (ws->wp_viewport) {
  516. wp_viewport_destroy(ws->wp_viewport);
  517. ws->wp_viewport = nullptr;
  518. }
  519. registry->wp_viewporter_name = 0;
  520. return;
  521. }
  522. if (name == registry->wp_fractional_scale_manager_name) {
  523. WindowState *ws = &registry->wayland_thread->main_window;
  524. if (registry->wp_fractional_scale_manager) {
  525. wp_fractional_scale_manager_v1_destroy(registry->wp_fractional_scale_manager);
  526. registry->wp_fractional_scale_manager = nullptr;
  527. }
  528. if (ws->wp_fractional_scale) {
  529. wp_fractional_scale_v1_destroy(ws->wp_fractional_scale);
  530. ws->wp_fractional_scale = nullptr;
  531. }
  532. registry->wp_fractional_scale_manager_name = 0;
  533. }
  534. if (name == registry->xdg_decoration_manager_name) {
  535. if (registry->xdg_decoration_manager) {
  536. zxdg_decoration_manager_v1_destroy(registry->xdg_decoration_manager);
  537. registry->xdg_decoration_manager = nullptr;
  538. }
  539. registry->xdg_decoration_manager_name = 0;
  540. return;
  541. }
  542. if (name == registry->xdg_activation_name) {
  543. if (registry->xdg_activation) {
  544. xdg_activation_v1_destroy(registry->xdg_activation);
  545. registry->xdg_activation = nullptr;
  546. }
  547. registry->xdg_activation_name = 0;
  548. return;
  549. }
  550. if (name == registry->wp_primary_selection_device_manager_name) {
  551. if (registry->wp_primary_selection_device_manager) {
  552. zwp_primary_selection_device_manager_v1_destroy(registry->wp_primary_selection_device_manager);
  553. registry->wp_primary_selection_device_manager = nullptr;
  554. }
  555. registry->wp_primary_selection_device_manager_name = 0;
  556. // This global is used to create some seat data. Let's clean it.
  557. for (struct wl_seat *wl_seat : registry->wl_seats) {
  558. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  559. ERR_FAIL_NULL(ss);
  560. if (ss->wp_primary_selection_device) {
  561. zwp_primary_selection_device_v1_destroy(ss->wp_primary_selection_device);
  562. ss->wp_primary_selection_device = nullptr;
  563. }
  564. if (ss->wp_primary_selection_source) {
  565. zwp_primary_selection_source_v1_destroy(ss->wp_primary_selection_source);
  566. ss->wp_primary_selection_source = nullptr;
  567. }
  568. if (ss->wp_primary_selection_offer) {
  569. memfree(wp_primary_selection_offer_get_offer_state(ss->wp_primary_selection_offer));
  570. zwp_primary_selection_offer_v1_destroy(ss->wp_primary_selection_offer);
  571. ss->wp_primary_selection_offer = nullptr;
  572. }
  573. }
  574. return;
  575. }
  576. if (name == registry->wp_relative_pointer_manager_name) {
  577. if (registry->wp_relative_pointer_manager) {
  578. zwp_relative_pointer_manager_v1_destroy(registry->wp_relative_pointer_manager);
  579. registry->wp_relative_pointer_manager = nullptr;
  580. }
  581. registry->wp_relative_pointer_manager_name = 0;
  582. // This global is used to create some seat data. Let's clean it.
  583. for (struct wl_seat *wl_seat : registry->wl_seats) {
  584. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  585. ERR_FAIL_NULL(ss);
  586. if (ss->wp_relative_pointer) {
  587. zwp_relative_pointer_v1_destroy(ss->wp_relative_pointer);
  588. ss->wp_relative_pointer = nullptr;
  589. }
  590. }
  591. return;
  592. }
  593. if (name == registry->wp_pointer_constraints_name) {
  594. if (registry->wp_pointer_constraints) {
  595. zwp_pointer_constraints_v1_destroy(registry->wp_pointer_constraints);
  596. registry->wp_pointer_constraints = nullptr;
  597. }
  598. registry->wp_pointer_constraints_name = 0;
  599. // This global is used to create some seat data. Let's clean it.
  600. for (struct wl_seat *wl_seat : registry->wl_seats) {
  601. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  602. ERR_FAIL_NULL(ss);
  603. if (ss->wp_relative_pointer) {
  604. zwp_relative_pointer_v1_destroy(ss->wp_relative_pointer);
  605. ss->wp_relative_pointer = nullptr;
  606. }
  607. if (ss->wp_locked_pointer) {
  608. zwp_locked_pointer_v1_destroy(ss->wp_locked_pointer);
  609. ss->wp_locked_pointer = nullptr;
  610. }
  611. if (ss->wp_confined_pointer) {
  612. zwp_confined_pointer_v1_destroy(ss->wp_confined_pointer);
  613. ss->wp_confined_pointer = nullptr;
  614. }
  615. }
  616. return;
  617. }
  618. if (name == registry->wp_pointer_gestures_name) {
  619. if (registry->wp_pointer_gestures) {
  620. zwp_pointer_gestures_v1_destroy(registry->wp_pointer_gestures);
  621. }
  622. registry->wp_pointer_gestures = nullptr;
  623. registry->wp_pointer_gestures_name = 0;
  624. // This global is used to create some seat data. Let's clean it.
  625. for (struct wl_seat *wl_seat : registry->wl_seats) {
  626. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  627. ERR_FAIL_NULL(ss);
  628. if (ss->wp_pointer_gesture_pinch) {
  629. zwp_pointer_gesture_pinch_v1_destroy(ss->wp_pointer_gesture_pinch);
  630. ss->wp_pointer_gesture_pinch = nullptr;
  631. }
  632. }
  633. return;
  634. }
  635. if (name == registry->wp_idle_inhibit_manager_name) {
  636. if (registry->wp_idle_inhibit_manager) {
  637. zwp_idle_inhibit_manager_v1_destroy(registry->wp_idle_inhibit_manager);
  638. registry->wp_idle_inhibit_manager = nullptr;
  639. }
  640. registry->wp_idle_inhibit_manager_name = 0;
  641. return;
  642. }
  643. if (name == registry->wp_tablet_manager_name) {
  644. if (registry->wp_tablet_manager) {
  645. zwp_tablet_manager_v2_destroy(registry->wp_tablet_manager);
  646. registry->wp_tablet_manager = nullptr;
  647. }
  648. registry->wp_tablet_manager_name = 0;
  649. // This global is used to create some seat data. Let's clean it.
  650. for (struct wl_seat *wl_seat : registry->wl_seats) {
  651. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  652. ERR_FAIL_NULL(ss);
  653. for (struct zwp_tablet_tool_v2 *tool : ss->tablet_tools) {
  654. TabletToolState *state = wp_tablet_tool_get_state(tool);
  655. if (state) {
  656. memdelete(state);
  657. }
  658. zwp_tablet_tool_v2_destroy(tool);
  659. }
  660. ss->tablet_tools.clear();
  661. }
  662. return;
  663. }
  664. if (name == registry->wp_text_input_manager_name) {
  665. if (registry->wp_text_input_manager) {
  666. zwp_text_input_manager_v3_destroy(registry->wp_text_input_manager);
  667. registry->wp_text_input_manager = nullptr;
  668. }
  669. registry->wp_text_input_manager_name = 0;
  670. for (struct wl_seat *wl_seat : registry->wl_seats) {
  671. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  672. ERR_FAIL_NULL(ss);
  673. zwp_text_input_v3_destroy(ss->wp_text_input);
  674. ss->wp_text_input = nullptr;
  675. }
  676. return;
  677. }
  678. {
  679. // Iterate through all of the seats to find if any got removed.
  680. List<struct wl_seat *>::Element *E = registry->wl_seats.front();
  681. while (E) {
  682. struct wl_seat *wl_seat = E->get();
  683. List<struct wl_seat *>::Element *N = E->next();
  684. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  685. ERR_FAIL_NULL(ss);
  686. if (ss->wl_seat_name == name) {
  687. if (wl_seat) {
  688. wl_seat_destroy(wl_seat);
  689. }
  690. if (ss->wl_data_device) {
  691. wl_data_device_destroy(ss->wl_data_device);
  692. }
  693. if (ss->wp_tablet_seat) {
  694. zwp_tablet_seat_v2_destroy(ss->wp_tablet_seat);
  695. for (struct zwp_tablet_tool_v2 *tool : ss->tablet_tools) {
  696. TabletToolState *state = wp_tablet_tool_get_state(tool);
  697. if (state) {
  698. memdelete(state);
  699. }
  700. zwp_tablet_tool_v2_destroy(tool);
  701. }
  702. }
  703. memdelete(ss);
  704. registry->wl_seats.erase(E);
  705. return;
  706. }
  707. E = N;
  708. }
  709. }
  710. {
  711. // Iterate through all of the outputs to find if any got removed.
  712. // FIXME: This is a very bruteforce approach.
  713. List<struct wl_output *>::Element *it = registry->wl_outputs.front();
  714. while (it) {
  715. // Iterate through all of the screens to find if any got removed.
  716. struct wl_output *wl_output = it->get();
  717. ERR_FAIL_NULL(wl_output);
  718. ScreenState *ss = wl_output_get_screen_state(wl_output);
  719. if (ss->wl_output_name == name) {
  720. registry->wl_outputs.erase(it);
  721. memdelete(ss);
  722. wl_output_destroy(wl_output);
  723. return;
  724. }
  725. it = it->next();
  726. }
  727. }
  728. }
  729. void WaylandThread::_wl_surface_on_enter(void *data, struct wl_surface *wl_surface, struct wl_output *wl_output) {
  730. if (!wl_output || !wl_proxy_is_godot((struct wl_proxy *)wl_output)) {
  731. // This won't have the right data bound to it. Not worth it and would probably
  732. // just break everything.
  733. return;
  734. }
  735. WindowState *ws = (WindowState *)data;
  736. ERR_FAIL_NULL(ws);
  737. DEBUG_LOG_WAYLAND_THREAD(vformat("Window entered output %x.\n", (size_t)wl_output));
  738. ws->wl_outputs.insert(wl_output);
  739. // Workaround for buffer scaling as there's no guaranteed way of knowing the
  740. // preferred scale.
  741. // TODO: Skip this branch for newer `wl_surface`s once we add support for
  742. // `wl_surface::preferred_buffer_scale`
  743. if (ws->preferred_fractional_scale == 0) {
  744. window_state_update_size(ws, ws->rect.size.width, ws->rect.size.height);
  745. }
  746. }
  747. void WaylandThread::_frame_wl_callback_on_done(void *data, struct wl_callback *wl_callback, uint32_t callback_data) {
  748. wl_callback_destroy(wl_callback);
  749. WindowState *ws = (WindowState *)data;
  750. ERR_FAIL_NULL(ws);
  751. ERR_FAIL_NULL(ws->wayland_thread);
  752. ERR_FAIL_NULL(ws->wl_surface);
  753. ws->wayland_thread->set_frame();
  754. ws->frame_callback = wl_surface_frame(ws->wl_surface),
  755. wl_callback_add_listener(ws->frame_callback, &frame_wl_callback_listener, ws);
  756. if (ws->wl_surface && ws->buffer_scale_changed) {
  757. // NOTE: We're only now setting the buffer scale as the idea is to get this
  758. // data committed together with the new frame, all by the rendering driver.
  759. // This is important because we might otherwise set an invalid combination of
  760. // buffer size and scale (e.g. odd size and 2x scale). We're pretty much
  761. // guaranteed to get a proper buffer in the next render loop as the rescaling
  762. // method also informs the engine of a "window rect change", triggering
  763. // rendering if needed.
  764. wl_surface_set_buffer_scale(ws->wl_surface, window_state_get_preferred_buffer_scale(ws));
  765. }
  766. }
  767. void WaylandThread::_wl_surface_on_leave(void *data, struct wl_surface *wl_surface, struct wl_output *wl_output) {
  768. if (!wl_output || !wl_proxy_is_godot((struct wl_proxy *)wl_output)) {
  769. // This won't have the right data bound to it. Not worth it and would probably
  770. // just break everything.
  771. return;
  772. }
  773. WindowState *ws = (WindowState *)data;
  774. ERR_FAIL_NULL(ws);
  775. ws->wl_outputs.erase(wl_output);
  776. DEBUG_LOG_WAYLAND_THREAD(vformat("Window left output %x.\n", (size_t)wl_output));
  777. }
  778. // TODO: Add support to this event.
  779. void WaylandThread::_wl_surface_on_preferred_buffer_scale(void *data, struct wl_surface *wl_surface, int32_t factor) {
  780. }
  781. // TODO: Add support to this event.
  782. void WaylandThread::_wl_surface_on_preferred_buffer_transform(void *data, struct wl_surface *wl_surface, uint32_t transform) {
  783. }
  784. void WaylandThread::_wl_output_on_geometry(void *data, struct wl_output *wl_output, int32_t x, int32_t y, int32_t physical_width, int32_t physical_height, int32_t subpixel, const char *make, const char *model, int32_t transform) {
  785. ScreenState *ss = (ScreenState *)data;
  786. ERR_FAIL_NULL(ss);
  787. ss->pending_data.position.x = x;
  788. ss->pending_data.position.x = x;
  789. ss->pending_data.position.y = y;
  790. ss->pending_data.physical_size.width = physical_width;
  791. ss->pending_data.physical_size.height = physical_height;
  792. ss->pending_data.make.parse_utf8(make);
  793. ss->pending_data.model.parse_utf8(model);
  794. // `wl_output::done` is a version 2 addition. We'll directly update the data
  795. // for compatibility.
  796. if (wl_output_get_version(wl_output) == 1) {
  797. ss->data = ss->pending_data;
  798. }
  799. }
  800. void WaylandThread::_wl_output_on_mode(void *data, struct wl_output *wl_output, uint32_t flags, int32_t width, int32_t height, int32_t refresh) {
  801. ScreenState *ss = (ScreenState *)data;
  802. ERR_FAIL_NULL(ss);
  803. ss->pending_data.size.width = width;
  804. ss->pending_data.size.height = height;
  805. ss->pending_data.refresh_rate = refresh ? refresh / 1000.0f : -1;
  806. // `wl_output::done` is a version 2 addition. We'll directly update the data
  807. // for compatibility.
  808. if (wl_output_get_version(wl_output) == 1) {
  809. ss->data = ss->pending_data;
  810. }
  811. }
  812. // NOTE: The following `wl_output` events are only for version 2 onwards, so we
  813. // can assume that they're "atomic" (i.e. rely on the `wl_output::done` event).
  814. void WaylandThread::_wl_output_on_done(void *data, struct wl_output *wl_output) {
  815. ScreenState *ss = (ScreenState *)data;
  816. ERR_FAIL_NULL(ss);
  817. ss->data = ss->pending_data;
  818. ss->wayland_thread->_update_scale(ss->data.scale);
  819. DEBUG_LOG_WAYLAND_THREAD(vformat("Output %x done.", (size_t)wl_output));
  820. }
  821. void WaylandThread::_wl_output_on_scale(void *data, struct wl_output *wl_output, int32_t factor) {
  822. ScreenState *ss = (ScreenState *)data;
  823. ERR_FAIL_NULL(ss);
  824. ss->pending_data.scale = factor;
  825. DEBUG_LOG_WAYLAND_THREAD(vformat("Output %x scale %d", (size_t)wl_output, factor));
  826. }
  827. void WaylandThread::_wl_output_on_name(void *data, struct wl_output *wl_output, const char *name) {
  828. }
  829. void WaylandThread::_wl_output_on_description(void *data, struct wl_output *wl_output, const char *description) {
  830. }
  831. void WaylandThread::_xdg_wm_base_on_ping(void *data, struct xdg_wm_base *xdg_wm_base, uint32_t serial) {
  832. xdg_wm_base_pong(xdg_wm_base, serial);
  833. }
  834. void WaylandThread::_xdg_surface_on_configure(void *data, struct xdg_surface *xdg_surface, uint32_t serial) {
  835. xdg_surface_ack_configure(xdg_surface, serial);
  836. WindowState *ws = (WindowState *)data;
  837. ERR_FAIL_NULL(ws);
  838. DEBUG_LOG_WAYLAND_THREAD(vformat("xdg surface on configure width %d height %d", ws->rect.size.width, ws->rect.size.height));
  839. }
  840. void WaylandThread::_xdg_toplevel_on_configure(void *data, struct xdg_toplevel *xdg_toplevel, int32_t width, int32_t height, struct wl_array *states) {
  841. WindowState *ws = (WindowState *)data;
  842. ERR_FAIL_NULL(ws);
  843. // Expect the window to be in a plain state. It will get properly set if the
  844. // compositor reports otherwise below.
  845. ws->mode = DisplayServer::WINDOW_MODE_WINDOWED;
  846. ws->suspended = false;
  847. uint32_t *state = nullptr;
  848. wl_array_for_each(state, states) {
  849. switch (*state) {
  850. case XDG_TOPLEVEL_STATE_MAXIMIZED: {
  851. ws->mode = DisplayServer::WINDOW_MODE_MAXIMIZED;
  852. } break;
  853. case XDG_TOPLEVEL_STATE_FULLSCREEN: {
  854. ws->mode = DisplayServer::WINDOW_MODE_FULLSCREEN;
  855. } break;
  856. case XDG_TOPLEVEL_STATE_SUSPENDED: {
  857. ws->suspended = true;
  858. } break;
  859. default: {
  860. // We don't care about the other states (for now).
  861. } break;
  862. }
  863. }
  864. if (width != 0 && height != 0) {
  865. window_state_update_size(ws, width, height);
  866. }
  867. DEBUG_LOG_WAYLAND_THREAD(vformat("XDG toplevel on configure width %d height %d.", width, height));
  868. }
  869. void WaylandThread::_xdg_toplevel_on_close(void *data, struct xdg_toplevel *xdg_toplevel) {
  870. WindowState *ws = (WindowState *)data;
  871. ERR_FAIL_NULL(ws);
  872. Ref<WindowEventMessage> msg;
  873. msg.instantiate();
  874. msg->event = DisplayServer::WINDOW_EVENT_CLOSE_REQUEST;
  875. ws->wayland_thread->push_message(msg);
  876. }
  877. void WaylandThread::_xdg_toplevel_on_configure_bounds(void *data, struct xdg_toplevel *xdg_toplevel, int32_t width, int32_t height) {
  878. }
  879. void WaylandThread::_xdg_toplevel_on_wm_capabilities(void *data, struct xdg_toplevel *xdg_toplevel, struct wl_array *capabilities) {
  880. WindowState *ws = (WindowState *)data;
  881. ERR_FAIL_NULL(ws);
  882. ws->can_maximize = false;
  883. ws->can_fullscreen = false;
  884. ws->can_minimize = false;
  885. uint32_t *capability = nullptr;
  886. wl_array_for_each(capability, capabilities) {
  887. switch (*capability) {
  888. case XDG_TOPLEVEL_WM_CAPABILITIES_MAXIMIZE: {
  889. ws->can_maximize = true;
  890. } break;
  891. case XDG_TOPLEVEL_WM_CAPABILITIES_FULLSCREEN: {
  892. ws->can_fullscreen = true;
  893. } break;
  894. case XDG_TOPLEVEL_WM_CAPABILITIES_MINIMIZE: {
  895. ws->can_minimize = true;
  896. } break;
  897. default: {
  898. } break;
  899. }
  900. }
  901. }
  902. void WaylandThread::_xdg_exported_on_exported(void *data, zxdg_exported_v1 *exported, const char *handle) {
  903. WindowState *ws = (WindowState *)data;
  904. ERR_FAIL_NULL(ws);
  905. ws->exported_handle = vformat("wayland:%s", String::utf8(handle));
  906. }
  907. void WaylandThread::_xdg_toplevel_decoration_on_configure(void *data, struct zxdg_toplevel_decoration_v1 *xdg_toplevel_decoration, uint32_t mode) {
  908. if (mode == ZXDG_TOPLEVEL_DECORATION_V1_MODE_CLIENT_SIDE) {
  909. #ifdef LIBDECOR_ENABLED
  910. WARN_PRINT_ONCE("Native client side decorations are not yet supported without libdecor!");
  911. #else
  912. WARN_PRINT_ONCE("Native client side decorations are not yet supported!");
  913. #endif // LIBDECOR_ENABLED
  914. }
  915. }
  916. #ifdef LIBDECOR_ENABLED
  917. void WaylandThread::libdecor_on_error(struct libdecor *context, enum libdecor_error error, const char *message) {
  918. ERR_PRINT(vformat("libdecor error %d: %s", error, message));
  919. }
  920. // NOTE: This is pretty much a reimplementation of _xdg_surface_on_configure
  921. // and _xdg_toplevel_on_configure. Libdecor really likes wrapping everything,
  922. // forcing us to do stuff like this.
  923. void WaylandThread::libdecor_frame_on_configure(struct libdecor_frame *frame, struct libdecor_configuration *configuration, void *user_data) {
  924. WindowState *ws = (WindowState *)user_data;
  925. ERR_FAIL_NULL(ws);
  926. int width = 0;
  927. int height = 0;
  928. ws->pending_libdecor_configuration = configuration;
  929. if (!libdecor_configuration_get_content_size(configuration, frame, &width, &height)) {
  930. // The configuration doesn't have a size. We'll use the one already set in the window.
  931. width = ws->rect.size.width;
  932. height = ws->rect.size.height;
  933. }
  934. ERR_FAIL_COND_MSG(width == 0 || height == 0, "Window has invalid size.");
  935. libdecor_window_state window_state = LIBDECOR_WINDOW_STATE_NONE;
  936. // Expect the window to be in a plain state. It will get properly set if the
  937. // compositor reports otherwise below.
  938. ws->mode = DisplayServer::WINDOW_MODE_WINDOWED;
  939. ws->suspended = false;
  940. if (libdecor_configuration_get_window_state(configuration, &window_state)) {
  941. if (window_state & LIBDECOR_WINDOW_STATE_MAXIMIZED) {
  942. ws->mode = DisplayServer::WINDOW_MODE_MAXIMIZED;
  943. }
  944. if (window_state & LIBDECOR_WINDOW_STATE_FULLSCREEN) {
  945. ws->mode = DisplayServer::WINDOW_MODE_FULLSCREEN;
  946. }
  947. if (window_state & LIBDECOR_WINDOW_STATE_SUSPENDED) {
  948. ws->suspended = true;
  949. }
  950. }
  951. window_state_update_size(ws, width, height);
  952. DEBUG_LOG_WAYLAND_THREAD(vformat("libdecor frame on configure rect %s", ws->rect));
  953. }
  954. void WaylandThread::libdecor_frame_on_close(struct libdecor_frame *frame, void *user_data) {
  955. WindowState *ws = (WindowState *)user_data;
  956. ERR_FAIL_NULL(ws);
  957. Ref<WindowEventMessage> winevent_msg;
  958. winevent_msg.instantiate();
  959. winevent_msg->event = DisplayServer::WINDOW_EVENT_CLOSE_REQUEST;
  960. ws->wayland_thread->push_message(winevent_msg);
  961. DEBUG_LOG_WAYLAND_THREAD("libdecor frame on close");
  962. }
  963. void WaylandThread::libdecor_frame_on_commit(struct libdecor_frame *frame, void *user_data) {
  964. // We're skipping this as we don't really care about libdecor's commit for
  965. // atomicity reasons. See `_frame_wl_callback_on_done` for more info.
  966. DEBUG_LOG_WAYLAND_THREAD("libdecor frame on commit");
  967. }
  968. void WaylandThread::libdecor_frame_on_dismiss_popup(struct libdecor_frame *frame, const char *seat_name, void *user_data) {
  969. }
  970. #endif // LIBDECOR_ENABLED
  971. void WaylandThread::_wl_seat_on_capabilities(void *data, struct wl_seat *wl_seat, uint32_t capabilities) {
  972. SeatState *ss = (SeatState *)data;
  973. ERR_FAIL_NULL(ss);
  974. // TODO: Handle touch.
  975. // Pointer handling.
  976. if (capabilities & WL_SEAT_CAPABILITY_POINTER) {
  977. if (!ss->wl_pointer) {
  978. ss->cursor_surface = wl_compositor_create_surface(ss->registry->wl_compositor);
  979. wl_surface_commit(ss->cursor_surface);
  980. ss->wl_pointer = wl_seat_get_pointer(wl_seat);
  981. wl_pointer_add_listener(ss->wl_pointer, &wl_pointer_listener, ss);
  982. if (ss->registry->wp_relative_pointer_manager) {
  983. ss->wp_relative_pointer = zwp_relative_pointer_manager_v1_get_relative_pointer(ss->registry->wp_relative_pointer_manager, ss->wl_pointer);
  984. zwp_relative_pointer_v1_add_listener(ss->wp_relative_pointer, &wp_relative_pointer_listener, ss);
  985. }
  986. if (ss->registry->wp_pointer_gestures) {
  987. ss->wp_pointer_gesture_pinch = zwp_pointer_gestures_v1_get_pinch_gesture(ss->registry->wp_pointer_gestures, ss->wl_pointer);
  988. zwp_pointer_gesture_pinch_v1_add_listener(ss->wp_pointer_gesture_pinch, &wp_pointer_gesture_pinch_listener, ss);
  989. }
  990. // TODO: Constrain new pointers if the global mouse mode is constrained.
  991. }
  992. } else {
  993. if (ss->cursor_frame_callback) {
  994. // Just in case. I got bitten by weird race-like conditions already.
  995. wl_callback_set_user_data(ss->cursor_frame_callback, nullptr);
  996. wl_callback_destroy(ss->cursor_frame_callback);
  997. ss->cursor_frame_callback = nullptr;
  998. }
  999. if (ss->cursor_surface) {
  1000. wl_surface_destroy(ss->cursor_surface);
  1001. ss->cursor_surface = nullptr;
  1002. }
  1003. if (ss->wl_pointer) {
  1004. wl_pointer_destroy(ss->wl_pointer);
  1005. ss->wl_pointer = nullptr;
  1006. }
  1007. if (ss->wp_relative_pointer) {
  1008. zwp_relative_pointer_v1_destroy(ss->wp_relative_pointer);
  1009. ss->wp_relative_pointer = nullptr;
  1010. }
  1011. if (ss->wp_confined_pointer) {
  1012. zwp_confined_pointer_v1_destroy(ss->wp_confined_pointer);
  1013. ss->wp_confined_pointer = nullptr;
  1014. }
  1015. if (ss->wp_locked_pointer) {
  1016. zwp_locked_pointer_v1_destroy(ss->wp_locked_pointer);
  1017. ss->wp_locked_pointer = nullptr;
  1018. }
  1019. }
  1020. // Keyboard handling.
  1021. if (capabilities & WL_SEAT_CAPABILITY_KEYBOARD) {
  1022. if (!ss->wl_keyboard) {
  1023. ss->xkb_context = xkb_context_new(XKB_CONTEXT_NO_FLAGS);
  1024. ERR_FAIL_NULL(ss->xkb_context);
  1025. ss->wl_keyboard = wl_seat_get_keyboard(wl_seat);
  1026. wl_keyboard_add_listener(ss->wl_keyboard, &wl_keyboard_listener, ss);
  1027. }
  1028. } else {
  1029. if (ss->xkb_context) {
  1030. xkb_context_unref(ss->xkb_context);
  1031. ss->xkb_context = nullptr;
  1032. }
  1033. if (ss->wl_keyboard) {
  1034. wl_keyboard_destroy(ss->wl_keyboard);
  1035. ss->wl_keyboard = nullptr;
  1036. }
  1037. }
  1038. }
  1039. void WaylandThread::_wl_seat_on_name(void *data, struct wl_seat *wl_seat, const char *name) {
  1040. }
  1041. void WaylandThread::_cursor_frame_callback_on_done(void *data, struct wl_callback *wl_callback, uint32_t time_ms) {
  1042. wl_callback_destroy(wl_callback);
  1043. SeatState *ss = (SeatState *)data;
  1044. ERR_FAIL_NULL(ss);
  1045. ss->cursor_frame_callback = nullptr;
  1046. ss->cursor_time_ms = time_ms;
  1047. seat_state_update_cursor(ss);
  1048. }
  1049. void WaylandThread::_wl_pointer_on_enter(void *data, struct wl_pointer *wl_pointer, uint32_t serial, struct wl_surface *surface, wl_fixed_t surface_x, wl_fixed_t surface_y) {
  1050. if (!surface || !wl_proxy_is_godot((struct wl_proxy *)surface)) {
  1051. return;
  1052. }
  1053. DEBUG_LOG_WAYLAND_THREAD("Pointing window.");
  1054. SeatState *ss = (SeatState *)data;
  1055. ERR_FAIL_NULL(ss);
  1056. ERR_FAIL_NULL(ss->cursor_surface);
  1057. ss->pointer_enter_serial = serial;
  1058. ss->pointed_surface = surface;
  1059. ss->last_pointed_surface = surface;
  1060. seat_state_update_cursor(ss);
  1061. Ref<WindowEventMessage> msg;
  1062. msg.instantiate();
  1063. msg->event = DisplayServer::WINDOW_EVENT_MOUSE_ENTER;
  1064. ss->wayland_thread->push_message(msg);
  1065. }
  1066. void WaylandThread::_wl_pointer_on_leave(void *data, struct wl_pointer *wl_pointer, uint32_t serial, struct wl_surface *surface) {
  1067. if (!surface || !wl_proxy_is_godot((struct wl_proxy *)surface)) {
  1068. return;
  1069. }
  1070. DEBUG_LOG_WAYLAND_THREAD("Left window.");
  1071. SeatState *ss = (SeatState *)data;
  1072. ERR_FAIL_NULL(ss);
  1073. WaylandThread *wayland_thread = ss->wayland_thread;
  1074. ERR_FAIL_NULL(wayland_thread);
  1075. ss->pointed_surface = nullptr;
  1076. ss->pointer_data_buffer.pressed_button_mask.clear();
  1077. Ref<WindowEventMessage> msg;
  1078. msg.instantiate();
  1079. msg->event = DisplayServer::WINDOW_EVENT_MOUSE_EXIT;
  1080. wayland_thread->push_message(msg);
  1081. }
  1082. void WaylandThread::_wl_pointer_on_motion(void *data, struct wl_pointer *wl_pointer, uint32_t time, wl_fixed_t surface_x, wl_fixed_t surface_y) {
  1083. SeatState *ss = (SeatState *)data;
  1084. ERR_FAIL_NULL(ss);
  1085. if (!ss->pointed_surface) {
  1086. // We're probably on a decoration or some other third-party thing.
  1087. return;
  1088. }
  1089. WindowState *ws = wl_surface_get_window_state(ss->pointed_surface);
  1090. ERR_FAIL_NULL(ws);
  1091. PointerData &pd = ss->pointer_data_buffer;
  1092. // TODO: Scale only when sending the Wayland message.
  1093. pd.position.x = wl_fixed_to_double(surface_x);
  1094. pd.position.y = wl_fixed_to_double(surface_y);
  1095. pd.position *= window_state_get_scale_factor(ws);
  1096. pd.motion_time = time;
  1097. }
  1098. void WaylandThread::_wl_pointer_on_button(void *data, struct wl_pointer *wl_pointer, uint32_t serial, uint32_t time, uint32_t button, uint32_t state) {
  1099. SeatState *ss = (SeatState *)data;
  1100. ERR_FAIL_NULL(ss);
  1101. if (!ss->pointed_surface) {
  1102. // We're probably on a decoration or some other third-party thing.
  1103. return;
  1104. }
  1105. PointerData &pd = ss->pointer_data_buffer;
  1106. MouseButton button_pressed = MouseButton::NONE;
  1107. switch (button) {
  1108. case BTN_LEFT:
  1109. button_pressed = MouseButton::LEFT;
  1110. break;
  1111. case BTN_MIDDLE:
  1112. button_pressed = MouseButton::MIDDLE;
  1113. break;
  1114. case BTN_RIGHT:
  1115. button_pressed = MouseButton::RIGHT;
  1116. break;
  1117. case BTN_EXTRA:
  1118. button_pressed = MouseButton::MB_XBUTTON1;
  1119. break;
  1120. case BTN_SIDE:
  1121. button_pressed = MouseButton::MB_XBUTTON2;
  1122. break;
  1123. default: {
  1124. }
  1125. }
  1126. MouseButtonMask mask = mouse_button_to_mask(button_pressed);
  1127. if (state & WL_POINTER_BUTTON_STATE_PRESSED) {
  1128. pd.pressed_button_mask.set_flag(mask);
  1129. pd.last_button_pressed = button_pressed;
  1130. pd.double_click_begun = true;
  1131. } else {
  1132. pd.pressed_button_mask.clear_flag(mask);
  1133. }
  1134. pd.button_time = time;
  1135. pd.button_serial = serial;
  1136. }
  1137. void WaylandThread::_wl_pointer_on_axis(void *data, struct wl_pointer *wl_pointer, uint32_t time, uint32_t axis, wl_fixed_t value) {
  1138. SeatState *ss = (SeatState *)data;
  1139. ERR_FAIL_NULL(ss);
  1140. if (!ss->pointed_surface) {
  1141. // We're probably on a decoration or some other third-party thing.
  1142. return;
  1143. }
  1144. PointerData &pd = ss->pointer_data_buffer;
  1145. switch (axis) {
  1146. case WL_POINTER_AXIS_VERTICAL_SCROLL: {
  1147. pd.scroll_vector.y = wl_fixed_to_double(value);
  1148. } break;
  1149. case WL_POINTER_AXIS_HORIZONTAL_SCROLL: {
  1150. pd.scroll_vector.x = wl_fixed_to_double(value);
  1151. } break;
  1152. }
  1153. pd.button_time = time;
  1154. }
  1155. void WaylandThread::_wl_pointer_on_frame(void *data, struct wl_pointer *wl_pointer) {
  1156. SeatState *ss = (SeatState *)data;
  1157. ERR_FAIL_NULL(ss);
  1158. if (!ss->pointed_surface) {
  1159. // We're probably on a decoration or some other third-party thing.
  1160. return;
  1161. }
  1162. WaylandThread *wayland_thread = ss->wayland_thread;
  1163. ERR_FAIL_NULL(wayland_thread);
  1164. wayland_thread->_set_current_seat(ss->wl_seat);
  1165. PointerData &old_pd = ss->pointer_data;
  1166. PointerData &pd = ss->pointer_data_buffer;
  1167. if (old_pd.motion_time != pd.motion_time || old_pd.relative_motion_time != pd.relative_motion_time) {
  1168. Ref<InputEventMouseMotion> mm;
  1169. mm.instantiate();
  1170. // Set all pressed modifiers.
  1171. mm->set_shift_pressed(ss->shift_pressed);
  1172. mm->set_ctrl_pressed(ss->ctrl_pressed);
  1173. mm->set_alt_pressed(ss->alt_pressed);
  1174. mm->set_meta_pressed(ss->meta_pressed);
  1175. mm->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1176. mm->set_button_mask(pd.pressed_button_mask);
  1177. mm->set_position(pd.position);
  1178. mm->set_global_position(pd.position);
  1179. Vector2 pos_delta = pd.position - old_pd.position;
  1180. if (old_pd.relative_motion_time != pd.relative_motion_time) {
  1181. uint32_t time_delta = pd.relative_motion_time - old_pd.relative_motion_time;
  1182. mm->set_relative(pd.relative_motion);
  1183. mm->set_velocity((Vector2)pos_delta / time_delta);
  1184. } else {
  1185. // The spec includes the possibility of having motion events without an
  1186. // associated relative motion event. If that's the case, fallback to a
  1187. // simple delta of the position. The captured mouse won't report the
  1188. // relative speed anymore though.
  1189. uint32_t time_delta = pd.motion_time - old_pd.motion_time;
  1190. mm->set_relative(pd.position - old_pd.position);
  1191. mm->set_velocity((Vector2)pos_delta / time_delta);
  1192. }
  1193. mm->set_relative_screen_position(mm->get_relative());
  1194. mm->set_screen_velocity(mm->get_velocity());
  1195. Ref<InputEventMessage> msg;
  1196. msg.instantiate();
  1197. msg->event = mm;
  1198. wayland_thread->push_message(msg);
  1199. }
  1200. if (pd.discrete_scroll_vector_120 - old_pd.discrete_scroll_vector_120 != Vector2i()) {
  1201. // This is a discrete scroll (eg. from a scroll wheel), so we'll just emit
  1202. // scroll wheel buttons.
  1203. if (pd.scroll_vector.y != 0) {
  1204. MouseButton button = pd.scroll_vector.y > 0 ? MouseButton::WHEEL_DOWN : MouseButton::WHEEL_UP;
  1205. pd.pressed_button_mask.set_flag(mouse_button_to_mask(button));
  1206. }
  1207. if (pd.scroll_vector.x != 0) {
  1208. MouseButton button = pd.scroll_vector.x > 0 ? MouseButton::WHEEL_RIGHT : MouseButton::WHEEL_LEFT;
  1209. pd.pressed_button_mask.set_flag(mouse_button_to_mask(button));
  1210. }
  1211. } else {
  1212. if (pd.scroll_vector - old_pd.scroll_vector != Vector2()) {
  1213. // This is a continuous scroll, so we'll emit a pan gesture.
  1214. Ref<InputEventPanGesture> pg;
  1215. pg.instantiate();
  1216. // Set all pressed modifiers.
  1217. pg->set_shift_pressed(ss->shift_pressed);
  1218. pg->set_ctrl_pressed(ss->ctrl_pressed);
  1219. pg->set_alt_pressed(ss->alt_pressed);
  1220. pg->set_meta_pressed(ss->meta_pressed);
  1221. pg->set_position(pd.position);
  1222. pg->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1223. pg->set_delta(pd.scroll_vector);
  1224. Ref<InputEventMessage> msg;
  1225. msg.instantiate();
  1226. msg->event = pg;
  1227. wayland_thread->push_message(msg);
  1228. }
  1229. }
  1230. if (old_pd.pressed_button_mask != pd.pressed_button_mask) {
  1231. BitField<MouseButtonMask> pressed_mask_delta = old_pd.pressed_button_mask ^ pd.pressed_button_mask;
  1232. const MouseButton buttons_to_test[] = {
  1233. MouseButton::LEFT,
  1234. MouseButton::MIDDLE,
  1235. MouseButton::RIGHT,
  1236. MouseButton::WHEEL_UP,
  1237. MouseButton::WHEEL_DOWN,
  1238. MouseButton::WHEEL_LEFT,
  1239. MouseButton::WHEEL_RIGHT,
  1240. MouseButton::MB_XBUTTON1,
  1241. MouseButton::MB_XBUTTON2,
  1242. };
  1243. for (MouseButton test_button : buttons_to_test) {
  1244. MouseButtonMask test_button_mask = mouse_button_to_mask(test_button);
  1245. if (pressed_mask_delta.has_flag(test_button_mask)) {
  1246. Ref<InputEventMouseButton> mb;
  1247. mb.instantiate();
  1248. // Set all pressed modifiers.
  1249. mb->set_shift_pressed(ss->shift_pressed);
  1250. mb->set_ctrl_pressed(ss->ctrl_pressed);
  1251. mb->set_alt_pressed(ss->alt_pressed);
  1252. mb->set_meta_pressed(ss->meta_pressed);
  1253. mb->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1254. mb->set_position(pd.position);
  1255. mb->set_global_position(pd.position);
  1256. if (test_button == MouseButton::WHEEL_UP || test_button == MouseButton::WHEEL_DOWN) {
  1257. // If this is a discrete scroll, specify how many "clicks" it did for this
  1258. // pointer frame.
  1259. mb->set_factor(Math::abs(pd.discrete_scroll_vector_120.y / (float)120));
  1260. }
  1261. if (test_button == MouseButton::WHEEL_RIGHT || test_button == MouseButton::WHEEL_LEFT) {
  1262. // If this is a discrete scroll, specify how many "clicks" it did for this
  1263. // pointer frame.
  1264. mb->set_factor(fabs(pd.discrete_scroll_vector_120.x / (float)120));
  1265. }
  1266. mb->set_button_mask(pd.pressed_button_mask);
  1267. mb->set_button_index(test_button);
  1268. mb->set_pressed(pd.pressed_button_mask.has_flag(test_button_mask));
  1269. // We have to set the last position pressed here as we can't take for
  1270. // granted what the individual events might have seen due to them not having
  1271. // a guaranteed order.
  1272. if (mb->is_pressed()) {
  1273. pd.last_pressed_position = pd.position;
  1274. }
  1275. if (old_pd.double_click_begun && mb->is_pressed() && pd.last_button_pressed == old_pd.last_button_pressed && (pd.button_time - old_pd.button_time) < 400 && Vector2(old_pd.last_pressed_position).distance_to(Vector2(pd.last_pressed_position)) < 5) {
  1276. pd.double_click_begun = false;
  1277. mb->set_double_click(true);
  1278. }
  1279. Ref<InputEventMessage> msg;
  1280. msg.instantiate();
  1281. msg->event = mb;
  1282. wayland_thread->push_message(msg);
  1283. // Send an event resetting immediately the wheel key.
  1284. // Wayland specification defines axis_stop events as optional and says to
  1285. // treat all axis events as unterminated. As such, we have to manually do
  1286. // it ourselves.
  1287. if (test_button == MouseButton::WHEEL_UP || test_button == MouseButton::WHEEL_DOWN || test_button == MouseButton::WHEEL_LEFT || test_button == MouseButton::WHEEL_RIGHT) {
  1288. // FIXME: This is ugly, I can't find a clean way to clone an InputEvent.
  1289. // This works for now, despite being horrible.
  1290. Ref<InputEventMouseButton> wh_up;
  1291. wh_up.instantiate();
  1292. wh_up->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1293. wh_up->set_position(pd.position);
  1294. wh_up->set_global_position(pd.position);
  1295. // We have to unset the button to avoid it getting stuck.
  1296. pd.pressed_button_mask.clear_flag(test_button_mask);
  1297. wh_up->set_button_mask(pd.pressed_button_mask);
  1298. wh_up->set_button_index(test_button);
  1299. wh_up->set_pressed(false);
  1300. Ref<InputEventMessage> msg_up;
  1301. msg_up.instantiate();
  1302. msg_up->event = wh_up;
  1303. wayland_thread->push_message(msg_up);
  1304. }
  1305. }
  1306. }
  1307. }
  1308. // Reset the scroll vectors as we already handled them.
  1309. pd.scroll_vector = Vector2();
  1310. pd.discrete_scroll_vector_120 = Vector2i();
  1311. // Update the data all getters read. Wayland's specification requires us to do
  1312. // this, since all pointer actions are sent in individual events.
  1313. old_pd = pd;
  1314. }
  1315. void WaylandThread::_wl_pointer_on_axis_source(void *data, struct wl_pointer *wl_pointer, uint32_t axis_source) {
  1316. SeatState *ss = (SeatState *)data;
  1317. ERR_FAIL_NULL(ss);
  1318. if (!ss->pointed_surface) {
  1319. // We're probably on a decoration or some other third-party thing.
  1320. return;
  1321. }
  1322. ss->pointer_data_buffer.scroll_type = axis_source;
  1323. }
  1324. void WaylandThread::_wl_pointer_on_axis_stop(void *data, struct wl_pointer *wl_pointer, uint32_t time, uint32_t axis) {
  1325. }
  1326. // NOTE: This event is deprecated since version 8 and superseded by
  1327. // `wl_pointer::axis_value120`. This thus converts the data to its
  1328. // fraction-of-120 format.
  1329. void WaylandThread::_wl_pointer_on_axis_discrete(void *data, struct wl_pointer *wl_pointer, uint32_t axis, int32_t discrete) {
  1330. SeatState *ss = (SeatState *)data;
  1331. ERR_FAIL_NULL(ss);
  1332. if (!ss->pointed_surface) {
  1333. // We're probably on a decoration or some other third-party thing.
  1334. return;
  1335. }
  1336. PointerData &pd = ss->pointer_data_buffer;
  1337. // NOTE: We can allow ourselves to not accumulate this data (and thus just
  1338. // assign it) as the spec guarantees only one event per axis type.
  1339. if (axis == WL_POINTER_AXIS_VERTICAL_SCROLL) {
  1340. pd.discrete_scroll_vector_120.y = discrete * 120;
  1341. }
  1342. if (axis == WL_POINTER_AXIS_VERTICAL_SCROLL) {
  1343. pd.discrete_scroll_vector_120.x = discrete * 120;
  1344. }
  1345. }
  1346. // Supersedes `wl_pointer::axis_discrete` Since version 8.
  1347. void WaylandThread::_wl_pointer_on_axis_value120(void *data, struct wl_pointer *wl_pointer, uint32_t axis, int32_t value120) {
  1348. SeatState *ss = (SeatState *)data;
  1349. ERR_FAIL_NULL(ss);
  1350. if (!ss->pointed_surface) {
  1351. // We're probably on a decoration or some other third-party thing.
  1352. return;
  1353. }
  1354. PointerData &pd = ss->pointer_data_buffer;
  1355. if (axis == WL_POINTER_AXIS_VERTICAL_SCROLL) {
  1356. pd.discrete_scroll_vector_120.y += value120;
  1357. }
  1358. if (axis == WL_POINTER_AXIS_VERTICAL_SCROLL) {
  1359. pd.discrete_scroll_vector_120.x += value120;
  1360. }
  1361. }
  1362. // TODO: Add support to this event.
  1363. void WaylandThread::_wl_pointer_on_axis_relative_direction(void *data, struct wl_pointer *wl_pointer, uint32_t axis, uint32_t direction) {
  1364. }
  1365. void WaylandThread::_wl_keyboard_on_keymap(void *data, struct wl_keyboard *wl_keyboard, uint32_t format, int32_t fd, uint32_t size) {
  1366. ERR_FAIL_COND_MSG(format != WL_KEYBOARD_KEYMAP_FORMAT_XKB_V1, "Unsupported keymap format announced from the Wayland compositor.");
  1367. SeatState *ss = (SeatState *)data;
  1368. ERR_FAIL_NULL(ss);
  1369. if (ss->keymap_buffer) {
  1370. // We have already a mapped buffer, so we unmap it. There's no need to reset
  1371. // its pointer or size, as we're gonna set them below.
  1372. munmap((void *)ss->keymap_buffer, ss->keymap_buffer_size);
  1373. ss->keymap_buffer = nullptr;
  1374. }
  1375. ss->keymap_buffer = (const char *)mmap(nullptr, size, PROT_READ, MAP_PRIVATE, fd, 0);
  1376. ss->keymap_buffer_size = size;
  1377. xkb_keymap_unref(ss->xkb_keymap);
  1378. ss->xkb_keymap = xkb_keymap_new_from_string(ss->xkb_context, ss->keymap_buffer,
  1379. XKB_KEYMAP_FORMAT_TEXT_V1, XKB_KEYMAP_COMPILE_NO_FLAGS);
  1380. xkb_state_unref(ss->xkb_state);
  1381. ss->xkb_state = xkb_state_new(ss->xkb_keymap);
  1382. }
  1383. void WaylandThread::_wl_keyboard_on_enter(void *data, struct wl_keyboard *wl_keyboard, uint32_t serial, struct wl_surface *surface, struct wl_array *keys) {
  1384. SeatState *ss = (SeatState *)data;
  1385. ERR_FAIL_NULL(ss);
  1386. WaylandThread *wayland_thread = ss->wayland_thread;
  1387. ERR_FAIL_NULL(wayland_thread);
  1388. wayland_thread->_set_current_seat(ss->wl_seat);
  1389. Ref<WindowEventMessage> msg;
  1390. msg.instantiate();
  1391. msg->event = DisplayServer::WINDOW_EVENT_FOCUS_IN;
  1392. wayland_thread->push_message(msg);
  1393. }
  1394. void WaylandThread::_wl_keyboard_on_leave(void *data, struct wl_keyboard *wl_keyboard, uint32_t serial, struct wl_surface *surface) {
  1395. SeatState *ss = (SeatState *)data;
  1396. ERR_FAIL_NULL(ss);
  1397. WaylandThread *wayland_thread = ss->wayland_thread;
  1398. ERR_FAIL_NULL(wayland_thread);
  1399. ss->repeating_keycode = XKB_KEYCODE_INVALID;
  1400. Ref<WindowEventMessage> msg;
  1401. msg.instantiate();
  1402. msg->event = DisplayServer::WINDOW_EVENT_FOCUS_OUT;
  1403. wayland_thread->push_message(msg);
  1404. }
  1405. void WaylandThread::_wl_keyboard_on_key(void *data, struct wl_keyboard *wl_keyboard, uint32_t serial, uint32_t time, uint32_t key, uint32_t state) {
  1406. SeatState *ss = (SeatState *)data;
  1407. ERR_FAIL_NULL(ss);
  1408. WaylandThread *wayland_thread = ss->wayland_thread;
  1409. ERR_FAIL_NULL(wayland_thread);
  1410. // We have to add 8 to the scancode to get an XKB-compatible keycode.
  1411. xkb_keycode_t xkb_keycode = key + 8;
  1412. bool pressed = state & WL_KEYBOARD_KEY_STATE_PRESSED;
  1413. if (pressed) {
  1414. if (xkb_keymap_key_repeats(ss->xkb_keymap, xkb_keycode)) {
  1415. ss->last_repeat_start_msec = OS::get_singleton()->get_ticks_msec();
  1416. ss->repeating_keycode = xkb_keycode;
  1417. }
  1418. ss->last_key_pressed_serial = serial;
  1419. } else if (ss->repeating_keycode == xkb_keycode) {
  1420. ss->repeating_keycode = XKB_KEYCODE_INVALID;
  1421. }
  1422. Ref<InputEventKey> k;
  1423. k.instantiate();
  1424. if (!_seat_state_configure_key_event(*ss, k, xkb_keycode, pressed)) {
  1425. return;
  1426. }
  1427. Ref<InputEventMessage> msg;
  1428. msg.instantiate();
  1429. msg->event = k;
  1430. wayland_thread->push_message(msg);
  1431. }
  1432. void WaylandThread::_wl_keyboard_on_modifiers(void *data, struct wl_keyboard *wl_keyboard, uint32_t serial, uint32_t mods_depressed, uint32_t mods_latched, uint32_t mods_locked, uint32_t group) {
  1433. SeatState *ss = (SeatState *)data;
  1434. ERR_FAIL_NULL(ss);
  1435. xkb_state_update_mask(ss->xkb_state, mods_depressed, mods_latched, mods_locked, ss->current_layout_index, ss->current_layout_index, group);
  1436. ss->shift_pressed = xkb_state_mod_name_is_active(ss->xkb_state, XKB_MOD_NAME_SHIFT, XKB_STATE_MODS_DEPRESSED);
  1437. ss->ctrl_pressed = xkb_state_mod_name_is_active(ss->xkb_state, XKB_MOD_NAME_CTRL, XKB_STATE_MODS_DEPRESSED);
  1438. ss->alt_pressed = xkb_state_mod_name_is_active(ss->xkb_state, XKB_MOD_NAME_ALT, XKB_STATE_MODS_DEPRESSED);
  1439. ss->meta_pressed = xkb_state_mod_name_is_active(ss->xkb_state, XKB_MOD_NAME_LOGO, XKB_STATE_MODS_DEPRESSED);
  1440. ss->current_layout_index = group;
  1441. }
  1442. void WaylandThread::_wl_keyboard_on_repeat_info(void *data, struct wl_keyboard *wl_keyboard, int32_t rate, int32_t delay) {
  1443. SeatState *ss = (SeatState *)data;
  1444. ERR_FAIL_NULL(ss);
  1445. ss->repeat_key_delay_msec = 1000 / rate;
  1446. ss->repeat_start_delay_msec = delay;
  1447. }
  1448. // NOTE: Don't forget to `memfree` the offer's state.
  1449. void WaylandThread::_wl_data_device_on_data_offer(void *data, struct wl_data_device *wl_data_device, struct wl_data_offer *id) {
  1450. wl_proxy_tag_godot((struct wl_proxy *)id);
  1451. wl_data_offer_add_listener(id, &wl_data_offer_listener, memnew(OfferState));
  1452. }
  1453. void WaylandThread::_wl_data_device_on_enter(void *data, struct wl_data_device *wl_data_device, uint32_t serial, struct wl_surface *surface, wl_fixed_t x, wl_fixed_t y, struct wl_data_offer *id) {
  1454. SeatState *ss = (SeatState *)data;
  1455. ERR_FAIL_NULL(ss);
  1456. ss->dnd_enter_serial = serial;
  1457. ss->wl_data_offer_dnd = id;
  1458. // Godot only supports DnD file copying for now.
  1459. wl_data_offer_accept(id, serial, "text/uri-list");
  1460. wl_data_offer_set_actions(id, WL_DATA_DEVICE_MANAGER_DND_ACTION_COPY, WL_DATA_DEVICE_MANAGER_DND_ACTION_COPY);
  1461. }
  1462. void WaylandThread::_wl_data_device_on_leave(void *data, struct wl_data_device *wl_data_device) {
  1463. SeatState *ss = (SeatState *)data;
  1464. ERR_FAIL_NULL(ss);
  1465. if (ss->wl_data_offer_dnd) {
  1466. memdelete(wl_data_offer_get_offer_state(ss->wl_data_offer_dnd));
  1467. wl_data_offer_destroy(ss->wl_data_offer_dnd);
  1468. ss->wl_data_offer_dnd = nullptr;
  1469. }
  1470. }
  1471. void WaylandThread::_wl_data_device_on_motion(void *data, struct wl_data_device *wl_data_device, uint32_t time, wl_fixed_t x, wl_fixed_t y) {
  1472. }
  1473. void WaylandThread::_wl_data_device_on_drop(void *data, struct wl_data_device *wl_data_device) {
  1474. SeatState *ss = (SeatState *)data;
  1475. ERR_FAIL_NULL(ss);
  1476. WaylandThread *wayland_thread = ss->wayland_thread;
  1477. ERR_FAIL_NULL(wayland_thread);
  1478. OfferState *os = wl_data_offer_get_offer_state(ss->wl_data_offer_dnd);
  1479. ERR_FAIL_NULL(os);
  1480. if (os) {
  1481. Ref<DropFilesEventMessage> msg;
  1482. msg.instantiate();
  1483. Vector<uint8_t> list_data = _wl_data_offer_read(wayland_thread->wl_display, "text/uri-list", ss->wl_data_offer_dnd);
  1484. msg->files = String::utf8((const char *)list_data.ptr(), list_data.size()).split("\r\n", false);
  1485. for (int i = 0; i < msg->files.size(); i++) {
  1486. msg->files.write[i] = msg->files[i].replace("file://", "").uri_decode();
  1487. }
  1488. wayland_thread->push_message(msg);
  1489. wl_data_offer_finish(ss->wl_data_offer_dnd);
  1490. }
  1491. memdelete(wl_data_offer_get_offer_state(ss->wl_data_offer_dnd));
  1492. wl_data_offer_destroy(ss->wl_data_offer_dnd);
  1493. ss->wl_data_offer_dnd = nullptr;
  1494. }
  1495. void WaylandThread::_wl_data_device_on_selection(void *data, struct wl_data_device *wl_data_device, struct wl_data_offer *id) {
  1496. SeatState *ss = (SeatState *)data;
  1497. ERR_FAIL_NULL(ss);
  1498. if (ss->wl_data_offer_selection) {
  1499. memdelete(wl_data_offer_get_offer_state(ss->wl_data_offer_selection));
  1500. wl_data_offer_destroy(ss->wl_data_offer_selection);
  1501. }
  1502. ss->wl_data_offer_selection = id;
  1503. }
  1504. void WaylandThread::_wl_data_offer_on_offer(void *data, struct wl_data_offer *wl_data_offer, const char *mime_type) {
  1505. OfferState *os = (OfferState *)data;
  1506. ERR_FAIL_NULL(os);
  1507. if (os) {
  1508. os->mime_types.insert(String::utf8(mime_type));
  1509. }
  1510. }
  1511. void WaylandThread::_wl_data_offer_on_source_actions(void *data, struct wl_data_offer *wl_data_offer, uint32_t source_actions) {
  1512. }
  1513. void WaylandThread::_wl_data_offer_on_action(void *data, struct wl_data_offer *wl_data_offer, uint32_t dnd_action) {
  1514. }
  1515. void WaylandThread::_wl_data_source_on_target(void *data, struct wl_data_source *wl_data_source, const char *mime_type) {
  1516. }
  1517. void WaylandThread::_wl_data_source_on_send(void *data, struct wl_data_source *wl_data_source, const char *mime_type, int32_t fd) {
  1518. SeatState *ss = (SeatState *)data;
  1519. ERR_FAIL_NULL(ss);
  1520. Vector<uint8_t> *data_to_send = nullptr;
  1521. if (wl_data_source == ss->wl_data_source_selection) {
  1522. data_to_send = &ss->selection_data;
  1523. DEBUG_LOG_WAYLAND_THREAD("Clipboard: requested selection.");
  1524. }
  1525. if (data_to_send) {
  1526. ssize_t written_bytes = 0;
  1527. bool valid_mime = false;
  1528. if (strcmp(mime_type, "text/plain;charset=utf-8") == 0) {
  1529. valid_mime = true;
  1530. } else if (strcmp(mime_type, "text/plain") == 0) {
  1531. valid_mime = true;
  1532. }
  1533. if (valid_mime) {
  1534. written_bytes = write(fd, data_to_send->ptr(), data_to_send->size());
  1535. }
  1536. if (written_bytes > 0) {
  1537. DEBUG_LOG_WAYLAND_THREAD(vformat("Clipboard: sent %d bytes.", written_bytes));
  1538. } else if (written_bytes == 0) {
  1539. DEBUG_LOG_WAYLAND_THREAD("Clipboard: no bytes sent.");
  1540. } else {
  1541. ERR_PRINT(vformat("Clipboard: write error %d.", errno));
  1542. }
  1543. }
  1544. close(fd);
  1545. }
  1546. void WaylandThread::_wl_data_source_on_cancelled(void *data, struct wl_data_source *wl_data_source) {
  1547. SeatState *ss = (SeatState *)data;
  1548. ERR_FAIL_NULL(ss);
  1549. wl_data_source_destroy(wl_data_source);
  1550. if (wl_data_source == ss->wl_data_source_selection) {
  1551. ss->wl_data_source_selection = nullptr;
  1552. ss->selection_data.clear();
  1553. DEBUG_LOG_WAYLAND_THREAD("Clipboard: selection set by another program.");
  1554. return;
  1555. }
  1556. }
  1557. void WaylandThread::_wl_data_source_on_dnd_drop_performed(void *data, struct wl_data_source *wl_data_source) {
  1558. }
  1559. void WaylandThread::_wl_data_source_on_dnd_finished(void *data, struct wl_data_source *wl_data_source) {
  1560. }
  1561. void WaylandThread::_wl_data_source_on_action(void *data, struct wl_data_source *wl_data_source, uint32_t dnd_action) {
  1562. }
  1563. void WaylandThread::_wp_fractional_scale_on_preferred_scale(void *data, struct wp_fractional_scale_v1 *wp_fractional_scale_v1, uint32_t scale) {
  1564. WindowState *ws = (WindowState *)data;
  1565. ERR_FAIL_NULL(ws);
  1566. ws->preferred_fractional_scale = (double)scale / 120;
  1567. window_state_update_size(ws, ws->rect.size.width, ws->rect.size.height);
  1568. }
  1569. void WaylandThread::_wp_relative_pointer_on_relative_motion(void *data, struct zwp_relative_pointer_v1 *wp_relative_pointer, uint32_t uptime_hi, uint32_t uptime_lo, wl_fixed_t dx, wl_fixed_t dy, wl_fixed_t dx_unaccel, wl_fixed_t dy_unaccel) {
  1570. SeatState *ss = (SeatState *)data;
  1571. ERR_FAIL_NULL(ss);
  1572. if (!ss->pointed_surface) {
  1573. // We're probably on a decoration or some other third-party thing.
  1574. return;
  1575. }
  1576. PointerData &pd = ss->pointer_data_buffer;
  1577. WindowState *ws = wl_surface_get_window_state(ss->pointed_surface);
  1578. ERR_FAIL_NULL(ws);
  1579. pd.relative_motion.x = wl_fixed_to_double(dx);
  1580. pd.relative_motion.y = wl_fixed_to_double(dy);
  1581. pd.relative_motion *= window_state_get_scale_factor(ws);
  1582. pd.relative_motion_time = uptime_lo;
  1583. }
  1584. void WaylandThread::_wp_pointer_gesture_pinch_on_begin(void *data, struct zwp_pointer_gesture_pinch_v1 *wp_pointer_gesture_pinch_v1, uint32_t serial, uint32_t time, struct wl_surface *surface, uint32_t fingers) {
  1585. SeatState *ss = (SeatState *)data;
  1586. ERR_FAIL_NULL(ss);
  1587. if (fingers == 2) {
  1588. ss->old_pinch_scale = wl_fixed_from_int(1);
  1589. ss->active_gesture = Gesture::MAGNIFY;
  1590. }
  1591. }
  1592. void WaylandThread::_wp_pointer_gesture_pinch_on_update(void *data, struct zwp_pointer_gesture_pinch_v1 *wp_pointer_gesture_pinch_v1, uint32_t time, wl_fixed_t dx, wl_fixed_t dy, wl_fixed_t scale, wl_fixed_t rotation) {
  1593. SeatState *ss = (SeatState *)data;
  1594. ERR_FAIL_NULL(ss);
  1595. WaylandThread *wayland_thread = ss->wayland_thread;
  1596. ERR_FAIL_NULL(wayland_thread);
  1597. PointerData &pd = ss->pointer_data_buffer;
  1598. if (ss->active_gesture == Gesture::MAGNIFY) {
  1599. Ref<InputEventMagnifyGesture> mg;
  1600. mg.instantiate();
  1601. mg->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1602. // Set all pressed modifiers.
  1603. mg->set_shift_pressed(ss->shift_pressed);
  1604. mg->set_ctrl_pressed(ss->ctrl_pressed);
  1605. mg->set_alt_pressed(ss->alt_pressed);
  1606. mg->set_meta_pressed(ss->meta_pressed);
  1607. mg->set_position(pd.position);
  1608. wl_fixed_t scale_delta = scale - ss->old_pinch_scale;
  1609. mg->set_factor(1 + wl_fixed_to_double(scale_delta));
  1610. Ref<InputEventMessage> magnify_msg;
  1611. magnify_msg.instantiate();
  1612. magnify_msg->event = mg;
  1613. // Since Wayland allows only one gesture at a time and godot instead expects
  1614. // both of them, we'll have to create two separate input events: one for
  1615. // magnification and one for panning.
  1616. Ref<InputEventPanGesture> pg;
  1617. pg.instantiate();
  1618. pg->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1619. // Set all pressed modifiers.
  1620. pg->set_shift_pressed(ss->shift_pressed);
  1621. pg->set_ctrl_pressed(ss->ctrl_pressed);
  1622. pg->set_alt_pressed(ss->alt_pressed);
  1623. pg->set_meta_pressed(ss->meta_pressed);
  1624. pg->set_position(pd.position);
  1625. pg->set_delta(Vector2(wl_fixed_to_double(dx), wl_fixed_to_double(dy)));
  1626. Ref<InputEventMessage> pan_msg;
  1627. pan_msg.instantiate();
  1628. pan_msg->event = pg;
  1629. wayland_thread->push_message(magnify_msg);
  1630. wayland_thread->push_message(pan_msg);
  1631. ss->old_pinch_scale = scale;
  1632. }
  1633. }
  1634. void WaylandThread::_wp_pointer_gesture_pinch_on_end(void *data, struct zwp_pointer_gesture_pinch_v1 *wp_pointer_gesture_pinch_v1, uint32_t serial, uint32_t time, int32_t cancelled) {
  1635. SeatState *ss = (SeatState *)data;
  1636. ERR_FAIL_NULL(ss);
  1637. ss->active_gesture = Gesture::NONE;
  1638. }
  1639. // NOTE: Don't forget to `memfree` the offer's state.
  1640. void WaylandThread::_wp_primary_selection_device_on_data_offer(void *data, struct zwp_primary_selection_device_v1 *wp_primary_selection_device_v1, struct zwp_primary_selection_offer_v1 *offer) {
  1641. wl_proxy_tag_godot((struct wl_proxy *)offer);
  1642. zwp_primary_selection_offer_v1_add_listener(offer, &wp_primary_selection_offer_listener, memnew(OfferState));
  1643. }
  1644. void WaylandThread::_wp_primary_selection_device_on_selection(void *data, struct zwp_primary_selection_device_v1 *wp_primary_selection_device_v1, struct zwp_primary_selection_offer_v1 *id) {
  1645. SeatState *ss = (SeatState *)data;
  1646. ERR_FAIL_NULL(ss);
  1647. if (ss->wp_primary_selection_offer) {
  1648. memfree(wp_primary_selection_offer_get_offer_state(ss->wp_primary_selection_offer));
  1649. zwp_primary_selection_offer_v1_destroy(ss->wp_primary_selection_offer);
  1650. }
  1651. ss->wp_primary_selection_offer = id;
  1652. }
  1653. void WaylandThread::_wp_primary_selection_offer_on_offer(void *data, struct zwp_primary_selection_offer_v1 *wp_primary_selection_offer_v1, const char *mime_type) {
  1654. OfferState *os = (OfferState *)data;
  1655. ERR_FAIL_NULL(os);
  1656. if (os) {
  1657. os->mime_types.insert(String::utf8(mime_type));
  1658. }
  1659. }
  1660. void WaylandThread::_wp_primary_selection_source_on_send(void *data, struct zwp_primary_selection_source_v1 *wp_primary_selection_source_v1, const char *mime_type, int32_t fd) {
  1661. SeatState *ss = (SeatState *)data;
  1662. ERR_FAIL_NULL(ss);
  1663. Vector<uint8_t> *data_to_send = nullptr;
  1664. if (wp_primary_selection_source_v1 == ss->wp_primary_selection_source) {
  1665. data_to_send = &ss->primary_data;
  1666. DEBUG_LOG_WAYLAND_THREAD("Clipboard: requested primary selection.");
  1667. }
  1668. if (data_to_send) {
  1669. ssize_t written_bytes = 0;
  1670. if (strcmp(mime_type, "text/plain") == 0) {
  1671. written_bytes = write(fd, data_to_send->ptr(), data_to_send->size());
  1672. }
  1673. if (written_bytes > 0) {
  1674. DEBUG_LOG_WAYLAND_THREAD(vformat("Clipboard: sent %d bytes.", written_bytes));
  1675. } else if (written_bytes == 0) {
  1676. DEBUG_LOG_WAYLAND_THREAD("Clipboard: no bytes sent.");
  1677. } else {
  1678. ERR_PRINT(vformat("Clipboard: write error %d.", errno));
  1679. }
  1680. }
  1681. close(fd);
  1682. }
  1683. void WaylandThread::_wp_primary_selection_source_on_cancelled(void *data, struct zwp_primary_selection_source_v1 *wp_primary_selection_source_v1) {
  1684. SeatState *ss = (SeatState *)data;
  1685. ERR_FAIL_NULL(ss);
  1686. if (wp_primary_selection_source_v1 == ss->wp_primary_selection_source) {
  1687. zwp_primary_selection_source_v1_destroy(ss->wp_primary_selection_source);
  1688. ss->wp_primary_selection_source = nullptr;
  1689. ss->primary_data.clear();
  1690. DEBUG_LOG_WAYLAND_THREAD("Clipboard: primary selection set by another program.");
  1691. return;
  1692. }
  1693. }
  1694. void WaylandThread::_wp_tablet_seat_on_tablet_added(void *data, struct zwp_tablet_seat_v2 *wp_tablet_seat_v2, struct zwp_tablet_v2 *id) {
  1695. }
  1696. void WaylandThread::_wp_tablet_seat_on_tool_added(void *data, struct zwp_tablet_seat_v2 *wp_tablet_seat_v2, struct zwp_tablet_tool_v2 *id) {
  1697. SeatState *ss = (SeatState *)data;
  1698. ERR_FAIL_NULL(ss);
  1699. TabletToolState *state = memnew(TabletToolState);
  1700. state->wl_seat = ss->wl_seat;
  1701. wl_proxy_tag_godot((struct wl_proxy *)id);
  1702. zwp_tablet_tool_v2_add_listener(id, &wp_tablet_tool_listener, state);
  1703. ss->tablet_tools.push_back(id);
  1704. }
  1705. void WaylandThread::_wp_tablet_seat_on_pad_added(void *data, struct zwp_tablet_seat_v2 *wp_tablet_seat_v2, struct zwp_tablet_pad_v2 *id) {
  1706. }
  1707. void WaylandThread::_wp_tablet_tool_on_type(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t tool_type) {
  1708. TabletToolState *state = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1709. if (state && tool_type == ZWP_TABLET_TOOL_V2_TYPE_ERASER) {
  1710. state->is_eraser = true;
  1711. }
  1712. }
  1713. void WaylandThread::_wp_tablet_tool_on_hardware_serial(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t hardware_serial_hi, uint32_t hardware_serial_lo) {
  1714. }
  1715. void WaylandThread::_wp_tablet_tool_on_hardware_id_wacom(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t hardware_id_hi, uint32_t hardware_id_lo) {
  1716. }
  1717. void WaylandThread::_wp_tablet_tool_on_capability(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t capability) {
  1718. }
  1719. void WaylandThread::_wp_tablet_tool_on_done(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2) {
  1720. }
  1721. void WaylandThread::_wp_tablet_tool_on_removed(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2) {
  1722. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1723. if (!ts) {
  1724. return;
  1725. }
  1726. SeatState *ss = wl_seat_get_seat_state(ts->wl_seat);
  1727. if (!ss) {
  1728. return;
  1729. }
  1730. List<struct zwp_tablet_tool_v2 *>::Element *E = ss->tablet_tools.find(wp_tablet_tool_v2);
  1731. if (E && E->get()) {
  1732. struct zwp_tablet_tool_v2 *tool = E->get();
  1733. TabletToolState *state = wp_tablet_tool_get_state(tool);
  1734. if (state) {
  1735. memdelete(state);
  1736. }
  1737. zwp_tablet_tool_v2_destroy(tool);
  1738. ss->tablet_tools.erase(E);
  1739. }
  1740. }
  1741. void WaylandThread::_wp_tablet_tool_on_proximity_in(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t serial, struct zwp_tablet_v2 *tablet, struct wl_surface *surface) {
  1742. if (!surface || !wl_proxy_is_godot((struct wl_proxy *)surface)) {
  1743. // We're probably on a decoration or something.
  1744. return;
  1745. }
  1746. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1747. if (!ts) {
  1748. return;
  1749. }
  1750. SeatState *ss = wl_seat_get_seat_state(ts->wl_seat);
  1751. if (!ss) {
  1752. return;
  1753. }
  1754. WaylandThread *wayland_thread = ss->wayland_thread;
  1755. ERR_FAIL_NULL(wayland_thread);
  1756. ts->data_pending.proximity_serial = serial;
  1757. ts->data_pending.proximal_surface = surface;
  1758. ts->last_surface = surface;
  1759. Ref<WindowEventMessage> msg;
  1760. msg.instantiate();
  1761. msg->event = DisplayServer::WINDOW_EVENT_MOUSE_ENTER;
  1762. wayland_thread->push_message(msg);
  1763. DEBUG_LOG_WAYLAND_THREAD("Tablet tool entered window.");
  1764. }
  1765. void WaylandThread::_wp_tablet_tool_on_proximity_out(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2) {
  1766. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1767. if (!ts || !ts->data_pending.proximal_surface) {
  1768. // Not our stuff, we don't care.
  1769. return;
  1770. }
  1771. SeatState *ss = wl_seat_get_seat_state(ts->wl_seat);
  1772. if (!ss) {
  1773. return;
  1774. }
  1775. WaylandThread *wayland_thread = ss->wayland_thread;
  1776. ERR_FAIL_NULL(wayland_thread);
  1777. ts->data_pending.proximal_surface = nullptr;
  1778. Ref<WindowEventMessage> msg;
  1779. msg.instantiate();
  1780. msg->event = DisplayServer::WINDOW_EVENT_MOUSE_EXIT;
  1781. wayland_thread->push_message(msg);
  1782. DEBUG_LOG_WAYLAND_THREAD("Tablet tool left window.");
  1783. }
  1784. void WaylandThread::_wp_tablet_tool_on_down(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t serial) {
  1785. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1786. if (!ts) {
  1787. return;
  1788. }
  1789. TabletToolData &td = ts->data_pending;
  1790. td.pressed_button_mask.set_flag(mouse_button_to_mask(MouseButton::LEFT));
  1791. td.last_button_pressed = MouseButton::LEFT;
  1792. td.double_click_begun = true;
  1793. // The protocol doesn't cover this, but we can use this funky hack to make
  1794. // double clicking work.
  1795. td.button_time = OS::get_singleton()->get_ticks_msec();
  1796. }
  1797. void WaylandThread::_wp_tablet_tool_on_up(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2) {
  1798. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1799. if (!ts) {
  1800. return;
  1801. }
  1802. TabletToolData &td = ts->data_pending;
  1803. td.pressed_button_mask.clear_flag(mouse_button_to_mask(MouseButton::LEFT));
  1804. // The protocol doesn't cover this, but we can use this funky hack to make
  1805. // double clicking work.
  1806. td.button_time = OS::get_singleton()->get_ticks_msec();
  1807. }
  1808. void WaylandThread::_wp_tablet_tool_on_motion(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, wl_fixed_t x, wl_fixed_t y) {
  1809. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1810. if (!ts) {
  1811. return;
  1812. }
  1813. if (!ts->data_pending.proximal_surface) {
  1814. // We're probably on a decoration or some other third-party thing.
  1815. return;
  1816. }
  1817. WindowState *ws = wl_surface_get_window_state(ts->data_pending.proximal_surface);
  1818. ERR_FAIL_NULL(ws);
  1819. TabletToolData &td = ts->data_pending;
  1820. double scale_factor = window_state_get_scale_factor(ws);
  1821. td.position.x = wl_fixed_to_double(x);
  1822. td.position.y = wl_fixed_to_double(y);
  1823. td.position *= scale_factor;
  1824. td.motion_time = OS::get_singleton()->get_ticks_msec();
  1825. }
  1826. void WaylandThread::_wp_tablet_tool_on_pressure(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t pressure) {
  1827. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1828. if (!ts) {
  1829. return;
  1830. }
  1831. ts->data_pending.pressure = pressure;
  1832. }
  1833. void WaylandThread::_wp_tablet_tool_on_distance(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t distance) {
  1834. // Unsupported
  1835. }
  1836. void WaylandThread::_wp_tablet_tool_on_tilt(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, wl_fixed_t tilt_x, wl_fixed_t tilt_y) {
  1837. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1838. if (!ts) {
  1839. return;
  1840. }
  1841. TabletToolData &td = ts->data_pending;
  1842. td.tilt.x = wl_fixed_to_double(tilt_x);
  1843. td.tilt.y = wl_fixed_to_double(tilt_y);
  1844. }
  1845. void WaylandThread::_wp_tablet_tool_on_rotation(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, wl_fixed_t degrees) {
  1846. // Unsupported.
  1847. }
  1848. void WaylandThread::_wp_tablet_tool_on_slider(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, int32_t position) {
  1849. // Unsupported.
  1850. }
  1851. void WaylandThread::_wp_tablet_tool_on_wheel(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, wl_fixed_t degrees, int32_t clicks) {
  1852. // TODO
  1853. }
  1854. void WaylandThread::_wp_tablet_tool_on_button(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t serial, uint32_t button, uint32_t state) {
  1855. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1856. if (!ts) {
  1857. return;
  1858. }
  1859. TabletToolData &td = ts->data_pending;
  1860. MouseButton mouse_button = MouseButton::NONE;
  1861. if (button == BTN_STYLUS) {
  1862. mouse_button = MouseButton::LEFT;
  1863. }
  1864. if (button == BTN_STYLUS2) {
  1865. mouse_button = MouseButton::RIGHT;
  1866. }
  1867. if (mouse_button != MouseButton::NONE) {
  1868. MouseButtonMask mask = mouse_button_to_mask(mouse_button);
  1869. if (state == ZWP_TABLET_TOOL_V2_BUTTON_STATE_PRESSED) {
  1870. td.pressed_button_mask.set_flag(mask);
  1871. td.last_button_pressed = mouse_button;
  1872. td.double_click_begun = true;
  1873. } else {
  1874. td.pressed_button_mask.clear_flag(mask);
  1875. }
  1876. // The protocol doesn't cover this, but we can use this funky hack to make
  1877. // double clicking work.
  1878. td.button_time = OS::get_singleton()->get_ticks_msec();
  1879. }
  1880. }
  1881. void WaylandThread::_wp_tablet_tool_on_frame(void *data, struct zwp_tablet_tool_v2 *wp_tablet_tool_v2, uint32_t time) {
  1882. TabletToolState *ts = wp_tablet_tool_get_state(wp_tablet_tool_v2);
  1883. if (!ts) {
  1884. return;
  1885. }
  1886. SeatState *ss = wl_seat_get_seat_state(ts->wl_seat);
  1887. if (!ss) {
  1888. return;
  1889. }
  1890. WaylandThread *wayland_thread = ss->wayland_thread;
  1891. ERR_FAIL_NULL(wayland_thread);
  1892. TabletToolData &old_td = ts->data;
  1893. TabletToolData &td = ts->data_pending;
  1894. if (old_td.position != td.position || old_td.tilt != td.tilt || old_td.pressure != td.pressure) {
  1895. Ref<InputEventMouseMotion> mm;
  1896. mm.instantiate();
  1897. mm->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1898. // Set all pressed modifiers.
  1899. mm->set_shift_pressed(ss->shift_pressed);
  1900. mm->set_ctrl_pressed(ss->ctrl_pressed);
  1901. mm->set_alt_pressed(ss->alt_pressed);
  1902. mm->set_meta_pressed(ss->meta_pressed);
  1903. mm->set_button_mask(td.pressed_button_mask);
  1904. mm->set_position(td.position);
  1905. mm->set_global_position(td.position);
  1906. // NOTE: The Godot API expects normalized values and we store them raw,
  1907. // straight from the compositor, so we have to normalize them here.
  1908. // According to the tablet proto spec, tilt is expressed in degrees relative
  1909. // to the Z axis of the tablet, so it shouldn't go over 90 degrees either way,
  1910. // I think. We'll clamp it just in case.
  1911. td.tilt = td.tilt.clampf(-90, 90);
  1912. mm->set_tilt(td.tilt / 90);
  1913. // The tablet proto spec explicitly says that pressure is defined as a value
  1914. // between 0 to 65535.
  1915. mm->set_pressure(td.pressure / (float)65535);
  1916. mm->set_pen_inverted(ts->is_eraser);
  1917. mm->set_relative(td.position - old_td.position);
  1918. mm->set_relative_screen_position(mm->get_relative());
  1919. Vector2 pos_delta = td.position - old_td.position;
  1920. uint32_t time_delta = td.motion_time - old_td.motion_time;
  1921. mm->set_velocity((Vector2)pos_delta / time_delta);
  1922. Ref<InputEventMessage> inputev_msg;
  1923. inputev_msg.instantiate();
  1924. inputev_msg->event = mm;
  1925. wayland_thread->push_message(inputev_msg);
  1926. }
  1927. if (old_td.pressed_button_mask != td.pressed_button_mask) {
  1928. BitField<MouseButtonMask> pressed_mask_delta = BitField<MouseButtonMask>((int64_t)old_td.pressed_button_mask ^ (int64_t)td.pressed_button_mask);
  1929. for (MouseButton test_button : { MouseButton::LEFT, MouseButton::RIGHT }) {
  1930. MouseButtonMask test_button_mask = mouse_button_to_mask(test_button);
  1931. if (pressed_mask_delta.has_flag(test_button_mask)) {
  1932. Ref<InputEventMouseButton> mb;
  1933. mb.instantiate();
  1934. // Set all pressed modifiers.
  1935. mb->set_shift_pressed(ss->shift_pressed);
  1936. mb->set_ctrl_pressed(ss->ctrl_pressed);
  1937. mb->set_alt_pressed(ss->alt_pressed);
  1938. mb->set_meta_pressed(ss->meta_pressed);
  1939. mb->set_window_id(DisplayServer::MAIN_WINDOW_ID);
  1940. mb->set_position(td.position);
  1941. mb->set_global_position(td.position);
  1942. mb->set_button_mask(td.pressed_button_mask);
  1943. mb->set_button_index(test_button);
  1944. mb->set_pressed(td.pressed_button_mask.has_flag(test_button_mask));
  1945. // We have to set the last position pressed here as we can't take for
  1946. // granted what the individual events might have seen due to them not having
  1947. // a garaunteed order.
  1948. if (mb->is_pressed()) {
  1949. td.last_pressed_position = td.position;
  1950. }
  1951. if (old_td.double_click_begun && mb->is_pressed() && td.last_button_pressed == old_td.last_button_pressed && (td.button_time - old_td.button_time) < 400 && Vector2(td.last_pressed_position).distance_to(Vector2(old_td.last_pressed_position)) < 5) {
  1952. td.double_click_begun = false;
  1953. mb->set_double_click(true);
  1954. }
  1955. Ref<InputEventMessage> msg;
  1956. msg.instantiate();
  1957. msg->event = mb;
  1958. wayland_thread->push_message(msg);
  1959. }
  1960. }
  1961. }
  1962. old_td = td;
  1963. }
  1964. void WaylandThread::_wp_text_input_on_enter(void *data, struct zwp_text_input_v3 *wp_text_input_v3, struct wl_surface *surface) {
  1965. SeatState *ss = (SeatState *)data;
  1966. if (!ss) {
  1967. return;
  1968. }
  1969. ss->ime_enabled = true;
  1970. }
  1971. void WaylandThread::_wp_text_input_on_leave(void *data, struct zwp_text_input_v3 *wp_text_input_v3, struct wl_surface *surface) {
  1972. SeatState *ss = (SeatState *)data;
  1973. if (!ss) {
  1974. return;
  1975. }
  1976. ss->ime_enabled = false;
  1977. ss->ime_active = false;
  1978. ss->ime_text = String();
  1979. ss->ime_text_commit = String();
  1980. ss->ime_cursor = Vector2i();
  1981. Ref<IMEUpdateEventMessage> msg;
  1982. msg.instantiate();
  1983. msg->text = String();
  1984. msg->selection = Vector2i();
  1985. ss->wayland_thread->push_message(msg);
  1986. }
  1987. void WaylandThread::_wp_text_input_on_preedit_string(void *data, struct zwp_text_input_v3 *wp_text_input_v3, const char *text, int32_t cursor_begin, int32_t cursor_end) {
  1988. SeatState *ss = (SeatState *)data;
  1989. if (!ss) {
  1990. return;
  1991. }
  1992. ss->ime_text = String::utf8(text);
  1993. // Convert cursor positions from UTF-8 to UTF-32 offset.
  1994. int32_t cursor_begin_utf32 = 0;
  1995. int32_t cursor_end_utf32 = 0;
  1996. for (int i = 0; i < ss->ime_text.length(); i++) {
  1997. uint32_t c = ss->ime_text[i];
  1998. if (c <= 0x7f) { // 7 bits.
  1999. cursor_begin -= 1;
  2000. cursor_end -= 1;
  2001. } else if (c <= 0x7ff) { // 11 bits
  2002. cursor_begin -= 2;
  2003. cursor_end -= 2;
  2004. } else if (c <= 0xffff) { // 16 bits
  2005. cursor_begin -= 3;
  2006. cursor_end -= 3;
  2007. } else if (c <= 0x001fffff) { // 21 bits
  2008. cursor_begin -= 4;
  2009. cursor_end -= 4;
  2010. } else if (c <= 0x03ffffff) { // 26 bits
  2011. cursor_begin -= 5;
  2012. cursor_end -= 5;
  2013. } else if (c <= 0x7fffffff) { // 31 bits
  2014. cursor_begin -= 6;
  2015. cursor_end -= 6;
  2016. } else {
  2017. cursor_begin -= 1;
  2018. cursor_end -= 1;
  2019. }
  2020. if (cursor_begin == 0) {
  2021. cursor_begin_utf32 = i + 1;
  2022. }
  2023. if (cursor_end == 0) {
  2024. cursor_end_utf32 = i + 1;
  2025. }
  2026. if (cursor_begin <= 0 && cursor_end <= 0) {
  2027. break;
  2028. }
  2029. }
  2030. ss->ime_cursor = Vector2i(cursor_begin_utf32, cursor_end_utf32 - cursor_begin_utf32);
  2031. }
  2032. void WaylandThread::_wp_text_input_on_commit_string(void *data, struct zwp_text_input_v3 *wp_text_input_v3, const char *text) {
  2033. SeatState *ss = (SeatState *)data;
  2034. if (!ss) {
  2035. return;
  2036. }
  2037. ss->ime_text_commit = String::utf8(text);
  2038. }
  2039. void WaylandThread::_wp_text_input_on_delete_surrounding_text(void *data, struct zwp_text_input_v3 *wp_text_input_v3, uint32_t before_length, uint32_t after_length) {
  2040. // Not implemented.
  2041. }
  2042. void WaylandThread::_wp_text_input_on_done(void *data, struct zwp_text_input_v3 *wp_text_input_v3, uint32_t serial) {
  2043. SeatState *ss = (SeatState *)data;
  2044. if (!ss) {
  2045. return;
  2046. }
  2047. if (!ss->ime_text_commit.is_empty()) {
  2048. Ref<IMECommitEventMessage> msg;
  2049. msg.instantiate();
  2050. msg->text = ss->ime_text_commit;
  2051. ss->wayland_thread->push_message(msg);
  2052. } else if (!ss->ime_text.is_empty()) {
  2053. Ref<IMEUpdateEventMessage> msg;
  2054. msg.instantiate();
  2055. msg->text = ss->ime_text;
  2056. msg->selection = ss->ime_cursor;
  2057. ss->wayland_thread->push_message(msg);
  2058. }
  2059. ss->ime_text = String();
  2060. ss->ime_text_commit = String();
  2061. ss->ime_cursor = Vector2i();
  2062. }
  2063. void WaylandThread::_xdg_activation_token_on_done(void *data, struct xdg_activation_token_v1 *xdg_activation_token, const char *token) {
  2064. WindowState *ws = (WindowState *)data;
  2065. ERR_FAIL_NULL(ws);
  2066. ERR_FAIL_NULL(ws->wayland_thread);
  2067. ERR_FAIL_NULL(ws->wl_surface);
  2068. xdg_activation_v1_activate(ws->wayland_thread->registry.xdg_activation, token, ws->wl_surface);
  2069. xdg_activation_token_v1_destroy(xdg_activation_token);
  2070. DEBUG_LOG_WAYLAND_THREAD(vformat("Received activation token and requested window activation."));
  2071. }
  2072. // NOTE: This must be started after a valid wl_display is loaded.
  2073. void WaylandThread::_poll_events_thread(void *p_data) {
  2074. ThreadData *data = (ThreadData *)p_data;
  2075. ERR_FAIL_NULL(data);
  2076. ERR_FAIL_NULL(data->wl_display);
  2077. struct pollfd poll_fd;
  2078. poll_fd.fd = wl_display_get_fd(data->wl_display);
  2079. poll_fd.events = POLLIN | POLLHUP;
  2080. while (true) {
  2081. // Empty the event queue while it's full.
  2082. while (wl_display_prepare_read(data->wl_display) != 0) {
  2083. // We aren't using wl_display_dispatch(), instead "manually" handling events
  2084. // through wl_display_dispatch_pending so that we can use a global mutex and
  2085. // be sure that this and the main thread won't race over stuff, as long as
  2086. // the main thread locks it too.
  2087. //
  2088. // Note that the main thread can still call wl_display_roundtrip as that
  2089. // method directly handles all events, effectively bypassing this polling
  2090. // loop and thus the mutex locking, avoiding a deadlock.
  2091. MutexLock mutex_lock(data->mutex);
  2092. if (wl_display_dispatch_pending(data->wl_display) == -1) {
  2093. // Oh no. We'll check and handle any display error below.
  2094. break;
  2095. }
  2096. }
  2097. int werror = wl_display_get_error(data->wl_display);
  2098. if (werror) {
  2099. if (werror == EPROTO) {
  2100. struct wl_interface *wl_interface = nullptr;
  2101. uint32_t id = 0;
  2102. int error_code = wl_display_get_protocol_error(data->wl_display, (const struct wl_interface **)&wl_interface, &id);
  2103. CRASH_NOW_MSG(vformat("Wayland protocol error %d on interface %s@%d.", error_code, wl_interface ? wl_interface->name : "unknown", id));
  2104. } else {
  2105. CRASH_NOW_MSG(vformat("Wayland client error code %d.", werror));
  2106. }
  2107. }
  2108. wl_display_flush(data->wl_display);
  2109. // Wait for the event file descriptor to have new data.
  2110. poll(&poll_fd, 1, -1);
  2111. if (data->thread_done.is_set()) {
  2112. wl_display_cancel_read(data->wl_display);
  2113. break;
  2114. }
  2115. if (poll_fd.revents | POLLIN) {
  2116. // Load the queues with fresh new data.
  2117. wl_display_read_events(data->wl_display);
  2118. } else {
  2119. // Oh well... Stop signaling that we want to read.
  2120. wl_display_cancel_read(data->wl_display);
  2121. }
  2122. // The docs advise to redispatch unconditionally and it looks like that if we
  2123. // don't do this we can't catch protocol errors, which is bad.
  2124. MutexLock mutex_lock(data->mutex);
  2125. wl_display_dispatch_pending(data->wl_display);
  2126. }
  2127. }
  2128. struct wl_display *WaylandThread::get_wl_display() const {
  2129. return wl_display;
  2130. }
  2131. // NOTE: Stuff like libdecor can (and will) register foreign proxies which
  2132. // aren't formatted as we like. This method is needed to detect whether a proxy
  2133. // has our tag. Also, be careful! The proxy has to be manually tagged or it
  2134. // won't be recognized.
  2135. bool WaylandThread::wl_proxy_is_godot(struct wl_proxy *p_proxy) {
  2136. ERR_FAIL_NULL_V(p_proxy, false);
  2137. return wl_proxy_get_tag(p_proxy) == &proxy_tag;
  2138. }
  2139. void WaylandThread::wl_proxy_tag_godot(struct wl_proxy *p_proxy) {
  2140. ERR_FAIL_NULL(p_proxy);
  2141. wl_proxy_set_tag(p_proxy, &proxy_tag);
  2142. }
  2143. // Returns the wl_surface's `WindowState`, otherwise `nullptr`.
  2144. // NOTE: This will fail if the surface isn't tagged as ours.
  2145. WaylandThread::WindowState *WaylandThread::wl_surface_get_window_state(struct wl_surface *p_surface) {
  2146. if (p_surface && wl_proxy_is_godot((wl_proxy *)p_surface)) {
  2147. return (WindowState *)wl_surface_get_user_data(p_surface);
  2148. }
  2149. return nullptr;
  2150. }
  2151. // Returns the wl_outputs's `ScreenState`, otherwise `nullptr`.
  2152. // NOTE: This will fail if the output isn't tagged as ours.
  2153. WaylandThread::ScreenState *WaylandThread::wl_output_get_screen_state(struct wl_output *p_output) {
  2154. if (p_output && wl_proxy_is_godot((wl_proxy *)p_output)) {
  2155. return (ScreenState *)wl_output_get_user_data(p_output);
  2156. }
  2157. return nullptr;
  2158. }
  2159. // Returns the wl_seat's `SeatState`, otherwise `nullptr`.
  2160. // NOTE: This will fail if the output isn't tagged as ours.
  2161. WaylandThread::SeatState *WaylandThread::wl_seat_get_seat_state(struct wl_seat *p_seat) {
  2162. if (p_seat && wl_proxy_is_godot((wl_proxy *)p_seat)) {
  2163. return (SeatState *)wl_seat_get_user_data(p_seat);
  2164. }
  2165. return nullptr;
  2166. }
  2167. // Returns the wp_tablet_tool's `TabletToolState`, otherwise `nullptr`.
  2168. // NOTE: This will fail if the output isn't tagged as ours.
  2169. WaylandThread::TabletToolState *WaylandThread::wp_tablet_tool_get_state(struct zwp_tablet_tool_v2 *p_tool) {
  2170. if (p_tool && wl_proxy_is_godot((wl_proxy *)p_tool)) {
  2171. return (TabletToolState *)zwp_tablet_tool_v2_get_user_data(p_tool);
  2172. }
  2173. return nullptr;
  2174. }
  2175. // Returns the wl_data_offer's `OfferState`, otherwise `nullptr`.
  2176. // NOTE: This will fail if the output isn't tagged as ours.
  2177. WaylandThread::OfferState *WaylandThread::wl_data_offer_get_offer_state(struct wl_data_offer *p_offer) {
  2178. if (p_offer && wl_proxy_is_godot((wl_proxy *)p_offer)) {
  2179. return (OfferState *)wl_data_offer_get_user_data(p_offer);
  2180. }
  2181. return nullptr;
  2182. }
  2183. // Returns the wl_data_offer's `OfferState`, otherwise `nullptr`.
  2184. // NOTE: This will fail if the output isn't tagged as ours.
  2185. WaylandThread::OfferState *WaylandThread::wp_primary_selection_offer_get_offer_state(struct zwp_primary_selection_offer_v1 *p_offer) {
  2186. if (p_offer && wl_proxy_is_godot((wl_proxy *)p_offer)) {
  2187. return (OfferState *)zwp_primary_selection_offer_v1_get_user_data(p_offer);
  2188. }
  2189. return nullptr;
  2190. }
  2191. // This is implemented as a method because this is the simplest way of
  2192. // accounting for dynamic output scale changes.
  2193. int WaylandThread::window_state_get_preferred_buffer_scale(WindowState *p_ws) {
  2194. ERR_FAIL_NULL_V(p_ws, 1);
  2195. if (p_ws->preferred_fractional_scale > 0) {
  2196. // We're scaling fractionally. Per spec, the buffer scale is always 1.
  2197. return 1;
  2198. }
  2199. if (p_ws->wl_outputs.is_empty()) {
  2200. DEBUG_LOG_WAYLAND_THREAD("Window has no output associated, returning buffer scale of 1.");
  2201. return 1;
  2202. }
  2203. // TODO: Cache value?
  2204. int max_size = 1;
  2205. // ================================ IMPORTANT =================================
  2206. // NOTE: Due to a Godot limitation, we can't really rescale the whole UI yet.
  2207. // Because of this reason, all platforms have resorted to forcing the highest
  2208. // scale possible of a system on any window, despite of what screen it's onto.
  2209. // On this backend everything's already in place for dynamic window scale
  2210. // handling, but in the meantime we'll just select the biggest _global_ output.
  2211. // To restore dynamic scale selection, simply iterate over `p_ws->wl_outputs`
  2212. // instead.
  2213. for (struct wl_output *wl_output : p_ws->registry->wl_outputs) {
  2214. ScreenState *ss = wl_output_get_screen_state(wl_output);
  2215. if (ss && ss->pending_data.scale > max_size) {
  2216. // NOTE: For some mystical reason, wl_output.done is emitted _after_ windows
  2217. // get resized but the scale event gets sent _before_ that. I'm still leaning
  2218. // towards the idea that rescaling when a window gets a resolution change is a
  2219. // pretty good approach, but this means that we'll have to use the screen data
  2220. // before it's "committed".
  2221. // FIXME: Use the committed data. Somehow.
  2222. max_size = ss->pending_data.scale;
  2223. }
  2224. }
  2225. return max_size;
  2226. }
  2227. double WaylandThread::window_state_get_scale_factor(WindowState *p_ws) {
  2228. ERR_FAIL_NULL_V(p_ws, 1);
  2229. if (p_ws->fractional_scale > 0) {
  2230. // The fractional scale amount takes priority.
  2231. return p_ws->fractional_scale;
  2232. }
  2233. return p_ws->buffer_scale;
  2234. }
  2235. void WaylandThread::window_state_update_size(WindowState *p_ws, int p_width, int p_height) {
  2236. ERR_FAIL_NULL(p_ws);
  2237. int preferred_buffer_scale = window_state_get_preferred_buffer_scale(p_ws);
  2238. bool using_fractional = p_ws->preferred_fractional_scale > 0;
  2239. // If neither is true we no-op.
  2240. bool scale_changed = false;
  2241. bool size_changed = false;
  2242. if (p_ws->rect.size.width != p_width || p_ws->rect.size.height != p_height) {
  2243. p_ws->rect.size.width = p_width;
  2244. p_ws->rect.size.height = p_height;
  2245. size_changed = true;
  2246. }
  2247. if (using_fractional && p_ws->fractional_scale != p_ws->preferred_fractional_scale) {
  2248. p_ws->fractional_scale = p_ws->preferred_fractional_scale;
  2249. scale_changed = true;
  2250. }
  2251. if (p_ws->buffer_scale != preferred_buffer_scale) {
  2252. // The buffer scale is always important, even if we use frac scaling.
  2253. p_ws->buffer_scale = preferred_buffer_scale;
  2254. p_ws->buffer_scale_changed = true;
  2255. if (!using_fractional) {
  2256. // We don't bother updating everything else if it's turned on though.
  2257. scale_changed = true;
  2258. }
  2259. }
  2260. if (p_ws->wl_surface && (size_changed || scale_changed)) {
  2261. if (p_ws->wp_viewport) {
  2262. wp_viewport_set_destination(p_ws->wp_viewport, p_width, p_height);
  2263. }
  2264. if (p_ws->xdg_surface) {
  2265. xdg_surface_set_window_geometry(p_ws->xdg_surface, 0, 0, p_width, p_height);
  2266. }
  2267. }
  2268. #ifdef LIBDECOR_ENABLED
  2269. if (p_ws->libdecor_frame) {
  2270. struct libdecor_state *state = libdecor_state_new(p_width, p_height);
  2271. libdecor_frame_commit(p_ws->libdecor_frame, state, p_ws->pending_libdecor_configuration);
  2272. libdecor_state_free(state);
  2273. p_ws->pending_libdecor_configuration = nullptr;
  2274. }
  2275. #endif
  2276. if (size_changed || scale_changed) {
  2277. Size2i scaled_size = scale_vector2i(p_ws->rect.size, window_state_get_scale_factor(p_ws));
  2278. if (using_fractional) {
  2279. DEBUG_LOG_WAYLAND_THREAD(vformat("Resizing the window from %s to %s (fractional scale x%f).", p_ws->rect.size, scaled_size, p_ws->fractional_scale));
  2280. } else {
  2281. DEBUG_LOG_WAYLAND_THREAD(vformat("Resizing the window from %s to %s (buffer scale x%d).", p_ws->rect.size, scaled_size, p_ws->buffer_scale));
  2282. }
  2283. // FIXME: Actually resize the hint instead of centering it.
  2284. p_ws->wayland_thread->pointer_set_hint(scaled_size / 2);
  2285. Ref<WindowRectMessage> rect_msg;
  2286. rect_msg.instantiate();
  2287. rect_msg->rect = p_ws->rect;
  2288. rect_msg->rect.size = scaled_size;
  2289. p_ws->wayland_thread->push_message(rect_msg);
  2290. }
  2291. if (scale_changed) {
  2292. Ref<WindowEventMessage> dpi_msg;
  2293. dpi_msg.instantiate();
  2294. dpi_msg->event = DisplayServer::WINDOW_EVENT_DPI_CHANGE;
  2295. p_ws->wayland_thread->push_message(dpi_msg);
  2296. }
  2297. }
  2298. // Scales a vector according to wp_fractional_scale's rules, where coordinates
  2299. // must be scaled with away from zero half-rounding.
  2300. Vector2i WaylandThread::scale_vector2i(const Vector2i &p_vector, double p_amount) {
  2301. // This snippet is tiny, I know, but this is done a lot.
  2302. int x = round(p_vector.x * p_amount);
  2303. int y = round(p_vector.y * p_amount);
  2304. return Vector2i(x, y);
  2305. }
  2306. void WaylandThread::seat_state_unlock_pointer(SeatState *p_ss) {
  2307. ERR_FAIL_NULL(p_ss);
  2308. if (p_ss->wl_pointer == nullptr) {
  2309. return;
  2310. }
  2311. if (p_ss->wp_locked_pointer) {
  2312. zwp_locked_pointer_v1_destroy(p_ss->wp_locked_pointer);
  2313. p_ss->wp_locked_pointer = nullptr;
  2314. }
  2315. if (p_ss->wp_confined_pointer) {
  2316. zwp_confined_pointer_v1_destroy(p_ss->wp_confined_pointer);
  2317. p_ss->wp_confined_pointer = nullptr;
  2318. }
  2319. }
  2320. void WaylandThread::seat_state_lock_pointer(SeatState *p_ss) {
  2321. ERR_FAIL_NULL(p_ss);
  2322. if (p_ss->wl_pointer == nullptr) {
  2323. return;
  2324. }
  2325. if (registry.wp_pointer_constraints == nullptr) {
  2326. return;
  2327. }
  2328. if (p_ss->wp_locked_pointer == nullptr) {
  2329. struct wl_surface *locked_surface = p_ss->last_pointed_surface;
  2330. if (locked_surface == nullptr) {
  2331. locked_surface = window_get_wl_surface(DisplayServer::MAIN_WINDOW_ID);
  2332. }
  2333. ERR_FAIL_NULL(locked_surface);
  2334. p_ss->wp_locked_pointer = zwp_pointer_constraints_v1_lock_pointer(registry.wp_pointer_constraints, locked_surface, p_ss->wl_pointer, nullptr, ZWP_POINTER_CONSTRAINTS_V1_LIFETIME_PERSISTENT);
  2335. }
  2336. }
  2337. void WaylandThread::seat_state_set_hint(SeatState *p_ss, int p_x, int p_y) {
  2338. if (p_ss->wp_locked_pointer == nullptr) {
  2339. return;
  2340. }
  2341. zwp_locked_pointer_v1_set_cursor_position_hint(p_ss->wp_locked_pointer, wl_fixed_from_int(p_x), wl_fixed_from_int(p_y));
  2342. }
  2343. void WaylandThread::seat_state_confine_pointer(SeatState *p_ss) {
  2344. ERR_FAIL_NULL(p_ss);
  2345. if (p_ss->wl_pointer == nullptr) {
  2346. return;
  2347. }
  2348. if (registry.wp_pointer_constraints == nullptr) {
  2349. return;
  2350. }
  2351. if (p_ss->wp_confined_pointer == nullptr) {
  2352. struct wl_surface *confined_surface = p_ss->last_pointed_surface;
  2353. if (confined_surface == nullptr) {
  2354. confined_surface = window_get_wl_surface(DisplayServer::MAIN_WINDOW_ID);
  2355. }
  2356. ERR_FAIL_NULL(confined_surface);
  2357. p_ss->wp_confined_pointer = zwp_pointer_constraints_v1_confine_pointer(registry.wp_pointer_constraints, confined_surface, p_ss->wl_pointer, nullptr, ZWP_POINTER_CONSTRAINTS_V1_LIFETIME_PERSISTENT);
  2358. }
  2359. }
  2360. void WaylandThread::seat_state_update_cursor(SeatState *p_ss) {
  2361. ERR_FAIL_NULL(p_ss);
  2362. ERR_FAIL_NULL(p_ss->wayland_thread);
  2363. if (p_ss->wl_pointer && p_ss->cursor_surface) {
  2364. // NOTE: Those values are valid by default and will hide the cursor when
  2365. // unchanged, which happens when both the current custom cursor and the
  2366. // current wl_cursor are `nullptr`.
  2367. struct wl_buffer *cursor_buffer = nullptr;
  2368. uint32_t hotspot_x = 0;
  2369. uint32_t hotspot_y = 0;
  2370. int scale = 1;
  2371. CustomCursor *custom_cursor = p_ss->wayland_thread->current_custom_cursor;
  2372. struct wl_cursor *wl_cursor = p_ss->wayland_thread->current_wl_cursor;
  2373. if (custom_cursor) {
  2374. cursor_buffer = custom_cursor->wl_buffer;
  2375. hotspot_x = custom_cursor->hotspot.x;
  2376. hotspot_y = custom_cursor->hotspot.y;
  2377. // We can't really reasonably scale custom cursors, so we'll let the
  2378. // compositor do it for us (badly).
  2379. scale = 1;
  2380. } else if (wl_cursor) {
  2381. int frame_idx = 0;
  2382. if (wl_cursor->image_count > 1) {
  2383. // The cursor is animated.
  2384. frame_idx = wl_cursor_frame(wl_cursor, p_ss->cursor_time_ms);
  2385. if (!p_ss->cursor_frame_callback) {
  2386. // Since it's animated, we'll re-update it the next frame.
  2387. p_ss->cursor_frame_callback = wl_surface_frame(p_ss->cursor_surface);
  2388. wl_callback_add_listener(p_ss->cursor_frame_callback, &cursor_frame_callback_listener, p_ss);
  2389. }
  2390. }
  2391. struct wl_cursor_image *wl_cursor_image = wl_cursor->images[frame_idx];
  2392. scale = p_ss->wayland_thread->cursor_scale;
  2393. cursor_buffer = wl_cursor_image_get_buffer(wl_cursor_image);
  2394. // As the surface's buffer is scaled (thus the surface is smaller) and the
  2395. // hotspot must be expressed in surface-local coordinates, we need to scale
  2396. // them down accordingly.
  2397. hotspot_x = wl_cursor_image->hotspot_x / scale;
  2398. hotspot_y = wl_cursor_image->hotspot_y / scale;
  2399. }
  2400. wl_pointer_set_cursor(p_ss->wl_pointer, p_ss->pointer_enter_serial, p_ss->cursor_surface, hotspot_x, hotspot_y);
  2401. wl_surface_set_buffer_scale(p_ss->cursor_surface, scale);
  2402. wl_surface_attach(p_ss->cursor_surface, cursor_buffer, 0, 0);
  2403. wl_surface_damage_buffer(p_ss->cursor_surface, 0, 0, INT_MAX, INT_MAX);
  2404. wl_surface_commit(p_ss->cursor_surface);
  2405. }
  2406. }
  2407. void WaylandThread::seat_state_echo_keys(SeatState *p_ss) {
  2408. ERR_FAIL_NULL(p_ss);
  2409. if (p_ss->wl_keyboard == nullptr) {
  2410. return;
  2411. }
  2412. // TODO: Comment and document out properly this block of code.
  2413. // In short, this implements key repeating.
  2414. if (p_ss->repeat_key_delay_msec && p_ss->repeating_keycode != XKB_KEYCODE_INVALID) {
  2415. uint64_t current_ticks = OS::get_singleton()->get_ticks_msec();
  2416. uint64_t delayed_start_ticks = p_ss->last_repeat_start_msec + p_ss->repeat_start_delay_msec;
  2417. if (p_ss->last_repeat_msec < delayed_start_ticks) {
  2418. p_ss->last_repeat_msec = delayed_start_ticks;
  2419. }
  2420. if (current_ticks >= delayed_start_ticks) {
  2421. uint64_t ticks_delta = current_ticks - p_ss->last_repeat_msec;
  2422. int keys_amount = (ticks_delta / p_ss->repeat_key_delay_msec);
  2423. for (int i = 0; i < keys_amount; i++) {
  2424. Ref<InputEventKey> k;
  2425. k.instantiate();
  2426. if (!_seat_state_configure_key_event(*p_ss, k, p_ss->repeating_keycode, true)) {
  2427. continue;
  2428. }
  2429. k->set_echo(true);
  2430. Input::get_singleton()->parse_input_event(k);
  2431. }
  2432. p_ss->last_repeat_msec += ticks_delta - (ticks_delta % p_ss->repeat_key_delay_msec);
  2433. }
  2434. }
  2435. }
  2436. void WaylandThread::push_message(Ref<Message> message) {
  2437. messages.push_back(message);
  2438. }
  2439. bool WaylandThread::has_message() {
  2440. return messages.front() != nullptr;
  2441. }
  2442. Ref<WaylandThread::Message> WaylandThread::pop_message() {
  2443. if (messages.front() != nullptr) {
  2444. Ref<Message> msg = messages.front()->get();
  2445. messages.pop_front();
  2446. return msg;
  2447. }
  2448. // This method should only be called if `has_messages` returns true but if
  2449. // that isn't the case we'll just return an invalid `Ref`. After all, due to
  2450. // its `InputEvent`-like interface, we still have to dynamically cast and check
  2451. // the `Ref`'s validity anyways.
  2452. return Ref<Message>();
  2453. }
  2454. void WaylandThread::window_create(DisplayServer::WindowID p_window_id, int p_width, int p_height) {
  2455. // TODO: Implement multi-window support.
  2456. WindowState &ws = main_window;
  2457. ws.registry = &registry;
  2458. ws.wayland_thread = this;
  2459. ws.rect.size.width = p_width;
  2460. ws.rect.size.height = p_height;
  2461. ws.wl_surface = wl_compositor_create_surface(registry.wl_compositor);
  2462. wl_proxy_tag_godot((struct wl_proxy *)ws.wl_surface);
  2463. wl_surface_add_listener(ws.wl_surface, &wl_surface_listener, &ws);
  2464. if (registry.wp_viewporter) {
  2465. ws.wp_viewport = wp_viewporter_get_viewport(registry.wp_viewporter, ws.wl_surface);
  2466. if (registry.wp_fractional_scale_manager) {
  2467. ws.wp_fractional_scale = wp_fractional_scale_manager_v1_get_fractional_scale(registry.wp_fractional_scale_manager, ws.wl_surface);
  2468. wp_fractional_scale_v1_add_listener(ws.wp_fractional_scale, &wp_fractional_scale_listener, &ws);
  2469. }
  2470. }
  2471. bool decorated = false;
  2472. #ifdef LIBDECOR_ENABLED
  2473. if (!decorated && libdecor_context) {
  2474. ws.libdecor_frame = libdecor_decorate(libdecor_context, ws.wl_surface, (struct libdecor_frame_interface *)&libdecor_frame_interface, &ws);
  2475. libdecor_frame_map(ws.libdecor_frame);
  2476. decorated = true;
  2477. }
  2478. #endif
  2479. if (!decorated) {
  2480. // libdecor has failed loading or is disabled, we shall handle xdg_toplevel
  2481. // creation and decoration ourselves (and by decorating for now I just mean
  2482. // asking for SSDs and hoping for the best).
  2483. ws.xdg_surface = xdg_wm_base_get_xdg_surface(registry.xdg_wm_base, ws.wl_surface);
  2484. xdg_surface_add_listener(ws.xdg_surface, &xdg_surface_listener, &ws);
  2485. ws.xdg_toplevel = xdg_surface_get_toplevel(ws.xdg_surface);
  2486. xdg_toplevel_add_listener(ws.xdg_toplevel, &xdg_toplevel_listener, &ws);
  2487. if (registry.xdg_decoration_manager) {
  2488. ws.xdg_toplevel_decoration = zxdg_decoration_manager_v1_get_toplevel_decoration(registry.xdg_decoration_manager, ws.xdg_toplevel);
  2489. zxdg_toplevel_decoration_v1_add_listener(ws.xdg_toplevel_decoration, &xdg_toplevel_decoration_listener, &ws);
  2490. decorated = true;
  2491. }
  2492. }
  2493. ws.frame_callback = wl_surface_frame(ws.wl_surface);
  2494. wl_callback_add_listener(ws.frame_callback, &frame_wl_callback_listener, &ws);
  2495. if (registry.xdg_exporter) {
  2496. ws.xdg_exported = zxdg_exporter_v1_export(registry.xdg_exporter, ws.wl_surface);
  2497. zxdg_exported_v1_add_listener(ws.xdg_exported, &xdg_exported_listener, &ws);
  2498. }
  2499. wl_surface_commit(ws.wl_surface);
  2500. // Wait for the surface to be configured before continuing.
  2501. wl_display_roundtrip(wl_display);
  2502. }
  2503. struct wl_surface *WaylandThread::window_get_wl_surface(DisplayServer::WindowID p_window_id) const {
  2504. // TODO: Use window IDs for multiwindow support.
  2505. const WindowState &ws = main_window;
  2506. return ws.wl_surface;
  2507. }
  2508. void WaylandThread::window_set_max_size(DisplayServer::WindowID p_window_id, const Size2i &p_size) {
  2509. // TODO: Use window IDs for multiwindow support.
  2510. WindowState &ws = main_window;
  2511. Vector2i logical_max_size = p_size / window_state_get_scale_factor(&ws);
  2512. if (ws.wl_surface && ws.xdg_toplevel) {
  2513. xdg_toplevel_set_max_size(ws.xdg_toplevel, logical_max_size.width, logical_max_size.height);
  2514. }
  2515. #ifdef LIBDECOR_ENABLED
  2516. if (ws.libdecor_frame) {
  2517. libdecor_frame_set_max_content_size(ws.libdecor_frame, logical_max_size.width, logical_max_size.height);
  2518. }
  2519. // FIXME: I'm not sure whether we have to commit the surface for this to apply.
  2520. #endif
  2521. }
  2522. void WaylandThread::window_set_min_size(DisplayServer::WindowID p_window_id, const Size2i &p_size) {
  2523. // TODO: Use window IDs for multiwindow support.
  2524. WindowState &ws = main_window;
  2525. Size2i logical_min_size = p_size / window_state_get_scale_factor(&ws);
  2526. if (ws.wl_surface && ws.xdg_toplevel) {
  2527. xdg_toplevel_set_min_size(ws.xdg_toplevel, logical_min_size.width, logical_min_size.height);
  2528. }
  2529. #ifdef LIBDECOR_ENABLED
  2530. if (ws.libdecor_frame) {
  2531. libdecor_frame_set_min_content_size(ws.libdecor_frame, logical_min_size.width, logical_min_size.height);
  2532. }
  2533. // FIXME: I'm not sure whether we have to commit the surface for this to apply.
  2534. #endif
  2535. }
  2536. bool WaylandThread::window_can_set_mode(DisplayServer::WindowID p_window_id, DisplayServer::WindowMode p_window_mode) const {
  2537. // TODO: Use window IDs for multiwindow support.
  2538. const WindowState &ws = main_window;
  2539. switch (p_window_mode) {
  2540. case DisplayServer::WINDOW_MODE_WINDOWED: {
  2541. // Looks like it's guaranteed.
  2542. return true;
  2543. };
  2544. case DisplayServer::WINDOW_MODE_MINIMIZED: {
  2545. #ifdef LIBDECOR_ENABLED
  2546. if (ws.libdecor_frame) {
  2547. return libdecor_frame_has_capability(ws.libdecor_frame, LIBDECOR_ACTION_MINIMIZE);
  2548. }
  2549. #endif // LIBDECOR_ENABLED
  2550. return ws.can_minimize;
  2551. };
  2552. case DisplayServer::WINDOW_MODE_MAXIMIZED: {
  2553. // NOTE: libdecor doesn't seem to have a maximize capability query?
  2554. // The fact that there's a fullscreen one makes me suspicious.
  2555. return ws.can_maximize;
  2556. };
  2557. case DisplayServer::WINDOW_MODE_FULLSCREEN: {
  2558. #ifdef LIBDECOR_ENABLED
  2559. if (ws.libdecor_frame) {
  2560. return libdecor_frame_has_capability(ws.libdecor_frame, LIBDECOR_ACTION_FULLSCREEN);
  2561. }
  2562. #endif // LIBDECOR_ENABLED
  2563. return ws.can_fullscreen;
  2564. };
  2565. case DisplayServer::WINDOW_MODE_EXCLUSIVE_FULLSCREEN: {
  2566. // I'm not really sure but from what I can find Wayland doesn't really have
  2567. // the concept of exclusive fullscreen.
  2568. // TODO: Discuss whether to fallback to regular fullscreen or not.
  2569. return false;
  2570. };
  2571. }
  2572. return false;
  2573. }
  2574. void WaylandThread::window_try_set_mode(DisplayServer::WindowID p_window_id, DisplayServer::WindowMode p_window_mode) {
  2575. // TODO: Use window IDs for multiwindow support.
  2576. WindowState &ws = main_window;
  2577. if (ws.mode == p_window_mode) {
  2578. return;
  2579. }
  2580. // Don't waste time with hidden windows and whatnot. Behave like it worked.
  2581. #ifdef LIBDECOR_ENABLED
  2582. if ((!ws.wl_surface || !ws.xdg_toplevel) && !ws.libdecor_frame) {
  2583. #else
  2584. if (!ws.wl_surface || !ws.xdg_toplevel) {
  2585. #endif // LIBDECOR_ENABLED
  2586. ws.mode = p_window_mode;
  2587. return;
  2588. }
  2589. // Return back to a windowed state so that we can apply what the user asked.
  2590. switch (ws.mode) {
  2591. case DisplayServer::WINDOW_MODE_WINDOWED: {
  2592. // Do nothing.
  2593. } break;
  2594. case DisplayServer::WINDOW_MODE_MINIMIZED: {
  2595. // We can't do much according to the xdg_shell protocol. I have no idea
  2596. // whether this implies that we should return or who knows what. For now
  2597. // we'll do nothing.
  2598. // TODO: Test this properly.
  2599. } break;
  2600. case DisplayServer::WINDOW_MODE_MAXIMIZED: {
  2601. // Try to unmaximize. This isn't garaunteed to work actually, so we'll have
  2602. // to check whether something changed.
  2603. if (ws.xdg_toplevel) {
  2604. xdg_toplevel_unset_maximized(ws.xdg_toplevel);
  2605. }
  2606. #ifdef LIBDECOR_ENABLED
  2607. if (ws.libdecor_frame) {
  2608. libdecor_frame_unset_maximized(ws.libdecor_frame);
  2609. }
  2610. #endif // LIBDECOR_ENABLED
  2611. } break;
  2612. case DisplayServer::WINDOW_MODE_FULLSCREEN:
  2613. case DisplayServer::WINDOW_MODE_EXCLUSIVE_FULLSCREEN: {
  2614. // Same thing as above, unset fullscreen and check later if it worked.
  2615. if (ws.xdg_toplevel) {
  2616. xdg_toplevel_unset_fullscreen(ws.xdg_toplevel);
  2617. }
  2618. #ifdef LIBDECOR_ENABLED
  2619. if (ws.libdecor_frame) {
  2620. libdecor_frame_unset_fullscreen(ws.libdecor_frame);
  2621. }
  2622. #endif // LIBDECOR_ENABLED
  2623. } break;
  2624. }
  2625. // Wait for a configure event and hope that something changed.
  2626. wl_display_roundtrip(wl_display);
  2627. if (ws.mode != DisplayServer::WINDOW_MODE_WINDOWED) {
  2628. // The compositor refused our "normalization" request. It'd be useless or
  2629. // unpredictable to attempt setting a new state. We're done.
  2630. return;
  2631. }
  2632. // Ask the compositor to set the state indicated by the new mode.
  2633. switch (p_window_mode) {
  2634. case DisplayServer::WINDOW_MODE_WINDOWED: {
  2635. // Do nothing. We're already windowed.
  2636. } break;
  2637. case DisplayServer::WINDOW_MODE_MINIMIZED: {
  2638. if (!window_can_set_mode(p_window_id, p_window_mode)) {
  2639. // Minimization is special (read below). Better not mess with it if the
  2640. // compositor explicitly announces that it doesn't support it.
  2641. break;
  2642. }
  2643. if (ws.xdg_toplevel) {
  2644. xdg_toplevel_set_minimized(ws.xdg_toplevel);
  2645. }
  2646. #ifdef LIBDECOR_ENABLED
  2647. if (ws.libdecor_frame) {
  2648. libdecor_frame_set_minimized(ws.libdecor_frame);
  2649. }
  2650. #endif // LIBDECOR_ENABLED
  2651. // We have no way to actually detect this state, so we'll have to report it
  2652. // manually to the engine (hoping that it worked). In the worst case it'll
  2653. // get reset by the next configure event.
  2654. ws.mode = DisplayServer::WINDOW_MODE_MINIMIZED;
  2655. } break;
  2656. case DisplayServer::WINDOW_MODE_MAXIMIZED: {
  2657. if (ws.xdg_toplevel) {
  2658. xdg_toplevel_set_maximized(ws.xdg_toplevel);
  2659. }
  2660. #ifdef LIBDECOR_ENABLED
  2661. if (ws.libdecor_frame) {
  2662. libdecor_frame_set_maximized(ws.libdecor_frame);
  2663. }
  2664. #endif // LIBDECOR_ENABLED
  2665. } break;
  2666. case DisplayServer::WINDOW_MODE_FULLSCREEN: {
  2667. if (ws.xdg_toplevel) {
  2668. xdg_toplevel_set_fullscreen(ws.xdg_toplevel, nullptr);
  2669. }
  2670. #ifdef LIBDECOR_ENABLED
  2671. if (ws.libdecor_frame) {
  2672. libdecor_frame_set_fullscreen(ws.libdecor_frame, nullptr);
  2673. }
  2674. #endif // LIBDECOR_ENABLED
  2675. } break;
  2676. default: {
  2677. } break;
  2678. }
  2679. }
  2680. void WaylandThread::window_set_borderless(DisplayServer::WindowID p_window_id, bool p_borderless) {
  2681. // TODO: Use window IDs for multiwindow support.
  2682. WindowState &ws = main_window;
  2683. if (ws.xdg_toplevel_decoration) {
  2684. if (p_borderless) {
  2685. // We implement borderless windows by simply asking the compositor to let
  2686. // us handle decorations (we don't).
  2687. zxdg_toplevel_decoration_v1_set_mode(ws.xdg_toplevel_decoration, ZXDG_TOPLEVEL_DECORATION_V1_MODE_CLIENT_SIDE);
  2688. } else {
  2689. zxdg_toplevel_decoration_v1_set_mode(ws.xdg_toplevel_decoration, ZXDG_TOPLEVEL_DECORATION_V1_MODE_SERVER_SIDE);
  2690. }
  2691. }
  2692. #ifdef LIBDECOR_ENABLED
  2693. if (ws.libdecor_frame) {
  2694. bool visible_current = libdecor_frame_is_visible(ws.libdecor_frame);
  2695. bool visible_target = !p_borderless;
  2696. // NOTE: We have to do this otherwise we trip on a libdecor bug where it's
  2697. // possible to destroy the frame more than once, by setting the visibility
  2698. // to false multiple times and thus crashing.
  2699. if (visible_current != visible_target) {
  2700. print_verbose(vformat("Setting libdecor frame visibility to %d", visible_target));
  2701. libdecor_frame_set_visibility(ws.libdecor_frame, visible_target);
  2702. }
  2703. }
  2704. #endif // LIBDECOR_ENABLED
  2705. }
  2706. void WaylandThread::window_set_title(DisplayServer::WindowID p_window_id, const String &p_title) {
  2707. // TODO: Use window IDs for multiwindow support.
  2708. WindowState &ws = main_window;
  2709. #ifdef LIBDECOR_ENABLED
  2710. if (ws.libdecor_frame) {
  2711. libdecor_frame_set_title(ws.libdecor_frame, p_title.utf8());
  2712. }
  2713. #endif // LIBDECOR_ENABLE
  2714. if (ws.xdg_toplevel) {
  2715. xdg_toplevel_set_title(ws.xdg_toplevel, p_title.utf8());
  2716. }
  2717. }
  2718. void WaylandThread::window_set_app_id(DisplayServer::WindowID p_window_id, const String &p_app_id) {
  2719. // TODO: Use window IDs for multiwindow support.
  2720. WindowState &ws = main_window;
  2721. #ifdef LIBDECOR_ENABLED
  2722. if (ws.libdecor_frame) {
  2723. libdecor_frame_set_app_id(ws.libdecor_frame, p_app_id.utf8());
  2724. return;
  2725. }
  2726. #endif // LIBDECOR_ENABLED
  2727. if (ws.xdg_toplevel) {
  2728. xdg_toplevel_set_app_id(ws.xdg_toplevel, p_app_id.utf8());
  2729. return;
  2730. }
  2731. }
  2732. DisplayServer::WindowMode WaylandThread::window_get_mode(DisplayServer::WindowID p_window_id) const {
  2733. // TODO: Use window IDs for multiwindow support.
  2734. const WindowState &ws = main_window;
  2735. return ws.mode;
  2736. }
  2737. void WaylandThread::window_request_attention(DisplayServer::WindowID p_window_id) {
  2738. // TODO: Use window IDs for multiwindow support.
  2739. WindowState &ws = main_window;
  2740. if (registry.xdg_activation) {
  2741. // Window attention requests are done through the XDG activation protocol.
  2742. xdg_activation_token_v1 *xdg_activation_token = xdg_activation_v1_get_activation_token(registry.xdg_activation);
  2743. xdg_activation_token_v1_add_listener(xdg_activation_token, &xdg_activation_token_listener, &ws);
  2744. xdg_activation_token_v1_commit(xdg_activation_token);
  2745. }
  2746. }
  2747. void WaylandThread::window_set_idle_inhibition(DisplayServer::WindowID p_window_id, bool p_enable) {
  2748. // TODO: Use window IDs for multiwindow support.
  2749. WindowState &ws = main_window;
  2750. if (p_enable) {
  2751. if (ws.registry->wp_idle_inhibit_manager && !ws.wp_idle_inhibitor) {
  2752. ERR_FAIL_NULL(ws.wl_surface);
  2753. ws.wp_idle_inhibitor = zwp_idle_inhibit_manager_v1_create_inhibitor(ws.registry->wp_idle_inhibit_manager, ws.wl_surface);
  2754. }
  2755. } else {
  2756. if (ws.wp_idle_inhibitor) {
  2757. zwp_idle_inhibitor_v1_destroy(ws.wp_idle_inhibitor);
  2758. ws.wp_idle_inhibitor = nullptr;
  2759. }
  2760. }
  2761. }
  2762. bool WaylandThread::window_get_idle_inhibition(DisplayServer::WindowID p_window_id) const {
  2763. // TODO: Use window IDs for multiwindow support.
  2764. const WindowState &ws = main_window;
  2765. return ws.wp_idle_inhibitor != nullptr;
  2766. }
  2767. WaylandThread::ScreenData WaylandThread::screen_get_data(int p_screen) const {
  2768. ERR_FAIL_INDEX_V(p_screen, registry.wl_outputs.size(), ScreenData());
  2769. return wl_output_get_screen_state(registry.wl_outputs.get(p_screen))->data;
  2770. }
  2771. int WaylandThread::get_screen_count() const {
  2772. return registry.wl_outputs.size();
  2773. }
  2774. DisplayServer::WindowID WaylandThread::pointer_get_pointed_window_id() const {
  2775. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2776. if (ss) {
  2777. WindowState *ws = wl_surface_get_window_state(ss->pointed_surface);
  2778. if (ws) {
  2779. return ws->id;
  2780. }
  2781. }
  2782. return DisplayServer::INVALID_WINDOW_ID;
  2783. }
  2784. void WaylandThread::pointer_set_constraint(PointerConstraint p_constraint) {
  2785. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2786. if (ss) {
  2787. seat_state_unlock_pointer(ss);
  2788. if (p_constraint == PointerConstraint::LOCKED) {
  2789. seat_state_lock_pointer(ss);
  2790. } else if (p_constraint == PointerConstraint::CONFINED) {
  2791. seat_state_confine_pointer(ss);
  2792. }
  2793. }
  2794. pointer_constraint = p_constraint;
  2795. }
  2796. void WaylandThread::pointer_set_hint(const Point2i &p_hint) {
  2797. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2798. if (!ss) {
  2799. return;
  2800. }
  2801. WindowState *ws = wl_surface_get_window_state(ss->pointed_surface);
  2802. int hint_x = 0;
  2803. int hint_y = 0;
  2804. if (ws) {
  2805. // NOTE: It looks like it's not really recommended to convert from
  2806. // "godot-space" to "wayland-space" and in general I received mixed feelings
  2807. // discussing about this. I'm not really sure about the maths behind this but,
  2808. // oh well, we're setting a cursor hint. ¯\_(ツ)_/¯
  2809. // See: https://oftc.irclog.whitequark.org/wayland/2023-08-23#1692756914-1692816818
  2810. hint_x = round(p_hint.x / window_state_get_scale_factor(ws));
  2811. hint_y = round(p_hint.y / window_state_get_scale_factor(ws));
  2812. }
  2813. if (ss) {
  2814. seat_state_set_hint(ss, hint_x, hint_y);
  2815. }
  2816. }
  2817. WaylandThread::PointerConstraint WaylandThread::pointer_get_constraint() const {
  2818. return pointer_constraint;
  2819. }
  2820. BitField<MouseButtonMask> WaylandThread::pointer_get_button_mask() const {
  2821. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2822. if (ss) {
  2823. return ss->pointer_data.pressed_button_mask;
  2824. }
  2825. return BitField<MouseButtonMask>();
  2826. }
  2827. Error WaylandThread::init() {
  2828. #ifdef SOWRAP_ENABLED
  2829. #ifdef DEBUG_ENABLED
  2830. int dylibloader_verbose = 1;
  2831. #else
  2832. int dylibloader_verbose = 0;
  2833. #endif // DEBUG_ENABLED
  2834. if (initialize_wayland_client(dylibloader_verbose) != 0) {
  2835. WARN_PRINT("Can't load the Wayland client library.");
  2836. return ERR_CANT_CREATE;
  2837. }
  2838. if (initialize_wayland_cursor(dylibloader_verbose) != 0) {
  2839. WARN_PRINT("Can't load the Wayland cursor library.");
  2840. return ERR_CANT_CREATE;
  2841. }
  2842. if (initialize_xkbcommon(dylibloader_verbose) != 0) {
  2843. WARN_PRINT("Can't load the XKBcommon library.");
  2844. return ERR_CANT_CREATE;
  2845. }
  2846. #endif // SOWRAP_ENABLED
  2847. KeyMappingXKB::initialize();
  2848. wl_display = wl_display_connect(nullptr);
  2849. ERR_FAIL_NULL_V_MSG(wl_display, ERR_CANT_CREATE, "Can't connect to a Wayland display.");
  2850. thread_data.wl_display = wl_display;
  2851. events_thread.start(_poll_events_thread, &thread_data);
  2852. wl_registry = wl_display_get_registry(wl_display);
  2853. ERR_FAIL_NULL_V_MSG(wl_registry, ERR_UNAVAILABLE, "Can't obtain the Wayland registry global.");
  2854. registry.wayland_thread = this;
  2855. wl_registry_add_listener(wl_registry, &wl_registry_listener, &registry);
  2856. // Wait for registry to get notified from the compositor.
  2857. wl_display_roundtrip(wl_display);
  2858. ERR_FAIL_NULL_V_MSG(registry.wl_shm, ERR_UNAVAILABLE, "Can't obtain the Wayland shared memory global.");
  2859. ERR_FAIL_NULL_V_MSG(registry.wl_compositor, ERR_UNAVAILABLE, "Can't obtain the Wayland compositor global.");
  2860. ERR_FAIL_NULL_V_MSG(registry.xdg_wm_base, ERR_UNAVAILABLE, "Can't obtain the Wayland XDG shell global.");
  2861. if (!registry.xdg_decoration_manager) {
  2862. #ifdef LIBDECOR_ENABLED
  2863. WARN_PRINT("Can't obtain the XDG decoration manager. Libdecor will be used for drawing CSDs, if available.");
  2864. #else
  2865. WARN_PRINT("Can't obtain the XDG decoration manager. Decorations won't show up.");
  2866. #endif // LIBDECOR_ENABLED
  2867. }
  2868. if (!registry.xdg_activation) {
  2869. WARN_PRINT("Can't obtain the XDG activation global. Attention requesting won't work!");
  2870. }
  2871. #ifndef DBUS_ENABLED
  2872. if (!registry.wp_idle_inhibit_manager) {
  2873. WARN_PRINT("Can't obtain the idle inhibition manager. The screen might turn off even after calling screen_set_keep_on()!");
  2874. }
  2875. #endif // DBUS_ENABLED
  2876. // Wait for seat capabilities.
  2877. wl_display_roundtrip(wl_display);
  2878. #ifdef LIBDECOR_ENABLED
  2879. bool libdecor_found = true;
  2880. #ifdef SOWRAP_ENABLED
  2881. if (initialize_libdecor(dylibloader_verbose) != 0) {
  2882. libdecor_found = false;
  2883. }
  2884. #endif // SOWRAP_ENABLED
  2885. if (libdecor_found) {
  2886. libdecor_context = libdecor_new(wl_display, (struct libdecor_interface *)&libdecor_interface);
  2887. } else {
  2888. print_verbose("libdecor not found. Client-side decorations disabled.");
  2889. }
  2890. #endif // LIBDECOR_ENABLED
  2891. cursor_theme_name = OS::get_singleton()->get_environment("XCURSOR_THEME");
  2892. unscaled_cursor_size = OS::get_singleton()->get_environment("XCURSOR_SIZE").to_int();
  2893. if (unscaled_cursor_size <= 0) {
  2894. print_verbose("Detected invalid cursor size preference, defaulting to 24.");
  2895. unscaled_cursor_size = 24;
  2896. }
  2897. // NOTE: The scale is useful here as it might've been updated by _update_scale.
  2898. bool cursor_theme_loaded = _load_cursor_theme(unscaled_cursor_size * cursor_scale);
  2899. if (!cursor_theme_loaded) {
  2900. return ERR_CANT_CREATE;
  2901. }
  2902. // Update the cursor.
  2903. cursor_set_shape(DisplayServer::CURSOR_ARROW);
  2904. initialized = true;
  2905. return OK;
  2906. }
  2907. void WaylandThread::cursor_hide() {
  2908. current_wl_cursor = nullptr;
  2909. current_custom_cursor = nullptr;
  2910. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2911. ERR_FAIL_NULL(ss);
  2912. seat_state_update_cursor(ss);
  2913. }
  2914. void WaylandThread::cursor_set_shape(DisplayServer::CursorShape p_cursor_shape) {
  2915. if (!wl_cursors[p_cursor_shape]) {
  2916. return;
  2917. }
  2918. // The point of this method is make the current cursor a "plain" shape and, as
  2919. // the custom cursor overrides what gets set, we have to clear it too.
  2920. current_custom_cursor = nullptr;
  2921. current_wl_cursor = wl_cursors[p_cursor_shape];
  2922. for (struct wl_seat *wl_seat : registry.wl_seats) {
  2923. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  2924. ERR_FAIL_NULL(ss);
  2925. seat_state_update_cursor(ss);
  2926. }
  2927. last_cursor_shape = p_cursor_shape;
  2928. }
  2929. void WaylandThread::cursor_set_custom_shape(DisplayServer::CursorShape p_cursor_shape) {
  2930. ERR_FAIL_COND(!custom_cursors.has(p_cursor_shape));
  2931. current_custom_cursor = &custom_cursors[p_cursor_shape];
  2932. for (struct wl_seat *wl_seat : registry.wl_seats) {
  2933. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  2934. ERR_FAIL_NULL(ss);
  2935. seat_state_update_cursor(ss);
  2936. }
  2937. last_cursor_shape = p_cursor_shape;
  2938. }
  2939. void WaylandThread::cursor_shape_set_custom_image(DisplayServer::CursorShape p_cursor_shape, Ref<Image> p_image, const Point2i &p_hotspot) {
  2940. ERR_FAIL_COND(!p_image.is_valid());
  2941. Size2i image_size = p_image->get_size();
  2942. // NOTE: The stride is the width of the image in bytes.
  2943. unsigned int image_stride = image_size.width * 4;
  2944. unsigned int data_size = image_stride * image_size.height;
  2945. // We need a shared memory object file descriptor in order to create a
  2946. // wl_buffer through wl_shm.
  2947. int fd = WaylandThread::_allocate_shm_file(data_size);
  2948. ERR_FAIL_COND(fd == -1);
  2949. CustomCursor &cursor = custom_cursors[p_cursor_shape];
  2950. cursor.hotspot = p_hotspot;
  2951. if (cursor.buffer_data) {
  2952. // Clean up the old buffer data.
  2953. munmap(cursor.buffer_data, cursor.buffer_data_size);
  2954. }
  2955. // NOTE: From `wl_keyboard`s of version 7 or later, the spec requires the mmap
  2956. // operation to be done with MAP_PRIVATE, as "MAP_SHARED may fail". We'll do it
  2957. // regardless of global version.
  2958. cursor.buffer_data = (uint32_t *)mmap(nullptr, data_size, PROT_READ | PROT_WRITE, MAP_PRIVATE, fd, 0);
  2959. if (cursor.wl_buffer) {
  2960. // Clean up the old Wayland buffer.
  2961. wl_buffer_destroy(cursor.wl_buffer);
  2962. }
  2963. // Create the Wayland buffer.
  2964. struct wl_shm_pool *wl_shm_pool = wl_shm_create_pool(registry.wl_shm, fd, image_size.height * data_size);
  2965. // TODO: Make sure that WL_SHM_FORMAT_ARGB8888 format is supported. It
  2966. // technically isn't garaunteed to be supported, but I think that'd be a
  2967. // pretty unlikely thing to stumble upon.
  2968. cursor.wl_buffer = wl_shm_pool_create_buffer(wl_shm_pool, 0, image_size.width, image_size.height, image_stride, WL_SHM_FORMAT_ARGB8888);
  2969. wl_shm_pool_destroy(wl_shm_pool);
  2970. // Fill the cursor buffer with the image data.
  2971. for (unsigned int index = 0; index < (unsigned int)(image_size.width * image_size.height); index++) {
  2972. int row_index = floor(index / image_size.width);
  2973. int column_index = (index % int(image_size.width));
  2974. cursor.buffer_data[index] = p_image->get_pixel(column_index, row_index).to_argb32();
  2975. // Wayland buffers, unless specified, require associated alpha, so we'll just
  2976. // associate the alpha in-place.
  2977. uint8_t *pixel_data = (uint8_t *)&cursor.buffer_data[index];
  2978. pixel_data[0] = pixel_data[0] * pixel_data[3] / 255;
  2979. pixel_data[1] = pixel_data[1] * pixel_data[3] / 255;
  2980. pixel_data[2] = pixel_data[2] * pixel_data[3] / 255;
  2981. }
  2982. }
  2983. void WaylandThread::cursor_shape_clear_custom_image(DisplayServer::CursorShape p_cursor_shape) {
  2984. if (custom_cursors.has(p_cursor_shape)) {
  2985. CustomCursor cursor = custom_cursors[p_cursor_shape];
  2986. custom_cursors.erase(p_cursor_shape);
  2987. current_custom_cursor = nullptr;
  2988. if (cursor.wl_buffer) {
  2989. wl_buffer_destroy(cursor.wl_buffer);
  2990. }
  2991. if (cursor.buffer_data) {
  2992. munmap(cursor.buffer_data, cursor.buffer_data_size);
  2993. }
  2994. }
  2995. }
  2996. void WaylandThread::window_set_ime_active(const bool p_active, DisplayServer::WindowID p_window_id) {
  2997. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  2998. if (ss && ss->wp_text_input && ss->ime_enabled) {
  2999. if (p_active) {
  3000. ss->ime_active = true;
  3001. zwp_text_input_v3_enable(ss->wp_text_input);
  3002. zwp_text_input_v3_set_cursor_rectangle(ss->wp_text_input, ss->ime_rect.position.x, ss->ime_rect.position.y, ss->ime_rect.size.x, ss->ime_rect.size.y);
  3003. } else {
  3004. ss->ime_active = false;
  3005. ss->ime_text = String();
  3006. ss->ime_text_commit = String();
  3007. ss->ime_cursor = Vector2i();
  3008. zwp_text_input_v3_disable(ss->wp_text_input);
  3009. }
  3010. zwp_text_input_v3_commit(ss->wp_text_input);
  3011. }
  3012. }
  3013. void WaylandThread::window_set_ime_position(const Point2i &p_pos, DisplayServer::WindowID p_window_id) {
  3014. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3015. if (ss && ss->wp_text_input && ss->ime_enabled) {
  3016. ss->ime_rect = Rect2i(p_pos, Size2i(1, 10));
  3017. zwp_text_input_v3_set_cursor_rectangle(ss->wp_text_input, ss->ime_rect.position.x, ss->ime_rect.position.y, ss->ime_rect.size.x, ss->ime_rect.size.y);
  3018. zwp_text_input_v3_commit(ss->wp_text_input);
  3019. }
  3020. }
  3021. int WaylandThread::keyboard_get_layout_count() const {
  3022. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3023. if (ss && ss->xkb_keymap) {
  3024. return xkb_keymap_num_layouts(ss->xkb_keymap);
  3025. }
  3026. return 0;
  3027. }
  3028. int WaylandThread::keyboard_get_current_layout_index() const {
  3029. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3030. if (ss) {
  3031. return ss->current_layout_index;
  3032. }
  3033. return 0;
  3034. }
  3035. void WaylandThread::keyboard_set_current_layout_index(int p_index) {
  3036. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3037. if (ss) {
  3038. ss->current_layout_index = p_index;
  3039. }
  3040. }
  3041. String WaylandThread::keyboard_get_layout_name(int p_index) const {
  3042. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3043. if (ss && ss->xkb_keymap) {
  3044. String ret;
  3045. ret.parse_utf8(xkb_keymap_layout_get_name(ss->xkb_keymap, p_index));
  3046. return ret;
  3047. }
  3048. return "";
  3049. }
  3050. Key WaylandThread::keyboard_get_key_from_physical(Key p_key) const {
  3051. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3052. if (ss && ss->xkb_state) {
  3053. xkb_keycode_t xkb_keycode = KeyMappingXKB::get_xkb_keycode(p_key);
  3054. return KeyMappingXKB::get_keycode(xkb_state_key_get_one_sym(ss->xkb_state, xkb_keycode));
  3055. }
  3056. return Key::NONE;
  3057. }
  3058. void WaylandThread::keyboard_echo_keys() {
  3059. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3060. if (ss) {
  3061. seat_state_echo_keys(ss);
  3062. }
  3063. }
  3064. void WaylandThread::selection_set_text(const String &p_text) {
  3065. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3066. if (registry.wl_data_device_manager == nullptr) {
  3067. DEBUG_LOG_WAYLAND_THREAD("Couldn't set selection, wl_data_device_manager global not available.");
  3068. }
  3069. if (ss == nullptr) {
  3070. DEBUG_LOG_WAYLAND_THREAD("Couldn't set selection, current seat not set.");
  3071. return;
  3072. }
  3073. if (ss->wl_data_device == nullptr) {
  3074. DEBUG_LOG_WAYLAND_THREAD("Couldn't set selection, seat doesn't have wl_data_device.");
  3075. }
  3076. ss->selection_data = p_text.to_utf8_buffer();
  3077. if (ss->wl_data_source_selection == nullptr) {
  3078. ss->wl_data_source_selection = wl_data_device_manager_create_data_source(registry.wl_data_device_manager);
  3079. wl_data_source_add_listener(ss->wl_data_source_selection, &wl_data_source_listener, ss);
  3080. wl_data_source_offer(ss->wl_data_source_selection, "text/plain;charset=utf-8");
  3081. wl_data_source_offer(ss->wl_data_source_selection, "text/plain");
  3082. }
  3083. // TODO: Implement a good way of getting the latest serial from the user.
  3084. wl_data_device_set_selection(ss->wl_data_device, ss->wl_data_source_selection, MAX(ss->pointer_data.button_serial, ss->last_key_pressed_serial));
  3085. // Wait for the message to get to the server before continuing, otherwise the
  3086. // clipboard update might come with a delay.
  3087. wl_display_roundtrip(wl_display);
  3088. }
  3089. bool WaylandThread::selection_has_mime(const String &p_mime) const {
  3090. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3091. if (ss == nullptr) {
  3092. DEBUG_LOG_WAYLAND_THREAD("Couldn't get selection, current seat not set.");
  3093. return false;
  3094. }
  3095. OfferState *os = wl_data_offer_get_offer_state(ss->wl_data_offer_selection);
  3096. if (!os) {
  3097. return false;
  3098. }
  3099. return os->mime_types.has(p_mime);
  3100. }
  3101. Vector<uint8_t> WaylandThread::selection_get_mime(const String &p_mime) const {
  3102. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3103. if (ss == nullptr) {
  3104. DEBUG_LOG_WAYLAND_THREAD("Couldn't get selection, current seat not set.");
  3105. return Vector<uint8_t>();
  3106. }
  3107. if (ss->wl_data_source_selection) {
  3108. // We have a source so the stuff we're pasting is ours. We'll have to pass the
  3109. // data directly or we'd stall waiting for Godot (ourselves) to send us the
  3110. // data :P
  3111. OfferState *os = wl_data_offer_get_offer_state(ss->wl_data_offer_selection);
  3112. ERR_FAIL_NULL_V(os, Vector<uint8_t>());
  3113. if (os->mime_types.has(p_mime)) {
  3114. // All righty, we're offering this type. Let's just return the data as is.
  3115. return ss->selection_data;
  3116. }
  3117. // ... we don't offer that type. Oh well.
  3118. return Vector<uint8_t>();
  3119. }
  3120. return _wl_data_offer_read(wl_display, p_mime.utf8(), ss->wl_data_offer_selection);
  3121. }
  3122. bool WaylandThread::primary_has_mime(const String &p_mime) const {
  3123. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3124. if (ss == nullptr) {
  3125. DEBUG_LOG_WAYLAND_THREAD("Couldn't get selection, current seat not set.");
  3126. return false;
  3127. }
  3128. OfferState *os = wp_primary_selection_offer_get_offer_state(ss->wp_primary_selection_offer);
  3129. if (!os) {
  3130. return false;
  3131. }
  3132. return os->mime_types.has(p_mime);
  3133. }
  3134. Vector<uint8_t> WaylandThread::primary_get_mime(const String &p_mime) const {
  3135. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3136. if (ss == nullptr) {
  3137. DEBUG_LOG_WAYLAND_THREAD("Couldn't get primary, current seat not set.");
  3138. return Vector<uint8_t>();
  3139. }
  3140. if (ss->wp_primary_selection_source) {
  3141. // We have a source so the stuff we're pasting is ours. We'll have to pass the
  3142. // data directly or we'd stall waiting for Godot (ourselves) to send us the
  3143. // data :P
  3144. OfferState *os = wp_primary_selection_offer_get_offer_state(ss->wp_primary_selection_offer);
  3145. ERR_FAIL_NULL_V(os, Vector<uint8_t>());
  3146. if (os->mime_types.has(p_mime)) {
  3147. // All righty, we're offering this type. Let's just return the data as is.
  3148. return ss->selection_data;
  3149. }
  3150. // ... we don't offer that type. Oh well.
  3151. return Vector<uint8_t>();
  3152. }
  3153. return _wp_primary_selection_offer_read(wl_display, p_mime.utf8(), ss->wp_primary_selection_offer);
  3154. }
  3155. void WaylandThread::primary_set_text(const String &p_text) {
  3156. SeatState *ss = wl_seat_get_seat_state(wl_seat_current);
  3157. if (registry.wp_primary_selection_device_manager == nullptr) {
  3158. DEBUG_LOG_WAYLAND_THREAD("Couldn't set primary, protocol not available");
  3159. return;
  3160. }
  3161. if (ss == nullptr) {
  3162. DEBUG_LOG_WAYLAND_THREAD("Couldn't set primary, current seat not set.");
  3163. return;
  3164. }
  3165. ss->primary_data = p_text.to_utf8_buffer();
  3166. if (ss->wp_primary_selection_source == nullptr) {
  3167. ss->wp_primary_selection_source = zwp_primary_selection_device_manager_v1_create_source(registry.wp_primary_selection_device_manager);
  3168. zwp_primary_selection_source_v1_add_listener(ss->wp_primary_selection_source, &wp_primary_selection_source_listener, ss);
  3169. zwp_primary_selection_source_v1_offer(ss->wp_primary_selection_source, "text/plain;charset=utf-8");
  3170. zwp_primary_selection_source_v1_offer(ss->wp_primary_selection_source, "text/plain");
  3171. }
  3172. // TODO: Implement a good way of getting the latest serial from the user.
  3173. zwp_primary_selection_device_v1_set_selection(ss->wp_primary_selection_device, ss->wp_primary_selection_source, MAX(ss->pointer_data.button_serial, ss->last_key_pressed_serial));
  3174. // Wait for the message to get to the server before continuing, otherwise the
  3175. // clipboard update might come with a delay.
  3176. wl_display_roundtrip(wl_display);
  3177. }
  3178. void WaylandThread::commit_surfaces() {
  3179. wl_surface_commit(main_window.wl_surface);
  3180. }
  3181. void WaylandThread::set_frame() {
  3182. frame = true;
  3183. }
  3184. bool WaylandThread::get_reset_frame() {
  3185. bool old_frame = frame;
  3186. frame = false;
  3187. return old_frame;
  3188. }
  3189. // Dispatches events until a frame event is received, a window is reported as
  3190. // suspended or the timeout expires.
  3191. bool WaylandThread::wait_frame_suspend_ms(int p_timeout) {
  3192. if (main_window.suspended) {
  3193. // The window is suspended! The compositor is telling us _explicitly_ that we
  3194. // don't need to draw, without letting us guess through the frame event's
  3195. // timing and stuff like that. Our job here is done.
  3196. return false;
  3197. }
  3198. if (frame) {
  3199. // We already have a frame! Probably it got there while the caller locked :D
  3200. frame = false;
  3201. return true;
  3202. }
  3203. struct pollfd poll_fd;
  3204. poll_fd.fd = wl_display_get_fd(wl_display);
  3205. poll_fd.events = POLLIN | POLLHUP;
  3206. int begin_ms = OS::get_singleton()->get_ticks_msec();
  3207. int remaining_ms = p_timeout;
  3208. while (remaining_ms > 0) {
  3209. // Empty the event queue while it's full.
  3210. while (wl_display_prepare_read(wl_display) != 0) {
  3211. if (wl_display_dispatch_pending(wl_display) == -1) {
  3212. // Oh no. We'll check and handle any display error below.
  3213. break;
  3214. }
  3215. if (main_window.suspended) {
  3216. return false;
  3217. }
  3218. if (frame) {
  3219. // We had a frame event in the queue :D
  3220. frame = false;
  3221. return true;
  3222. }
  3223. }
  3224. int werror = wl_display_get_error(wl_display);
  3225. if (werror) {
  3226. if (werror == EPROTO) {
  3227. struct wl_interface *wl_interface = nullptr;
  3228. uint32_t id = 0;
  3229. int error_code = wl_display_get_protocol_error(wl_display, (const struct wl_interface **)&wl_interface, &id);
  3230. CRASH_NOW_MSG(vformat("Wayland protocol error %d on interface %s@%d.", error_code, wl_interface ? wl_interface->name : "unknown", id));
  3231. } else {
  3232. CRASH_NOW_MSG(vformat("Wayland client error code %d.", werror));
  3233. }
  3234. }
  3235. wl_display_flush(wl_display);
  3236. // Wait for the event file descriptor to have new data.
  3237. poll(&poll_fd, 1, remaining_ms);
  3238. if (poll_fd.revents | POLLIN) {
  3239. // Load the queues with fresh new data.
  3240. wl_display_read_events(wl_display);
  3241. } else {
  3242. // Oh well... Stop signaling that we want to read.
  3243. wl_display_cancel_read(wl_display);
  3244. // We've got no new events :(
  3245. // We won't even bother with checking the frame flag.
  3246. return false;
  3247. }
  3248. // Let's try dispatching now...
  3249. wl_display_dispatch_pending(wl_display);
  3250. if (main_window.suspended) {
  3251. return false;
  3252. }
  3253. if (frame) {
  3254. frame = false;
  3255. return true;
  3256. }
  3257. remaining_ms -= OS::get_singleton()->get_ticks_msec() - begin_ms;
  3258. }
  3259. DEBUG_LOG_WAYLAND_THREAD("Frame timeout.");
  3260. return false;
  3261. }
  3262. bool WaylandThread::is_suspended() const {
  3263. return main_window.suspended;
  3264. }
  3265. void WaylandThread::destroy() {
  3266. if (!initialized) {
  3267. return;
  3268. }
  3269. if (wl_display && events_thread.is_started()) {
  3270. thread_data.thread_done.set();
  3271. // By sending a roundtrip message we're unblocking the polling thread so that
  3272. // it can realize that it's done and also handle every event that's left.
  3273. wl_display_roundtrip(wl_display);
  3274. events_thread.wait_to_finish();
  3275. }
  3276. if (main_window.wp_fractional_scale) {
  3277. wp_fractional_scale_v1_destroy(main_window.wp_fractional_scale);
  3278. }
  3279. if (main_window.wp_viewport) {
  3280. wp_viewport_destroy(main_window.wp_viewport);
  3281. }
  3282. if (main_window.frame_callback) {
  3283. wl_callback_destroy(main_window.frame_callback);
  3284. }
  3285. #ifdef LIBDECOR_ENABLED
  3286. if (main_window.libdecor_frame) {
  3287. libdecor_frame_close(main_window.libdecor_frame);
  3288. }
  3289. #endif // LIBDECOR_ENABLED
  3290. if (main_window.xdg_toplevel) {
  3291. xdg_toplevel_destroy(main_window.xdg_toplevel);
  3292. }
  3293. if (main_window.xdg_surface) {
  3294. xdg_surface_destroy(main_window.xdg_surface);
  3295. }
  3296. if (main_window.wl_surface) {
  3297. wl_surface_destroy(main_window.wl_surface);
  3298. }
  3299. for (struct wl_seat *wl_seat : registry.wl_seats) {
  3300. SeatState *ss = wl_seat_get_seat_state(wl_seat);
  3301. ERR_FAIL_NULL(ss);
  3302. wl_seat_destroy(wl_seat);
  3303. xkb_context_unref(ss->xkb_context);
  3304. xkb_state_unref(ss->xkb_state);
  3305. xkb_keymap_unref(ss->xkb_keymap);
  3306. if (ss->wl_keyboard) {
  3307. wl_keyboard_destroy(ss->wl_keyboard);
  3308. }
  3309. if (ss->keymap_buffer) {
  3310. munmap((void *)ss->keymap_buffer, ss->keymap_buffer_size);
  3311. }
  3312. if (ss->wl_pointer) {
  3313. wl_pointer_destroy(ss->wl_pointer);
  3314. }
  3315. if (ss->cursor_frame_callback) {
  3316. // We don't need to set a null userdata for safety as the thread is done.
  3317. wl_callback_destroy(ss->cursor_frame_callback);
  3318. }
  3319. if (ss->cursor_surface) {
  3320. wl_surface_destroy(ss->cursor_surface);
  3321. }
  3322. if (ss->wl_data_device) {
  3323. wl_data_device_destroy(ss->wl_data_device);
  3324. }
  3325. if (ss->wp_relative_pointer) {
  3326. zwp_relative_pointer_v1_destroy(ss->wp_relative_pointer);
  3327. }
  3328. if (ss->wp_locked_pointer) {
  3329. zwp_locked_pointer_v1_destroy(ss->wp_locked_pointer);
  3330. }
  3331. if (ss->wp_confined_pointer) {
  3332. zwp_confined_pointer_v1_destroy(ss->wp_confined_pointer);
  3333. }
  3334. if (ss->wp_tablet_seat) {
  3335. zwp_tablet_seat_v2_destroy(ss->wp_tablet_seat);
  3336. }
  3337. for (struct zwp_tablet_tool_v2 *tool : ss->tablet_tools) {
  3338. TabletToolState *state = wp_tablet_tool_get_state(tool);
  3339. if (state) {
  3340. memdelete(state);
  3341. }
  3342. zwp_tablet_tool_v2_destroy(tool);
  3343. }
  3344. memdelete(ss);
  3345. }
  3346. for (struct wl_output *wl_output : registry.wl_outputs) {
  3347. ERR_FAIL_NULL(wl_output);
  3348. memdelete(wl_output_get_screen_state(wl_output));
  3349. wl_output_destroy(wl_output);
  3350. }
  3351. if (wl_cursor_theme) {
  3352. wl_cursor_theme_destroy(wl_cursor_theme);
  3353. }
  3354. if (registry.wp_idle_inhibit_manager) {
  3355. zwp_idle_inhibit_manager_v1_destroy(registry.wp_idle_inhibit_manager);
  3356. }
  3357. if (registry.wp_pointer_constraints) {
  3358. zwp_pointer_constraints_v1_destroy(registry.wp_pointer_constraints);
  3359. }
  3360. if (registry.wp_pointer_gestures) {
  3361. zwp_pointer_gestures_v1_destroy(registry.wp_pointer_gestures);
  3362. }
  3363. if (registry.wp_relative_pointer_manager) {
  3364. zwp_relative_pointer_manager_v1_destroy(registry.wp_relative_pointer_manager);
  3365. }
  3366. if (registry.xdg_activation) {
  3367. xdg_activation_v1_destroy(registry.xdg_activation);
  3368. }
  3369. if (registry.xdg_decoration_manager) {
  3370. zxdg_decoration_manager_v1_destroy(registry.xdg_decoration_manager);
  3371. }
  3372. if (registry.wp_fractional_scale_manager) {
  3373. wp_fractional_scale_manager_v1_destroy(registry.wp_fractional_scale_manager);
  3374. }
  3375. if (registry.wp_viewporter) {
  3376. wp_viewporter_destroy(registry.wp_viewporter);
  3377. }
  3378. if (registry.xdg_wm_base) {
  3379. xdg_wm_base_destroy(registry.xdg_wm_base);
  3380. }
  3381. if (registry.xdg_exporter) {
  3382. zxdg_exporter_v1_destroy(registry.xdg_exporter);
  3383. }
  3384. if (registry.wl_shm) {
  3385. wl_shm_destroy(registry.wl_shm);
  3386. }
  3387. if (registry.wl_compositor) {
  3388. wl_compositor_destroy(registry.wl_compositor);
  3389. }
  3390. if (wl_registry) {
  3391. wl_registry_destroy(wl_registry);
  3392. }
  3393. if (wl_display) {
  3394. wl_display_disconnect(wl_display);
  3395. }
  3396. }
  3397. #endif // WAYLAND_ENABLED