colin/wireplumber
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

policy-dsp: expect policy-device-profile to manage profiles

Browse Source
This commit is contained in:
Dmitry Sharshakov
2023-09-22 19:08:38 +03:00
parent 2dd28c0015
commit 2970ee2634
1 changed files with 1 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
src/scripts/policy-dsp.lua
View File

@@ -6,7 +6,6 @@
-- SPDX-License-Identifier: MIT -- SPDX-License-Identifier: MIT
local config = ... or {} local config = ... or {}
config.properties = config.properties or {}
config.rules = config.rules or {} config.rules = config.rules or {}
for _, r in ipairs(config.rules) do for _, r in ipairs(config.rules) do
@@ -22,77 +21,21 @@ for _, r in ipairs(config.rules) do
local interest = Interest(interest_desc) local interest = Interest(interest_desc)
table.insert(r.interests, interest) table.insert(r.interests, interest)
end end
if r.device_matches then
r.device_interests = {}
for _, i in ipairs(r.device_matches) do
local interest_desc = { type = "properties" }
for _, c in ipairs(i) do
c.type = "pw"
table.insert(interest_desc, Constraint(c))
end end
local interest = Interest(interest_desc) -- TODO: only check for hotplug of nodes with known DSP rules
table.insert(r.device_interests, interest)
end
end
end
-- Look up device which owns the sink (for profile switching)
devices_om = ObjectManager {
Interest { type = "device" }
}
-- TODO: only check for hotplug of devices with known DSP rules
nodes_om = ObjectManager { nodes_om = ObjectManager {
Interest { type = "node" }, Interest { type = "node" },
} }
filter_chains = {} filter_chains = {}
-- Check if the device matches any of the interests
function checkDevice (device, device_interests)
for _, interest in ipairs(device_interests) do
if interest:matches(device["global-properties"]) then
return true
end
end
return false
end
nodes_om:connect("object-added", function (om, node) nodes_om:connect("object-added", function (om, node)
for _, r in ipairs(config.rules or {}) do for _, r in ipairs(config.rules or {}) do
for _, interest in ipairs(r.interests) do for _, interest in ipairs(r.interests) do
if interest:matches(node["global-properties"]) then if interest:matches(node["global-properties"]) then
local id = node["global-properties"]["object.id"] local id = node["global-properties"]["object.id"]
local device = devices_om:lookup(Interest {
type = "device",
Constraint { "object.id", "=", node["global-properties"]["device.id"] }
})
if r.device_interests and not checkDevice(device, r.device_interests) then
-- This node belongs to another device rather than the specified one
return
end
if r.properties and r.properties.profile then
local index = nil
for profile in device:iterate_params("EnumProfile") do
local p = profile:parse()
if p.properties.name == r.properties.profile then
local pod = Pod.Object {
"Spa:Pod:Object:Param:Profile", "Profile",
index = p.properties.index
}
device:set_param("Profile", pod)
break
end
end
end
if r.filter_chain then if r.filter_chain then
if filter_chains[id] then if filter_chains[id] then
Log.warning("Sink " .. id .. " has been plugged now, but has a filter chain loaded. Skipping") Log.warning("Sink " .. id .. " has been plugged now, but has a filter chain loaded. Skipping")
@@ -115,5 +58,4 @@ nodes_om:connect("object-removed", function (om, node)
end end
end) end)
devices_om:activate()
nodes_om:activate() nodes_om:activate()