Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

wal: Fix the walWriteBytes metric

Browse Source 
Signed-off-by: SimFG <1142838399@qq.com>
This commit is contained in:
SimFG 2022-09-22 16:21:46 +08:00
parent 997260a832
commit 5702765729
2 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/ioutil/pagewriter.go
View File

@ -104,11 +104,6 @@ func (pw *PageWriter) Flush() error {
return err
}
// FlushN flushes buffered data and returns the number of written bytes.
func (pw *PageWriter) FlushN() (int, error) {
return pw.flush()
}
func (pw *PageWriter) flush() (int, error) {
if pw.bufferedBytes == 0 {
return 0, nil

6
server/storage/wal/encoder.go
View File

@ -109,10 +109,8 @@ func encodeFrameSize(dataBytes int) (lenField uint64, padBytes int) {
func (e *encoder) flush() error {
e.mu.Lock()
n, err := e.bw.FlushN()
e.mu.Unlock()
walWriteBytes.Add(float64(n))
return err
defer e.mu.Unlock()
return e.bw.Flush()
}
func writeUint64(w io.Writer, n uint64, buf []byte) error {