vbatts/cri-o
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

restore server rewrite

Browse source 
Signed-off-by: Antonio Murdaca <runcom@redhat.com>
This commit is contained in:
Antonio Murdaca 2016-09-19 09:39:13 +02:00
parent 22d434c1e6
commit b053e63995
No known key found for this signature in database
GPG key ID: B2BEAD150DE936B9
1 changed files with 39 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

80
server/server.go
View file

@ -28,46 +28,44 @@ type Server struct {
netPlugin ocicni.CNIPlugin netPlugin ocicni.CNIPlugin
} }
func (s *Server) loadSandboxes() error { func (s *Server) loadSandbox(id string) error {
err := filepath.Walk(s.sandboxDir, func(path string, info os.FileInfo, err error) error { metaJSON, err := ioutil.ReadFile(filepath.Join(s.sandboxDir, id, "metadata.json"))
if err != nil { if err != nil {
return err return err
} }
if !info.IsDir() { var m metadata
return nil if err = json.Unmarshal(metaJSON, &m); err != nil {
} return err
if path == s.sandboxDir { }
return nil s.addSandbox(&sandbox{
} name: id,
metaJSON, err := ioutil.ReadFile(filepath.Join(path, "metadata.json")) logDir: m.LogDir,
if err != nil { labels: m.Labels,
return err containers: oci.NewMemoryStore(),
}
var m metadata
if err2 := json.Unmarshal(metaJSON, &m); err2 != nil {
return err2
}
sname, err := filepath.Rel(s.sandboxDir, path)
if err != nil {
return err
}
s.addSandbox(&sandbox{
name: sname,
logDir: m.LogDir,
labels: m.Labels,
containers: oci.NewMemoryStore(),
})
scontainer, err := oci.NewContainer(m.ContainerName, path, path, m.Labels, sname, false)
if err != nil {
return err
}
s.addContainer(scontainer)
if err = s.runtime.UpdateStatus(scontainer); err != nil {
logrus.Warnf("error updating status for container %s: %v", scontainer, err)
}
return nil
}) })
return err sandboxPath := filepath.Join(s.sandboxDir, id)
scontainer, err := oci.NewContainer(m.ContainerName, sandboxPath, sandboxPath, m.Labels, id, false)
if err != nil {
return err
}
s.addContainer(scontainer)
if err = s.runtime.UpdateStatus(scontainer); err != nil {
logrus.Warnf("error updating status for container %s: %v", scontainer, err)
}
return nil
}
func (s *Server) restore() error {
dir, err := ioutil.ReadDir(s.sandboxDir)
if err != nil {
return err
}
for _, v := range dir {
if err := s.loadSandbox(v.Name()); err != nil {
return err
}
}
return nil
} }
// New creates a new Server with options provided // New creates a new Server with options provided
@ -107,8 +105,8 @@ func New(runtimePath, sandboxDir, containerDir string) (*Server, error) {
containers: containers, containers: containers,
}, },
} }
if err := s.loadSandboxes(); err != nil { if err := s.restore(); err != nil {
logrus.Warnf("couldn't get sandboxes: %v", err) logrus.Warnf("couldn't restore: %v", err)
} }
logrus.Debugf("sandboxes: %v", s.state.sandboxes) logrus.Debugf("sandboxes: %v", s.state.sandboxes)
logrus.Debugf("containers: %v", s.state.containers) logrus.Debugf("containers: %v", s.state.containers)