mirror of
https://github.com/kata-containers/kata-containers.git
synced 2025-06-30 17:22:33 +00:00
vc: remove BlockIndex from container state
No longer used. Fixes: #1562 Signed-off-by: Peng Tao <bergwolf@hyper.sh>
This commit is contained in:
parent
717a30bfe0
commit
203728676a
@ -361,12 +361,6 @@ func (c *Container) SetPid(pid int) error {
|
|||||||
return c.storeProcess()
|
return c.storeProcess()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Container) setStateBlockIndex(index int) error {
|
|
||||||
c.state.BlockIndex = index
|
|
||||||
|
|
||||||
return c.storeState()
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Container) setStateFstype(fstype string) error {
|
func (c *Container) setStateFstype(fstype string) error {
|
||||||
c.state.Fstype = fstype
|
c.state.Fstype = fstype
|
||||||
|
|
||||||
|
@ -750,100 +750,6 @@ func TestSandboxGetContainer(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestContainerSetStateBlockIndex(t *testing.T) {
|
|
||||||
containers := []ContainerConfig{
|
|
||||||
{
|
|
||||||
ID: "100",
|
|
||||||
Annotations: containerAnnotations,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
hConfig := newHypervisorConfig(nil, nil)
|
|
||||||
sandbox, err := testCreateSandbox(t, testSandboxID, MockHypervisor, hConfig, NoopAgentType, NetworkConfig{}, containers, nil)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
defer cleanUp()
|
|
||||||
|
|
||||||
sandboxStore, err := store.NewVCSandboxStore(sandbox.ctx, sandbox.id)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
sandbox.store = sandboxStore
|
|
||||||
|
|
||||||
c := sandbox.GetContainer("100")
|
|
||||||
if c == nil {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
cImpl, ok := c.(*Container)
|
|
||||||
assert.True(t, ok)
|
|
||||||
|
|
||||||
containerStore, err := store.NewVCContainerStore(sandbox.ctx, sandbox.id, c.ID())
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
cImpl.store = containerStore
|
|
||||||
|
|
||||||
path := store.ContainerRuntimeRootPath(testSandboxID, c.ID())
|
|
||||||
stateFilePath := filepath.Join(path, store.StateFile)
|
|
||||||
|
|
||||||
f, err := os.Create(stateFilePath)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
state := types.ContainerState{
|
|
||||||
State: "stopped",
|
|
||||||
Fstype: "vfs",
|
|
||||||
}
|
|
||||||
|
|
||||||
cImpl.state = state
|
|
||||||
|
|
||||||
stateData := `{
|
|
||||||
"state":"stopped",
|
|
||||||
"fstype":"vfs"
|
|
||||||
}`
|
|
||||||
|
|
||||||
n, err := f.WriteString(stateData)
|
|
||||||
if err != nil || n != len(stateData) {
|
|
||||||
f.Close()
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
f.Close()
|
|
||||||
|
|
||||||
newIndex := 20
|
|
||||||
if err := cImpl.setStateBlockIndex(newIndex); err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if cImpl.state.BlockIndex != newIndex {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
fileData, err := ioutil.ReadFile(stateFilePath)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
var res types.ContainerState
|
|
||||||
err = json.Unmarshal([]byte(string(fileData)), &res)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if res.BlockIndex != newIndex {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
if res.Fstype != state.Fstype {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
if res.State != state.State {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestContainerStateSetFstype(t *testing.T) {
|
func TestContainerStateSetFstype(t *testing.T) {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
@ -889,9 +795,8 @@ func TestContainerStateSetFstype(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
state := types.ContainerState{
|
state := types.ContainerState{
|
||||||
State: "ready",
|
State: "ready",
|
||||||
Fstype: "vfs",
|
Fstype: "vfs",
|
||||||
BlockIndex: 3,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
cImpl.state = state
|
cImpl.state = state
|
||||||
@ -899,7 +804,6 @@ func TestContainerStateSetFstype(t *testing.T) {
|
|||||||
stateData := `{
|
stateData := `{
|
||||||
"state":"ready",
|
"state":"ready",
|
||||||
"fstype":"vfs",
|
"fstype":"vfs",
|
||||||
"blockIndex": 3
|
|
||||||
}`
|
}`
|
||||||
|
|
||||||
n, err := f.WriteString(stateData)
|
n, err := f.WriteString(stateData)
|
||||||
@ -933,10 +837,6 @@ func TestContainerStateSetFstype(t *testing.T) {
|
|||||||
t.Fatal()
|
t.Fatal()
|
||||||
}
|
}
|
||||||
|
|
||||||
if res.BlockIndex != state.BlockIndex {
|
|
||||||
t.Fatal()
|
|
||||||
}
|
|
||||||
|
|
||||||
if res.State != state.State {
|
if res.State != state.State {
|
||||||
t.Fatal()
|
t.Fatal()
|
||||||
}
|
}
|
||||||
|
@ -10,8 +10,6 @@ type ContainerState struct {
|
|||||||
State StateString `json:"state"`
|
State StateString `json:"state"`
|
||||||
|
|
||||||
BlockDeviceID string
|
BlockDeviceID string
|
||||||
// Index of the block device passed to hypervisor.
|
|
||||||
BlockIndex int `json:"blockIndex"`
|
|
||||||
|
|
||||||
// File system of the rootfs incase it is block device
|
// File system of the rootfs incase it is block device
|
||||||
Fstype string `json:"fstype"`
|
Fstype string `json:"fstype"`
|
||||||
|
Loading…
Reference in New Issue
Block a user