Skip to content

Commit

Permalink
Merge pull request #412 from ReactiveBayes/remove-marginal-msg-depend…
Browse files Browse the repository at this point in the history
…encies

remove msg_dep and mar_dep functions
  • Loading branch information
wouterwln authored Aug 7, 2024
2 parents 92ca484 + f149644 commit af12812
Showing 1 changed file with 0 additions and 24 deletions.
24 changes: 0 additions & 24 deletions src/nodes/dependencies.jl
Original file line number Diff line number Diff line change
Expand Up @@ -111,30 +111,6 @@ end

RequireMessageFunctionalDependencies(; kwargs...) = RequireMessageFunctionalDependencies((; kwargs...))

function message_dependencies(dependencies::RequireMessageFunctionalDependencies, nodeinterfaces, nodelocalmarginals, varcluster, cindex, iindex)

# First we find dependency index in `indices`, we use it later to find `start_with` distribution
depindex = findfirst((i) -> i === iindex, dependencies.indices)

# If we have `depindex` in our `indices` we include it in our list of functional dependencies. It effectively forces rule to require inbound message
if depindex !== nothing
# `mapindex` is a lambda function here
output = messagein(nodeinterfaces[iindex])
start_with = dependencies.start_with[depindex]
# Initialise now, if message has not been initialised before and `start_with` element is not empty
if isnothing(getrecent(output)) && !isnothing(start_with)
setmessage!(output, start_with)
end
return map(inds -> map(i -> @inbounds(nodeinterfaces[i]), inds), varcluster)
else
return message_dependencies(DefaultFunctionalDependencies(), nodeinterfaces, nodelocalmarginals, varcluster, cindex, iindex)
end
end

function marginal_dependencies(::RequireMessageFunctionalDependencies, nodeinterfaces, nodelocalmarginals, varcluster, cindex, iindex)
return marginal_dependencies(DefaultFunctionalDependencies(), nodeinterfaces, nodelocalmarginals, varcluster, cindex, iindex)
end

function functional_dependencies(dependencies::RequireMessageFunctionalDependencies, factornode, interface, iindex)
specification = dependencies.specification

Expand Down

0 comments on commit af12812

Please sign in to comment.