github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-01 14:47:38 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/protoparser: avoid copying of buffer read from the network to unmarshal buffer

Browse source
This commit is contained in:
Aliaksandr Valialkin 2020-09-28 17:06:26 +03:00
parent 8df33bd5c1
commit 1481d6d8ff
8 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/protoparser/csvimport/streamparser.go
View file

@ -48,7 +48,7 @@ func ParseStream(req *http.Request, callback func(rows []Row) error) error {
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.cds = cds uw.cds = cds
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()

2
lib/protoparser/graphite/streamparser.go
View file

@ -33,7 +33,7 @@ func ParseStream(r io.Reader, callback func(rows []Row) error) error {
for ctx.Read() { for ctx.Read() {
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()

2
lib/protoparser/influx/streamparser.go
View file

@ -59,7 +59,7 @@ func ParseStream(r io.Reader, isGzipped bool, precision, db string, callback fun
uw.callback = callback uw.callback = callback
uw.db = db uw.db = db
uw.tsMultiplier = tsMultiplier uw.tsMultiplier = tsMultiplier
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()

2
lib/protoparser/opentsdb/streamparser.go
View file

@ -32,7 +32,7 @@ func ParseStream(r io.Reader, callback func(rows []Row) error) error {
for ctx.Read() { for ctx.Read() {
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()

2
lib/protoparser/opentsdbhttp/streamparser.go
View file

@ -59,7 +59,7 @@ func ParseStream(req *http.Request, callback func(rows []Row) error) error {
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf.B...) uw.reqBuf, ctx.reqBuf.B = ctx.reqBuf.B, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
return nil return nil
} }

2
lib/protoparser/prometheus/streamparser.go
View file

@ -34,7 +34,7 @@ func ParseStream(r io.Reader, defaultTimestamp int64, isGzipped bool, callback f
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.defaultTimestamp = defaultTimestamp uw.defaultTimestamp = defaultTimestamp
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()

2
lib/protoparser/promremotewrite/streamparser.go
View file

@ -30,7 +30,7 @@ func ParseStream(req *http.Request, callback func(tss []prompb.TimeSeries) error
} }
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf.B...) uw.reqBuf, ctx.reqBuf.B = ctx.reqBuf.B, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
return nil return nil
} }

2
lib/protoparser/vmimport/streamparser.go
View file

@ -39,7 +39,7 @@ func ParseStream(req *http.Request, callback func(rows []Row) error) error {
for ctx.Read() { for ctx.Read() {
uw := getUnmarshalWork() uw := getUnmarshalWork()
uw.callback = callback uw.callback = callback
uw.reqBuf = append(uw.reqBuf[:0], ctx.reqBuf...) uw.reqBuf, ctx.reqBuf = ctx.reqBuf, uw.reqBuf
common.ScheduleUnmarshalWork(uw) common.ScheduleUnmarshalWork(uw)
} }
return ctx.Error() return ctx.Error()