@@ -1849,9 +1849,11 @@ func TestOOM_Isolated(t *testing.T) {
1849
1849
containerd .WithSnapshotter (defaultSnapshotterName ),
1850
1850
containerd .WithNewSnapshot ("snapshot-" + vmID , image ),
1851
1851
containerd .WithNewSpec (
1852
- oci .WithProcessArgs ("/bin/dd" , "if=/dev/zero" , "ibs=10M" ),
1853
- firecrackeroci .WithVMID (vmID ),
1852
+ // The container is having 2MB of memory.
1854
1853
oci .WithMemoryLimit (2 * 1024 * 1024 ),
1854
+ // But the dd command allocates 10MB of data on memory, which will be OOM killed.
1855
+ oci .WithProcessArgs ("/bin/dd" , "if=/dev/zero" , "ibs=10M" , "of=/dev/null" ),
1856
+ firecrackeroci .WithVMID (vmID ),
1855
1857
),
1856
1858
)
1857
1859
require .NoError (t , err )
@@ -2057,29 +2059,25 @@ func TestPauseResume_Isolated(t *testing.T) {
2057
2059
fcClient := fccontrol .NewFirecrackerClient (pluginClient .Client ())
2058
2060
2059
2061
subtests := []struct {
2060
- name string
2061
- request * proto.CreateVMRequest
2062
- state func (ctx context.Context , resp * proto.CreateVMResponse )
2062
+ name string
2063
+ state func (ctx context.Context , resp * proto.CreateVMResponse )
2063
2064
}{
2064
2065
{
2065
- name : "PauseVM" ,
2066
- request : & proto.CreateVMRequest {},
2066
+ name : "PauseVM" ,
2067
2067
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2068
2068
_ , err := fcClient .PauseVM (ctx , & proto.PauseVMRequest {VMID : resp .VMID })
2069
2069
require .NoError (t , err )
2070
2070
},
2071
2071
},
2072
2072
{
2073
- name : "ResumeVM" ,
2074
- request : & proto.CreateVMRequest {},
2073
+ name : "ResumeVM" ,
2075
2074
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2076
2075
_ , err := fcClient .ResumeVM (ctx , & proto.ResumeVMRequest {VMID : resp .VMID })
2077
2076
require .NoError (t , err )
2078
2077
},
2079
2078
},
2080
2079
{
2081
- name : "Consecutive PauseVM" ,
2082
- request : & proto.CreateVMRequest {},
2080
+ name : "Consecutive PauseVM" ,
2083
2081
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2084
2082
_ , err := fcClient .PauseVM (ctx , & proto.PauseVMRequest {VMID : resp .VMID })
2085
2083
require .NoError (t , err )
@@ -2089,8 +2087,7 @@ func TestPauseResume_Isolated(t *testing.T) {
2089
2087
},
2090
2088
},
2091
2089
{
2092
- name : "Consecutive ResumeVM" ,
2093
- request : & proto.CreateVMRequest {},
2090
+ name : "Consecutive ResumeVM" ,
2094
2091
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2095
2092
_ , err := fcClient .ResumeVM (ctx , & proto.ResumeVMRequest {VMID : resp .VMID })
2096
2093
require .NoError (t , err )
@@ -2100,8 +2097,7 @@ func TestPauseResume_Isolated(t *testing.T) {
2100
2097
},
2101
2098
},
2102
2099
{
2103
- name : "PauseResume" ,
2104
- request : & proto.CreateVMRequest {},
2100
+ name : "PauseResume" ,
2105
2101
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2106
2102
_ , err := fcClient .PauseVM (ctx , & proto.PauseVMRequest {VMID : resp .VMID })
2107
2103
require .NoError (t , err )
@@ -2111,8 +2107,7 @@ func TestPauseResume_Isolated(t *testing.T) {
2111
2107
},
2112
2108
},
2113
2109
{
2114
- name : "ResumePause" ,
2115
- request : & proto.CreateVMRequest {},
2110
+ name : "ResumePause" ,
2116
2111
state : func (ctx context.Context , resp * proto.CreateVMResponse ) {
2117
2112
_ , err := fcClient .ResumeVM (ctx , & proto.ResumeVMRequest {VMID : resp .VMID })
2118
2113
require .NoError (t , err )
@@ -2164,18 +2159,14 @@ func TestPauseResume_Isolated(t *testing.T) {
2164
2159
2165
2160
for _ , subtest := range subtests {
2166
2161
state := subtest .state
2167
- request := subtest .request
2168
2162
t .Run (subtest .name , func (t * testing.T ) {
2169
- runTest (t , request , state )
2163
+ t .Parallel ()
2164
+ runTest (t , & proto.CreateVMRequest {}, state )
2170
2165
})
2171
2166
2172
- requestWithJailer := subtest .request
2173
- requestWithJailer .JailerConfig = & proto.JailerConfig {
2174
- UID : 30000 ,
2175
- GID : 30000 ,
2176
- }
2177
2167
t .Run (subtest .name + "/Jailer" , func (t * testing.T ) {
2178
- runTest (t , requestWithJailer , state )
2168
+ t .Parallel ()
2169
+ runTest (t , & proto.CreateVMRequest {JailerConfig : & proto.JailerConfig {UID : 30000 , GID : 30000 }}, state )
2179
2170
})
2180
2171
}
2181
2172
}
0 commit comments