Skip to content

Commit faca1a2

Browse files
committed
small fix to TagsToGroupID and batch timings
1 parent 541ac20 commit faca1a2

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

batch.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,7 @@ func (b *BatchNode) doQuery() error {
269269
}
270270
if err != nil {
271271
b.logger.Println("E! failed to connect to InfluxDB:", err)
272+
b.timer.Stop()
272273
break
273274
}
274275
q := client.Query{
@@ -279,11 +280,13 @@ func (b *BatchNode) doQuery() error {
279280
resp, err := con.Query(q)
280281
if err != nil {
281282
b.logger.Println("E! query failed:", err)
283+
b.timer.Stop()
282284
break
283285
}
284286

285287
if err := resp.Error(); err != nil {
286288
b.logger.Println("E! query failed:", err)
289+
b.timer.Stop()
287290
break
288291
}
289292

models/point.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -150,10 +150,10 @@ func TagsToGroupID(dims []string, tags map[string]string) GroupID {
150150
}
151151
var buf bytes.Buffer
152152
for _, d := range dims {
153-
buf.Write([]byte(d))
154-
buf.Write([]byte("="))
155-
buf.Write([]byte(tags[d]))
156-
buf.Write([]byte(","))
153+
buf.WriteString(d)
154+
buf.WriteString("=")
155+
buf.WriteString(tags[d])
156+
buf.WriteString(",")
157157
}
158158
return GroupID(buf.Bytes())
159159
}

0 commit comments

Comments
 (0)