1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
package main
import (
"fmt"
"os"
"testing"
)
func TestRoundJava(t *testing.T) {
for _, tc := range []struct {
value float64
expected string
}{
{value: -1.5, expected: "-1.0"},
{value: -1.0, expected: "-1.0"},
{value: -0.7, expected: "-1.0"},
{value: -0.5, expected: "0.0"},
{value: -0.3, expected: "0.0"},
{value: 0.0, expected: "0.0"},
{value: 0.3, expected: "0.0"},
{value: 0.5, expected: "1.0"},
{value: 0.7, expected: "1.0"},
{value: 1.0, expected: "1.0"},
{value: 1.5, expected: "2.0"},
} {
if rounded := roundJava(tc.value); fmt.Sprintf("%.1f", rounded) != tc.expected {
t.Errorf("Wrong rounding of %v, expected: %s, got: %.1f", tc.value, tc.expected, rounded)
}
}
}
func TestParseNumber(t *testing.T) {
for _, tc := range []struct {
value string
expected string
}{
{value: "-99.9", expected: "-999"},
{value: "-12.3", expected: "-123"},
{value: "-1.5", expected: "-15"},
{value: "-1.0", expected: "-10"},
{value: "0.0", expected: "0"},
{value: "0.3", expected: "3"},
{value: "12.3", expected: "123"},
{value: "99.9", expected: "999"},
} {
if number := parseNumber([]byte(tc.value)); fmt.Sprintf("%d", number) != tc.expected {
t.Errorf("Wrong parsing of %v, expected: %s, got: %d", tc.value, tc.expected, number)
}
}
}
var parseNumberSink int64
func BenchmarkParseNumber(b *testing.B) {
data1 := []byte("1.2")
data2 := []byte("-12.3")
for i := 0; i < b.N; i++ {
parseNumberSink = parseNumber(data1) + parseNumber(data2)
}
}
func BenchmarkProcess(b *testing.B) {
// $ ./create_measurements.sh 1000000 && mv measurements.txt measurements-1e6.txt
// Created file with 1,000,000 measurements in 514 ms
const filename = "../../../../measurements-1e6.txt"
data, err := os.ReadFile(filename)
if err != nil {
b.Fatal(err)
}
measurements := process(data)
rows := int64(0)
for _, m := range measurements {
rows += m.count
}
b.ReportAllocs()
b.ResetTimer()
b.ReportMetric(float64(rows), "rows/op")
for i := 0; i < b.N; i++ {
process(data)
}
}
|
