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" },
261 name = { mdb.string, "<unknown>", "rw" },
266 if not m:plugin_exists('gam-resource-manager') then
268 name = "audio_recording",
271 role = { mdb.string, "music" , "rw" },
272 pid = { mdb.string, "<unknown>", "rw" },
273 policy = { mdb.string, "relaxed" , "rw" },
274 name = { mdb.string, "<unknown>", "rw" },
280 name = "video_playback",
285 name = "video_recording",
290 name = "speech_recognition",
295 name = "speech_synthesis",
299 -- PulseAudio volume context
301 name = "volume_context",
305 { "id", mdb.unsigned },
306 { "value", mdb.string, 64 },
310 -- put default volume context to the table
311 mdb.table.volume_context:insert({ id = 1, value = "default" })
313 if not m:plugin_exists('ivi-resource-manager') and
314 not with_system_controller
316 resource.method.veto = {
317 function(zone, rset, grant, owners, req_set)
323 -- test for creating selections
325 name = "audio_owner",
326 table = "audio_playback_owner",
327 columns = {"application_class"},
328 condition = "zone_name = 'driver'"
332 name = "vehicle_speed",
333 table = "amb_vehicle_speed",
335 condition = "key = 'VehicleSpeed'"
339 name = "speed2volume",
340 inputs = { speed = mdb.select.vehicle_speed, param = 9 },
341 outputs = { mdb.table { name = "speedvol",
342 index = {"zone", "device"},
343 columns = {{"zone", mdb.string, 16},
344 {"device", mdb.string, 16},
345 {"value", mdb.floating}},
350 update = function(self)
351 speed = self.inputs.speed.single_value
353 volume = (speed - 144.0) / 7.0
357 diff = volume - self.oldvolume
358 if (diff*diff > self.inputs.param) then
359 print("*** element "..self.name.." update "..volume)
360 self.oldvolume = volume
361 mdb.table.speedvol:replace({zone = "driver", device = "speakers", value = volume})
369 columns = { "state" },
373 -- Night mode processing chain
376 name = "exterior_brightness",
377 table = "amb_exterior_brightness",
378 columns = { "value" },
379 condition = "key = 'ExteriorBrightness'"
384 inputs = { brightness = mdb.select.exterior_brightness },
388 name = "amb_nightmode",
392 { "id", mdb.unsigned },
393 { "night_mode", mdb.unsigned }
397 update = function(self)
398 -- This is a trivial function to calculate night mode. Later, we will
399 -- need a better threshold value and hysteresis to prevent oscillation.
401 brightness = self.inputs.brightness.single_value
403 if not brightness then
407 print("*** element "..self.name.." update brightness: "..brightness)
409 if brightness > 300 then
415 print("*** resulting mode: ".. mode)
417 if not (mode == self.oldmode) then
418 mdb.table.amb_nightmode:replace({ id = 0, night_mode = mode })
426 name = "select_night_mode",
427 table = "amb_nightmode",
428 columns = { "night_mode" },
435 inputs = { NightMode = mdb.select.select_night_mode,
436 amb_state = mdb.select.amb_state },
437 property = "NightMode",
439 initiate = builtin.method.amb_initiate,
440 update = builtin.method.amb_update
444 -- Night mode general handlers
446 if with_system_controller then
448 name = "nightmode_homescreen",
449 inputs = { owner = mdb.select.select_night_mode },
450 initiate = function(self)
451 -- data = mdb.select.select_night_mode.single_value
454 update = function(self)
455 send_night_mode_to(homescreen)
460 -- Driving mode processing chain
463 name = "drivingmode",
464 inputs = { speed = mdb.select.vehicle_speed },
468 name = "amb_drivingmode",
472 { "id", mdb.unsigned },
473 { "driving_mode", mdb.unsigned }
477 update = function(self)
479 speed = self.inputs.speed.single_value
491 if not (mode == self.oldmode) then
492 mdb.table.amb_drivingmode:replace({ id = 0, driving_mode = mode })
500 name = "select_driving_mode",
501 table = "amb_drivingmode",
502 columns = { "driving_mode" },
508 name = "driving_mode",
509 inputs = { DrivingMode = mdb.select.select_driving_mode,
510 amb_state = mdb.select.amb_state },
511 property = "DrivingMode",
513 initiate = builtin.method.amb_initiate,
514 update = builtin.method.amb_update
518 -- turn signals (left, right)
522 table = "amb_turn_signal",
523 columns = { "value" },
524 condition = "key = 'TurnSignal'"
527 -- define three categories
530 name = "undefined_applications",
531 table = "aul_applications",
532 columns = { "appid" },
533 condition = "category = '<undefined>'"
537 name = "basic_applications",
538 table = "aul_applications",
539 columns = { "appid" },
540 condition = "category = 'basic'"
544 name = "entertainment_applications",
545 table = "aul_applications",
546 columns = { "appid" },
547 condition = "category = 'entertainment'"
551 -- filter the object garbage out of the tables
554 for k,v in pairs(t) do
555 if k ~= "userdata" and k ~= "new" then
563 function getApplication(appid)
566 -- find the correct local application definition
568 for k,v in pairs(ft(application)) do
569 if appid == v.appid then
578 function regulateApplications(t, regulation)
579 for k,v in pairs(ft(t)) do
583 -- our local application config, which takes precedence
584 local conf = getApplication(v.appid)
587 if conf.resource_class ~= "player" then
591 if conf.requisites and conf.requisites.screen then
592 if conf.requisites.screen.driving then
599 -- override, don't disable
600 resmgr:disable_screen_by_appid("*", "*", v.appid, false, false)
602 resmgr:disable_screen_by_appid("*", "*", v.appid, regulation == 1, false)
605 resource.method.recalc("driver")
608 -- regulation (on), use "select_driving_mode"
611 name = "driving_regulation",
612 inputs = { owner = mdb.select.select_driving_mode },
613 initiate = function(self)
614 -- local data = mdb.select.select_driving_mode.single_value
617 update = function(self)
618 local data = mdb.select.select_driving_mode.single_value
621 print("Driving mode updated: " .. tostring(data))
628 -- tell homescreen that driving mode was updated
629 send_driving_mode_to(homescreen)
631 regulateApplications(ft(mdb.select.entertainment_applications), data)
632 regulateApplications(ft(mdb.select.undefined_applications), data)
639 name = "regulated_app_change",
640 inputs = { undef = mdb.select.undefined_applications,
641 entertainment = mdb.select.entertainment_applications },
642 initiate = function(self)
645 update = function(self)
646 local data = mdb.select.select_driving_mode.single_value
653 print("regulated application list was changed")
656 regulateApplications(ft(mdb.select.entertainment_applications), data)
657 regulateApplications(ft(mdb.select.undefined_applications), data)
664 -- shift position (parking, reverse, other)
667 name = "gear_position",
668 table = "amb_gear_position",
669 columns = { "value" },
670 condition = "key = 'GearPosition'"
673 -- cameras (back, front, left, right)
676 name = "camera_state",
677 inputs = { winker = mdb.select.winker, gear = mdb.select.gear_position },
681 name = "target_camera_state",
685 { "id", mdb.unsigned },
686 { "front_camera", mdb.unsigned },
687 { "back_camera", mdb.unsigned },
688 { "right_camera", mdb.unsigned },
689 { "left_camera", mdb.unsigned }
693 update = function(self)
700 if self.inputs.gear == 128 then
702 elseif self.inputs.winker == 1 then
704 elseif self.inputs.winker == 2 then
708 mdb.table.target_camera_state:replace({ id = 0, front_camera = front_camera, back_camera = back_camera, right_camera = right_camera, left_camera = left_camera })
713 -- system controller test setup
715 if not with_system_controller then
716 -- ok, we should have 'audio_playback' defined by now
717 m:try_load_plugin('telephony')
721 m:load_plugin('system-controller')
725 window_manager_operation_names = {
730 function window_manager_operation_name(oper)
731 local name = window_manager_operation_names[oper]
732 if name then return name end
733 return "<unknown " .. tostring(oper) .. ">"
736 window_operation_names = {
747 function window_operation_name(oper)
748 local name = window_operation_names[oper]
749 if name then return name end
750 return "<unknown " .. tostring(oper) .. ">"
753 layer_operation_names = {
759 function layer_operation_name(oper)
760 local name = layer_operation_names[oper]
761 if name then return name end
762 return "<unknown " .. tostring(oper) .. ">"
765 input_manager_operation_names = {
771 function input_manager_operation_name(oper)
772 local name = input_manager_operation_names[oper]
773 if name then return name end
774 return "<unknown " .. tostring(oper) .. ">"
777 input_operation_names = {
783 function input_operation_name(oper)
784 local name = input_operation_names[oper]
785 if name then return name end
786 return "<unknown " .. tostring(oper) .. ">"
789 code_operation_names = {
795 function code_operation_name(oper)
796 local name = code_operation_names[oper]
797 if name then return name end
798 return "<unknown " .. tostring(oper) .. ">"
802 [0x00001] = "send_appid",
803 [0x10001] = "create",
804 [0x10002] = "destroy",
808 [0x10006] = "animation",
809 [0x10007] = "change_active",
810 [0x10008] = "change_layer",
811 [0x10009] = "change_attr",
813 [0x10020] = "map_thumb",
814 [0x10021] = "unmap_thumb",
815 [0x10022] = "map_get",
816 [0x10030] = "show layer",
817 [0x10031] = "hide_layer",
818 [0x10032] = "change_layer_attr",
819 [0x20001] = "add_input",
820 [0x20002] = "del_input",
821 [0x30001] = "change_user",
822 [0x30002] = "get_userlist",
823 [0x30003] = "get_lastinfo",
824 [0x30004] = "set_lastinfo",
825 [0x40001] = "acquire_res",
826 [0x40002] = "release_res",
827 [0x40003] = "deprive_res",
828 [0x40004] = "waiting_res",
829 [0x40005] = "revert_res",
830 [0x40006] = "window_id_res",
831 [0x40011] = "create_res",
832 [0x40012] = "destroy_res",
833 [0x50001] = "set_region",
834 [0x50002] = "unset_region",
835 [0x60001] = "change_state"
838 function command_name(command)
839 local name = command_names[command]
840 if name then return name end
841 return "<unknown " .. tostring(command) .. ">"
845 [101] = true, -- input
846 [102] = true, -- touch
847 [103] = true -- cursor
850 -- some day this should be merged with wmgr.layers
852 [1] = 0x1000, -- background
853 [2] = 0x2000, -- application
854 [3] = 0x2000, -- homescreen
855 [4] = 0x2000, -- interrupt application
856 [5] = 0x2000, -- onscreen application
857 [6] = 0xc000, -- startup
858 [7] = 0x3000, -- fullscreen
859 [101] = 0x4000, -- input
860 [102] = 0xa000, -- touch
861 [103] = 0xb000 -- cursor
864 resmgr = resource_manager {
865 screen_event_handler = function(self, ev)
866 local event = ev.event
867 local surface = ev.surface
869 if event == "init" then
871 print("*** init screen resource allocation -- disable all 'player'")
873 resmgr:disable_audio_by_appid("*", "player", "*", true, false)
874 elseif event == "preallocate" then
876 print("*** preallocate screen resource "..
877 "for '" .. ev.appid .. "' -- enable 'player', if any")
879 resmgr:disable_audio_by_appid("*", "player", ev.appid, false, false)
880 elseif event == "grant" then
882 print("*** make visible surface "..surface)
884 local a = animation({})
885 local r = m:JSON({surface = surface,
888 if ev.appid == onscreen then
889 onscreen_counter = onscreen_counter + 1
890 wmgr:layer_request(m:JSON({layer = 5, visible = 1}))
893 wmgr:window_request(r,a,0)
894 elseif event == "revoke" then
896 print("*** hide surface "..surface)
898 local a = animation({})
899 local r = m:JSON({surface = ev.surface,
901 if ev.appid == onscreen then
902 onscreen_counter = onscreen_counter - 1
903 if onscreen_counter <= 0 then
905 wmgr:layer_request(m:JSON({layer = 5, visible = 0}))
908 wmgr:window_request(r,a,0)
910 elseif event == "create" then
913 print("*** screen resource event: " ..
917 local regulation = mdb.select.select_driving_mode.single_value
919 if regulation == 1 then
921 local blacklisted = false
923 -- applications which have their category set to "entertainment"
924 -- or "undefined" are blacklisted, meaning they should be regulated
926 for i,v in pairs(ft(mdb.select.undefined_applications)) do
927 if v.appid == ev.appid then
929 print(ev.appid .. " was blacklisted (undefined)")
936 if not blacklisted then
937 for i,v in pairs(ft(mdb.select.entertainment_applications)) do
938 if v.appid == ev.appid then
940 print(ev.appid .. " was blacklisted (entertainment)")
948 -- our local application config, which takes precedence
949 local conf = getApplication(ev.appid)
954 if conf.resource_class == "player" then
958 -- check the exceptions
959 if conf.requisites and conf.requisites.screen then
960 if conf.requisites.screen.driving then
966 -- disable only non-whitelisted applications
969 print("disabling screen for " .. ev.appid)
971 resmgr:disable_screen_by_appid("*", "*", ev.appid, true, true)
975 elseif event == "destroy" then
977 print("*** screen resource event: " ..
982 print("*** screen resource event: " ..
987 audio_event_handler = function(self, ev)
988 local event = ev.event
989 local appid = ev.appid
990 local audioid = ev.audioid
992 if event == "grant" then
994 print("*** grant audio to "..appid..
995 " ("..audioid..") in '" ..
998 elseif event == "revoke" then
1000 print("*** revoke audio from "..appid..
1001 " ("..audioid..") in '" ..
1002 ev.zone .. "' zone")
1006 print("*** audio resource event: " ..
1013 resclnt = resource_client {}
1015 wmgr = window_manager {
1016 geometry = function(self, w,h, v)
1017 if type(v) == "function" then
1023 application = function(self, appid)
1025 local app = application_lookup(appid)
1027 app = application_lookup("default")
1031 return { privileges = {screen="none", audio="none"} }
1034 output_order = { 1, 0 },
1036 outputs = { { name = "Mid",
1043 width = function(w,h) return w end,
1044 height = function(w,h) return h end
1051 height = function(w,h) return h end
1055 pos_x = function(w,h) return w-320 end,
1058 height = function(w,h) return h end
1065 areas = { Status = {
1069 width = function(w,h) return w end,
1076 width = function(w,h) return w end,
1077 height = function(w,h) return h-64-128 end
1083 width = function(w,h) return w end,
1084 height = function(w,h) return (h-64-128)/2 end
1089 pos_y = function(w,h) return (h-64-128)/2+64 end,
1090 width = function(w,h) return w end,
1091 height = function(w,h) return (h-64-128)/2 end
1097 width = function(w,h) return w/2 end,
1098 height = function(w,h) return (h-64-128)/2 end
1102 pos_x = function(w,h) return w/2 end,
1104 width = function(w,h) return w/2 end,
1105 height = function(w,h) return (h-64-128)/2 end
1110 pos_y = function(w,h) return (h-64-128/2)+64 end,
1111 width = function(w,h) return w/2 end,
1112 height = function(w,h) return (h-64-128)/2 end
1116 pos_x = function(w,h) return w/2 end,
1117 pos_y = function(w,h) return (h-64-128/2)+64 end,
1118 width = function(w,h) return w/2 end,
1119 height = function(w,h) return (h-64-128)/2 end
1125 width = function(w,h) return w end,
1126 height = function(w,h) return h-64-128 end
1132 width = function(w,h) return w/2-181 end,
1133 height = function(w,h) return h-64-128 end
1135 ["SysApp.Right"] = {
1137 pos_x = function(w,h) return w/2+181 end,
1139 width = function(w,h) return w/2-181 end,
1140 height = function(w,h) return h-64-128 end
1146 width = function(w,h) return w end,
1147 height = function(w,h) return h-64-128 end
1153 width = function(w,h) return w end,
1154 height = function(w,h) return (h-64-128)/2 end
1159 pos_y = function(w,h) return (h-64-128)/2+64 end,
1160 width = function(w,h) return w end,
1161 height = function(w,h) return (h-64-128)/2 end
1166 pos_y = function(w,h) return h-128 end,
1167 width = function(w,h) return w end,
1173 -- id name type output
1174 layers = { { 0, "BackGround" , 1, "Center" },
1175 { 1, "Application" , 2, "Center" },
1176 { 2, "HomeScreen" , 3, "Center" },
1177 { 3, "ControlBar" , 3, "Center" },
1178 { 4, "InterruptApp" , 4, "Center" },
1179 { 5, "OnScreen" , 5, "Center" },
1180 { 6, "Touch" , 102, "Center" },
1181 { 7, "Cursor" , 103, "Center" }
1185 manager_update = function(self, oper)
1187 print("### <== WINDOW MANAGER UPDATE:" ..
1188 window_manager_operation_name(oper))
1191 local wumask = window_mask { --raise = true,
1194 local wrmask = window_mask { raise = true,
1197 local lumask = layer_mask { visible = true }
1198 local lrmask = layer_mask { visible = true }
1199 local req = m:JSON({
1200 passthrough_window_update = wumask:tointeger(),
1201 passthrough_window_request = wrmask:tointeger(),
1202 passthrough_layer_update = lumask:tointeger(),
1203 passthrough_layer_request = lrmask:tointeger()
1205 self:manager_request(req)
1209 window_update = function(self, oper, win, mask)
1211 print("### <== WINDOW UPDATE oper:" ..
1212 window_operation_name(oper) ..
1213 " mask: " .. tostring(mask))
1219 local arg = m:JSON({ surface = win.surface,
1224 if oper == 1 then -- create
1225 local layertype = win.layertype
1226 if layertype and input_layer[layertype] then
1228 print("ignoring input panel creation")
1233 elseif oper == 2 then -- destroy
1235 elseif oper == 3 then -- namechange
1237 elseif oper == 4 or oper == 5 then -- visible/configure
1241 if win.layertype then
1242 arg.layertype = win.layertype
1244 arg.layer = win.layer
1245 arg.pos_x = win.pos_x
1246 arg.pos_y = win.pos_y
1247 arg.width = win.width
1248 arg.height = win.height
1249 arg.raise = win.raise
1250 arg.visible = win.visible
1251 if win.active == 0 then
1256 elseif oper == 6 then -- active
1257 if win.active == 0 then
1259 print("ignoring inactive event")
1264 elseif oper == 7 then -- map
1269 if win.mapped == 0 then
1275 --arg.name = map.target
1276 arg.width = map.width
1277 arg.height = map.height
1278 arg.stride = map.stride
1279 arg.format = map.format
1282 print("### nothing to do")
1287 local msg = m:JSON({ command = command,
1293 print("### <== sending " ..
1294 command_name(msg.command) ..
1295 " window message to '" .. homescreen .. "'")
1300 sc:send_message(homescreen, msg)
1302 if oper == 1 then -- create
1303 local i = input_layer[win.layertype]
1304 local p = self:application(win.appid)
1305 local s = p.privileges.screen
1307 if s == "system" then
1308 local a = animation({})
1309 local r = m:JSON({surface = win.surface,
1312 self:window_request(r,a,0)
1316 print("do not make resource for " ..
1320 resclnt:resource_set_create("screen",
1324 special_screen_sets[win.surface] = true
1328 if onscreen and win.appid == onscreen then
1329 local resmsg = m:JSON({
1330 command = 0x40006, -- window_id_res
1342 resourceId = win.surface
1347 print("### <== sending " ..
1348 command_name(resmsg.command) ..
1349 " message to '" .. onscreen .. "'")
1354 sc:send_message(onscreen, resmsg);
1356 elseif oper == 2 then -- destroy
1357 resclnt:resource_set_destroy("screen", win.surface)
1358 special_screen_sets[win.surface] = nil
1359 elseif oper == 6 then -- active
1361 local i = input_layer[win.layertype]
1362 local p = self:application(win.appid)
1363 local s = p.privileges.screen
1364 local surface = win.surface
1365 if not i and s ~= "system" then
1366 resclnt:resource_set_acquire("screen",surface)
1367 resmgr:window_raise(win.appid, surface, 1)
1373 layer_update = function(self, oper, layer, mask)
1375 print("### LAYER UPDATE:" ..
1376 layer_operation_name(oper) ..
1377 " mask: " .. tostring(mask))
1382 if oper == 3 then -- visible
1383 local command = 0x10008 -- change_layer
1384 local msg = m:JSON({
1387 arg = m:JSON({layer = layer.id,
1388 visible = layer.visible
1392 print("### <== sending "..command_name(command)..
1398 sc:send_message(homescreen, msg)
1401 print("### nothing to do")
1406 output_update = function(self, oper, out, mask)
1407 local idx = out.index
1408 local defidx = self.output_order[idx+1]
1410 print("### OUTPUT UPDATE:" .. oper ..
1411 " mask: "..tostring(mask))
1417 local outdef = self.outputs[defidx+1]
1418 if (oper == 1) then -- create
1420 self:output_request(m:JSON({index = idx,
1425 elseif (oper == 5) then -- done
1426 local ads = outdef.areas
1427 local on = outdef.name
1429 for name,ad in pairs(ads) do
1430 local can = wmgr:canonical_name(on.."."..name)
1431 local a = m:JSON({name = name,
1432 output = out.index})
1433 for fld,val in pairs(ad) do
1434 a[fld] = self:geometry(out.width,
1439 resmgr:area_create(area[can], outdef.zone)
1447 imgr = input_manager {
1448 inputs = {{ name = "G27 Racing Wheel",
1450 switch = { [2] = {appid="org.tizen.ico.app-soundsample" },
1451 [3] = {appid="org.tizen.ico.homescreen", keycode=1},
1452 [4] = {appid="org.tizen.ico.app-soundsample" },
1453 [5] = {appid="org.tizen.ico.homescreen", keycode=2}
1457 manager_update = function(self, oper)
1459 print("### <== INPUT MANAGER UPDATE:" ..
1460 input_manager_operation_name(oper))
1464 input_update = function(self, oper, inp, mask)
1466 print("### INPUT UPDATE:" ..
1467 input_operation_name(oper) ..
1468 " mask: " .. tostring(mask))
1474 code_update = function(self, oper, code, mask)
1476 print("### CODE UPDATE: mask: " .. tostring(mask))
1481 local msg = m:JSON({ command = 1,
1482 appid = "org.tizen.ico.homescreen",
1483 arg = m:JSON({ device = code.device,
1491 print("### <== sending " ..
1492 command_name(msg.command) ..
1498 sc:send_message(homescreen, msg)
1502 sc = m:get_system_controller()
1507 -- special screen resource sets
1508 -- TODO: just rewrite screen resource handling to use regular resource API
1510 special_screen_sets = {}
1513 um = m:UserManager()
1521 -- these shoud be before wmgr:connect() is called
1523 print("====== creating applications ======")
1527 area = "Center.Full",
1528 privileges = { screen = "none", audio = "none" },
1529 resource_class = "player",
1535 area = "Center.Full",
1536 privileges = { screen = "system", audio = "none" },
1537 resource_class = "implicit",
1538 screen_priority = 30
1542 appid = "org.tizen.ico.homescreen",
1543 area = "Center.Full",
1544 windows = { {'ico_hs_controlbarwindow', 'Center.Control'} },
1545 privileges = { screen = "system", audio = "system" },
1546 resource_class = "player",
1547 screen_priority = 20
1551 appid = "org.tizen.ico.statusbar",
1552 area = "Center.Status",
1553 privileges = { screen = "system", audio = "none" },
1554 resource_class = "player",
1555 screen_priority = 20
1559 appid = "org.tizen.ico.onscreen",
1560 area = "Center.Full",
1561 privileges = { screen = "system", audio = "system" },
1562 resource_class = "player",
1563 screen_priority = 20
1567 appid = "org.tizen.ico.login",
1568 area = "Center.Full",
1569 privileges = { screen = "system", audio = "system" },
1570 resource_class = "player",
1571 screen_priority = 20
1575 appid = "org.tizen.ico.camera_left",
1576 area = "Center.SysApp.Left",
1577 privileges = { screen = "system", audio = "none" },
1578 requisites = { screen = "blinker_left", audio = "none" },
1579 resource_class = "player",
1580 screen_priority = 30
1584 appid = "org.tizen.ico.camera_right",
1585 area = "Center.SysApp.Right",
1586 privileges = { screen = "system", audio = "none" },
1587 requisites = { screen = "blinker_right", audio = "none" },
1588 resource_class = "player",
1589 screen_priority = 30
1593 appid = "net.zmap.navi",
1594 area = "Center.Full",
1595 privileges = { screen = "none", audio = "none" },
1596 resource_class = "navigator",
1597 screen_priority = 30
1601 appid = "GV3ySIINq7.GhostCluster",
1602 area = "Center.Full",
1603 privileges = { screen = "none", audio = "none" },
1604 resource_class = "system",
1605 requisites = { screen = "driving", audio = "none" },
1606 screen_priority = 30
1610 appid = "MediaPlayer",
1611 area = "Center.Full",
1612 privileges = { screen = "none", audio = "none" },
1613 requisites = { screen = "driving", audio = "none" },
1614 resource_class = "player",
1619 appid = "MyMediaPlayer",
1620 area = "Center.Full",
1621 privileges = { screen = "none", audio = "none" },
1622 requisites = { screen = "driving", audio = "none" },
1623 resource_class = "player",
1628 appid = "MeterWidget",
1629 area = "Center.Full",
1630 privileges = { screen = "none", audio = "none" },
1631 requisites = { screen = "driving", audio = "none" },
1632 resource_class = "player",
1637 appid = "org.tizen.ico.app-soundsample",
1638 area = "Center.Full",
1639 privileges = { screen = "none", audio = "none" },
1640 -- uncomment the next line to make the app exempt from regulation
1641 -- requisites = { screen = "driving", audio = "none" },
1642 resource_class = "player",
1648 sc.client_handler = function (self, cid, msg)
1649 local command = msg.command
1650 local appid = msg.appid
1652 print('### ==> client handler:')
1658 -- known commands: 1 for SEND_APPID, synthetic command 0xFFFF for
1661 if command == 0xFFFF then
1663 print('client ' .. cid .. ' disconnected')
1665 if msg.appid == homescreen then
1667 for i,v in pairs(special_screen_sets) do
1668 resclnt:resource_set_destroy("screen", i)
1669 special_screen_sets[i] = nil
1675 -- handle the connection to weston
1678 if appid == "org.tizen.ico.homescreen" then
1679 print('Setting homescreen='..appid)
1681 if command and command == 1 then
1682 send_driving_mode_to(homescreen)
1683 send_night_mode_to(homescreen)
1685 elseif appid == "org.tizen.ico.onscreen" then
1687 if command and command == 1 then
1688 send_driving_mode_to(onscreen)
1689 send_night_mode_to(onscreen)
1693 if not connected and appid == "org.tizen.ico.homescreen" then
1694 print('Trying to connect to weston...')
1695 connected = wmgr:connect()
1701 sc.generic_handler = function (self, cid, msg)
1703 print('### ==> generic handler:')
1710 sc.window_handler = function (self, cid, msg)
1712 print('### ==> received ' ..
1713 command_name(msg.command) .. ' message from ' .. cids[cid])
1715 print(tostring(msg))
1719 local a = animation({})
1721 if msg.command == 0x10003 then -- ico SHOW command
1722 local raise_mask = 0x01000000
1723 local lower_mask = 0x02000000
1724 local nores_mask = 0x40000000
1725 local time_mask = 0x00ffffff
1727 local surface = msg.arg.surface
1728 local system_surface = false
1729 local appdb = wmgr:application(msg.appid)
1730 system_surface = appdb.privileges.screen == "system"
1736 if msg.arg.anim_time then
1737 local t = msg.arg.anim_time
1738 -- the actual time for the animation
1739 time = m:AND(t, time_mask)
1740 -- flag for ignoring resource control
1741 nores = m:AND(t, nores_mask)
1742 if m:AND(t, raise_mask) then
1744 elseif m:AND(t, lower_mask) then
1748 if msg.arg.anim_name then
1749 a.show = { msg.arg.anim_name, time }
1750 print('time: ' .. tostring(time))
1754 -- all show messages from system surfaces are forced
1755 if not nores and system_surface then
1757 if not msg.arg.raise then
1763 print('### ==> SHOW')
1764 print(tostring(msg.arg) .. ", system_surface=" .. tostring(system_surface))
1768 wmgr:window_request(msg.arg, a, 0)
1770 -- only non-system surfaces have resource sets
1771 if not system_surface then
1772 resclnt:resource_set_acquire("screen", surface)
1775 resclnt:resource_set_acquire("screen", surface)
1776 resmgr:window_raise(msg.appid, surface, 1)
1778 elseif msg.command == 0x10004 then -- ico HIDE command
1779 local raise_mask = 0x01000000
1780 local lower_mask = 0x02000000
1781 local nores_mask = 0x40000000
1782 local time_mask = 0x00ffffff
1786 if msg.arg.anim_time then
1787 local t = msg.arg.anim_time
1788 -- the actual time for the animation
1789 time = m:AND(t, time_mask)
1790 -- flag for ignoring resource control
1791 nores = m:AND(t, nores_mask)
1793 if msg.arg.anim_name then
1794 a.hide = { msg.arg.anim_name, time }
1795 print('hide animation time: ' .. tostring(a.hide[2]))
1799 local p = wmgr:application(msg.appid)
1800 local s = p.privileges.screen
1801 if s == "system" then
1807 print('### ==> HIDE REQUEST')
1808 print(tostring(msg.arg))
1811 wmgr:window_request(msg.arg, a, 0)
1813 resmgr:window_raise(msg.appid, msg.arg.surface, -1)
1815 elseif msg.command == 0x10005 then -- ico MOVE
1817 print('### ==> MOVE REQUEST')
1818 print(tostring(msg.arg))
1820 if msg.arg.zone then
1821 msg.arg.area = msg.arg.zone
1823 wmgr:window_request(msg.arg, a, 0)
1824 -- TODO: handle if area changed
1825 elseif msg.command == 0x10007 then -- ico CHANGE_ACTIVE
1826 if not msg.arg.active then
1827 msg.arg.active = 3 -- pointer + keyboard
1830 print('### ==> CHANGE_ACTIVE REQUEST')
1831 print(tostring(msg.arg))
1833 wmgr:window_request(msg.arg, a, 0)
1834 elseif msg.command == 0x10008 then -- ico CHANGE_LAYER
1836 print('### ==> CHANGE_LAYER REQUEST')
1837 print(tostring(msg.arg))
1840 if msg.arg.layer ~= 4 or msg.arg.layer ~= 5 then
1841 print("do not change layer for other than cursor or touch")
1845 wmgr:window_request(msg.arg, a, 0)
1846 elseif msg.command == 0x10020 then -- ico MAP_THUMB
1847 local framerate = msg.arg.framerate
1848 local animname = msg.arg.anim_name
1850 a.map = { animname, 1 }
1851 if not framerate or framerate < 0 then
1856 print('### ==> MAP_THUMB REQUEST')
1858 print('framerate: '..framerate)
1860 wmgr:window_request(msg.arg, a, framerate)
1862 elseif msg.command == 0x10021 then -- ico UNMAP_THUMB
1865 print('### ==> UNMAP_THUMB REQUEST')
1868 wmgr:window_request(msg.arg, a, 0)
1870 elseif msg.command == 0x10013 then -- ico MAP_BUFFER command
1871 local shmname = msg.arg.anim_name
1872 local bufsize = msg.arg.width
1873 local bufnum = msg.arg.height
1874 if shmname and bufsize and bufnum then
1876 print('### ==> MAP_BUFFER REQUEST')
1877 print("shmaname='" .. shmname ..
1878 "' bufsize='" .. bufsize ..
1879 " bufnum=" .. bufnum)
1881 wmgr:buffer_request(shmname, bufsize, bufnum)
1884 elseif msg.command == 0x10030 then -- ico SHOW_LAYER command
1887 print('### ==> SHOW_LAYER REQUEST')
1890 wmgr:layer_request(msg.arg)
1891 elseif msg.command == 0x10031 then -- ico HIDE_LAYER command
1894 print('### ==> HIDE_LAYER REQUEST')
1897 wmgr:layer_request(msg.arg)
1901 sc.input_handler = function (self, cid, msg)
1903 print('### ==> input handler: ' .. command_name(msg.command))
1908 if msg.command == 0x20001 then -- add_input
1909 msg.arg.appid = msg.appid
1911 print('### ==> ADD_INPUT REQUEST')
1912 print(tostring(msg.arg))
1914 imgr:input_request(msg.arg)
1915 elseif msg.command == 0x20002 then -- del_input
1918 print('### ==> DEL_INPUT REQUEST')
1919 print(tostring(msg.arg))
1921 imgr:input_request(msg.arg)
1922 -- elseif msg.command == 0x20003 then -- send_input
1926 sc.user_handler = function (self, cid, msg)
1928 print('### ==> user handler: ' .. command_name(msg.command))
1935 print("User Manager not initialized")
1939 if msg.command == 0x30001 then -- change_user
1940 print("command CHANGE_USER")
1942 print("invalid message")
1946 username = msg.arg.user
1947 passwd = msg.arg.pass
1949 if not username then
1957 success = um:changeUser(username, passwd)
1964 if sc:send_message(msg.appid, reply) then
1965 print('*** sent authentication failed message')
1967 print('*** failed to send authentication failed message')
1971 elseif msg.command == 0x30002 then -- get_userlist
1972 print("command GET_USERLIST")
1973 if not msg.appid then
1974 print("invalid message")
1978 users, currentUser = um:getUserList()
1981 print("failed to get user list")
1987 for i,v in pairs(users) do
1991 if not currentUser then
1996 print("current user: " .. currentUser)
1998 for i,v in pairs(users) do
2009 user_login = currentUser
2014 print("### <== GetUserList reply: " .. tostring(reply))
2017 if sc:send_message(msg.appid, reply) then
2018 print('*** reply OK')
2020 print('*** reply FAILED')
2023 elseif msg.command == 0x30003 then -- get_lastinfo
2024 print("command GET_LASTINFO")
2025 if not msg.appid then
2026 print("invalid message")
2030 lastInfo = um:getLastInfo(msg.appid)
2032 if not lastInfo then
2033 print("failed to get last info for app" .. msg.appid)
2045 if sc:send_message(msg.appid, reply) then
2046 print('*** reply OK')
2048 print('*** reply FAILED')
2051 elseif msg.command == 0x30004 then -- set_lastinfo
2052 print("command SET_LASTINFO")
2053 if not msg.arg or not msg.appid then
2054 print("invalid message")
2058 lastInfo = um:setLastInfo(msg.appid, msg.arg.lastinfo)
2062 sc.resource_handler = function (self, cid, msg)
2064 print('### ==> resource handler: ' .. command_name(msg.command))
2070 getKey = function (msg)
2071 -- Field rset.key is an id for distinguishing between rsets. All
2072 -- resource types appear to contain a different key. Just pick one
2073 -- based on what we have on the message.
2077 if msg and msg.res then
2078 if msg.res.sound then
2079 key = msg.res.sound.id
2080 elseif msg.res.input then
2081 key = msg.res.input.name
2082 elseif msg.res.window then
2083 -- alarm! this appars to be non-unique?
2084 key = msg.res.window.resourceId
2091 createResourceSet = function (ctl, client, msg)
2094 -- m:info("*** resource_cb: client = '" .. msg.appid .. "'")
2096 -- type is either basic (0) or interrupt (1)
2098 if msg.res.type then
2099 requestType = msg.res.type
2102 if rset.data.filter_first then
2103 rset.data.filter_first = false
2107 if rset.acquired then
2108 cmd = 0x00040001 -- acquire
2110 if msg.appid == onscreen then
2111 -- notifications are valid only for a number of seconds
2112 rset.timer = m:Timer({
2115 callback = function (t)
2116 m:info("notification timer expired")
2119 reply.res.window = rset.data.window
2125 -- Send a "RELEASE" message to client.
2126 -- This triggers the resource deletion
2127 -- cycle in OnScreen.
2137 sc:send_message(client, reply)
2142 cmd = 0x00040002 -- release
2144 rset.timer.callback = nil
2157 if rset.data.sound then
2158 reply.res.sound = rset.data.sound
2161 if rset.data.window then
2162 reply.res.window = rset.data.window
2165 if rset.data.input then
2166 reply.res.input = rset.data.input
2169 if rset.acquired then
2170 m:info("resource cb: 'acquire' reply to client " .. client)
2172 m:info("resource cb: 'release' reply to client " .. client)
2175 if not sc:send_message(client, reply) then
2176 m:info('*** reply FAILED')
2180 local rset = m:ResourceSet({
2181 application_class = "player",
2182 zone = "driver", -- msg.zone ("full")
2192 if msg.res.sound then
2194 resource_name = "audio_playback"
2196 rset.resources.audio_playback.attributes.pid = tostring(msg.pid)
2197 rset.resources.audio_playback.attributes.appid = msg.appid
2198 print("sound name: " .. msg.res.sound.name)
2199 print("sound zone:" .. msg.res.sound.zone)
2200 print("sound adjust: " .. tostring(msg.res.sound.adjust))
2202 rset.data.sound = msg.res.sound
2205 if msg.res.input then
2207 resource_name = "input"
2209 rset.resources.input.attributes.pid = tostring(msg.pid)
2210 rset.resources.input.attributes.appid = msg.appid
2211 print("input name: " .. msg.res.input.name)
2212 print("input event:" .. tostring(msg.res.input.event))
2214 rset.data.input = msg.res.input
2217 if msg.res.window then
2219 resource_name = "screen",
2222 rset.resources.screen.attributes.pid = tostring(msg.pid)
2223 rset.resources.screen.attributes.appid = msg.appid
2224 rset.resources.screen.attributes.surface = msg.res.window.resourceId
2225 complete_area = msg.res.window.display .. '.' .. msg.res.window.area
2226 rset.resources.screen.attributes.area = complete_area
2227 if msg.appid == onscreen then
2228 rset.resources.screen.attributes.classpri = 1
2230 rset.resources.screen.attributes.classpri = 0
2233 rset.data.window = msg.res.window
2236 rset.key = getKey(msg)
2241 -- parse the message
2243 -- fields common to all messages:
2248 if msg.command == 0x40011 then -- create_res
2249 print("command CREATE_RES")
2253 if not sets.cid then
2256 sets.cid[key] = createResourceSet(self, cid, msg)
2259 elseif msg.command == 0x40012 then -- destroy_res
2260 print("command DESTROY_RES")
2264 if sets.cid and sets.cid[key] then
2265 sets.cid[key]:release()
2266 sets.cid[key].timer = nil
2267 sets.cid[key] = nil -- garbage collecting
2271 elseif msg.command == 0x40001 then -- acquire_res
2272 print("command ACQUIRE_RES")
2276 if not sets.cid then
2279 if not sets.cid[key] then
2280 sets.cid[key] = createResourceSet(self, cid, msg)
2282 print("acquiring the resource set")
2283 sets.cid[key]:acquire()
2286 elseif msg.command == 0x40002 then -- release_res
2287 print("command RELEASE_RES")
2292 if sets.cid and sets.cid[key] then
2293 sets.cid[key]:release()
2295 if msg.appid == onscreen then
2296 -- in case of OnScreen, this actually means that the
2297 -- resource set is never used again; let gc do its job
2298 sets.cid[key].timer = nil
2299 sets.cid[key] = nil -- garbage collecting
2304 elseif msg.command == 0x40003 then -- deprive_res
2305 print("command DEPRIVE_RES")
2307 elseif msg.command == 0x40004 then -- waiting_res
2308 print("command WAITING_RES")
2310 elseif msg.command == 0x40005 then -- revert_res
2311 print("command REVERT_RES")
2315 sc.inputdev_handler = function (self, cid, msg)
2317 print('*** inputdev handler: ' .. command_name(msg.command))
2324 sc.notify_handler = function (self, cid, msg)
2326 print('### notify handler: ' .. command_name(msg.command))
2334 function send_driving_mode_to(client)
2335 if client == "" then
2339 local driving_mode = mdb.select.select_driving_mode.single_value
2341 if not driving_mode then driving_mode = 0 end
2343 local reply = m:JSON({ command = 0x60001,
2344 arg = m:JSON({ stateid = 1,
2345 state = driving_mode
2350 print("### <== sending " .. command_name(reply.command) .. " message")
2356 sc:send_message(client, reply)
2359 function send_night_mode_to(client)
2360 if client == "" then
2364 local night_mode = mdb.select.select_night_mode.single_value
2366 if not night_mode then night_mode = 0 end
2368 local reply = m:JSON({ command = 0x60001,
2369 arg = m:JSON({ stateid = 2,
2375 print("### <== sending " .. command_name(reply.command) .. " message")
2381 sc:send_message(client, reply)
2384 -- we should have 'audio_playback' defined by now
2385 m:try_load_plugin('telephony')