b5659e27ab2b843cf9a20b13738c455453817229
[apps/agl-service-windowmanager-2017.git] / src / main.cpp
1 /*
2  * Copyright (c) 2017 TOYOTA MOTOR CORPORATION
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16
17 #include <unistd.h>
18 #include <algorithm>
19 #include <mutex>
20 #include <json.h>
21 #include "../include/json.hpp"
22 #include "window_manager.hpp"
23 #include "json_helper.hpp"
24 #include "wayland_ivi_wm.hpp"
25
26 extern "C"
27 {
28 #include <afb/afb-binding.h>
29 #include <systemd/sd-event.h>
30 }
31
32 typedef struct WMClientCtxt
33 {
34     std::string name;
35     std::string role;
36     WMClientCtxt(const char *appName, const char* appRole)
37     {
38         name = appName;
39         role = appRole;
40     }
41 } WMClientCtxt;
42
43 struct afb_instance
44 {
45     std::unique_ptr<wl::display> display;
46     wm::WindowManager wmgr;
47
48     afb_instance() : display{new wl::display}, wmgr{this->display.get()} {}
49
50     int init();
51 };
52
53 struct afb_instance *g_afb_instance;
54 std::mutex binding_m;
55
56 int afb_instance::init()
57 {
58     return this->wmgr.init();
59 }
60
61 int display_event_callback(sd_event_source *evs, int /*fd*/, uint32_t events,
62                            void * /*data*/)
63 {
64     ST();
65
66     if ((events & EPOLLHUP) != 0)
67     {
68         HMI_ERROR("wm", "The compositor hung up, dying now.");
69         delete g_afb_instance;
70         g_afb_instance = nullptr;
71         goto error;
72     }
73
74     if ((events & EPOLLIN) != 0u)
75     {
76         {
77             STN(display_read_events);
78             g_afb_instance->wmgr.display->read_events();
79             g_afb_instance->wmgr.set_pending_events();
80         }
81         {
82             // We want do dispatch pending wayland events from within
83             // the API context
84             STN(winman_ping_api_call);
85             afb_service_call("windowmanager", "ping", json_object_new_object(),
86                             [](void *c, int st, json_object *j) {
87                                 STN(winman_ping_api_call_return);
88                             },
89                             nullptr);
90         }
91     }
92
93     return 0;
94
95 error:
96     sd_event_source_unref(evs);
97     if (getenv("WINMAN_EXIT_ON_HANGUP") != nullptr)
98     {
99         exit(1);
100     }
101     return -1;
102 }
103
104 int _binding_init()
105 {
106     HMI_NOTICE("wm", "WinMan ver. %s", WINMAN_VERSION_STRING);
107
108     if (g_afb_instance != nullptr)
109     {
110         HMI_ERROR("wm", "Wayland context already initialized?");
111         return 0;
112     }
113
114     if (getenv("XDG_RUNTIME_DIR") == nullptr)
115     {
116         HMI_ERROR("wm", "Environment variable XDG_RUNTIME_DIR not set");
117         goto error;
118     }
119
120     {
121         // wait until wayland compositor starts up.
122         int cnt = 0;
123         g_afb_instance = new afb_instance;
124         while (!g_afb_instance->display->ok())
125         {
126             cnt++;
127             if (20 <= cnt)
128             {
129                 HMI_ERROR("wm", "Could not connect to compositor");
130                 goto error;
131             }
132             HMI_ERROR("wm", "Wait to start weston ...");
133             sleep(1);
134             delete g_afb_instance;
135             g_afb_instance = new afb_instance;
136         }
137     }
138
139     if (g_afb_instance->init() == -1)
140     {
141         HMI_ERROR("wm", "Could not connect to compositor");
142         goto error;
143     }
144
145     {
146         int ret = sd_event_add_io(afb_daemon_get_event_loop(), nullptr,
147                                   g_afb_instance->display->get_fd(), EPOLLIN,
148                                   display_event_callback, g_afb_instance);
149         if (ret < 0)
150         {
151             HMI_ERROR("wm", "Could not initialize afb_instance event handler: %d", -ret);
152             goto error;
153         }
154     }
155
156     atexit([] { delete g_afb_instance; });
157
158     return 0;
159
160 error:
161     delete g_afb_instance;
162     g_afb_instance = nullptr;
163     return -1;
164 }
165
166 int binding_init() noexcept
167 {
168     try
169     {
170         return _binding_init();
171     }
172     catch (std::exception &e)
173     {
174         HMI_ERROR("wm", "Uncaught exception in binding_init(): %s", e.what());
175     }
176     return -1;
177 }
178
179 static void cbRemoveClientCtxt(void *data)
180 {
181     WMClientCtxt *ctxt = (WMClientCtxt *)data;
182     if (ctxt == nullptr)
183     {
184         return;
185     }
186     HMI_DEBUG("wm", "remove app %s", ctxt->name.c_str());
187     // Lookup surfaceID and remove it because App is dead.
188     auto pSid = g_afb_instance->wmgr.id_alloc.lookup(ctxt->role.c_str());
189     if (pSid)
190     {
191         auto sid = *pSid;
192         auto o_state = *g_afb_instance->wmgr.layers.get_layout_state(sid);
193         if (o_state != nullptr)
194         {
195             if (o_state->main == sid)
196             {
197                 o_state->main = -1;
198             }
199             else if (o_state->sub == sid)
200             {
201                 o_state->sub = -1;
202             }
203         }
204         g_afb_instance->wmgr.id_alloc.remove_id(sid);
205         g_afb_instance->wmgr.layers.remove_surface(sid);
206         g_afb_instance->wmgr.controller->sprops.erase(sid);
207         g_afb_instance->wmgr.controller->surfaces.erase(sid);
208         HMI_DEBUG("wm", "delete surfaceID %d", sid);
209     }
210     g_afb_instance->wmgr.removeClient(ctxt->name);
211     delete ctxt;
212 }
213
214 static void createSecurityContext(afb_req req, const char* appid, const char* role)
215 {
216     WMClientCtxt *ctxt = (WMClientCtxt *)afb_req_context_get(req);
217     if (!ctxt)
218     {
219         // Create Security Context at first time
220         const char *new_role = g_afb_instance->wmgr.convertRoleOldToNew(role);
221         WMClientCtxt *ctxt = new WMClientCtxt(appid, new_role);
222         HMI_DEBUG("wm", "create session for %s", ctxt->name.c_str());
223         afb_req_session_set_LOA(req, 1);
224         afb_req_context_set(req, ctxt, cbRemoveClientCtxt);
225     }
226 }
227
228 void windowmanager_requestsurface(afb_req req) noexcept
229 {
230     std::lock_guard<std::mutex> guard(binding_m);
231 #ifdef ST
232     ST();
233 #endif
234     if (g_afb_instance == nullptr)
235     {
236         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
237         return;
238     }
239
240     try
241     {
242         const char *a_drawing_name = afb_req_value(req, "drawing_name");
243         if (!a_drawing_name)
244         {
245             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
246             return;
247         }
248
249         const char *appid = afb_req_get_application_id(req);
250         auto ret = g_afb_instance->wmgr.api_request_surface(
251             appid, a_drawing_name);
252         if (ret.is_err())
253         {
254             afb_req_fail(req, "failed", ret.unwrap_err());
255             return;
256         }
257
258         createSecurityContext(req, appid, a_drawing_name);
259
260         afb_req_success(req, json_object_new_int(ret.unwrap()), "success");
261     }
262     catch (std::exception &e)
263     {
264         afb_req_fail_f(req, "failed", "Uncaught exception while calling requestsurface: %s", e.what());
265         return;
266     }
267 }
268
269 void windowmanager_requestsurfacexdg(afb_req req) noexcept
270 {
271     std::lock_guard<std::mutex> guard(binding_m);
272 #ifdef ST
273     ST();
274 #endif
275     if (g_afb_instance == nullptr)
276     {
277         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
278         return;
279     }
280
281     try
282     {
283         json_object *jreq = afb_req_json(req);
284
285         json_object *j_drawing_name = nullptr;
286         if (!json_object_object_get_ex(jreq, "drawing_name", &j_drawing_name))
287         {
288             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
289             return;
290         }
291         char const *a_drawing_name = json_object_get_string(j_drawing_name);
292
293         json_object *j_ivi_id = nullptr;
294         if (!json_object_object_get_ex(jreq, "ivi_id", &j_ivi_id))
295         {
296             afb_req_fail(req, "failed", "Need char const* argument ivi_id");
297             return;
298         }
299         char const *a_ivi_id = json_object_get_string(j_ivi_id);
300         char const *appid = afb_req_get_application_id(req);
301         auto ret = g_afb_instance->wmgr.api_request_surface(
302             appid, a_drawing_name, a_ivi_id);
303
304         if (ret != nullptr)
305         {
306             afb_req_fail(req, "failed", ret);
307             return;
308         }
309
310         createSecurityContext(req, appid, a_drawing_name);
311
312         afb_req_success(req, NULL, "success");
313     }
314     catch (std::exception &e)
315     {
316         afb_req_fail_f(req, "failed", "Uncaught exception while calling requestsurfacexdg: %s", e.what());
317         return;
318     }
319 }
320
321 void windowmanager_activatewindow(afb_req req) noexcept
322 {
323     std::lock_guard<std::mutex> guard(binding_m);
324 #ifdef ST
325     ST();
326 #endif
327     if (g_afb_instance == nullptr)
328     {
329         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
330         return;
331     }
332
333     try
334     {
335         const char *a_drawing_name = afb_req_value(req, "drawing_name");
336         if (!a_drawing_name)
337         {
338             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
339             return;
340         }
341
342         const char *a_drawing_area = afb_req_value(req, "drawing_area");
343         if (!a_drawing_area)
344         {
345             afb_req_fail(req, "failed", "Need char const* argument drawing_area");
346             return;
347         }
348
349         g_afb_instance->wmgr.api_activate_surface(
350             afb_req_get_application_id(req),
351             a_drawing_name, a_drawing_area,
352             [&req](const char *errmsg) {
353                 if (errmsg != nullptr)
354                 {
355                     HMI_ERROR("wm", errmsg);
356                     afb_req_fail(req, "failed", errmsg);
357                     return;
358                 }
359                 afb_req_success(req, NULL, "success");
360             });
361     }
362     catch (std::exception &e)
363     {
364         HMI_WARNING("wm", "failed: Uncaught exception while calling activatesurface: %s", e.what());
365         g_afb_instance->wmgr.exceptionProcessForTransition();
366         return;
367     }
368 }
369
370 void windowmanager_deactivatewindow(afb_req req) noexcept
371 {
372     std::lock_guard<std::mutex> guard(binding_m);
373 #ifdef ST
374     ST();
375 #endif
376     if (g_afb_instance == nullptr)
377     {
378         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
379         return;
380     }
381
382     try
383     {
384         const char *a_drawing_name = afb_req_value(req, "drawing_name");
385         if (!a_drawing_name)
386         {
387             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
388             return;
389         }
390
391         g_afb_instance->wmgr.api_deactivate_surface(
392             afb_req_get_application_id(req), a_drawing_name,
393             [&req](const char *errmsg) {
394                 if (errmsg != nullptr)
395                 {
396                     HMI_ERROR("wm", errmsg);
397                     afb_req_fail(req, "failed", errmsg);
398                     return;
399                 }
400                 afb_req_success(req, NULL, "success");
401             });
402     }
403     catch (std::exception &e)
404     {
405         HMI_WARNING("wm", "failed: Uncaught exception while calling deactivatesurface: %s", e.what());
406         g_afb_instance->wmgr.exceptionProcessForTransition();
407         return;
408     }
409 }
410
411 void windowmanager_enddraw(afb_req req) noexcept
412 {
413     std::lock_guard<std::mutex> guard(binding_m);
414 #ifdef ST
415     ST();
416 #endif
417     if (g_afb_instance == nullptr)
418     {
419         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
420         return;
421     }
422
423     try
424     {
425         const char *a_drawing_name = afb_req_value(req, "drawing_name");
426         if (!a_drawing_name)
427         {
428             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
429             return;
430         }
431         afb_req_success(req, NULL, "success");
432
433         g_afb_instance->wmgr.api_enddraw(
434             afb_req_get_application_id(req), a_drawing_name);
435     }
436     catch (std::exception &e)
437     {
438         HMI_WARNING("wm", "failed: Uncaught exception while calling enddraw: %s", e.what());
439         g_afb_instance->wmgr.exceptionProcessForTransition();
440         return;
441     }
442 }
443
444 void windowmanager_getdisplayinfo_thunk(afb_req req) noexcept
445 {
446     std::lock_guard<std::mutex> guard(binding_m);
447 #ifdef ST
448     ST();
449 #endif
450     if (g_afb_instance == nullptr)
451     {
452         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
453         return;
454     }
455
456     try
457     {
458         auto ret = g_afb_instance->wmgr.api_get_display_info();
459         if (ret.is_err())
460         {
461             afb_req_fail(req, "failed", ret.unwrap_err());
462             return;
463         }
464
465         afb_req_success(req, ret.unwrap(), "success");
466     }
467     catch (std::exception &e)
468     {
469         afb_req_fail_f(req, "failed", "Uncaught exception while calling getdisplayinfo: %s", e.what());
470         return;
471     }
472 }
473
474 void windowmanager_getareainfo_thunk(afb_req req) noexcept
475 {
476     std::lock_guard<std::mutex> guard(binding_m);
477 #ifdef ST
478     ST();
479 #endif
480     if (g_afb_instance == nullptr)
481     {
482         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
483         return;
484     }
485
486     try
487     {
488         json_object *jreq = afb_req_json(req);
489
490         json_object *j_drawing_name = nullptr;
491         if (!json_object_object_get_ex(jreq, "drawing_name", &j_drawing_name))
492         {
493             afb_req_fail(req, "failed", "Need char const* argument drawing_name");
494             return;
495         }
496         char const *a_drawing_name = json_object_get_string(j_drawing_name);
497
498         auto ret = g_afb_instance->wmgr.api_get_area_info(a_drawing_name);
499         if (ret.is_err())
500         {
501             afb_req_fail(req, "failed", ret.unwrap_err());
502             return;
503         }
504
505         afb_req_success(req, ret.unwrap(), "success");
506     }
507     catch (std::exception &e)
508     {
509         afb_req_fail_f(req, "failed", "Uncaught exception while calling getareainfo: %s", e.what());
510         return;
511     }
512 }
513
514 void windowmanager_wm_subscribe(afb_req req) noexcept
515 {
516     std::lock_guard<std::mutex> guard(binding_m);
517 #ifdef ST
518     ST();
519 #endif
520     if (g_afb_instance == nullptr)
521     {
522         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
523         return;
524     }
525
526     try
527     {
528         json_object *jreq = afb_req_json(req);
529         json_object *j = nullptr;
530         if (!json_object_object_get_ex(jreq, "event", &j))
531         {
532             afb_req_fail(req, "failed", "Need char const* argument event");
533             return;
534         }
535         int event_type = json_object_get_int(j);
536         const char *event_name = g_afb_instance->wmgr.kListEventName[event_type];
537         struct afb_event event = g_afb_instance->wmgr.map_afb_event[event_name];
538         int ret = afb_req_subscribe(req, event);
539         if (ret)
540         {
541             afb_req_fail(req, "failed", "Error: afb_req_subscribe()");
542             return;
543         }
544         afb_req_success(req, NULL, "success");
545     }
546     catch (std::exception &e)
547     {
548         afb_req_fail_f(req, "failed", "Uncaught exception while calling wm_subscribe: %s", e.what());
549         return;
550     }
551 }
552
553 void windowmanager_list_drawing_names(afb_req req) noexcept
554 {
555     std::lock_guard<std::mutex> guard(binding_m);
556 #ifdef ST
557     ST();
558 #endif
559     if (g_afb_instance == nullptr)
560     {
561         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
562         return;
563     }
564
565     try
566     {
567
568         nlohmann::json j = g_afb_instance->wmgr.id_alloc.name2id;
569         auto ret = wm::Ok(json_tokener_parse(j.dump().c_str()));
570         if (ret.is_err())
571         {
572             afb_req_fail(req, "failed", ret.unwrap_err());
573             return;
574         }
575
576         afb_req_success(req, ret.unwrap(), "success");
577     }
578     catch (std::exception &e)
579     {
580         afb_req_fail_f(req, "failed", "Uncaught exception while calling list_drawing_names: %s", e.what());
581         return;
582     }
583 }
584
585 void windowmanager_ping(afb_req req) noexcept
586 {
587     std::lock_guard<std::mutex> guard(binding_m);
588 #ifdef ST
589     ST();
590 #endif
591     if (g_afb_instance == nullptr)
592     {
593         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
594         return;
595     }
596
597     try
598     {
599
600         g_afb_instance->wmgr.api_ping();
601
602         afb_req_success(req, NULL, "success");
603     }
604     catch (std::exception &e)
605     {
606         afb_req_fail_f(req, "failed", "Uncaught exception while calling ping: %s", e.what());
607         return;
608     }
609 }
610
611 void windowmanager_debug_status(afb_req req) noexcept
612 {
613     std::lock_guard<std::mutex> guard(binding_m);
614 #ifdef ST
615     ST();
616 #endif
617     if (g_afb_instance == nullptr)
618     {
619         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
620         return;
621     }
622
623     try
624     {
625
626         json_object *jr = json_object_new_object();
627         json_object_object_add(jr, "surfaces",
628                                to_json(g_afb_instance->wmgr.controller->sprops));
629         json_object_object_add(jr, "layers", to_json(g_afb_instance->wmgr.controller->lprops));
630
631         afb_req_success(req, jr, "success");
632     }
633     catch (std::exception &e)
634     {
635         afb_req_fail_f(req, "failed", "Uncaught exception while calling debug_status: %s", e.what());
636         return;
637     }
638 }
639
640 void windowmanager_debug_layers(afb_req req) noexcept
641 {
642     std::lock_guard<std::mutex> guard(binding_m);
643 #ifdef ST
644     ST();
645 #endif
646     if (g_afb_instance == nullptr)
647     {
648         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
649         return;
650     }
651
652     try
653     {
654         auto ret = wm::Ok(json_tokener_parse(g_afb_instance->wmgr.layers.to_json().dump().c_str()));
655
656         afb_req_success(req, ret, "success");
657     }
658     catch (std::exception &e)
659     {
660         afb_req_fail_f(req, "failed", "Uncaught exception while calling debug_layers: %s", e.what());
661         return;
662     }
663 }
664
665 void windowmanager_debug_surfaces(afb_req req) noexcept
666 {
667     std::lock_guard<std::mutex> guard(binding_m);
668 #ifdef ST
669     ST();
670 #endif
671     if (g_afb_instance == nullptr)
672     {
673         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
674         return;
675     }
676
677     try
678     {
679
680         auto ret = wm::Ok(to_json(g_afb_instance->wmgr.controller->sprops));
681         if (ret.is_err())
682         {
683             afb_req_fail(req, "failed", ret.unwrap_err());
684             return;
685         }
686
687         afb_req_success(req, ret.unwrap(), "success");
688     }
689     catch (std::exception &e)
690     {
691         afb_req_fail_f(req, "failed", "Uncaught exception while calling debug_surfaces: %s", e.what());
692         return;
693     }
694 }
695
696 void windowmanager_debug_terminate(afb_req req) noexcept
697 {
698     std::lock_guard<std::mutex> guard(binding_m);
699 #ifdef ST
700     ST();
701 #endif
702     if (g_afb_instance == nullptr)
703     {
704         afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?");
705         return;
706     }
707
708     try
709     {
710
711         if (getenv("WINMAN_DEBUG_TERMINATE") != nullptr)
712         {
713             raise(SIGKILL); // afb-daemon kills it's pgroup using TERM, which
714                             // doesn't play well with perf
715         }
716
717         afb_req_success(req, NULL, "success");
718     }
719     catch (std::exception &e)
720     {
721         afb_req_fail_f(req, "failed", "Uncaught exception while calling debug_terminate: %s", e.what());
722         return;
723     }
724 }
725
726 const struct afb_verb_v2 windowmanager_verbs[] = {
727     {"requestsurface", windowmanager_requestsurface, nullptr, nullptr, AFB_SESSION_NONE},
728     {"requestsurfacexdg", windowmanager_requestsurfacexdg, nullptr, nullptr, AFB_SESSION_NONE},
729     {"activatewindow", windowmanager_activatewindow, nullptr, nullptr, AFB_SESSION_NONE},
730     {"deactivatewindow", windowmanager_deactivatewindow, nullptr, nullptr, AFB_SESSION_NONE},
731     {"enddraw", windowmanager_enddraw, nullptr, nullptr, AFB_SESSION_NONE},
732     {"getdisplayinfo", windowmanager_getdisplayinfo_thunk, nullptr, nullptr, AFB_SESSION_NONE},
733     {"getareainfo", windowmanager_getareainfo_thunk, nullptr, nullptr, AFB_SESSION_NONE},
734     {"wm_subscribe", windowmanager_wm_subscribe, nullptr, nullptr, AFB_SESSION_NONE},
735     {"list_drawing_names", windowmanager_list_drawing_names, nullptr, nullptr, AFB_SESSION_NONE},
736     {"ping", windowmanager_ping, nullptr, nullptr, AFB_SESSION_NONE},
737     {"debug_status", windowmanager_debug_status, nullptr, nullptr, AFB_SESSION_NONE},
738     {"debug_layers", windowmanager_debug_layers, nullptr, nullptr, AFB_SESSION_NONE},
739     {"debug_surfaces", windowmanager_debug_surfaces, nullptr, nullptr, AFB_SESSION_NONE},
740     {"debug_terminate", windowmanager_debug_terminate, nullptr, nullptr, AFB_SESSION_NONE},
741     {}};
742
743 extern "C" const struct afb_binding_v2 afbBindingV2 = {
744     "windowmanager", nullptr, nullptr, windowmanager_verbs, nullptr, binding_init, nullptr, 0};