Change message log
[apps/agl-service-windowmanager.git] / src / app.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 "app.hpp"
18 #include "json_helper.hpp"
19 #include "layers.hpp"
20 #include "layout.hpp"
21 #include "util.hpp"
22 #include "wayland_ivi_wm.hpp"
23
24 #include <cstdio>
25 #include <memory>
26
27 #include <cassert>
28
29 #include <json-c/json.h>
30
31 #include <algorithm>
32 #include <csignal>
33 #include <fstream>
34 #include <json.hpp>
35 #include <regex>
36 #include <thread>
37
38 #include "wm-client.hpp"
39 #include "applist.hpp"
40
41 extern "C"
42 {
43 #include <systemd/sd-event.h>
44 }
45
46 namespace wm
47 {
48
49 const unsigned TIME_OUT = 10000000UL; /* 10s */
50
51 /* DrawingArea name used by "{layout}.{area}" */
52 const char kNameLayoutNormal[] = "normal";
53 const char kNameLayoutSplit[] = "split";
54 const char kNameAreaFull[] = "full";
55 const char kNameAreaMain[] = "main";
56 const char kNameAreaSub[] = "sub";
57
58 /* Key for json obejct */
59 const char kKeyDrawingName[] = "drawing_name";
60 const char kKeyDrawingArea[] = "drawing_area";
61 const char kKeyDrawingRect[] = "drawing_rect";
62 const char kKeyX[] = "x";
63 const char kKeyY[] = "y";
64 const char kKeyWidth[] = "width";
65 const char kKeyHeight[] = "height";
66 const char kKeyWidthPixel[] = "width_pixel";
67 const char kKeyHeightPixel[] = "height_pixel";
68 const char kKeyWidthMm[] = "width_mm";
69 const char kKeyHeightMm[] = "height_mm";
70
71 static const std::string task_allocate = "allocate";
72 static const std::string task_release = "release";
73 static sd_event_source *timer_ev_src = nullptr;
74
75 static AppList app_list;
76
77 namespace
78 {
79
80 using nlohmann::json;
81
82 result<json> file_to_json(char const *filename)
83 {
84     json j;
85     std::ifstream i(filename);
86     if (i.fail())
87     {
88         HMI_DEBUG("wm", "Could not open config file, so use default layer information");
89         j = default_layers_json;
90     }
91     else
92     {
93         i >> j;
94     }
95
96     return Ok(j);
97 }
98
99 struct result<layer_map> load_layer_map(char const *filename)
100 {
101     HMI_DEBUG("wm", "loading IDs from %s", filename);
102
103     auto j = file_to_json(filename);
104     if (j.is_err())
105     {
106         return Err<layer_map>(j.unwrap_err());
107     }
108     json jids = j.unwrap();
109
110     return to_layer_map(jids);
111 }
112
113 static int
114 processTimerHandler(sd_event_source *s, uint64_t usec, void *userdata)
115 {
116     HMI_NOTICE("wm", "Time out occurs because the client replys endDraw slow, so revert the request");
117     reinterpret_cast<wm::App *>(userdata)->timerHandler();
118     return 0;
119 }
120
121 } // namespace
122
123 void App::timerHandler()
124 {
125     unsigned seq = app_list.currentSequenceNumber();
126     HMI_SEQ_DEBUG(seq, "Timer expired, remove Request");
127     app_list.req_dump();
128     app_list.removeRequest(seq);
129     app_list.next();
130     app_list.req_dump();
131     if (app_list.haveRequest())
132     {
133         this->process_request();
134     }
135 }
136
137 void App::removeClient(const std::string &appid)
138 {
139     HMI_DEBUG("wm", "Remove clinet %s from list", appid.c_str());
140     app_list.removeClient(appid);
141 }
142
143 bool App::subscribeEventForApp(const std::string &appid, afb_req req, const std::string &evname)
144 {
145     if(!app_list.contains(appid)){
146         HMI_DEBUG("wm", "Client %s is not registered", appid.c_str());
147         return false;
148     }
149     auto client = app_list.lookUpClient(appid);
150     return client->subscribe(req, evname);
151 }
152
153 /**
154  * App Impl
155  */
156 App::App(wl::display *d)
157     : chooks{this},
158       display{d},
159       controller{},
160       outputs(),
161       config(),
162       layers(),
163       id_alloc{},
164       pending_events(false),
165       policy{}
166 {
167     try
168     {
169         {
170             auto l = load_layer_map(
171                 this->config.get_string("layers.json").value().c_str());
172             if (l.is_ok())
173             {
174                 this->layers = l.unwrap();
175             }
176             else
177             {
178                 HMI_ERROR("wm", "%s", l.err().value());
179             }
180         }
181     }
182     catch (std::exception &e)
183     {
184         HMI_ERROR("wm", "Loading of configuration failed: %s", e.what());
185     }
186 }
187
188 int App::init()
189 {
190     if (!this->display->ok())
191     {
192         return -1;
193     }
194
195     if (this->layers.mapping.empty())
196     {
197         HMI_ERROR("wm", "No surface -> layer mapping loaded");
198         return -1;
199     }
200
201     // Make afb event
202     for (int i = Event_Val_Min; i <= Event_Val_Max; i++)
203     {
204         map_afb_event[kListEventName[i]] = afb_daemon_make_event(kListEventName[i]);
205     }
206
207     this->display->add_global_handler(
208         "wl_output", [this](wl_registry *r, uint32_t name, uint32_t v) {
209             this->outputs.emplace_back(std::make_unique<wl::output>(r, name, v));
210         });
211
212     this->display->add_global_handler(
213         "ivi_wm", [this](wl_registry *r, uint32_t name, uint32_t v) {
214             this->controller =
215                 std::make_unique<struct compositor::controller>(r, name, v);
216
217             // Init controller hooks
218             this->controller->chooks = &this->chooks;
219
220             // This protocol needs the output, so lets just add our mapping here...
221             this->controller->add_proxy_to_id_mapping(
222                 this->outputs.back()->proxy.get(),
223                 wl_proxy_get_id(reinterpret_cast<struct wl_proxy *>(
224                     this->outputs.back()->proxy.get())));
225
226             // Create screen
227             this->controller->create_screen(this->outputs.back()->proxy.get());
228
229             // Set display to controller
230             this->controller->display = this->display;
231         });
232
233     // First level objects
234     this->display->roundtrip();
235     // Second level objects
236     this->display->roundtrip();
237     // Third level objects
238     this->display->roundtrip();
239
240     return init_layers();
241 }
242
243 int App::dispatch_pending_events()
244 {
245     if (this->pop_pending_events())
246     {
247         this->display->dispatch_pending();
248         return 0;
249     }
250     return -1;
251 }
252
253 bool App::pop_pending_events()
254 {
255     bool x{true};
256     return this->pending_events.compare_exchange_strong(
257         x, false, std::memory_order_consume);
258 }
259
260 void App::set_pending_events()
261 {
262     this->pending_events.store(true, std::memory_order_release);
263 }
264
265 optional<int> App::lookup_id(char const *name)
266 {
267     return this->id_alloc.lookup(std::string(name));
268 }
269 optional<std::string> App::lookup_name(int id)
270 {
271     return this->id_alloc.lookup(id);
272 }
273
274 /**
275  * init_layers()
276  */
277 int App::init_layers()
278 {
279     if (!this->controller)
280     {
281         HMI_ERROR("wm", "ivi_controller global not available");
282         return -1;
283     }
284
285     if (this->outputs.empty())
286     {
287         HMI_ERROR("wm", "no output was set up!");
288         return -1;
289     }
290
291     auto &c = this->controller;
292
293     auto &o = this->outputs.front();
294     auto &s = c->screens.begin()->second;
295     auto &layers = c->layers;
296
297     // Write output dimensions to ivi controller...
298     c->output_size = compositor::size{uint32_t(o->width), uint32_t(o->height)};
299     c->physical_size = compositor::size{uint32_t(o->physical_width),
300                                         uint32_t(o->physical_height)};
301
302     // Clear scene
303     layers.clear();
304
305     // Clear screen
306     s->clear();
307
308     // Quick and dirty setup of layers
309     for (auto const &i : this->layers.mapping)
310     {
311         c->layer_create(i.second.layer_id, o->width, o->height);
312         auto &l = layers[i.second.layer_id];
313         l->set_destination_rectangle(0, 0, o->width, o->height);
314         l->set_visibility(1);
315         HMI_DEBUG("wm", "Setting up layer %s (%d) for surface role match \"%s\"",
316                   i.second.name.c_str(), i.second.layer_id, i.second.role.c_str());
317     }
318
319     // Add layers to screen
320     s->set_render_order(this->layers.layers);
321
322     this->layout_commit();
323
324     return 0;
325 }
326
327 void App::surface_set_layout(int surface_id, optional<int> sub_surface_id)
328 {
329     if (!this->controller->surface_exists(surface_id))
330     {
331         HMI_ERROR("wm", "Surface %d does not exist", surface_id);
332         return;
333     }
334
335     auto o_layer_id = this->layers.get_layer_id(surface_id);
336
337     if (!o_layer_id)
338     {
339         HMI_ERROR("wm", "Surface %d is not associated with any layer!", surface_id);
340         return;
341     }
342
343     uint32_t layer_id = *o_layer_id;
344
345     auto const &layer = this->layers.get_layer(layer_id);
346     auto rect = layer.value().rect;
347     auto &s = this->controller->surfaces[surface_id];
348
349     int x = rect.x;
350     int y = rect.y;
351     int w = rect.w;
352     int h = rect.h;
353
354     // less-than-0 values refer to MAX + 1 - $VALUE
355     // e.g. MAX is either screen width or height
356     if (w < 0)
357     {
358         w = this->controller->output_size.w + 1 + w;
359     }
360     if (h < 0)
361     {
362         h = this->controller->output_size.h + 1 + h;
363     }
364
365     if (sub_surface_id)
366     {
367         if (o_layer_id != this->layers.get_layer_id(*sub_surface_id))
368         {
369             HMI_ERROR("wm",
370                       "surface_set_layout: layers of surfaces (%d and %d) don't match!",
371                       surface_id, *sub_surface_id);
372             return;
373         }
374
375         int x_off = 0;
376         int y_off = 0;
377
378         // split along major axis
379         if (w > h)
380         {
381             w /= 2;
382             x_off = w;
383         }
384         else
385         {
386             h /= 2;
387             y_off = h;
388         }
389
390         auto &ss = this->controller->surfaces[*sub_surface_id];
391
392         HMI_DEBUG("wm", "surface_set_layout for sub surface %u on layer %u",
393                   *sub_surface_id, layer_id);
394
395         // set destination to the display rectangle
396         ss->set_destination_rectangle(x + x_off, y + y_off, w, h);
397
398         this->area_info[*sub_surface_id].x = x;
399         this->area_info[*sub_surface_id].y = y;
400         this->area_info[*sub_surface_id].w = w;
401         this->area_info[*sub_surface_id].h = h;
402     }
403
404     HMI_DEBUG("wm", "surface_set_layout for surface %u on layer %u", surface_id,
405               layer_id);
406
407     // set destination to the display rectangle
408     s->set_destination_rectangle(x, y, w, h);
409
410     // update area information
411     this->area_info[surface_id].x = x;
412     this->area_info[surface_id].y = y;
413     this->area_info[surface_id].w = w;
414     this->area_info[surface_id].h = h;
415
416     HMI_DEBUG("wm", "Surface %u now on layer %u with rect { %d, %d, %d, %d }",
417               surface_id, layer_id, x, y, w, h);
418 }
419
420 void App::layout_commit()
421 {
422     this->controller->commit_changes();
423     this->display->flush();
424 }
425
426 void App::set_timer()
427 {
428     HMI_SEQ_DEBUG(app_list.currentSequenceNumber(), "Timer set activate");
429     if (timer_ev_src == nullptr)
430     {
431         // firsttime set into sd_event
432         int ret = sd_event_add_time(afb_daemon_get_event_loop(), &timer_ev_src,
433                                     CLOCK_REALTIME, time(NULL) * (1000000UL) + TIME_OUT, 1, processTimerHandler, this);
434         if (ret < 0)
435         {
436             HMI_ERROR("wm", "Could't set timer");
437         }
438     }
439     else
440     {
441         // update timer limitation after second time
442         sd_event_source_set_time(timer_ev_src, time(NULL) * (1000000UL) + TIME_OUT);
443         sd_event_source_set_enabled(timer_ev_src, SD_EVENT_ONESHOT);
444     }
445 }
446
447 void App::stop_timer()
448 {
449     unsigned seq = app_list.currentSequenceNumber();
450     HMI_SEQ_DEBUG(seq, "Timer stop");
451     int rc = sd_event_source_set_enabled(timer_ev_src, SD_EVENT_OFF);
452     if (rc < 0)
453     {
454         HMI_SEQ_ERROR(seq, "Timer stop failed");
455     }
456 }
457
458 bool App::lm_release(const struct WMAction &action)
459 {
460     //auto const &surface_id = this->lookup_id(drawing_name);
461     unsigned req_num = app_list.currentSequenceNumber();
462     auto const &surface_id = this->lookup_id(action.role.c_str());
463     if (!surface_id)
464     {
465         HMI_SEQ_ERROR(req_num, "Surface does not exist");
466         return false;
467     }
468
469     if (*surface_id == this->layers.main_surface)
470     {
471         HMI_SEQ_ERROR(req_num, "Cannot deactivate main_surface");
472         return false;
473     }
474
475     auto o_state = *this->layers.get_layout_state(*surface_id);
476
477     if (o_state == nullptr)
478     {
479         HMI_SEQ_ERROR(req_num, "Could not find layer for surface");
480         return false;
481     }
482
483     struct LayoutState &state = *o_state;
484
485     if (state.main == -1)
486     {
487         HMI_SEQ_ERROR(req_num, "No surface active");
488         return false;
489     }
490
491     // Check against main_surface, main_surface_name is the configuration item.
492     if (*surface_id == this->layers.main_surface)
493     {
494         HMI_SEQ_DEBUG(req_num, "Refusing to deactivate main_surface %d", *surface_id);
495         //reply(nullptr);
496         return true;
497     }
498     if ((state.main == *surface_id) && (state.sub == *surface_id))
499     {
500         HMI_SEQ_ERROR(req_num, "Surface is not active");
501         return false;
502     }
503
504     if (state.main == *surface_id)
505     {
506         if (state.sub != -1)
507         {
508             this->try_layout(
509                 state, LayoutState{state.sub, -1}, [&](LayoutState const &nl) {
510                     std::string sub = std::move(*this->lookup_name(state.sub));
511
512                     this->deactivate(*surface_id);
513                     this->surface_set_layout(state.sub);
514                     state = nl;
515
516                     this->layout_commit();
517                     std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
518                     compositor::rect area_rect = this->area_info[state.sub];
519                     this->emit_syncdraw(sub.c_str(), str_area.c_str(),
520                                         area_rect.x, area_rect.y, area_rect.w, area_rect.h);
521                     this->enqueue_flushdraw(state.sub);
522                 });
523         }
524         else
525         {
526             this->try_layout(state, LayoutState{-1, -1}, [&](LayoutState const &nl) {
527                 this->deactivate(*surface_id);
528                 state = nl;
529                 this->layout_commit();
530             });
531         }
532     }
533     else if (state.sub == *surface_id)
534     {
535         this->try_layout(
536             state, LayoutState{state.main, -1}, [&](LayoutState const &nl) {
537                 std::string main = std::move(*this->lookup_name(state.main));
538
539                 this->deactivate(*surface_id);
540                 this->surface_set_layout(state.main);
541                 state = nl;
542
543                 this->layout_commit();
544                 std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
545                 compositor::rect area_rect = this->area_info[state.main];
546                 this->emit_syncdraw(main.c_str(), str_area.c_str(),
547                                     area_rect.x, area_rect.y, area_rect.w, area_rect.h);
548                 this->enqueue_flushdraw(state.main);
549             });
550     }
551     return true;
552 }
553
554 bool App::lm_layout_change(const struct WMAction &action)
555 {
556     const char *msg = this->check_surface_exist(action.role.c_str());
557
558     /*
559     lm_.updateLayout(action);
560     TODO: emit syncDraw with application*/
561     if (msg)
562     {
563         HMI_SEQ_DEBUG(app_list.currentSequenceNumber(), msg);
564         //app_list.removeRequest(req_num);
565         return false;
566     }
567     this->lm_layout_change(action.role.c_str());
568     return true;
569 }
570
571 bool App::do_transition(unsigned req_num)
572 {
573     /*
574     * Check Policy
575     */
576     // get current trigger
577     auto trigger = app_list.getRequest(req_num);
578     bool is_activate = true;
579
580     /*  get new status from Policy Manager
581
582     (json_object*?) newLayout = checkPolicy(trigger);
583     (vector<struct WMAction>&) auto actions = translator.inputActionFromLayout(newLayout, currentLayout)
584     for(const auto& x : actions){
585         app_list.setAciton(req_num, x)
586     }
587
588     or
589
590     translator.inputActionFromLayout(newLayout, currentLayout, &app_list, req_num);
591
592     /* The following error check is not necessary because main.cpp will reject the message form not registered object
593    } */
594     HMI_SEQ_NOTICE(req_num, "ATM, Policy manager does't exist, then set WMAction as is");
595
596     if (TASK_RELEASE == trigger.task)
597     {
598         is_activate = false;
599     }
600     bool ret = app_list.setAction(req_num, trigger.appid, trigger.role, trigger.area, is_activate);
601     app_list.req_dump();
602
603     if (!ret)
604     {
605         HMI_SEQ_ERROR(req_num, "Failed to set action");
606         return ret;
607     }
608
609     // layer manager task
610     bool sync_draw_happen = false;
611     for (const auto &y : app_list.getActions(req_num))
612     {
613         /*
614         do_task(y);
615         */
616         /*  TODO
617            but current we can't do do_task,
618            so divide the processing into lm_layout_change and lm_release
619         */
620         if (y.visible)
621         {
622             sync_draw_happen = true;
623             ret = lm_layout_change(y);
624             if (!ret)
625             {
626                 HMI_SEQ_ERROR(req_num, "Failed layout change: %s", y.appid.c_str());
627                 app_list.removeRequest(req_num);
628                 break;
629                 // TODO: if transition fails, what should we do?
630             }
631             /* app_list.lookUpClient(y.appid)->emit_syncdraw(y.role, y.area); */
632         }
633         else
634         {
635             ret = lm_release(y);
636             if (!ret)
637             {
638                 HMI_SEQ_ERROR(req_num, "Failed release resource: %s", y.appid.c_str());
639                 app_list.removeRequest(req_num);
640                 break;
641                 // TODO: if transition fails, what should we do?
642             }
643             /* app_list.lookUpClient(y.appid)->emit_invisible(y.role, y.area); */
644         }
645     }
646
647     if (!ret)
648     {
649         //this->emit_error(request_seq, 0 /*error_num*/, "error happens"); // test
650     }
651     else if (ret && sync_draw_happen)
652     {
653         this->set_timer();
654     }
655     else
656     {
657         app_list.removeRequest(req_num); // HACK!!!
658     }
659     return ret;
660 }
661
662 void App::lm_layout_change(const char *drawing_name)
663 {
664     auto const &surface_id = this->lookup_id(drawing_name);
665     auto layer_id = this->layers.get_layer_id(*surface_id);
666     auto o_state = *this->layers.get_layout_state(*surface_id);
667     struct LayoutState &state = *o_state;
668
669     // disable layers that are above our current layer
670     for (auto const &l : this->layers.mapping)
671     {
672         if (l.second.layer_id <= *layer_id)
673         {
674             continue;
675         }
676
677         bool flush = false;
678         if (l.second.state.main != -1)
679         {
680             this->deactivate(l.second.state.main);
681             l.second.state.main = -1;
682             flush = true;
683         }
684
685         if (l.second.state.sub != -1)
686         {
687             this->deactivate(l.second.state.sub);
688             l.second.state.sub = -1;
689             flush = true;
690         }
691
692         if (flush)
693         {
694             this->layout_commit();
695         }
696     }
697
698     auto layer = this->layers.get_layer(*layer_id);
699
700     if (state.main == -1)
701     {
702         this->try_layout(
703             state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
704                 HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
705                 this->surface_set_layout(*surface_id);
706                 state = nl;
707
708                 // Commit for configuraton
709                 this->layout_commit();
710
711                 std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
712                 compositor::rect area_rect = this->area_info[*surface_id];
713                 this->emit_syncdraw(drawing_name, str_area.c_str(),
714                                     area_rect.x, area_rect.y, area_rect.w, area_rect.h);
715                 this->enqueue_flushdraw(state.main);
716             });
717     }
718     else
719     {
720         if (0 == strcmp(drawing_name, "HomeScreen"))
721         {
722             this->try_layout(
723                 state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
724                     HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
725                     std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
726                     compositor::rect area_rect = this->area_info[*surface_id];
727                     this->emit_syncdraw(drawing_name, str_area.c_str(),
728                                         area_rect.x, area_rect.y, area_rect.w, area_rect.h);
729                     this->enqueue_flushdraw(state.main);
730                 });
731         }
732         else
733         {
734             bool can_split = this->can_split(state, *surface_id);
735
736             if (can_split)
737             {
738                 this->try_layout(
739                     state,
740                     LayoutState{state.main, *surface_id},
741                     [&](LayoutState const &nl) {
742                         HMI_DEBUG("wm", "Layout: %s", kNameLayoutSplit);
743                         std::string main =
744                             std::move(*this->lookup_name(state.main));
745
746                         this->surface_set_layout(state.main, surface_id);
747                         if (state.sub != *surface_id)
748                         {
749                             if (state.sub != -1)
750                             {
751                                 this->deactivate(state.sub);
752                             }
753                         }
754                         state = nl;
755
756                         // Commit for configuration and visibility(0)
757                         this->layout_commit();
758
759                         std::string str_area_main = std::string(kNameLayoutSplit) + "." + std::string(kNameAreaMain);
760                         std::string str_area_sub = std::string(kNameLayoutSplit) + "." + std::string(kNameAreaSub);
761                         compositor::rect area_rect_main = this->area_info[state.main];
762                         compositor::rect area_rect_sub = this->area_info[*surface_id];
763                         this->emit_syncdraw(main.c_str(), str_area_main.c_str(),
764                                             area_rect_main.x, area_rect_main.y,
765                                             area_rect_main.w, area_rect_main.h);
766                         this->emit_syncdraw(drawing_name, str_area_sub.c_str(),
767                                             area_rect_sub.x, area_rect_sub.y,
768                                             area_rect_sub.w, area_rect_sub.h);
769                         this->enqueue_flushdraw(state.main);
770                         this->enqueue_flushdraw(state.sub);
771                     });
772             }
773             else
774             {
775                 this->try_layout(
776                     state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
777                         HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
778
779                         this->surface_set_layout(*surface_id);
780                         if (state.main != *surface_id)
781                         {
782                             this->deactivate(state.main);
783                         }
784                         if (state.sub != -1)
785                         {
786                             if (state.sub != *surface_id)
787                             {
788                                 this->deactivate(state.sub);
789                             }
790                         }
791                         state = nl;
792
793                         // Commit for configuraton and visibility(0)
794                         this->layout_commit();
795
796                         std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
797                         compositor::rect area_rect = this->area_info[*surface_id];
798                         this->emit_syncdraw(drawing_name, str_area.c_str(),
799                                             area_rect.x, area_rect.y, area_rect.w, area_rect.h);
800                         this->enqueue_flushdraw(state.main);
801                     });
802             }
803         }
804     }
805 }
806
807 const char *App::check_surface_exist(const char *drawing_name)
808 {
809     auto const &surface_id = this->lookup_id(drawing_name);
810     if (!surface_id)
811     {
812         //reply("Surface does not exist");
813         return "Surface does not exist";
814     }
815
816     if (!this->controller->surface_exists(*surface_id))
817     {
818         //reply("Surface does not exist in controller!");
819         return "Surface does not exist in controller!";
820     }
821
822     auto layer_id = this->layers.get_layer_id(*surface_id);
823
824     if (!layer_id)
825     {
826         //reply("Surface is not on any layer!");
827         return "Surface is not on any layer!";
828     }
829
830     auto o_state = *this->layers.get_layout_state(*surface_id);
831
832     if (o_state == nullptr)
833     {
834         //reply("Could not find layer for surface");
835         return "Could not find layer for surface";
836     }
837
838     HMI_DEBUG("wm", "surface %d is detected", *surface_id);
839     return nullptr;
840     //reply(nullptr);
841 }
842
843 void App::api_activate_surface(char const *appid, char const *drawing_name, char const *drawing_area, const reply_func &reply)
844 {
845     ST();
846
847     /*
848    * Check Phase
849    */
850
851     std::string id = appid;
852     std::string role = drawing_name;
853     std::string area = drawing_area;
854
855     if (!app_list.contains(id))
856     {
857         reply("app doesn't request 'requestSurface' yet");
858         return;
859     }
860
861     auto client = app_list.lookUpClient(id);
862
863     /*
864    * Queueing Phase
865    */
866     unsigned current = app_list.currentSequenceNumber();
867     unsigned requested_num = app_list.getSequenceNumber(id);
868     if (requested_num != 0)
869     {
870         HMI_SEQ_INFO(requested_num, "%s %s %s request is already queued", id.c_str(), role.c_str(), area.c_str());
871         reply("already requested");
872         return;
873     }
874
875     WMRequest req = WMRequest(id, role, area, Task::TASK_ALLOCATE);
876     unsigned new_req = app_list.addAllocateRequest(req);
877     app_list.req_dump();
878
879     HMI_SEQ_DEBUG(current, "%s start sequence with %s, %s", id.c_str(), role.c_str(), area.c_str());
880
881     reply(nullptr);
882     if (new_req != current)
883     {
884         // Add request, then invoked after the previous task is finished
885         HMI_SEQ_DEBUG(new_req, "request is accepted");
886         return;
887     }
888
889     /*
890     * Do allocate tasks
891     */
892     bool ret = this->do_transition(new_req);
893
894     if (!ret)
895     {
896         HMI_SEQ_ERROR(new_req, "failed to do_transition");
897         //this->emit_error()
898     }
899 }
900
901 void App::api_deactivate_surface(char const *appid, char const *drawing_name, const reply_func &reply)
902 {
903     ST();
904
905     /*
906    * Check Phase
907    */
908     std::string id = appid;
909     std::string role = drawing_name;
910     std::string area = ""; //drawing_area;
911
912     if (!app_list.contains(id))
913     {
914         reply("app doesn't request 'requestSurface' yet");
915         return;
916     }
917     auto client = app_list.lookUpClient(id);
918
919     /*
920    * Queueing Phase
921    */
922     unsigned current = app_list.currentSequenceNumber();
923     unsigned requested_num = app_list.getSequenceNumber(id);
924     if (requested_num != 0)
925     {
926         HMI_SEQ_INFO(requested_num, "%s %s %s request is already queued", id.c_str(), role.c_str(), area.c_str());
927         reply("already requested");
928         return;
929     }
930
931     WMRequest req = WMRequest(id, role, area, Task::TASK_RELEASE);
932     unsigned new_req = app_list.addAllocateRequest(req);
933     app_list.req_dump();
934
935     HMI_SEQ_DEBUG(current, "%s start sequence with %s, %s", id.c_str(), role.c_str(), area.c_str());
936
937     reply(nullptr);
938     if (new_req != current)
939     {
940         // Add request, then invoked after the previous task is finished
941         HMI_SEQ_DEBUG(new_req, "request is accepted");
942         return;
943     }
944
945     /*
946     * Do allocate tasks
947     */
948     bool ret = this->do_transition(new_req);
949
950     if (!ret)
951     {
952         HMI_SEQ_ERROR(new_req, "failed to do_transition");
953         //this->emit_error()
954     }
955 }
956
957 void App::enqueue_flushdraw(int surface_id)
958 {
959     this->check_flushdraw(surface_id);
960     HMI_DEBUG("wm", "Enqueuing EndDraw for surface_id %d", surface_id);
961     this->pending_end_draw.push_back(surface_id);
962 }
963
964 void App::check_flushdraw(int surface_id)
965 {
966     auto i = std::find(std::begin(this->pending_end_draw),
967                        std::end(this->pending_end_draw), surface_id);
968     if (i != std::end(this->pending_end_draw))
969     {
970         auto n = this->lookup_name(surface_id);
971         HMI_ERROR("wm", "Application %s (%d) has pending EndDraw call(s)!",
972                   n ? n->c_str() : "unknown-name", surface_id);
973         std::swap(this->pending_end_draw[std::distance(
974                       std::begin(this->pending_end_draw), i)],
975                   this->pending_end_draw.back());
976         this->pending_end_draw.resize(this->pending_end_draw.size() - 1);
977     }
978 }
979
980 void App::lm_enddraw(const char *drawing_name)
981 {
982     HMI_DEBUG("wm", "end draw %s", drawing_name);
983     for (unsigned i = 0, iend = this->pending_end_draw.size(); i < iend; i++)
984     {
985         auto n = this->lookup_name(this->pending_end_draw[i]);
986         if (n && *n == drawing_name)
987         {
988             std::swap(this->pending_end_draw[i], this->pending_end_draw[iend - 1]);
989             this->pending_end_draw.resize(iend - 1);
990             this->activate(this->pending_end_draw[i]);
991             this->emit_flushdraw(drawing_name);
992         }
993     }
994 }
995
996 void App::do_enddraw(unsigned request_seq)
997 {
998     // get actions
999     auto actions = app_list.getActions(request_seq);
1000     HMI_SEQ_INFO(request_seq, "do endDraw");
1001
1002     for (const auto &act : actions)
1003     {
1004         HMI_SEQ_DEBUG(request_seq, "visible %s", act.role.c_str());
1005         this->lm_enddraw(act.role.c_str());
1006     }
1007
1008     HMI_SEQ_INFO(request_seq, "emit flushDraw");
1009     /*     do
1010     {
1011         // emit flush Draw
1012         //emitFlushDrawToAll(&app_list, request_seq);
1013         // emit status change event
1014     } while (!app_list.requestFinished());*/
1015 }
1016
1017 void App::process_request()
1018 {
1019     unsigned req = app_list.currentSequenceNumber();
1020     HMI_SEQ_DEBUG(req, "Do next request");
1021     do_transition(req);
1022 }
1023
1024 void App::api_enddraw(char const *appid, char const *drawing_name)
1025 {
1026     std::string id(appid);
1027     std::string role(drawing_name);
1028     unsigned current_seq = app_list.currentSequenceNumber();
1029     bool result = app_list.setEndDrawFinished(current_seq, id, role);
1030
1031     if (!result)
1032     {
1033         HMI_ERROR("wm", "%s doesn't have Window Resource", id.c_str());
1034         return;
1035     }
1036
1037     if (app_list.endDrawFullfilled(current_seq))
1038     {
1039         // do task for endDraw
1040         //this->stop_timer();
1041         this->do_enddraw(current_seq);
1042
1043         this->stop_timer();
1044
1045         app_list.removeRequest(current_seq);
1046         HMI_SEQ_INFO(current_seq, "Finish request");
1047         app_list.next();
1048         if (app_list.haveRequest())
1049         {
1050             this->process_request();
1051         }
1052     }
1053     else
1054     {
1055         HMI_SEQ_INFO(current_seq, "Wait other App call endDraw");
1056         return;
1057     }
1058 }
1059
1060 void App::api_ping() { this->dispatch_pending_events(); }
1061
1062 void App::send_event(char const *evname, char const *label)
1063 {
1064     HMI_DEBUG("wm", "%s: %s(%s)", __func__, evname, label);
1065
1066     json_object *j = json_object_new_object();
1067     json_object_object_add(j, kKeyDrawingName, json_object_new_string(label));
1068
1069     int ret = afb_event_push(this->map_afb_event[evname], j);
1070     if (ret != 0)
1071     {
1072         HMI_DEBUG("wm", "afb_event_push failed: %m");
1073     }
1074 }
1075
1076 void App::send_event(char const *evname, char const *label, char const *area,
1077                      int x, int y, int w, int h)
1078 {
1079     HMI_DEBUG("wm", "%s: %s(%s, %s) x:%d y:%d w:%d h:%d",
1080               __func__, evname, label, area, x, y, w, h);
1081
1082     json_object *j_rect = json_object_new_object();
1083     json_object_object_add(j_rect, kKeyX, json_object_new_int(x));
1084     json_object_object_add(j_rect, kKeyY, json_object_new_int(y));
1085     json_object_object_add(j_rect, kKeyWidth, json_object_new_int(w));
1086     json_object_object_add(j_rect, kKeyHeight, json_object_new_int(h));
1087
1088     json_object *j = json_object_new_object();
1089     json_object_object_add(j, kKeyDrawingName, json_object_new_string(label));
1090     json_object_object_add(j, kKeyDrawingArea, json_object_new_string(area));
1091     json_object_object_add(j, kKeyDrawingRect, j_rect);
1092
1093     int ret = afb_event_push(this->map_afb_event[evname], j);
1094     if (ret != 0)
1095     {
1096         HMI_DEBUG("wm", "afb_event_push failed: %m");
1097     }
1098 }
1099
1100 /**
1101  * proxied events
1102  */
1103 void App::surface_created(uint32_t surface_id)
1104 {
1105     auto layer_id = this->layers.get_layer_id(surface_id);
1106     if (!layer_id)
1107     {
1108         HMI_DEBUG("wm", "Newly created surfce %d is not associated with any layer!",
1109                   surface_id);
1110         return;
1111     }
1112
1113     HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", surface_id, *layer_id);
1114
1115     this->controller->layers[*layer_id]->add_surface(surface_id);
1116     this->layout_commit();
1117     // activate the main_surface right away
1118     /*if (surface_id == static_cast<unsigned>(this->layers.main_surface)) {
1119       HMI_DEBUG("wm", "Activating main_surface (%d)", surface_id);
1120
1121       this->api_activate_surface(
1122          this->lookup_name(surface_id).value_or("unknown-name").c_str());
1123    }*/
1124
1125     // search pid from surfaceID
1126
1127     // pick up appid from pid from application manager
1128
1129     // check appid then add it to the client
1130 }
1131
1132 void App::surface_removed(uint32_t surface_id)
1133 {
1134     HMI_DEBUG("wm", "surface_id is %u", surface_id);
1135
1136     app_list.removeSurface(surface_id);
1137 }
1138
1139 void App::emit_activated(char const *label)
1140 {
1141     this->send_event(kListEventName[Event_Active], label);
1142 }
1143
1144 void App::emit_deactivated(char const *label)
1145 {
1146     this->send_event(kListEventName[Event_Inactive], label);
1147 }
1148
1149 void App::emit_syncdraw(char const *label, char const *area, int x, int y, int w, int h)
1150 {
1151     this->send_event(kListEventName[Event_SyncDraw], label, area, x, y, w, h);
1152 }
1153
1154 void App::emit_flushdraw(char const *label)
1155 {
1156     this->send_event(kListEventName[Event_FlushDraw], label);
1157 }
1158
1159 void App::emit_visible(char const *label, bool is_visible)
1160 {
1161     this->send_event(is_visible ? kListEventName[Event_Visible] : kListEventName[Event_Invisible], label);
1162 }
1163
1164 void App::emit_invisible(char const *label)
1165 {
1166     return emit_visible(label, false);
1167 }
1168
1169 void App::emit_visible(char const *label) { return emit_visible(label, true); }
1170
1171 result<int> App::api_request_surface(char const *appid, char const *drawing_name)
1172 {
1173     auto lid = this->layers.get_layer_id(std::string(drawing_name));
1174     if (!lid)
1175     {
1176         /**
1177        * register drawing_name as fallback and make it displayed.
1178        */
1179         lid = this->layers.get_layer_id(std::string("Fallback"));
1180         HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name);
1181         if (!lid)
1182         {
1183             return Err<int>("Drawing name does not match any role, Fallback is disabled");
1184         }
1185     }
1186
1187     auto rname = this->lookup_id(drawing_name);
1188     if (!rname)
1189     {
1190         // name does not exist yet, allocate surface id...
1191         auto id = int(this->id_alloc.generate_id(drawing_name));
1192         this->layers.add_surface(id, *lid);
1193
1194         // set the main_surface[_name] here and now
1195         if (!this->layers.main_surface_name.empty() &&
1196             this->layers.main_surface_name == drawing_name)
1197         {
1198             this->layers.main_surface = id;
1199             HMI_DEBUG("wm", "Set main_surface id to %u", id);
1200         }
1201
1202         // add client into the db
1203         std::string appid_str(appid);
1204         std::string role(drawing_name);
1205         //app_list.addClient(appid_str, role);
1206         app_list.addClient(appid_str, *lid, id, role);
1207
1208         return Ok<int>(id);
1209     }
1210
1211     // Check currently registered drawing names if it is already there.
1212     return Err<int>("Surface already present");
1213 }
1214
1215 char const *App::api_request_surface(char const *appid, char const *drawing_name,
1216                                      char const *ivi_id)
1217 {
1218     ST();
1219
1220     auto lid = this->layers.get_layer_id(std::string(drawing_name));
1221     unsigned sid = std::stol(ivi_id);
1222
1223     if (!lid)
1224     {
1225         /**
1226        * register drawing_name as fallback and make it displayed.
1227        */
1228         lid = this->layers.get_layer_id(std::string("Fallback"));
1229         HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name);
1230         if (!lid)
1231         {
1232             return "Drawing name does not match any role, Fallback is disabled";
1233         }
1234     }
1235
1236     auto rname = this->lookup_id(drawing_name);
1237
1238     if (rname)
1239     {
1240         return "Surface already present";
1241     }
1242
1243     // register pair drawing_name and ivi_id
1244     this->id_alloc.register_name_id(drawing_name, sid);
1245     this->layers.add_surface(sid, *lid);
1246
1247     // this surface is already created
1248     HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", sid, *lid);
1249
1250     this->controller->layers[*lid]->add_surface(sid);
1251     this->layout_commit();
1252
1253     return nullptr;
1254 }
1255
1256 result<json_object *> App::api_get_display_info()
1257 {
1258     // Check controller
1259     if (!this->controller)
1260     {
1261         return Err<json_object *>("ivi_controller global not available");
1262     }
1263
1264     // Set display info
1265     compositor::size o_size = this->controller->output_size;
1266     compositor::size p_size = this->controller->physical_size;
1267
1268     json_object *object = json_object_new_object();
1269     json_object_object_add(object, kKeyWidthPixel, json_object_new_int(o_size.w));
1270     json_object_object_add(object, kKeyHeightPixel, json_object_new_int(o_size.h));
1271     json_object_object_add(object, kKeyWidthMm, json_object_new_int(p_size.w));
1272     json_object_object_add(object, kKeyHeightMm, json_object_new_int(p_size.h));
1273
1274     return Ok<json_object *>(object);
1275 }
1276
1277 result<json_object *> App::api_get_area_info(char const *drawing_name)
1278 {
1279     HMI_DEBUG("wm", "called");
1280
1281     // Check drawing name, surface/layer id
1282     auto const &surface_id = this->lookup_id(drawing_name);
1283     if (!surface_id)
1284     {
1285         return Err<json_object *>("Surface does not exist");
1286     }
1287
1288     if (!this->controller->surface_exists(*surface_id))
1289     {
1290         return Err<json_object *>("Surface does not exist in controller!");
1291     }
1292
1293     auto layer_id = this->layers.get_layer_id(*surface_id);
1294     if (!layer_id)
1295     {
1296         return Err<json_object *>("Surface is not on any layer!");
1297     }
1298
1299     auto o_state = *this->layers.get_layout_state(*surface_id);
1300     if (o_state == nullptr)
1301     {
1302         return Err<json_object *>("Could not find layer for surface");
1303     }
1304
1305     struct LayoutState &state = *o_state;
1306     if ((state.main != *surface_id) && (state.sub != *surface_id))
1307     {
1308         return Err<json_object *>("Surface is inactive");
1309     }
1310
1311     // Set area rectangle
1312     compositor::rect area_info = this->area_info[*surface_id];
1313     json_object *object = json_object_new_object();
1314     json_object_object_add(object, kKeyX, json_object_new_int(area_info.x));
1315     json_object_object_add(object, kKeyY, json_object_new_int(area_info.y));
1316     json_object_object_add(object, kKeyWidth, json_object_new_int(area_info.w));
1317     json_object_object_add(object, kKeyHeight, json_object_new_int(area_info.h));
1318
1319     return Ok<json_object *>(object);
1320 }
1321
1322 void App::activate(int id)
1323 {
1324     auto ip = this->controller->sprops.find(id);
1325     if (ip != this->controller->sprops.end())
1326     {
1327         this->controller->surfaces[id]->set_visibility(1);
1328         char const *label =
1329             this->lookup_name(id).value_or("unknown-name").c_str();
1330
1331         // FOR CES DEMO >>>
1332         if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation")))
1333         {
1334             for (auto i = surface_bg.begin(); i != surface_bg.end(); ++i)
1335             {
1336                 if (id == *i)
1337                 {
1338                     // Remove id
1339                     this->surface_bg.erase(i);
1340
1341                     // Remove from BG layer (999)
1342                     HMI_DEBUG("wm", "Remove %s(%d) from BG layer", label, id);
1343                     this->controller->layers[999]->remove_surface(id);
1344
1345                     // Add to FG layer (1001)
1346                     HMI_DEBUG("wm", "Add %s(%d) to FG layer", label, id);
1347                     this->controller->layers[1001]->add_surface(id);
1348
1349                     for (int j : this->surface_bg)
1350                     {
1351                         HMI_DEBUG("wm", "Stored id:%d", j);
1352                     }
1353                     break;
1354                 }
1355             }
1356         }
1357         // <<< FOR CES DEMO
1358         this->layout_commit();
1359
1360         this->emit_visible(label);
1361         this->emit_activated(label);
1362     }
1363 }
1364
1365 void App::deactivate(int id)
1366 {
1367     auto ip = this->controller->sprops.find(id);
1368     if (ip != this->controller->sprops.end())
1369     {
1370         char const *label =
1371             this->lookup_name(id).value_or("unknown-name").c_str();
1372
1373         // FOR CES DEMO >>>
1374         if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation")))
1375         {
1376
1377             // Store id
1378             this->surface_bg.push_back(id);
1379
1380             // Remove from FG layer (1001)
1381             HMI_DEBUG("wm", "Remove %s(%d) from FG layer", label, id);
1382             this->controller->layers[1001]->remove_surface(id);
1383
1384             // Add to BG layer (999)
1385             HMI_DEBUG("wm", "Add %s(%d) to BG layer", label, id);
1386             this->controller->layers[999]->add_surface(id);
1387
1388             for (int j : surface_bg)
1389             {
1390                 HMI_DEBUG("wm", "Stored id:%d", j);
1391             }
1392         }
1393         else
1394         {
1395             this->controller->surfaces[id]->set_visibility(0);
1396         }
1397         // <<< FOR CES DEMO
1398
1399         this->emit_deactivated(label);
1400         this->emit_invisible(label);
1401     }
1402 }
1403
1404 void App::deactivate_main_surface()
1405 {
1406     this->layers.main_surface = -1;
1407     std::string appid = "HomeScreen";
1408     this->api_deactivate_surface(appid.c_str(), this->layers.main_surface_name.c_str(), [](const char *) {});
1409 }
1410
1411 bool App::can_split(struct LayoutState const &state, int new_id)
1412 {
1413     if (state.main != -1 && state.main != new_id)
1414     {
1415         auto new_id_layer = this->layers.get_layer_id(new_id).value();
1416         auto current_id_layer = this->layers.get_layer_id(state.main).value();
1417
1418         // surfaces are on separate layers, don't bother.
1419         if (new_id_layer != current_id_layer)
1420         {
1421             return false;
1422         }
1423
1424         std::string const &new_id_str = this->lookup_name(new_id).value();
1425         std::string const &cur_id_str = this->lookup_name(state.main).value();
1426
1427         auto const &layer = this->layers.get_layer(new_id_layer);
1428
1429         HMI_DEBUG("wm", "layer info name: %s", layer->name.c_str());
1430
1431         if (layer->layouts.empty())
1432         {
1433             return false;
1434         }
1435
1436         for (auto i = layer->layouts.cbegin(); i != layer->layouts.cend(); i++)
1437         {
1438             HMI_DEBUG("wm", "%d main_match '%s'", new_id_layer, i->main_match.c_str());
1439             auto rem = std::regex(i->main_match);
1440             if (std::regex_match(cur_id_str, rem))
1441             {
1442                 // build the second one only if the first already matched
1443                 HMI_DEBUG("wm", "%d sub_match '%s'", new_id_layer, i->sub_match.c_str());
1444                 auto res = std::regex(i->sub_match);
1445                 if (std::regex_match(new_id_str, res))
1446                 {
1447                     HMI_DEBUG("wm", "layout matched!");
1448                     return true;
1449                 }
1450             }
1451         }
1452     }
1453
1454     return false;
1455 }
1456
1457 void App::try_layout(struct LayoutState & /*state*/,
1458                      struct LayoutState const &new_layout,
1459                      std::function<void(LayoutState const &nl)> apply)
1460 {
1461     if (this->policy.layout_is_valid(new_layout))
1462     {
1463         apply(new_layout);
1464     }
1465 }
1466
1467 /**
1468  * controller_hooks
1469  */
1470 void controller_hooks::surface_created(uint32_t surface_id)
1471 {
1472     this->app->surface_created(surface_id);
1473 }
1474
1475 void controller_hooks::surface_removed(uint32_t surface_id)
1476 {
1477     this->app->surface_removed(surface_id);
1478 }
1479
1480 void controller_hooks::surface_visibility(uint32_t /*surface_id*/,
1481                                           uint32_t /*v*/) {}
1482
1483 void controller_hooks::surface_destination_rectangle(uint32_t /*surface_id*/,
1484                                                      uint32_t /*x*/,
1485                                                      uint32_t /*y*/,
1486                                                      uint32_t /*w*/,
1487                                                      uint32_t /*h*/) {}
1488
1489 } // namespace wm