|
@@ -5,6 +5,7 @@ import (
|
|
"strings"
|
|
"strings"
|
|
|
|
|
|
"github.com/Sirupsen/logrus"
|
|
"github.com/Sirupsen/logrus"
|
|
|
|
+ dockercontainer "github.com/docker/docker/container"
|
|
"github.com/docker/libnetwork"
|
|
"github.com/docker/libnetwork"
|
|
)
|
|
)
|
|
|
|
|
|
@@ -40,10 +41,23 @@ func (daemon *Daemon) ContainerRename(oldName, newName string) error {
|
|
container.Lock()
|
|
container.Lock()
|
|
defer container.Unlock()
|
|
defer container.Unlock()
|
|
|
|
|
|
|
|
+ links := map[string]*dockercontainer.Container{}
|
|
|
|
+ for k, v := range daemon.linkIndex.children(container) {
|
|
|
|
+ if !strings.HasPrefix(k, oldName) {
|
|
|
|
+ return fmt.Errorf("Linked container %s does not match parent %s", k, oldName)
|
|
|
|
+ }
|
|
|
|
+ links[strings.TrimPrefix(k, oldName)] = v
|
|
|
|
+ }
|
|
|
|
+
|
|
if newName, err = daemon.reserveName(container.ID, newName); err != nil {
|
|
if newName, err = daemon.reserveName(container.ID, newName); err != nil {
|
|
return fmt.Errorf("Error when allocating new name: %v", err)
|
|
return fmt.Errorf("Error when allocating new name: %v", err)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ for k, v := range links {
|
|
|
|
+ daemon.nameIndex.Reserve(newName+k, v.ID)
|
|
|
|
+ daemon.linkIndex.link(container, v, newName+k)
|
|
|
|
+ }
|
|
|
|
+
|
|
container.Name = newName
|
|
container.Name = newName
|
|
container.NetworkSettings.IsAnonymousEndpoint = false
|
|
container.NetworkSettings.IsAnonymousEndpoint = false
|
|
|
|
|
|
@@ -52,10 +66,20 @@ func (daemon *Daemon) ContainerRename(oldName, newName string) error {
|
|
container.Name = oldName
|
|
container.Name = oldName
|
|
container.NetworkSettings.IsAnonymousEndpoint = oldIsAnonymousEndpoint
|
|
container.NetworkSettings.IsAnonymousEndpoint = oldIsAnonymousEndpoint
|
|
daemon.reserveName(container.ID, oldName)
|
|
daemon.reserveName(container.ID, oldName)
|
|
|
|
+ for k, v := range links {
|
|
|
|
+ daemon.nameIndex.Reserve(oldName+k, v.ID)
|
|
|
|
+ daemon.linkIndex.link(container, v, oldName+k)
|
|
|
|
+ daemon.linkIndex.unlink(newName+k, v, container)
|
|
|
|
+ daemon.nameIndex.Release(newName + k)
|
|
|
|
+ }
|
|
daemon.releaseName(newName)
|
|
daemon.releaseName(newName)
|
|
}
|
|
}
|
|
}()
|
|
}()
|
|
|
|
|
|
|
|
+ for k, v := range links {
|
|
|
|
+ daemon.linkIndex.unlink(oldName+k, v, container)
|
|
|
|
+ daemon.nameIndex.Release(oldName + k)
|
|
|
|
+ }
|
|
daemon.releaseName(oldName)
|
|
daemon.releaseName(oldName)
|
|
if err = container.ToDisk(); err != nil {
|
|
if err = container.ToDisk(); err != nil {
|
|
return err
|
|
return err
|