The following pull request was submitted through Github.
It can be accessed and reviewed at: https://github.com/lxc/lxd/pull/6500
This e-mail was sent by the LXC bot, direct replies will not reach the author
unless they happen to be subscribed to this list.
=== Description (from pull-request) ===
- Where instance.Instance can satisfy dependency, uses that.
- Otherwise uses containerLXC directly.
From 8b6d7fcd51fd8d948d1a34bebc67ed451cde593e Mon Sep 17 00:00:00 2001
From: Thomas Parrott <thomas.parr...@canonical.com>
Date: Mon, 25 Nov 2019 10:49:53 +0000
Subject: [PATCH 1/3] lxd: Instance is not container type error consistency
Signed-off-by: Thomas Parrott <thomas.parr...@canonical.com>
---
lxd/container.go | 2 +-
lxd/container_snapshot.go | 2 +-
lxd/migrate_container.go | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/lxd/container.go b/lxd/container.go
index 54ab1691d7..daf9da1394 100644
--- a/lxd/container.go
+++ b/lxd/container.go
@@ -763,7 +763,7 @@ func instanceCreateAsCopy(s *state.State, args
db.InstanceArgs, sourceInst insta
func containerCreateAsSnapshot(s *state.State, args db.InstanceArgs,
sourceInstance instance.Instance) (instance.Instance, error) {
if sourceInstance.Type() != instancetype.Container {
- return nil, fmt.Errorf("Instance not container type")
+ return nil, fmt.Errorf("Instance is not container type")
}
// Deal with state
diff --git a/lxd/container_snapshot.go b/lxd/container_snapshot.go
index f0b37f1ff8..4ad2de4b1d 100644
--- a/lxd/container_snapshot.go
+++ b/lxd/container_snapshot.go
@@ -220,7 +220,7 @@ func containerSnapshotHandler(d *Daemon, r *http.Request)
response.Response {
}
if inst.Type() != instancetype.Container {
- return response.SmartError(fmt.Errorf("Instance not container
type"))
+ return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
sc := inst.(container)
diff --git a/lxd/migrate_container.go b/lxd/migrate_container.go
index 739f75cdb5..4acbe28c7c 100644
--- a/lxd/migrate_container.go
+++ b/lxd/migrate_container.go
@@ -255,7 +255,7 @@ func (s *migrationSourceWs) preDumpLoop(args
*preDumpLoopArgs) (bool, error) {
final := args.final
if s.instance.Type() != instancetype.Container {
- return false, fmt.Errorf("Instance not container type")
+ return false, fmt.Errorf("Instance is not container type")
}
c := s.instance.(container)
@@ -343,7 +343,7 @@ func (s *migrationSourceWs) Do(migrateOp
*operations.Operation) error {
}
if s.instance.Type() != instancetype.Container {
- return fmt.Errorf("Instance not container type")
+ return fmt.Errorf("Instance is not container type")
}
c := s.instance.(container)
From 77542e9ffb471cbbf12fba2195eb999050aff2d1 Mon Sep 17 00:00:00 2001
From: Thomas Parrott <thomas.parr...@canonical.com>
Date: Mon, 25 Nov 2019 12:19:26 +0000
Subject: [PATCH 2/3] lxd/container: Removes container type
- Will use instance.Instance, containerLXC or vmQemu instead.
Signed-off-by: Thomas Parrott <thomas.parr...@canonical.com>
---
lxd/container.go | 27 ---------------------------
1 file changed, 27 deletions(-)
diff --git a/lxd/container.go b/lxd/container.go
index daf9da1394..38069bed62 100644
--- a/lxd/container.go
+++ b/lxd/container.go
@@ -33,7 +33,6 @@ import (
"github.com/lxc/lxd/lxd/task"
"github.com/lxc/lxd/shared"
"github.com/lxc/lxd/shared/api"
- "github.com/lxc/lxd/shared/idmap"
"github.com/lxc/lxd/shared/ioprogress"
log "github.com/lxc/lxd/shared/log15"
"github.com/lxc/lxd/shared/logger"
@@ -256,32 +255,6 @@ func instanceValidDevices(state *state.State, cluster
*db.Cluster, instanceType
return nil
}
-// The container interface
-type container interface {
- instance.Instance
-
- /* actionScript here is a script called action.sh in the stateDir, to
- * be passed to CRIU as --action-script
- */
- Migrate(args *CriuMigrationArgs) error
-
- ConsoleLog(opts lxc.ConsoleLogOptions) (string, error)
-
- // Status
- IsNesting() bool
-
- // Hooks
- OnStart() error
- OnStopNS(target string, netns string) error
- OnStop(target string) error
-
- InsertSeccompUnixDevice(prefix string, m deviceConfig.Device, pid int)
error
-
- CurrentIdmap() (*idmap.IdmapSet, error)
- DiskIdmap() (*idmap.IdmapSet, error)
- NextIdmap() (*idmap.IdmapSet, error)
-}
-
// instanceCreateAsEmpty creates an empty instance.
func instanceCreateAsEmpty(d *Daemon, args db.InstanceArgs)
(instance.Instance, error) {
// Create the instance record.
From 7203430ffafcd551674d23ba7d58dd8101ffcb26 Mon Sep 17 00:00:00 2001
From: Thomas Parrott <thomas.parr...@canonical.com>
Date: Mon, 25 Nov 2019 12:20:05 +0000
Subject: [PATCH 3/3] lxd: Removes use of container type
- Where instance.Instance can satisfy dependency, uses that.
- Otherwise uses containerLXC directly.
Signed-off-by: Thomas Parrott <thomas.parr...@canonical.com>
---
lxd/api_internal.go | 6 +++---
lxd/container.go | 2 +-
lxd/container_console.go | 4 ++--
lxd/container_exec.go | 2 +-
lxd/container_lxc.go | 6 +++---
lxd/container_post.go | 3 +--
lxd/container_snapshot.go | 23 ++++++++++-------------
lxd/devlxd.go | 27 ++++++++++++++-------------
lxd/migrate_container.go | 8 +++-----
lxd/storage.go | 6 +++---
lxd/storage_btrfs.go | 3 +--
lxd/storage_ceph.go | 4 ++--
lxd/storage_ceph_utils.go | 2 +-
lxd/storage_dir.go | 2 +-
lxd/storage_lvm.go | 4 ++--
lxd/storage_lvm_utils.go | 2 +-
lxd/storage_migration.go | 6 +++---
lxd/storage_utils.go | 3 ++-
lxd/storage_zfs.go | 4 ++--
19 files changed, 56 insertions(+), 61 deletions(-)
diff --git a/lxd/api_internal.go b/lxd/api_internal.go
index 934ea7ad7c..957b0107b7 100644
--- a/lxd/api_internal.go
+++ b/lxd/api_internal.go
@@ -135,7 +135,7 @@ func internalContainerOnStart(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
+ c := inst.(*containerLXC)
err = c.OnStart()
if err != nil {
logger.Error("The start hook failed", log.Ctx{"container":
c.Name(), "err": err})
@@ -166,7 +166,7 @@ func internalContainerOnStopNS(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
+ c := inst.(*containerLXC)
err = c.OnStopNS(target, netns)
if err != nil {
logger.Error("The stopns hook failed", log.Ctx{"container":
c.Name(), "err": err})
@@ -196,7 +196,7 @@ func internalContainerOnStop(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
+ c := inst.(*containerLXC)
err = c.OnStop(target)
if err != nil {
logger.Error("The stop hook failed", log.Ctx{"container":
c.Name(), "err": err})
diff --git a/lxd/container.go b/lxd/container.go
index 38069bed62..d95bcbf389 100644
--- a/lxd/container.go
+++ b/lxd/container.go
@@ -776,7 +776,7 @@ func containerCreateAsSnapshot(s *state.State, args
db.InstanceArgs, sourceInsta
preDumpDir: "",
}
- c := sourceInstance.(container)
+ c := sourceInstance.(*containerLXC)
err = c.Migrate(&criuMigrationArgs)
if err != nil {
os.RemoveAll(sourceInstance.StatePath())
diff --git a/lxd/container_console.go b/lxd/container_console.go
index 3ac9fd45e0..41440db208 100644
--- a/lxd/container_console.go
+++ b/lxd/container_console.go
@@ -352,7 +352,7 @@ func containerConsoleLogGet(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
+ c := inst.(*containerLXC)
ent := response.FileResponseEntry{}
if !c.IsRunning() {
// Hand back the contents of the console ringbuffer logfile.
@@ -406,7 +406,7 @@ func containerConsoleLogDelete(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
+ c := inst.(*containerLXC)
truncateConsoleLogFile := func(path string) error {
// Check that this is a regular file. We don't want to try and
unlink
diff --git a/lxd/container_exec.go b/lxd/container_exec.go
index de7e6ded6d..dd2e95c2d6 100644
--- a/lxd/container_exec.go
+++ b/lxd/container_exec.go
@@ -434,7 +434,7 @@ func containerExecPost(d *Daemon, r *http.Request)
response.Response {
ws.fds = map[int]string{}
if inst.Type() == instancetype.Container {
- c := inst.(container)
+ c := inst.(*containerLXC)
idmapset, err := c.CurrentIdmap()
if err != nil {
return response.InternalError(err)
diff --git a/lxd/container_lxc.go b/lxd/container_lxc.go
index 5b03cfd138..c93b7c22bf 100644
--- a/lxd/container_lxc.go
+++ b/lxd/container_lxc.go
@@ -236,7 +236,7 @@ func lxcStatusCode(state lxc.State) api.StatusCode {
}
// Loader functions
-func containerLXCCreate(s *state.State, args db.InstanceArgs) (container,
error) {
+func containerLXCCreate(s *state.State, args db.InstanceArgs)
(instance.Instance, error) {
// Create the container struct
c := &containerLXC{
state: s,
@@ -442,7 +442,7 @@ func containerLXCCreate(s *state.State, args
db.InstanceArgs) (container, error)
return c, nil
}
-func containerLXCLoad(s *state.State, args db.InstanceArgs, profiles
[]api.Profile) (container, error) {
+func containerLXCLoad(s *state.State, args db.InstanceArgs, profiles
[]api.Profile) (instance.Instance, error) {
// Create the container struct
c := containerLXCInstantiate(s, args)
@@ -5097,7 +5097,7 @@ func (c *containerLXC) Export(w io.Writer, properties
map[string]string) error {
return nil
}
-func collectCRIULogFile(c container, imagesDir string, function string, method
string) error {
+func collectCRIULogFile(c instance.Instance, imagesDir string, function
string, method string) error {
t := time.Now().Format(time.RFC3339)
newPath := shared.LogPath(c.Name(), fmt.Sprintf("%s_%s_%s.log",
function, method, t))
return shared.FileCopy(filepath.Join(imagesDir, fmt.Sprintf("%s.log",
method)), newPath)
diff --git a/lxd/container_post.go b/lxd/container_post.go
index 65010b9338..b8b6ba8592 100644
--- a/lxd/container_post.go
+++ b/lxd/container_post.go
@@ -211,8 +211,7 @@ func containerPost(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- c := inst.(container)
- ws, err := NewMigrationSource(c, stateful, instanceOnly)
+ ws, err := NewMigrationSource(inst, stateful, instanceOnly)
if err != nil {
return response.InternalError(err)
}
diff --git a/lxd/container_snapshot.go b/lxd/container_snapshot.go
index 4ad2de4b1d..06f463b048 100644
--- a/lxd/container_snapshot.go
+++ b/lxd/container_snapshot.go
@@ -13,6 +13,7 @@ import (
"github.com/gorilla/mux"
"github.com/lxc/lxd/lxd/db"
+ "github.com/lxc/lxd/lxd/instance"
"github.com/lxc/lxd/lxd/instance/instancetype"
"github.com/lxc/lxd/lxd/operations"
"github.com/lxc/lxd/lxd/response"
@@ -167,9 +168,7 @@ func containerSnapshotsPost(d *Daemon, r *http.Request)
response.Response {
return fmt.Errorf("Instance is not container type")
}
- c := inst.(container)
-
- _, err := containerCreateAsSnapshot(d.State(), args, c)
+ _, err := containerCreateAsSnapshot(d.State(), args, inst)
if err != nil {
return err
}
@@ -223,23 +222,21 @@ func containerSnapshotHandler(d *Daemon, r *http.Request)
response.Response {
return response.SmartError(fmt.Errorf("Instance is not
container type"))
}
- sc := inst.(container)
-
switch r.Method {
case "GET":
- return snapshotGet(sc, snapshotName)
+ return snapshotGet(inst, snapshotName)
case "POST":
- return snapshotPost(d, r, sc, containerName)
+ return snapshotPost(d, r, inst, containerName)
case "DELETE":
- return snapshotDelete(sc, snapshotName)
+ return snapshotDelete(inst, snapshotName)
case "PUT":
- return snapshotPut(d, r, sc, snapshotName)
+ return snapshotPut(d, r, inst, snapshotName)
default:
return response.NotFound(fmt.Errorf("Method '%s' not found",
r.Method))
}
}
-func snapshotPut(d *Daemon, r *http.Request, sc container, name string)
response.Response {
+func snapshotPut(d *Daemon, r *http.Request, sc instance.Instance, name
string) response.Response {
// Validate the ETag
etag := []interface{}{sc.ExpiryDate()}
err := util.EtagCheck(r, etag)
@@ -313,7 +310,7 @@ func snapshotPut(d *Daemon, r *http.Request, sc container,
name string) response
return operations.OperationResponse(op)
}
-func snapshotGet(sc container, name string) response.Response {
+func snapshotGet(sc instance.Instance, name string) response.Response {
render, _, err := sc.Render()
if err != nil {
return response.SmartError(err)
@@ -322,7 +319,7 @@ func snapshotGet(sc container, name string)
response.Response {
return response.SyncResponse(true, render.(*api.InstanceSnapshot))
}
-func snapshotPost(d *Daemon, r *http.Request, sc container, containerName
string) response.Response {
+func snapshotPost(d *Daemon, r *http.Request, sc instance.Instance,
containerName string) response.Response {
body, err := ioutil.ReadAll(r.Body)
if err != nil {
return response.InternalError(err)
@@ -432,7 +429,7 @@ func snapshotPost(d *Daemon, r *http.Request, sc container,
containerName string
return operations.OperationResponse(op)
}
-func snapshotDelete(sc container, name string) response.Response {
+func snapshotDelete(sc instance.Instance, name string) response.Response {
remove := func(op *operations.Operation) error {
return sc.Delete()
}
diff --git a/lxd/devlxd.go b/lxd/devlxd.go
index 24fb8811b3..aa113de9c9 100644
--- a/lxd/devlxd.go
+++ b/lxd/devlxd.go
@@ -18,6 +18,7 @@ import (
"github.com/gorilla/mux"
"github.com/lxc/lxd/lxd/daemon"
+ "github.com/lxc/lxd/lxd/instance"
"github.com/lxc/lxd/lxd/instance/instancetype"
"github.com/lxc/lxd/lxd/project"
"github.com/lxc/lxd/lxd/state"
@@ -56,10 +57,10 @@ type devLxdHandler struct {
* server side right now either, I went the simple route to avoid
* needless noise.
*/
- f func(d *Daemon, c container, w http.ResponseWriter, r *http.Request)
*devLxdResponse
+ f func(d *Daemon, c instance.Instance, w http.ResponseWriter, r
*http.Request) *devLxdResponse
}
-var devlxdConfigGet = devLxdHandler{"/1.0/config", func(d *Daemon, c
container, w http.ResponseWriter, r *http.Request) *devLxdResponse {
+var devlxdConfigGet = devLxdHandler{"/1.0/config", func(d *Daemon, c
instance.Instance, w http.ResponseWriter, r *http.Request) *devLxdResponse {
filtered := []string{}
for k := range c.ExpandedConfig() {
if strings.HasPrefix(k, "user.") {
@@ -69,7 +70,7 @@ var devlxdConfigGet = devLxdHandler{"/1.0/config", func(d
*Daemon, c container,
return okResponse(filtered, "json")
}}
-var devlxdConfigKeyGet = devLxdHandler{"/1.0/config/{key}", func(d *Daemon, c
container, w http.ResponseWriter, r *http.Request) *devLxdResponse {
+var devlxdConfigKeyGet = devLxdHandler{"/1.0/config/{key}", func(d *Daemon, c
instance.Instance, w http.ResponseWriter, r *http.Request) *devLxdResponse {
key := mux.Vars(r)["key"]
if !strings.HasPrefix(key, "user.") {
return &devLxdResponse{"not authorized", http.StatusForbidden,
"raw"}
@@ -83,7 +84,7 @@ var devlxdConfigKeyGet = devLxdHandler{"/1.0/config/{key}",
func(d *Daemon, c co
return okResponse(value, "raw")
}}
-var devlxdImageExport = devLxdHandler{"/1.0/images/{fingerprint}/export",
func(d *Daemon, c container, w http.ResponseWriter, r *http.Request)
*devLxdResponse {
+var devlxdImageExport = devLxdHandler{"/1.0/images/{fingerprint}/export",
func(d *Daemon, c instance.Instance, w http.ResponseWriter, r *http.Request)
*devLxdResponse {
if !shared.IsTrue(c.ExpandedConfig()["security.devlxd.images"]) {
return &devLxdResponse{"not authorized", http.StatusForbidden,
"raw"}
}
@@ -100,12 +101,12 @@ var devlxdImageExport =
devLxdHandler{"/1.0/images/{fingerprint}/export", func(d
return &devLxdResponse{"", http.StatusOK, "raw"}
}}
-var devlxdMetadataGet = devLxdHandler{"/1.0/meta-data", func(d *Daemon, c
container, w http.ResponseWriter, r *http.Request) *devLxdResponse {
+var devlxdMetadataGet = devLxdHandler{"/1.0/meta-data", func(d *Daemon, c
instance.Instance, w http.ResponseWriter, r *http.Request) *devLxdResponse {
value := c.ExpandedConfig()["user.meta-data"]
return okResponse(fmt.Sprintf("#cloud-config\ninstance-id:
%s\nlocal-hostname: %s\n%s", c.Name(), c.Name(), value), "raw")
}}
-var devlxdEventsGet = devLxdHandler{"/1.0/events", func(d *Daemon, c
container, w http.ResponseWriter, r *http.Request) *devLxdResponse {
+var devlxdEventsGet = devLxdHandler{"/1.0/events", func(d *Daemon, c
instance.Instance, w http.ResponseWriter, r *http.Request) *devLxdResponse {
typeStr := r.FormValue("type")
if typeStr == "" {
typeStr = "config,device"
@@ -150,7 +151,7 @@ var devlxdEventsGet = devLxdHandler{"/1.0/events", func(d
*Daemon, c container,
return &devLxdResponse{"websocket", http.StatusOK, "websocket"}
}}
-func devlxdEventSend(c container, eventType string, eventMessage interface{})
error {
+func devlxdEventSend(c instance.Instance, eventType string, eventMessage
interface{}) error {
event := shared.Jmap{}
event["type"] = eventType
event["timestamp"] = time.Now()
@@ -160,10 +161,10 @@ func devlxdEventSend(c container, eventType string,
eventMessage interface{}) er
}
var handlers = []devLxdHandler{
- {"/", func(d *Daemon, c container, w http.ResponseWriter, r
*http.Request) *devLxdResponse {
+ {"/", func(d *Daemon, c instance.Instance, w http.ResponseWriter, r
*http.Request) *devLxdResponse {
return okResponse([]string{"/1.0"}, "json")
}},
- {"/1.0", func(d *Daemon, c container, w http.ResponseWriter, r
*http.Request) *devLxdResponse {
+ {"/1.0", func(d *Daemon, c instance.Instance, w http.ResponseWriter, r
*http.Request) *devLxdResponse {
return okResponse(shared.Jmap{"api_version":
version.APIVersion}, "json")
}},
devlxdConfigGet,
@@ -173,7 +174,7 @@ var handlers = []devLxdHandler{
devlxdImageExport,
}
-func hoistReq(f func(*Daemon, container, http.ResponseWriter, *http.Request)
*devLxdResponse, d *Daemon) func(http.ResponseWriter, *http.Request) {
+func hoistReq(f func(*Daemon, instance.Instance, http.ResponseWriter,
*http.Request) *devLxdResponse, d *Daemon) func(http.ResponseWriter,
*http.Request) {
return func(w http.ResponseWriter, r *http.Request) {
conn := extractUnderlyingConn(w)
cred, ok := pidMapper.m[conn]
@@ -317,7 +318,7 @@ func extractUnderlyingConn(w http.ResponseWriter)
*net.UnixConn {
var pidNotInContainerErr = fmt.Errorf("pid not in container?")
-func findContainerForPid(pid int32, s *state.State) (container, error) {
+func findContainerForPid(pid int32, s *state.State) (*containerLXC, error) {
/*
* Try and figure out which container a pid is in. There is probably a
* better way to do this. Based on rharper's initial performance
@@ -364,7 +365,7 @@ func findContainerForPid(pid int32, s *state.State)
(container, error) {
return nil, fmt.Errorf("Instance is not
container type")
}
- c := inst.(container)
+ c := inst.(*containerLXC)
return c, nil
}
@@ -414,7 +415,7 @@ func findContainerForPid(pid int32, s *state.State)
(container, error) {
}
if origPidNs == pidNs {
- return inst.(container), nil
+ return inst.(*containerLXC), nil
}
}
diff --git a/lxd/migrate_container.go b/lxd/migrate_container.go
index 4acbe28c7c..280a94311f 100644
--- a/lxd/migrate_container.go
+++ b/lxd/migrate_container.go
@@ -142,8 +142,7 @@ func (s *migrationSourceWs) checkForPreDumpSupport() (bool,
int) {
return false, 0
}
- c := s.instance.(container)
-
+ c := s.instance.(*containerLXC)
err := c.Migrate(&criuMigrationArgs)
if err != nil {
@@ -258,8 +257,7 @@ func (s *migrationSourceWs) preDumpLoop(args
*preDumpLoopArgs) (bool, error) {
return false, fmt.Errorf("Instance is not container type")
}
- c := s.instance.(container)
-
+ c := s.instance.(*containerLXC)
err := c.Migrate(&criuMigrationArgs)
if err != nil {
return final, err
@@ -346,7 +344,7 @@ func (s *migrationSourceWs) Do(migrateOp
*operations.Operation) error {
return fmt.Errorf("Instance is not container type")
}
- c := s.instance.(container)
+ c := s.instance.(*containerLXC)
// Storage needs to start unconditionally now, since we need to
// initialize a new storage interface.
diff --git a/lxd/storage.go b/lxd/storage.go
index 4fca279fca..64172414df 100644
--- a/lxd/storage.go
+++ b/lxd/storage.go
@@ -436,7 +436,7 @@ func storagePoolInit(s *state.State, poolName string)
(storage, error) {
return storageInit(s, "default", poolName, "", -1)
}
-func storagePoolVolumeAttachInit(s *state.State, poolName string, volumeName
string, volumeType int, c container) (storage, error) {
+func storagePoolVolumeAttachInit(s *state.State, poolName string, volumeName
string, volumeType int, c *containerLXC) (storage, error) {
st, err := storageInit(s, "default", poolName, volumeName, volumeType)
if err != nil {
return nil, err
@@ -505,7 +505,7 @@ func storagePoolVolumeAttachInit(s *state.State, poolName
string, volumeName str
continue
}
- ct := instt.(container)
+ ct := instt.(*containerLXC)
var ctNextIdmap *idmap.IdmapSet
if ct.IsRunning() {
@@ -712,7 +712,7 @@ func deleteSnapshotMountpoint(snapshotMountpoint string,
snapshotsSymlinkTarget
return nil
}
-func resetContainerDiskIdmap(container container, srcIdmap *idmap.IdmapSet)
error {
+func resetContainerDiskIdmap(container *containerLXC, srcIdmap
*idmap.IdmapSet) error {
dstIdmap, err := container.DiskIdmap()
if err != nil {
return err
diff --git a/lxd/storage_btrfs.go b/lxd/storage_btrfs.go
index 99fa8d264d..d800f931e3 100644
--- a/lxd/storage_btrfs.go
+++ b/lxd/storage_btrfs.go
@@ -2701,11 +2701,10 @@ func (s *storageBtrfs) btrfsLookupFsUUID(fs string)
(string, error) {
func (s *storageBtrfs) StorageEntitySetQuota(volumeType int, size int64, data
interface{}) error {
logger.Debugf(`Setting BTRFS quota for "%s"`, s.volume.Name)
- var c container
+ var c instance.Instance
var subvol string
switch volumeType {
case storagePoolVolumeTypeContainer:
- c = data.(container)
subvol = driver.GetContainerMountPoint(c.Project(),
s.pool.Name, c.Name())
case storagePoolVolumeTypeCustom:
subvol = driver.GetStoragePoolVolumeMountPoint(s.pool.Name,
s.volume.Name)
diff --git a/lxd/storage_ceph.go b/lxd/storage_ceph.go
index 2b19a9134a..30be16af00 100644
--- a/lxd/storage_ceph.go
+++ b/lxd/storage_ceph.go
@@ -2379,14 +2379,14 @@ func (s *storageCeph) StorageEntitySetQuota(volumeType
int, size int64, data int
}
var ret int
- var c container
+ var c instance.Instance
fsType := s.getRBDFilesystem()
mountpoint := ""
RBDDevPath := ""
volumeName := ""
switch volumeType {
case storagePoolVolumeTypeContainer:
- c = data.(container)
+ c = data.(instance.Instance)
ctName := c.Name()
if c.IsRunning() {
msg := fmt.Sprintf(`Cannot resize RBD storage volume `+
diff --git a/lxd/storage_ceph_utils.go b/lxd/storage_ceph_utils.go
index 41cf3e8e97..f5d5b75f74 100644
--- a/lxd/storage_ceph_utils.go
+++ b/lxd/storage_ceph_utils.go
@@ -1553,7 +1553,7 @@ func (s *storageCeph) rbdGrow(path string, size int64,
fsType string,
// Mount the filesystem
switch volumeType {
case storagePoolVolumeTypeContainer:
- c := data.(container)
+ c := data.(instance.Instance)
ourMount, err := c.StorageStart()
if err != nil {
return err
diff --git a/lxd/storage_dir.go b/lxd/storage_dir.go
index a72fc65b66..e9db7b8c23 100644
--- a/lxd/storage_dir.go
+++ b/lxd/storage_dir.go
@@ -1309,7 +1309,7 @@ func (s *storageDir) StorageEntitySetQuota(volumeType
int, size int64, data inte
var path string
switch volumeType {
case storagePoolVolumeTypeContainer:
- c := data.(container)
+ c := data.(instance.Instance)
path = driver.GetContainerMountPoint(c.Project(), s.pool.Name,
c.Name())
case storagePoolVolumeTypeCustom:
path = driver.GetStoragePoolVolumeMountPoint(s.pool.Name,
s.volume.Name)
diff --git a/lxd/storage_lvm.go b/lxd/storage_lvm.go
index 8fef0f4735..e13a9652f6 100644
--- a/lxd/storage_lvm.go
+++ b/lxd/storage_lvm.go
@@ -2074,13 +2074,13 @@ func (s *storageLvm) StorageEntitySetQuota(volumeType
int, size int64, data inte
}
poolName := s.getOnDiskPoolName()
- var c container
+ var c instance.Instance
fsType := s.getLvmFilesystem()
lvDevPath := ""
mountpoint := ""
switch volumeType {
case storagePoolVolumeTypeContainer:
- c = data.(container)
+ c = data.(instance.Instance)
ctName := c.Name()
if c.IsRunning() {
msg := fmt.Sprintf(`Cannot resize LVM storage volume `+
diff --git a/lxd/storage_lvm_utils.go b/lxd/storage_lvm_utils.go
index c6cdaf0793..cec7c223f9 100644
--- a/lxd/storage_lvm_utils.go
+++ b/lxd/storage_lvm_utils.go
@@ -41,7 +41,7 @@ func (s *storageLvm) lvExtend(lvPath string, lvSize int64,
fsType string, fsMntP
switch volumeType {
case storagePoolVolumeTypeContainer:
- c := data.(container)
+ c := data.(instance.Instance)
ourMount, err := c.StorageStart()
if err != nil {
return err
diff --git a/lxd/storage_migration.go b/lxd/storage_migration.go
index c1bcdd2c37..19626c1375 100644
--- a/lxd/storage_migration.go
+++ b/lxd/storage_migration.go
@@ -369,7 +369,7 @@ func rsyncMigrationSink(conn *websocket.Conn, op
*operations.Operation, args Mig
}
if args.Instance.Type() ==
instancetype.Container {
- c := args.Instance.(container)
+ c := args.Instance.(*containerLXC)
err = resetContainerDiskIdmap(c,
args.Idmap)
if err != nil {
return err
@@ -423,7 +423,7 @@ func rsyncMigrationSink(conn *websocket.Conn, op
*operations.Operation, args Mig
}
if args.Instance.Type() ==
instancetype.Container {
- c := args.Instance.(container)
+ c := args.Instance.(*containerLXC)
err = resetContainerDiskIdmap(c,
args.Idmap)
if err != nil {
return err
@@ -458,7 +458,7 @@ func rsyncMigrationSink(conn *websocket.Conn, op
*operations.Operation, args Mig
}
if args.Instance.Type() == instancetype.Container {
- c := args.Instance.(container)
+ c := args.Instance.(*containerLXC)
err = resetContainerDiskIdmap(c, args.Idmap)
if err != nil {
return err
diff --git a/lxd/storage_utils.go b/lxd/storage_utils.go
index fd4ecf11bd..468a1982ff 100644
--- a/lxd/storage_utils.go
+++ b/lxd/storage_utils.go
@@ -3,6 +3,7 @@ package main
import (
"fmt"
+ "github.com/lxc/lxd/lxd/instance"
driver "github.com/lxc/lxd/lxd/storage"
"github.com/lxc/lxd/shared/logger"
)
@@ -20,7 +21,7 @@ func shrinkVolumeFilesystem(s storage, volumeType int, fsType
string, devPath st
case "ext4":
switch volumeType {
case storagePoolVolumeTypeContainer:
- c := data.(container)
+ c := data.(instance.Instance)
ourMount, err := c.StorageStop()
if err != nil {
return nil, err
diff --git a/lxd/storage_zfs.go b/lxd/storage_zfs.go
index f154dcb1fe..1692a3be23 100644
--- a/lxd/storage_zfs.go
+++ b/lxd/storage_zfs.go
@@ -2743,11 +2743,11 @@ func (s *storageZfs) StorageEntitySetQuota(volumeType
int, size int64, data inte
return fmt.Errorf("Invalid storage type")
}
- var c container
+ var c instance.Instance
var fs string
switch volumeType {
case storagePoolVolumeTypeContainer:
- c = data.(container)
+ c = data.(instance.Instance)
fs = fmt.Sprintf("containers/%s", project.Prefix(c.Project(),
c.Name()))
case storagePoolVolumeTypeCustom:
fs = fmt.Sprintf("custom/%s", s.volume.Name)
_______________________________________________
lxc-devel mailing list
lxc-devel@lists.linuxcontainers.org
http://lists.linuxcontainers.org/listinfo/lxc-devel
