1 with_system_controller = false
7 -- try loading the various logging plugins
8 m:try_load_plugin('systemd')
9 m:try_load_plugin('dlog')
11 -- load the console plugin
12 m:try_load_plugin('console')
14 m:try_load_plugin('console.disabled', 'webconsole', {
15 address = 'wsck:127.0.0.1:3000/murphy',
16 httpdir = '/usr/share/murphy/webconsole' });
18 -- load the dbus plugin
19 if m:plugin_exists('dbus') then
23 -- load the native resource plugin
24 if m:plugin_exists('resource-native') then
25 m:load_plugin('resource-native')
26 m:info("native resource plugin loaded")
28 m:info("No native resource plugin found...")
31 -- load the dbus resource plugin
32 m:try_load_plugin('resource-dbus', {
34 dbus_service = "org.Murphy",
36 default_zone = "driver",
37 default_class = "implicit"
40 -- load the domain control plugin
41 if m:plugin_exists('domain-control') then
42 m:load_plugin('domain-control')
44 m:info("No domain-control plugin found...")
47 if m:plugin_exists('glib') then
50 m:info("No glib plugin found...")
53 if m:plugin_exists("gam-resource-manager") then
55 function get_general_priorities(self)
56 print("*** get_general_priorities\n")
57 return { "USB Headset", "wiredHeadset", "speakers" }
60 function get_phone_priorities(self)
61 print("*** get_phone_priorities\n")
62 return { "wiredHeadset", "USB Headset" }
65 m:load_plugin('gam-resource-manager', {
66 config_dir = '/etc/murphy/gam',
67 decision_names = 'gam-wrtApplication-4',
70 ['t8j6HTRpuz.MediaPlayer'] = 'wrtApplication',
71 ['pacat'] = 'icoApplication'
73 app_default = 'icoApplication'
76 routing_sink_priority {
77 application_class = "player",
78 priority_queue = get_general_priorities
81 routing_sink_priority {
82 application_class = "game",
83 priority_queue = get_general_priorities
86 routing_sink_priority {
87 application_class = "implicit",
88 priority_queue = get_general_priorities
91 routing_sink_priority {
92 application_class = "phone",
93 priority_queue = get_phone_priorities
96 routing_sink_priority {
97 application_class = "basic",
98 priority_queue = get_phone_priorities
101 routing_sink_priority {
102 application_class = "event",
103 priority_queue = get_phone_priorities
107 -- load the AMB plugin
108 if m:plugin_exists('amb') then
109 m:try_load_plugin('amb')
111 if builtin.method.amb_initiate and
112 builtin.method.amb_update
117 m:info("No amb plugin found...")
120 -- load the ASM resource plugin
121 if m:plugin_exists('resource-asm') then
122 m:try_load_plugin('resource-asm', {
124 share_mmplayer = "player:AVP,mandatory,exclusive,strict",
125 ignored_argv0 = "WebProcess"
128 m:info("No audio session manager plugin found...")
131 if m:plugin_exists('system-controller') then
132 with_system_controller = true
133 elseif m:plugin_exists('ivi-resource-manager') then
134 m:load_plugin('ivi-resource-manager')
135 with_system_controller = false
138 -- define application classes
192 application_class { name="event" , priority=4 , modal=false, share=true , order="fifo" }
193 application_class { name="game" , priority=3 , modal=false, share=false, order="lifo" }
194 --# doesn't need to be created here, ivi-resource-manager creates it if loaded
195 --#application_class { name="basic" , priority=2 , modal=false, share=false, order="lifo" }
196 application_class { name="player" , priority=1 , modal=false, share=true , order="lifo" }
197 application_class { name="implicit" , priority=0 , modal=false, share=false, order="lifo" }
199 -- define zone attributes
201 type = {mdb.string, "common", "rw"},
202 location = {mdb.string, "anywhere", "rw"}
210 location = "front-left"
218 location = "front-right"
226 location = "back-left"
234 location = "back-right"
242 location = "back-left"
247 -- define resource classes
248 if not m:plugin_exists('ivi-resource-manager') and
249 not with_system_controller and
250 not m:plugin_exists('gam-resource-manager')
253 name = "audio_playback",
256 role = { mdb.string, "music", "rw" },
257 pid = { mdb.string, "<unknown>", "rw" },
258 policy = { mdb.string, "relaxed", "rw" },
259 source = { mdb.string, "webkit", "rw" },
260 conn_id = { mdb.unsigned, 0, "rw" }
265 if not m:plugin_exists('gam-resource-manager') then
267 name = "audio_recording",
270 role = { mdb.string, "music" , "rw" },
271 pid = { mdb.string, "<unknown>", "rw" },
272 policy = { mdb.string, "relaxed" , "rw" }
278 name = "video_playback",
283 name = "video_recording",
288 name = "speech_recognition",
293 name = "speech_synthesis",
297 -- PulseAudio volume context
299 name = "volume_context",
303 { "id", mdb.unsigned },
304 { "value", mdb.string, 64 },
308 -- put default volume context to the table
309 mdb.table.volume_context:insert({ id = 1, value = "default" })
311 if not m:plugin_exists('ivi-resource-manager') and
312 not with_system_controller
314 resource.method.veto = {
315 function(zone, rset, grant, owners, req_set)
321 -- test for creating selections
323 name = "audio_owner",
324 table = "audio_playback_owner",
325 columns = {"application_class"},
326 condition = "zone_name = 'driver'"
330 name = "vehicle_speed",
331 table = "amb_vehicle_speed",
333 condition = "key = 'VehicleSpeed'"
337 name = "speed2volume",
338 inputs = { speed = mdb.select.vehicle_speed, param = 9 },
339 outputs = { mdb.table { name = "speedvol",
340 index = {"zone", "device"},
341 columns = {{"zone", mdb.string, 16},
342 {"device", mdb.string, 16},
343 {"value", mdb.floating}},
348 update = function(self)
349 speed = self.inputs.speed.single_value
351 volume = (speed - 144.0) / 7.0
355 diff = volume - self.oldvolume
356 if (diff*diff > self.inputs.param) then
357 print("*** element "..self.name.." update "..volume)
358 self.oldvolume = volume
359 mdb.table.speedvol:replace({zone = "driver", device = "speakers", value = volume})
367 columns = { "state" },
371 -- Night mode processing chain
374 name = "exterior_brightness",
375 table = "amb_exterior_brightness",
376 columns = { "value" },
377 condition = "key = 'ExteriorBrightness'"
382 inputs = { brightness = mdb.select.exterior_brightness },
386 name = "amb_nightmode",
390 { "id", mdb.unsigned },
391 { "night_mode", mdb.unsigned }
395 update = function(self)
396 -- This is a trivial function to calculate night mode. Later, we will
397 -- need a better threshold value and hysteresis to prevent oscillation.
399 brightness = self.inputs.brightness.single_value
401 if not brightness then
405 print("*** element "..self.name.." update brightness: "..brightness)
407 if brightness > 300 then
413 print("*** resulting mode: ".. mode)
415 if not (mode == self.oldmode) then
416 mdb.table.amb_nightmode:replace({ id = 0, night_mode = mode })
424 name = "select_night_mode",
425 table = "amb_nightmode",
426 columns = { "night_mode" },
433 inputs = { NightMode = mdb.select.select_night_mode,
434 amb_state = mdb.select.amb_state },
435 property = "NightMode",
437 initiate = builtin.method.amb_initiate,
438 update = builtin.method.amb_update
442 -- Night mode general handlers
444 if with_system_controller then
446 name = "nightmode_homescreen",
447 inputs = { owner = mdb.select.select_night_mode },
448 initiate = function(self)
449 -- data = mdb.select.select_night_mode.single_value
452 update = function(self)
453 send_night_mode_to(homescreen)
458 -- Driving mode processing chain
461 name = "drivingmode",
462 inputs = { speed = mdb.select.vehicle_speed },
466 name = "amb_drivingmode",
470 { "id", mdb.unsigned },
471 { "driving_mode", mdb.unsigned }
475 update = function(self)
477 speed = self.inputs.speed.single_value
489 if not (mode == self.oldmode) then
490 mdb.table.amb_drivingmode:replace({ id = 0, driving_mode = mode })
498 name = "select_driving_mode",
499 table = "amb_drivingmode",
500 columns = { "driving_mode" },
506 name = "driving_mode",
507 inputs = { DrivingMode = mdb.select.select_driving_mode,
508 amb_state = mdb.select.amb_state },
509 property = "DrivingMode",
511 initiate = builtin.method.amb_initiate,
512 update = builtin.method.amb_update
516 -- turn signals (left, right)
520 table = "amb_turn_signal",
521 columns = { "value" },
522 condition = "key = 'TurnSignal'"
525 -- define three categories
528 name = "undefined_applications",
529 table = "aul_applications",
530 columns = { "appid" },
531 condition = "category = '<undefined>'"
535 name = "basic_applications",
536 table = "aul_applications",
537 columns = { "appid" },
538 condition = "category = 'basic'"
542 name = "entertainment_applications",
543 table = "aul_applications",
544 columns = { "appid" },
545 condition = "category = 'entertainment'"
549 -- filter the object garbage out of the tables
552 for k,v in pairs(t) do
553 if k ~= "userdata" and k ~= "new" then
561 function getApplication(appid)
564 -- find the correct local application definition
566 for k,v in pairs(ft(application)) do
567 if appid == v.appid then
576 function regulateApplications(t, regulation)
577 for k,v in pairs(ft(t)) do
579 -- iterate through the undefined and entertainment apps, see if
580 -- they have been overruled in local config
582 local conf = getApplication(v.appid)
584 if conf and conf.resource_class ~= "player" then
585 -- override, don't disable
586 resmgr:disable_screen_by_appid("*", "*", v.appid, false, false)
588 resmgr:disable_screen_by_appid("*", "*", v.appid, regulation == 1, false)
591 resource.method.recalc("driver")
594 -- regulation (on), use "select_driving_mode"
597 name = "driving_regulation",
598 inputs = { owner = mdb.select.select_driving_mode },
599 initiate = function(self)
600 -- local data = mdb.select.select_driving_mode.single_value
603 update = function(self)
604 local data = mdb.select.select_driving_mode.single_value
607 print("Driving mode updated: " .. tostring(data))
614 -- tell homescreen that driving mode was updated
615 send_driving_mode_to(homescreen)
617 regulateApplications(ft(mdb.select.entertainment_applications), data)
618 regulateApplications(ft(mdb.select.undefined_applications), data)
625 name = "regulated_app_change",
626 inputs = { undef = mdb.select.undefined_applications,
627 entertainment = mdb.select.entertainment_applications },
628 initiate = function(self)
631 update = function(self)
632 local data = mdb.select.select_driving_mode.single_value
639 print("regulated application list was changed")
642 regulateApplications(ft(mdb.select.entertainment_applications), data)
643 regulateApplications(ft(mdb.select.undefined_applications), data)
650 -- shift position (parking, reverse, other)
653 name = "gear_position",
654 table = "amb_gear_position",
655 columns = { "value" },
656 condition = "key = 'GearPosition'"
659 -- cameras (back, front, left, right)
662 name = "camera_state",
663 inputs = { winker = mdb.select.winker, gear = mdb.select.gear_position },
667 name = "target_camera_state",
671 { "id", mdb.unsigned },
672 { "front_camera", mdb.unsigned },
673 { "back_camera", mdb.unsigned },
674 { "right_camera", mdb.unsigned },
675 { "left_camera", mdb.unsigned }
679 update = function(self)
686 if self.inputs.gear == 128 then
688 elseif self.inputs.winker == 1 then
690 elseif self.inputs.winker == 2 then
694 mdb.table.target_camera_state:replace({ id = 0, front_camera = front_camera, back_camera = back_camera, right_camera = right_camera, left_camera = left_camera })
699 -- system controller test setup
701 if not with_system_controller then
702 -- ok, we should have 'audio_playback' defined by now
703 m:try_load_plugin('telephony')
707 m:load_plugin('system-controller')
711 window_manager_operation_names = {
716 function window_manager_operation_name(oper)
717 local name = window_manager_operation_names[oper]
718 if name then return name end
719 return "<unknown " .. tostring(oper) .. ">"
722 window_operation_names = {
733 function window_operation_name(oper)
734 local name = window_operation_names[oper]
735 if name then return name end
736 return "<unknown " .. tostring(oper) .. ">"
739 layer_operation_names = {
745 function layer_operation_name(oper)
746 local name = layer_operation_names[oper]
747 if name then return name end
748 return "<unknown " .. tostring(oper) .. ">"
751 input_manager_operation_names = {
757 function input_manager_operation_name(oper)
758 local name = input_manager_operation_names[oper]
759 if name then return name end
760 return "<unknown " .. tostring(oper) .. ">"
763 input_operation_names = {
769 function input_operation_name(oper)
770 local name = input_operation_names[oper]
771 if name then return name end
772 return "<unknown " .. tostring(oper) .. ">"
775 code_operation_names = {
781 function code_operation_name(oper)
782 local name = code_operation_names[oper]
783 if name then return name end
784 return "<unknown " .. tostring(oper) .. ">"
788 [0x00001] = "send_appid",
789 [0x10001] = "create",
790 [0x10002] = "destroy",
794 [0x10006] = "animation",
795 [0x10007] = "change_active",
796 [0x10008] = "change_layer",
797 [0x10009] = "change_attr",
799 [0x10020] = "map_thumb",
800 [0x10021] = "unmap_thumb",
801 [0x10022] = "map_get",
802 [0x10030] = "show layer",
803 [0x10031] = "hide_layer",
804 [0x10032] = "change_layer_attr",
805 [0x20001] = "add_input",
806 [0x20002] = "del_input",
807 [0x30001] = "change_user",
808 [0x30002] = "get_userlist",
809 [0x30003] = "get_lastinfo",
810 [0x30004] = "set_lastinfo",
811 [0x40001] = "acquire_res",
812 [0x40002] = "release_res",
813 [0x40003] = "deprive_res",
814 [0x40004] = "waiting_res",
815 [0x40005] = "revert_res",
816 [0x40006] = "window_id_res",
817 [0x40011] = "create_res",
818 [0x40012] = "destroy_res",
819 [0x50001] = "set_region",
820 [0x50002] = "unset_region",
821 [0x60001] = "change_state"
824 function command_name(command)
825 local name = command_names[command]
826 if name then return name end
827 return "<unknown " .. tostring(command) .. ">"
831 [101] = true, -- input
832 [102] = true, -- touch
833 [103] = true -- cursor
836 -- some day this should be merged with wmgr.layers
838 [1] = 0x1000, -- background
839 [2] = 0x2000, -- application
840 [3] = 0x2000, -- homescreen
841 [4] = 0x2000, -- interrupt application
842 [5] = 0x2000, -- onscreen application
843 [6] = 0xc000, -- startup
844 [7] = 0x3000, -- fullscreen
845 [101] = 0x4000, -- input
846 [102] = 0xa000, -- touch
847 [103] = 0xb000 -- cursor
850 resmgr = resource_manager {
851 screen_event_handler = function(self, ev)
852 local event = ev.event
853 local surface = ev.surface
855 if event == "init" then
857 print("*** init screen resource allocation -- disable all 'player'")
859 resmgr:disable_audio_by_appid("*", "player", "*", true, false)
860 elseif event == "preallocate" then
862 print("*** preallocate screen resource "..
863 "for '" .. ev.appid .. "' -- enable 'player', if any")
865 resmgr:disable_audio_by_appid("*", "player", ev.appid, false, false)
866 elseif event == "grant" then
868 print("*** make visible surface "..surface)
870 local a = animation({})
871 local r = m:JSON({surface = surface,
874 if ev.appid == onscreen then
875 onscreen_counter = onscreen_counter + 1
876 wmgr:layer_request(m:JSON({layer = 5, visible = 1}))
879 wmgr:window_request(r,a,0)
880 elseif event == "revoke" then
882 print("*** hide surface "..surface)
884 local a = animation({})
885 local r = m:JSON({surface = ev.surface,
887 if ev.appid == onscreen then
888 onscreen_counter = onscreen_counter - 1
889 if onscreen_counter <= 0 then
891 wmgr:layer_request(m:JSON({layer = 5, visible = 0}))
894 wmgr:window_request(r,a,0)
896 elseif event == "create" then
899 print("*** screen resource event: " ..
903 local regulation = mdb.select.select_driving_mode.single_value
905 if regulation == 1 then
907 local blacklisted = false
909 -- applications which have their category set to "entertainment"
910 -- or "undefined" are blacklisted, meaning they should be regulated
912 for i,v in pairs(ft(mdb.select.undefined_applications)) do
913 if v.appid == ev.appid then
915 print(ev.appid .. " was blacklisted (undefined)")
922 if not blacklisted then
923 for i,v in pairs(ft(mdb.select.entertainment_applications)) do
924 if v.appid == ev.appid then
926 print(ev.appid .. " was blacklisted (entertainment)")
934 -- our local application config, which takes precedence
935 local conf = getApplication(ev.appid)
937 -- disable only non-whitelisted applications
938 if not conf or conf.resource_class == "player" then
941 print("disabling screen for " .. ev.appid)
943 resmgr:disable_screen_by_appid("*", "*", ev.appid, true, true)
948 elseif event == "destroy" then
950 print("*** screen resource event: " ..
955 print("*** screen resource event: " ..
960 audio_event_handler = function(self, ev)
961 local event = ev.event
962 local appid = ev.appid
963 local audioid = ev.audioid
965 if event == "grant" then
967 print("*** grant audio to "..appid..
968 " ("..audioid..") in '" ..
971 elseif event == "revoke" then
973 print("*** revoke audio from "..appid..
974 " ("..audioid..") in '" ..
979 print("*** audio resource event: " ..
986 resclnt = resource_client {}
988 wmgr = window_manager {
989 geometry = function(self, w,h, v)
990 if type(v) == "function" then
996 application = function(self, appid)
998 local app = application_lookup(appid)
1000 app = application_lookup("default")
1004 return { privileges = {screen="none", audio="none"} }
1007 output_order = { 1, 0 },
1009 outputs = { { name = "Mid",
1016 width = function(w,h) return w end,
1017 height = function(w,h) return h end
1024 height = function(w,h) return h end
1028 pos_x = function(w,h) return w-320 end,
1031 height = function(w,h) return h end
1038 areas = { Status = {
1042 width = function(w,h) return w end,
1049 width = function(w,h) return w end,
1050 height = function(w,h) return h-64-128 end
1056 width = function(w,h) return w end,
1057 height = function(w,h) return (h-64-128)/2 end
1062 pos_y = function(w,h) return (h-64-128)/2+64 end,
1063 width = function(w,h) return w end,
1064 height = function(w,h) return (h-64-128)/2 end
1070 width = function(w,h) return w/2 end,
1071 height = function(w,h) return (h-64-128)/2 end
1075 pos_x = function(w,h) return w/2 end,
1077 width = function(w,h) return w/2 end,
1078 height = function(w,h) return (h-64-128)/2 end
1083 pos_y = function(w,h) return (h-64-128/2)+64 end,
1084 width = function(w,h) return w/2 end,
1085 height = function(w,h) return (h-64-128)/2 end
1089 pos_x = function(w,h) return w/2 end,
1090 pos_y = function(w,h) return (h-64-128/2)+64 end,
1091 width = function(w,h) return w/2 end,
1092 height = function(w,h) return (h-64-128)/2 end
1098 width = function(w,h) return w end,
1099 height = function(w,h) return h-64-128 end
1105 width = function(w,h) return w/2-181 end,
1106 height = function(w,h) return h-64-128 end
1108 ["SysApp.Right"] = {
1110 pos_x = function(w,h) return w/2+181 end,
1112 width = function(w,h) return w/2-181 end,
1113 height = function(w,h) return h-64-128 end
1119 width = function(w,h) return w end,
1120 height = function(w,h) return h-64-128 end
1126 width = function(w,h) return w end,
1127 height = function(w,h) return (h-64-128)/2 end
1132 pos_y = function(w,h) return (h-64-128)/2+64 end,
1133 width = function(w,h) return w end,
1134 height = function(w,h) return (h-64-128)/2 end
1139 pos_y = function(w,h) return h-128 end,
1140 width = function(w,h) return w end,
1146 -- id name type output
1147 layers = { { 0, "BackGround" , 1, "Center" },
1148 { 1, "Application" , 2, "Center" },
1149 { 2, "HomeScreen" , 3, "Center" },
1150 { 3, "ControlBar" , 3, "Center" },
1151 { 4, "InterruptApp" , 4, "Center" },
1152 { 5, "OnScreen" , 5, "Center" },
1153 { 6, "Touch" , 102, "Center" },
1154 { 7, "Cursor" , 103, "Center" }
1158 manager_update = function(self, oper)
1160 print("### <== WINDOW MANAGER UPDATE:" ..
1161 window_manager_operation_name(oper))
1164 local wumask = window_mask { --raise = true,
1167 local wrmask = window_mask { raise = true,
1170 local lumask = layer_mask { visible = true }
1171 local lrmask = layer_mask { visible = true }
1172 local req = m:JSON({
1173 passthrough_window_update = wumask:tointeger(),
1174 passthrough_window_request = wrmask:tointeger(),
1175 passthrough_layer_update = lumask:tointeger(),
1176 passthrough_layer_request = lrmask:tointeger()
1178 self:manager_request(req)
1182 window_update = function(self, oper, win, mask)
1184 print("### <== WINDOW UPDATE oper:" ..
1185 window_operation_name(oper) ..
1186 " mask: " .. tostring(mask))
1192 local arg = m:JSON({ surface = win.surface,
1197 if oper == 1 then -- create
1198 local layertype = win.layertype
1199 if layertype and input_layer[layertype] then
1201 print("ignoring input panel creation")
1206 elseif oper == 2 then -- destroy
1208 elseif oper == 3 then -- namechange
1210 elseif oper == 4 or oper == 5 then -- visible/configure
1214 if win.layertype then
1215 arg.layertype = win.layertype
1217 arg.layer = win.layer
1218 arg.pos_x = win.pos_x
1219 arg.pos_y = win.pos_y
1220 arg.width = win.width
1221 arg.height = win.height
1222 arg.raise = win.raise
1223 arg.visible = win.visible
1224 if win.active == 0 then
1229 elseif oper == 6 then -- active
1230 if win.active == 0 then
1232 print("ignoring inactive event")
1237 elseif oper == 7 then -- map
1242 if win.mapped == 0 then
1248 --arg.name = map.target
1249 arg.width = map.width
1250 arg.height = map.height
1251 arg.stride = map.stride
1252 arg.format = map.format
1255 print("### nothing to do")
1260 local msg = m:JSON({ command = command,
1266 print("### <== sending " ..
1267 command_name(msg.command) ..
1268 " window message to '" .. homescreen .. "'")
1273 sc:send_message(homescreen, msg)
1275 if oper == 1 then -- create
1276 local i = input_layer[win.layertype]
1277 local p = self:application(win.appid)
1278 local s = p.privileges.screen
1280 if s == "system" then
1281 local a = animation({})
1282 local r = m:JSON({surface = win.surface,
1285 self:window_request(r,a,0)
1289 print("do not make resource for " ..
1293 resclnt:resource_set_create("screen",
1297 special_screen_sets[win.surface] = true
1301 if onscreen and win.appid == onscreen then
1302 local resmsg = m:JSON({
1303 command = 0x40006, -- window_id_res
1315 resourceId = win.surface
1320 print("### <== sending " ..
1321 command_name(resmsg.command) ..
1322 " message to '" .. onscreen .. "'")
1327 sc:send_message(onscreen, resmsg);
1329 elseif oper == 2 then -- destroy
1330 resclnt:resource_set_destroy("screen", win.surface)
1331 special_screen_sets[win.surface] = nil
1332 elseif oper == 6 then -- active
1334 local i = input_layer[win.layertype]
1335 local p = self:application(win.appid)
1336 local s = p.privileges.screen
1337 local surface = win.surface
1338 if not i and s ~= "system" then
1339 resclnt:resource_set_acquire("screen",surface)
1340 resmgr:window_raise(win.appid, surface, 1)
1346 layer_update = function(self, oper, layer, mask)
1348 print("### LAYER UPDATE:" ..
1349 layer_operation_name(oper) ..
1350 " mask: " .. tostring(mask))
1355 if oper == 3 then -- visible
1356 local command = 0x10008 -- change_layer
1357 local msg = m:JSON({
1360 arg = m:JSON({layer = layer.id,
1361 visible = layer.visible
1365 print("### <== sending "..command_name(command)..
1371 sc:send_message(homescreen, msg)
1374 print("### nothing to do")
1379 output_update = function(self, oper, out, mask)
1380 local idx = out.index
1381 local defidx = self.output_order[idx+1]
1383 print("### OUTPUT UPDATE:" .. oper ..
1384 " mask: "..tostring(mask))
1390 local outdef = self.outputs[defidx+1]
1391 if (oper == 1) then -- create
1393 self:output_request(m:JSON({index = idx,
1398 elseif (oper == 5) then -- done
1399 local ads = outdef.areas
1400 local on = outdef.name
1402 for name,ad in pairs(ads) do
1403 local can = wmgr:canonical_name(on.."."..name)
1404 local a = m:JSON({name = name,
1405 output = out.index})
1406 for fld,val in pairs(ad) do
1407 a[fld] = self:geometry(out.width,
1412 resmgr:area_create(area[can], outdef.zone)
1420 imgr = input_manager {
1421 inputs = {{ name = "G27 Racing Wheel",
1423 switch = { [2] = {appid="org.tizen.ico.app-soundsample" },
1424 [3] = {appid="org.tizen.ico.homescreen", keycode=1},
1425 [4] = {appid="org.tizen.ico.app-soundsample" },
1426 [5] = {appid="org.tizen.ico.homescreen", keycode=2}
1430 manager_update = function(self, oper)
1432 print("### <== INPUT MANAGER UPDATE:" ..
1433 input_manager_operation_name(oper))
1437 input_update = function(self, oper, inp, mask)
1439 print("### INPUT UPDATE:" ..
1440 input_operation_name(oper) ..
1441 " mask: " .. tostring(mask))
1447 code_update = function(self, oper, code, mask)
1449 print("### CODE UPDATE: mask: " .. tostring(mask))
1454 local msg = m:JSON({ command = 1,
1455 appid = "org.tizen.ico.homescreen",
1456 arg = m:JSON({ device = code.device,
1464 print("### <== sending " ..
1465 command_name(msg.command) ..
1471 sc:send_message(homescreen, msg)
1475 sc = m:get_system_controller()
1480 -- special screen resource sets
1481 -- TODO: just rewrite screen resource handling to use regular resource API
1483 special_screen_sets = {}
1486 um = m:UserManager()
1494 -- these shoud be before wmgr:connect() is called
1496 print("====== creating applications ======")
1500 area = "Center.Full",
1501 privileges = { screen = "none", audio = "none" },
1502 resource_class = "player",
1508 area = "Center.Full",
1509 privileges = { screen = "system", audio = "none" },
1510 resource_class = "implicit",
1511 screen_priority = 30
1515 appid = "org.tizen.ico.homescreen",
1516 area = "Center.Full",
1517 windows = { {'ico_hs_controlbarwindow', 'Center.Control'} },
1518 privileges = { screen = "system", audio = "system" },
1519 resource_class = "player",
1520 screen_priority = 20
1524 appid = "org.tizen.ico.statusbar",
1525 area = "Center.Status",
1526 privileges = { screen = "system", audio = "none" },
1527 resource_class = "player",
1528 screen_priority = 20
1532 appid = "org.tizen.ico.onscreen",
1533 area = "Center.Full",
1534 privileges = { screen = "system", audio = "system" },
1535 resource_class = "player",
1536 screen_priority = 20
1540 appid = "org.tizen.ico.login",
1541 area = "Center.Full",
1542 privileges = { screen = "system", audio = "system" },
1543 resource_class = "player",
1544 screen_priority = 20
1548 appid = "org.tizen.ico.camera_left",
1549 area = "Center.SysApp.Left",
1550 privileges = { screen = "system", audio = "none" },
1551 requisites = { screen = "blinker_left", audio = "none" },
1552 resource_class = "player",
1553 screen_priority = 30
1557 appid = "org.tizen.ico.camera_right",
1558 area = "Center.SysApp.Right",
1559 privileges = { screen = "system", audio = "none" },
1560 requisites = { screen = "blinker_right", audio = "none" },
1561 resource_class = "player",
1562 screen_priority = 30
1566 appid = "net.zmap.navi",
1567 area = "Center.Full",
1568 privileges = { screen = "none", audio = "none" },
1569 resource_class = "navigator",
1570 screen_priority = 30
1574 appid = "GV3ySIINq7.GhostCluster",
1575 area = "Center.Full",
1576 privileges = { screen = "none", audio = "none" },
1577 resource_class = "system",
1578 screen_priority = 30
1582 sc.client_handler = function (self, cid, msg)
1583 local command = msg.command
1584 local appid = msg.appid
1586 print('### ==> client handler:')
1592 -- known commands: 1 for SEND_APPID, synthetic command 0xFFFF for
1595 if command == 0xFFFF then
1597 print('client ' .. cid .. ' disconnected')
1599 if msg.appid == homescreen then
1601 for i,v in pairs(special_screen_sets) do
1602 resclnt:resource_set_destroy("screen", i)
1603 special_screen_sets[i] = nil
1609 -- handle the connection to weston
1612 if appid == "org.tizen.ico.homescreen" then
1613 print('Setting homescreen='..appid)
1615 if command and command == 1 then
1616 send_driving_mode_to(homescreen)
1617 send_night_mode_to(homescreen)
1619 elseif appid == "org.tizen.ico.onscreen" then
1621 if command and command == 1 then
1622 send_driving_mode_to(onscreen)
1623 send_night_mode_to(onscreen)
1627 if not connected and appid == "org.tizen.ico.homescreen" then
1628 print('Trying to connect to weston...')
1629 connected = wmgr:connect()
1635 sc.generic_handler = function (self, cid, msg)
1637 print('### ==> generic handler:')
1644 sc.window_handler = function (self, cid, msg)
1646 print('### ==> received ' ..
1647 command_name(msg.command) .. ' message from ' .. cids[cid])
1649 print(tostring(msg))
1653 local a = animation({})
1655 if msg.command == 0x10003 then -- ico SHOW command
1656 local raise_mask = 0x01000000
1657 local lower_mask = 0x02000000
1658 local nores_mask = 0x40000000
1659 local time_mask = 0x00ffffff
1663 if msg.arg.anim_time then
1664 local t = msg.arg.anim_time
1665 time = m:AND(t, time_mask)
1666 nores = not m:AND(t, nores_mask)
1667 if m:AND(t, raise_mask) then
1669 elseif m:AND(t, lower_mask) then
1673 if msg.arg.anim_name then
1674 a.show = { msg.arg.anim_name, time }
1675 print('time: ' .. tostring(time))
1679 local p = wmgr:application(msg.appid)
1680 local s = p.privileges.screen
1681 if s == "system" then
1683 if not msg.arg.raise then
1689 print('### ==> SHOW')
1690 print(tostring(msg.arg))
1693 wmgr:window_request(msg.arg, a, 0)
1695 local surface = msg.arg.surface
1696 resclnt:resource_set_acquire("screen", surface)
1697 resmgr:window_raise(msg.appid, surface, 1)
1699 elseif msg.command == 0x10004 then -- ico HIDE command
1700 local raise_mask = 0x01000000
1701 local lower_mask = 0x02000000
1702 local nores_mask = 0x40000000
1703 local time_mask = 0x00ffffff
1707 if msg.arg.anim_time then
1708 local t = msg.arg.anim_time
1709 time = m:AND(t, time_mask)
1710 nores = not m:AND(t, nores_mask)
1712 if msg.arg.anim_name then
1713 a.hide = { msg.arg.anim_name, time }
1714 print('hide animation time: ' .. tostring(a.hide[2]))
1718 local p = wmgr:application(msg.appid)
1719 local s = p.privileges.screen
1720 if s == "system" then
1726 print('### ==> HIDE REQUEST')
1727 print(tostring(msg.arg))
1730 wmgr:window_request(msg.arg, a, 0)
1732 resmgr:window_raise(msg.appid, msg.arg.surface, -1)
1734 elseif msg.command == 0x10005 then -- ico MOVE
1736 print('### ==> MOVE REQUEST')
1737 print(tostring(msg.arg))
1739 if msg.arg.zone then
1740 msg.arg.area = msg.arg.zone
1742 wmgr:window_request(msg.arg, a, 0)
1743 -- TODO: handle if area changed
1744 elseif msg.command == 0x10007 then -- ico CHANGE_ACTIVE
1745 if not msg.arg.active then
1746 msg.arg.active = 3 -- pointer + keyboard
1749 print('### ==> CHANGE_ACTIVE REQUEST')
1750 print(tostring(msg.arg))
1752 wmgr:window_request(msg.arg, a, 0)
1753 elseif msg.command == 0x10008 then -- ico CHANGE_LAYER
1755 print('### ==> CHANGE_LAYER REQUEST')
1756 print(tostring(msg.arg))
1759 if msg.arg.layer ~= 4 or msg.arg.layer ~= 5 then
1760 print("do not change layer for other than cursor or touch")
1764 wmgr:window_request(msg.arg, a, 0)
1765 elseif msg.command == 0x10020 then -- ico MAP_THUMB
1766 local framerate = msg.arg.framerate
1767 local animname = msg.arg.anim_name
1769 a.map = { animname, 1 }
1770 if not framerate or framerate < 0 then
1775 print('### ==> MAP_THUMB REQUEST')
1777 print('framerate: '..framerate)
1779 wmgr:window_request(msg.arg, a, framerate)
1781 elseif msg.command == 0x10021 then -- ico UNMAP_THUMB
1784 print('### ==> UNMAP_THUMB REQUEST')
1787 wmgr:window_request(msg.arg, a, 0)
1789 elseif msg.command == 0x10013 then -- ico MAP_BUFFER command
1790 local shmname = msg.arg.anim_name
1791 local bufsize = msg.arg.width
1792 local bufnum = msg.arg.height
1793 if shmname and bufsize and bufnum then
1795 print('### ==> MAP_BUFFER REQUEST')
1796 print("shmaname='" .. shmname ..
1797 "' bufsize='" .. bufsize ..
1798 " bufnum=" .. bufnum)
1800 wmgr:buffer_request(shmname, bufsize, bufnum)
1803 elseif msg.command == 0x10030 then -- ico SHOW_LAYER command
1806 print('### ==> SHOW_LAYER REQUEST')
1809 wmgr:layer_request(msg.arg)
1810 elseif msg.command == 0x10031 then -- ico HIDE_LAYER command
1813 print('### ==> HIDE_LAYER REQUEST')
1816 wmgr:layer_request(msg.arg)
1820 sc.input_handler = function (self, cid, msg)
1822 print('### ==> input handler: ' .. command_name(msg.command))
1827 if msg.command == 0x20001 then -- add_input
1828 msg.arg.appid = msg.appid
1830 print('### ==> ADD_INPUT REQUEST')
1831 print(tostring(msg.arg))
1833 imgr:input_request(msg.arg)
1834 elseif msg.command == 0x20002 then -- del_input
1837 print('### ==> DEL_INPUT REQUEST')
1838 print(tostring(msg.arg))
1840 imgr:input_request(msg.arg)
1841 -- elseif msg.command == 0x20003 then -- send_input
1845 sc.user_handler = function (self, cid, msg)
1847 print('### ==> user handler: ' .. command_name(msg.command))
1854 print("User Manager not initialized")
1858 if msg.command == 0x30001 then -- change_user
1859 print("command CHANGE_USER")
1861 print("invalid message")
1865 username = msg.arg.user
1866 passwd = msg.arg.pass
1868 if not username then
1876 success = um:changeUser(username, passwd)
1883 if sc:send_message(msg.appid, reply) then
1884 print('*** sent authentication failed message')
1886 print('*** failed to send authentication failed message')
1890 elseif msg.command == 0x30002 then -- get_userlist
1891 print("command GET_USERLIST")
1892 if not msg.appid then
1893 print("invalid message")
1897 users, currentUser = um:getUserList()
1900 print("failed to get user list")
1906 for i,v in pairs(users) do
1910 if not currentUser then
1915 print("current user: " .. currentUser)
1917 for i,v in pairs(users) do
1928 user_login = currentUser
1933 print("### <== GetUserList reply: " .. tostring(reply))
1936 if sc:send_message(msg.appid, reply) then
1937 print('*** reply OK')
1939 print('*** reply FAILED')
1942 elseif msg.command == 0x30003 then -- get_lastinfo
1943 print("command GET_LASTINFO")
1944 if not msg.appid then
1945 print("invalid message")
1949 lastInfo = um:getLastInfo(msg.appid)
1951 if not lastInfo then
1952 print("failed to get last info for app" .. msg.appid)
1964 if sc:send_message(msg.appid, reply) then
1965 print('*** reply OK')
1967 print('*** reply FAILED')
1970 elseif msg.command == 0x30004 then -- set_lastinfo
1971 print("command SET_LASTINFO")
1972 if not msg.arg or not msg.appid then
1973 print("invalid message")
1977 lastInfo = um:setLastInfo(msg.appid, msg.arg.lastinfo)
1981 sc.resource_handler = function (self, cid, msg)
1983 print('### ==> resource handler: ' .. command_name(msg.command))
1989 getKey = function (msg)
1990 -- Field rset.key is an id for distinguishing between rsets. All
1991 -- resource types appear to contain a different key. Just pick one
1992 -- based on what we have on the message.
1996 if msg and msg.res then
1997 if msg.res.sound then
1998 key = msg.res.sound.id
1999 elseif msg.res.input then
2000 key = msg.res.input.name
2001 elseif msg.res.window then
2002 key = msg.res.window.resourceId
2009 createResourceSet = function (ctl, client, msg)
2010 cb = function(rset, data)
2012 -- m:info("*** resource_cb: client = '" .. msg.appid .. "'")
2014 -- type is either basic (0) or interrupt (1)
2016 if msg.res.type then
2017 requestType = msg.res.type
2020 if data.filter_first then
2021 data.filter_first = false
2025 if rset.acquired then
2026 cmd = 0x00040001 -- acquire
2028 if msg.appid == onscreen then
2029 -- notifications are valid only for a number of seconds
2030 rset.timer = m:Timer({
2033 callback = function (t, data)
2034 m:info("notification resource set timer expired")
2036 -- destroy the internal resource set
2040 -- Send a "RELEASE" message to client.
2041 -- This triggers the resource deletion
2042 -- cycle in OnScreen.
2052 if rset.data.window then
2053 reply.res.window = rset.data.window
2056 sc:send_message(client, reply)
2061 cmd = 0x00040002 -- release
2063 rset.timer.callback = nil
2075 if rset.data.sound then
2076 reply.res.sound = rset.data.sound
2079 if rset.data.window then
2080 reply.res.window = rset.data.window
2083 if rset.data.input then
2084 reply.res.input = rset.data.input
2087 if rset.acquired then
2088 m:info("resource cb: 'acquire' reply to client " .. client)
2090 m:info("resource cb: 'release' reply to client " .. client)
2093 if not sc:send_message(client, reply) then
2094 m:info('*** reply FAILED')
2098 rset = m:ResourceSet({
2099 application_class = "player",
2100 zone = "driver", -- msg.zone ("full")
2110 if msg.res.sound then
2112 resource_name = "audio_playback"
2114 rset.resources.audio_playback.attributes.pid = tostring(msg.pid)
2115 rset.resources.audio_playback.attributes.appid = msg.appid
2116 print("sound name: " .. msg.res.sound.name)
2117 print("sound zone:" .. msg.res.sound.zone)
2118 print("sound adjust: " .. tostring(msg.res.sound.adjust))
2120 rset.data.sound = msg.res.sound
2123 if msg.res.input then
2125 resource_name = "input"
2127 rset.resources.input.attributes.pid = tostring(msg.pid)
2128 rset.resources.input.attributes.appid = msg.appid
2129 print("input name: " .. msg.res.input.name)
2130 print("input event:" .. tostring(msg.res.input.event))
2132 rset.data.input = msg.res.input
2135 if msg.res.window then
2137 resource_name = "screen",
2140 rset.resources.screen.attributes.pid = tostring(msg.pid)
2141 rset.resources.screen.attributes.appid = msg.appid
2142 rset.resources.screen.attributes.surface = msg.res.window.resourceId
2143 complete_area = msg.res.window.display .. '.' .. msg.res.window.area
2144 rset.resources.screen.attributes.area = complete_area
2145 if msg.appid == onscreen then
2146 rset.resources.screen.attributes.classpri = 1
2148 rset.resources.screen.attributes.classpri = 0
2151 rset.data.window = msg.res.window
2154 rset.key = getKey(msg)
2159 -- parse the message
2161 -- fields common to all messages:
2166 if msg.command == 0x40011 then -- create_res
2167 print("command CREATE_RES")
2171 if not sets.cid then
2174 sets.cid.key = createResourceSet(self, cid, msg)
2177 elseif msg.command == 0x40012 then -- destroy_res
2178 print("command DESTROY_RES")
2182 if sets.cid and sets.cid[key] then
2183 sets.cid[key]:release()
2184 sets.cid[key] = nil -- garbage collecting
2188 elseif msg.command == 0x40001 then -- acquire_res
2189 print("command ACQUIRE_RES")
2193 print("key is " .. tostring(key))
2194 if not sets.cid then
2197 if not sets.cid[key] then
2198 print("creating a resource set")
2199 sets.cid[key] = createResourceSet(self, cid, msg)
2201 print("acquiring the resource set")
2202 sets.cid[key]:acquire()
2205 elseif msg.command == 0x40002 then -- release_res
2206 print("command RELEASE_RES")
2211 if sets.cid and sets.cid[key] then
2212 sets.cid[key]:release()
2215 if msg.appid == onscreen then
2216 -- in case of OnScreen, this actually means that the
2217 -- resource set is never used again; let gc do its job
2218 if sets.cid and sets.cid[key] then
2219 sets.cid[key] = nil -- garbage collecting
2226 elseif msg.command == 0x40003 then -- deprive_res
2227 print("command DEPRIVE_RES")
2229 elseif msg.command == 0x40004 then -- waiting_res
2230 print("command WAITING_RES")
2232 elseif msg.command == 0x40005 then -- revert_res
2233 print("command REVERT_RES")
2237 sc.inputdev_handler = function (self, cid, msg)
2239 print('*** inputdev handler: ' .. command_name(msg.command))
2246 sc.notify_handler = function (self, cid, msg)
2248 print('### notify handler: ' .. command_name(msg.command))
2256 function send_driving_mode_to(client)
2257 if client == "" then
2261 local driving_mode = mdb.select.select_driving_mode.single_value
2263 if not driving_mode then driving_mode = 0 end
2265 local reply = m:JSON({ command = 0x60001,
2266 arg = m:JSON({ stateid = 1,
2267 state = driving_mode
2272 print("### <== sending " .. command_name(reply.command) .. " message")
2278 sc:send_message(client, reply)
2281 function send_night_mode_to(client)
2282 if client == "" then
2286 local night_mode = mdb.select.select_night_mode.single_value
2288 if not night_mode then night_mode = 0 end
2290 local reply = m:JSON({ command = 0x60001,
2291 arg = m:JSON({ stateid = 2,
2297 print("### <== sending " .. command_name(reply.command) .. " message")
2303 sc:send_message(client, reply)
2306 -- we should have 'audio_playback' defined by now
2307 m:try_load_plugin('telephony')