|
|
@ -4,7 +4,7 @@ import ( |
|
|
|
"git.jfdev.de/JonasFranzDEV/hal/hal" |
|
|
|
"git.jfdev.de/JonasFranzDEV/hal/hal" |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
func getModulesFromConfig(config *hal.ClusterConfig) (modules map[string]*hal.Module, err error) { |
|
|
|
func getModulesFromConfig(config *hal.ClusterConfig, debug bool) (modules map[string]*hal.Module, err error) { |
|
|
|
// all modules with their name as key
|
|
|
|
// all modules with their name as key
|
|
|
|
modules = make(map[string]*hal.Module) |
|
|
|
modules = make(map[string]*hal.Module) |
|
|
|
|
|
|
|
|
|
|
@ -13,7 +13,8 @@ func getModulesFromConfig(config *hal.ClusterConfig) (modules map[string]*hal.Mo |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
return nil, err |
|
|
|
return nil, err |
|
|
|
} |
|
|
|
} |
|
|
|
modules[node.Name], err = hal.NewHALModule(program, 256, 0, false) |
|
|
|
// By default, all IO is the standard IO, we'll override it with channels where needed.
|
|
|
|
|
|
|
|
modules[node.Name], err = hal.NewHALModule(program, 256, 4, debug) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
return nil, err |
|
|
|
return nil, err |
|
|
|
} |
|
|
|
} |
|
|
|