Skip to content

Commit dc896c4

Browse files
Modify order Harvest Host Tests to not collision cached files (#1886)
1 parent c88f8d3 commit dc896c4

File tree

1 file changed

+40
-40
lines changed

1 file changed

+40
-40
lines changed

test/harvest/hostmetrics_linux_test.go

Lines changed: 40 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -64,46 +64,6 @@ func TestHostSharedMemory(t *testing.T) {
6464
})
6565
}
6666

67-
func TestHostCachedMemory(t *testing.T) {
68-
ctx := new(mocks.AgentContext)
69-
ctx.On("Config").Return(&config.Config{
70-
MetricsNetworkSampleRate: 1,
71-
})
72-
storageSampler := storage.NewSampler(ctx)
73-
74-
hostIDProvider := &hostid.ProviderMock{}
75-
hostIDProvider.On("Provide").Return("some-host-id", nil)
76-
77-
systemSampler := metrics.NewSystemSampler(ctx, storageSampler, nil, hostIDProvider)
78-
79-
sampleB, _ := systemSampler.Sample()
80-
beforeSample := sampleB[0].(*metrics.SystemSample)
81-
82-
f, err := ioutil.TempFile("/tmp", "")
83-
assert.NoError(t, err)
84-
defer os.Remove(f.Name())
85-
86-
// Force memory spike
87-
for i := 0; i < 1e5; i++ {
88-
f.Write([]byte("00000000000000000000"))
89-
}
90-
91-
f.Sync()
92-
f.Close()
93-
94-
_, err = ioutil.ReadFile(f.Name())
95-
96-
assert.NoError(t, err)
97-
98-
testhelpers.Eventually(t, timeout, func(st require.TestingT) {
99-
sampleB, _ = systemSampler.Sample()
100-
afterSample := sampleB[0].(*metrics.SystemSample)
101-
102-
expectedIncreaseBytes := 500000.0
103-
assert.True(st, beforeSample.MemoryCachedBytes+expectedIncreaseBytes <= afterSample.MemoryCachedBytes, "CachedMemory used did not increase enough, expected an increase by %f CachedMemoryBefore: %f CachedMemoryAfter %f ", expectedIncreaseBytes, beforeSample.MemoryCachedBytes, afterSample.MemoryCachedBytes)
104-
})
105-
}
106-
10767
func TestHostDisk(t *testing.T) {
10868
ctx := new(mocks.AgentContext)
10969
ctx.On("Config").Return(&config.Config{
@@ -144,6 +104,46 @@ func TestHostDisk(t *testing.T) {
144104
assert.True(t, *storageSample.UsedBytes+1e4 < sampleA.UsedBytes, "Used bytes did not increase enough, UserBytesBefore: %f UserBytesAfter %f ", *(storageSample.UsedBytes), sampleA.UsedBytes)
145105
}
146106

107+
func TestHostCachedMemory(t *testing.T) {
108+
ctx := new(mocks.AgentContext)
109+
ctx.On("Config").Return(&config.Config{
110+
MetricsNetworkSampleRate: 1,
111+
})
112+
storageSampler := storage.NewSampler(ctx)
113+
114+
hostIDProvider := &hostid.ProviderMock{}
115+
hostIDProvider.On("Provide").Return("some-host-id", nil)
116+
117+
systemSampler := metrics.NewSystemSampler(ctx, storageSampler, nil, hostIDProvider)
118+
119+
sampleB, _ := systemSampler.Sample()
120+
beforeSample := sampleB[0].(*metrics.SystemSample)
121+
122+
f, err := ioutil.TempFile("/tmp", "")
123+
assert.NoError(t, err)
124+
defer os.Remove(f.Name())
125+
126+
// Force memory spike
127+
for i := 0; i < 1e5; i++ {
128+
f.Write([]byte("00000000000000000000"))
129+
}
130+
131+
f.Sync()
132+
f.Close()
133+
134+
_, err = ioutil.ReadFile(f.Name())
135+
136+
assert.NoError(t, err)
137+
138+
testhelpers.Eventually(t, timeout, func(st require.TestingT) {
139+
sampleB, _ = systemSampler.Sample()
140+
afterSample := sampleB[0].(*metrics.SystemSample)
141+
142+
expectedIncreaseBytes := 500000.0
143+
assert.True(st, beforeSample.MemoryCachedBytes+expectedIncreaseBytes <= afterSample.MemoryCachedBytes, "CachedMemory used did not increase enough, expected an increase by %f CachedMemoryBefore: %f CachedMemoryAfter %f ", expectedIncreaseBytes, beforeSample.MemoryCachedBytes, afterSample.MemoryCachedBytes)
144+
})
145+
}
146+
147147
func TestHostSlabMemory(t *testing.T) {
148148
ctx := new(mocks.AgentContext)
149149
ctx.On("Config").Return(&config.Config{

0 commit comments

Comments
 (0)