commit
0918a70c49
@ -276,7 +276,7 @@ func (self *dockerContainerHandler) GetStats() (*info.ContainerStats, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func convertInterfaceStats(stats *info.InterfaceStats) {
|
func convertInterfaceStats(stats *info.InterfaceStats) {
|
||||||
net := stats
|
net := *stats
|
||||||
|
|
||||||
// Ingress for host veth is from the container.
|
// Ingress for host veth is from the container.
|
||||||
// Hence tx_bytes stat on the host veth is actually number of bytes received by the container.
|
// Hence tx_bytes stat on the host veth is actually number of bytes received by the container.
|
||||||
|
@ -249,7 +249,7 @@ func TestDockerContainerNetworkStats(t *testing.T) {
|
|||||||
defer fm.Cleanup()
|
defer fm.Cleanup()
|
||||||
|
|
||||||
// Wait for the container to show up.
|
// Wait for the container to show up.
|
||||||
containerId := fm.Docker().RunBusybox("ping", "www.google.com")
|
containerId := fm.Docker().RunBusybox("sh", "-c", "wget www.google.com && ping www.google.com")
|
||||||
waitForContainer(containerId, fm)
|
waitForContainer(containerId, fm)
|
||||||
|
|
||||||
request := &info.ContainerInfoRequest{
|
request := &info.ContainerInfoRequest{
|
||||||
@ -261,7 +261,11 @@ func TestDockerContainerNetworkStats(t *testing.T) {
|
|||||||
|
|
||||||
// Checks for NetworkStats.
|
// Checks for NetworkStats.
|
||||||
stat := containerInfo.Stats[0]
|
stat := containerInfo.Stats[0]
|
||||||
assert.NotEqual(t, 0, stat.Network.TxBytes, "Network tx bytes should not be zero")
|
assert := assert.New(t)
|
||||||
assert.NotEqual(t, 0, stat.Network.TxPackets, "Network tx packets should not be zero")
|
assert.NotEqual(0, stat.Network.TxBytes, "Network tx bytes should not be zero")
|
||||||
// TODO(vmarmol): Can probably do a better test with two containers pinging each other.
|
assert.NotEqual(0, stat.Network.TxPackets, "Network tx packets should not be zero")
|
||||||
|
assert.NotEqual(0, stat.Network.RxBytes, "Network rx bytes should not be zero")
|
||||||
|
assert.NotEqual(0, stat.Network.RxPackets, "Network rx packets should not be zero")
|
||||||
|
assert.NotEqual(stat.Network.RxBytes, stat.Network.TxBytes, "Network tx and rx bytes should not be equal")
|
||||||
|
assert.NotEqual(stat.Network.RxPackets, stat.Network.TxPackets, "Network tx and rx packets should not be equal")
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user