(t *testing.T)
| 144 | } |
| 145 | |
| 146 | func TestGetSampleInfo(t *testing.T) { |
| 147 | filter := []uint32{DataCounterSample} |
| 148 | reader := bytes.NewReader(TestsFlowRawPacket) |
| 149 | // skip sflow header |
| 150 | skip := make([]byte, 4*7) |
| 151 | reader.Read(skip) |
| 152 | |
| 153 | d := NewSFDecoder(reader, filter) |
| 154 | |
| 155 | sizes := []uint32{232, 232, 232, 172, 232} |
| 156 | |
| 157 | for i := 0; i < 5; i++ { |
| 158 | sfTypeFormat, sfDataLength, err := d.getSampleInfo() |
| 159 | if err != nil { |
| 160 | t.Error("unexpected error", err) |
| 161 | } |
| 162 | if sfTypeFormat != 1 { |
| 163 | t.Error("expected type format# 1, got", sfTypeFormat) |
| 164 | } |
| 165 | if sfDataLength != sizes[i] { |
| 166 | t.Error("expected data length: ", sizes[i], ", got", sfDataLength) |
| 167 | } |
| 168 | |
| 169 | d.reader.Seek(int64(sfDataLength), 1) |
| 170 | } |
| 171 | } |
| 172 | |
| 173 | func TestSFDecode(t *testing.T) { |
| 174 | filter := []uint32{DataCounterSample} |
nothing calls this directly
no test coverage detected