mirror of
https://github.com/rancher/os.git
synced 2025-09-04 16:21:07 +00:00
Fix loading network files from ros service
compose commands
This commit is contained in:
@@ -23,7 +23,7 @@ func (p *projectFactory) Create(c *cli.Context) (*project.Project, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return compose.GetProject(cfg)
|
return compose.GetProject(cfg, true)
|
||||||
}
|
}
|
||||||
|
|
||||||
func beforeApp(c *cli.Context) error {
|
func beforeApp(c *cli.Context) error {
|
||||||
|
@@ -53,7 +53,7 @@ func enter(cfg *config.CloudConfig) error {
|
|||||||
|
|
||||||
log.Infof("Starting Docker in context: %s", context)
|
log.Infof("Starting Docker in context: %s", context)
|
||||||
|
|
||||||
p, err := compose.GetProject(cfg)
|
p, err := compose.GetProject(cfg, true)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@@ -40,17 +40,8 @@ func RunServiceSet(name string, cfg *config.CloudConfig, configs map[string]*pro
|
|||||||
return p, p.Up()
|
return p, p.Up()
|
||||||
}
|
}
|
||||||
|
|
||||||
func RunServices(cfg *config.CloudConfig) error {
|
func GetProject(cfg *config.CloudConfig, networkingAvailable bool) (*project.Project, error) {
|
||||||
p, err := newCoreServiceProject(cfg)
|
return newCoreServiceProject(cfg, networkingAvailable)
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return p.Up()
|
|
||||||
}
|
|
||||||
|
|
||||||
func GetProject(cfg *config.CloudConfig) (*project.Project, error) {
|
|
||||||
return newCoreServiceProject(cfg)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func newProject(name string, cfg *config.CloudConfig) (*project.Project, error) {
|
func newProject(name string, cfg *config.CloudConfig) (*project.Project, error) {
|
||||||
@@ -102,8 +93,7 @@ func addServices(p *project.Project, enabled map[interface{}]interface{}, config
|
|||||||
return enabled
|
return enabled
|
||||||
}
|
}
|
||||||
|
|
||||||
func newCoreServiceProject(cfg *config.CloudConfig) (*project.Project, error) {
|
func newCoreServiceProject(cfg *config.CloudConfig, network bool) (*project.Project, error) {
|
||||||
network := false
|
|
||||||
projectEvents := make(chan project.ProjectEvent)
|
projectEvents := make(chan project.ProjectEvent)
|
||||||
enabled := map[interface{}]interface{}{}
|
enabled := map[interface{}]interface{}{}
|
||||||
|
|
||||||
|
@@ -98,7 +98,11 @@ func SysInit() error {
|
|||||||
_, err = config.ChainCfgFuncs(cfg,
|
_, err = config.ChainCfgFuncs(cfg,
|
||||||
loadImages,
|
loadImages,
|
||||||
func(cfg *config.CloudConfig) (*config.CloudConfig, error) {
|
func(cfg *config.CloudConfig) (*config.CloudConfig, error) {
|
||||||
return cfg, compose.RunServices(cfg)
|
p, err := compose.GetProject(cfg, false)
|
||||||
|
if err != nil {
|
||||||
|
return cfg, err
|
||||||
|
}
|
||||||
|
return cfg, p.Up()
|
||||||
},
|
},
|
||||||
func(cfg *config.CloudConfig) (*config.CloudConfig, error) {
|
func(cfg *config.CloudConfig) (*config.CloudConfig, error) {
|
||||||
syscall.Sync()
|
syscall.Sync()
|
||||||
|
Reference in New Issue
Block a user