Function TestDecodeSampleHeader

sflow/decoder_test.go:183–232

(t *testing.T)

}

func TestDecodeSampleHeader(t *testing.T) {
	filter := []uint32{DataCounterSample}
	reader := bytes.NewReader(TestsFlowRawPacket)

	d := NewSFDecoder(reader, filter)

	datagram, err := d.SFDecode()
	if err != nil {
		t.Error("unexpected error", err)
	}

	if len(datagram.Samples) != 5 {
		t.Error("expected samples## 5, got", len(datagram.Samples))
	}

	sample := datagram.Samples[0].(*FlowSample)

	if sample.SequenceNo != 0xa65cc8eb {
		t.Error("expected SequenceNo 0xa65cc8eb, got", sample.SequenceNo)
	}

	if sample.SourceID != 0 {
		t.Error("expected SourceID 0, got", sample.SourceID)
	}

	if sample.SamplingRate != 0x1000 {
		t.Error("expected SamplingRate 0x1000, got", sample.SamplingRate)
	}

	if sample.SamplePool != 0xcc8ec000 {
		t.Error("expected SamplePool 0xcc8ec000, got", sample.SamplePool)
	}

	if sample.Drops != 0 {
		t.Error("expected Drops 0, got", sample.Drops)
	}

	if sample.Input != 0x231 {
		t.Error("expected Input 0x231, got", sample.Input)
	}

	if sample.Output != 0x2c3 {
		t.Error("expected Output 0x2c3, got", sample.Output)
	}

	if sample.RecordsNo != 0x3 {
		t.Error("expected RecordsNo 0x3, got", sample.RecordsNo)
	}

}

func BenchmarkSFDecode(b *testing.B) {
	filter := []uint32{DataCounterSample}