mirror of
https://github.com/octoleo/syncthing.git
synced 2024-11-18 19:15:19 +00:00
59 lines
1.1 KiB
Go
59 lines
1.1 KiB
Go
// Copyright (C) 2014 The Protocol Authors.
|
|
|
|
package protocol
|
|
|
|
import (
|
|
"io"
|
|
"sync/atomic"
|
|
"time"
|
|
)
|
|
|
|
type countingReader struct {
|
|
io.Reader
|
|
tot atomic.Int64 // bytes
|
|
last atomic.Int64 // unix nanos
|
|
}
|
|
|
|
var (
|
|
totalIncoming atomic.Int64
|
|
totalOutgoing atomic.Int64
|
|
)
|
|
|
|
func (c *countingReader) Read(bs []byte) (int, error) {
|
|
n, err := c.Reader.Read(bs)
|
|
c.tot.Add(int64(n))
|
|
totalIncoming.Add(int64(n))
|
|
c.last.Store(time.Now().UnixNano())
|
|
return n, err
|
|
}
|
|
|
|
func (c *countingReader) Tot() int64 { return c.tot.Load() }
|
|
|
|
func (c *countingReader) Last() time.Time {
|
|
return time.Unix(0, c.last.Load())
|
|
}
|
|
|
|
type countingWriter struct {
|
|
io.Writer
|
|
tot atomic.Int64 // bytes
|
|
last atomic.Int64 // unix nanos
|
|
}
|
|
|
|
func (c *countingWriter) Write(bs []byte) (int, error) {
|
|
n, err := c.Writer.Write(bs)
|
|
c.tot.Add(int64(n))
|
|
totalOutgoing.Add(int64(n))
|
|
c.last.Store(time.Now().UnixNano())
|
|
return n, err
|
|
}
|
|
|
|
func (c *countingWriter) Tot() int64 { return c.tot.Load() }
|
|
|
|
func (c *countingWriter) Last() time.Time {
|
|
return time.Unix(0, c.last.Load())
|
|
}
|
|
|
|
func TotalInOut() (int64, int64) {
|
|
return totalIncoming.Load(), totalOutgoing.Load()
|
|
}
|