anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

GO-2828: added AliveTimeSecs field

Browse source 
Signed-off-by: AnastasiaShemyakinskaya <shem98a@mail.ru>
This commit is contained in:
AnastasiaShemyakinskaya 2024-11-18 12:40:55 +01:00
parent bdd028b1e1
commit 7a9666ce09
No known key found for this signature in database
GPG key ID: CCD60ED83B103281
2 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
net/peer/peer.go
View file

@ -59,6 +59,7 @@ type Stat struct {
SubConnections int `json:"subConnections"`
Created time.Time `json:"created"`
Version uint32 `json:"version"`
AliveTimeSecs float64 `json:"aliveTimeSecs"`
}
type StatProvider interface {
@ -342,5 +343,6 @@ func (p *peer) ProvideStat() *Stat {
SubConnections: subConnectionsCount,
Created: p.created,
Version: protoVersion,
AliveTimeSecs: time.Now().Sub(p.created).Seconds(),
}
}

7
net/pool/pool_test.go
View file

@ -189,7 +189,7 @@ func TestPool_Pick(t *testing.T) {
})
}
func TestProvideStat_NoPeers(t *testing.T) {
func TestProvideStat(t *testing.T) {
t.Run("only incoming peers", func(t *testing.T) {
// given
fx := newFixture(t)
@ -214,6 +214,7 @@ func TestProvideStat_NoPeers(t *testing.T) {
assert.Equal(t, p1.created, poolStat.PeerStats[0].Created)
assert.Equal(t, p1.subConnections, poolStat.PeerStats[0].SubConnections)
assert.Equal(t, p1.version, poolStat.PeerStats[0].Version)
assert.NotEmpty(t, poolStat.PeerStats[0].AliveTimeSecs)
})
t.Run("outgoing and incoming peers", func(t *testing.T) {
// given
@ -248,11 +249,13 @@ func TestProvideStat_NoPeers(t *testing.T) {
assert.Equal(t, created1, poolStat.PeerStats[0].Created)
assert.Equal(t, 0, poolStat.PeerStats[0].SubConnections)
assert.Equal(t, uint32(0), poolStat.PeerStats[0].Version)
assert.NotEmpty(t, poolStat.PeerStats[0].AliveTimeSecs)
assert.Equal(t, p1.id, poolStat.PeerStats[1].PeerId)
assert.Equal(t, p1.created, poolStat.PeerStats[1].Created)
assert.Equal(t, p1.subConnections, poolStat.PeerStats[1].SubConnections)
assert.Equal(t, p1.version, poolStat.PeerStats[1].Version)
assert.NotEmpty(t, poolStat.PeerStats[1].AliveTimeSecs)
})
t.Run("only outcoming peers", func(t *testing.T) {
// given
@ -286,6 +289,7 @@ func TestProvideStat_NoPeers(t *testing.T) {
assert.Equal(t, created, poolStat.PeerStats[0].Created)
assert.Equal(t, subConn, poolStat.PeerStats[0].SubConnections)
assert.Equal(t, version, poolStat.PeerStats[0].Version)
assert.NotEmpty(t, version, poolStat.PeerStats[0].AliveTimeSecs)
})
t.Run("no peers", func(t *testing.T) {
// given
@ -388,6 +392,7 @@ func (t *testPeer) ProvideStat() *peer.Stat {
Created: t.created,
SubConnections: t.subConnections,
Version: t.version,
AliveTimeSecs: time.Now().Sub(t.created).Seconds(),
}
}