From 6d4bbe0a6acfff719ce0dc44761b211eb4ba198c Mon Sep 17 00:00:00 2001 From: Vladimir Barsukov Date: Sun, 19 Nov 2023 15:27:18 +0200 Subject: [PATCH] zgo_debug --- zdb/dev.go | 2 +- zdb/pool.go | 10 ++++++++-- zdb/prod.go | 2 +- 3 files changed, 10 insertions(+), 4 deletions(-) diff --git a/zdb/dev.go b/zdb/dev.go index 164bc1e..6f9f2c3 100644 --- a/zdb/dev.go +++ b/zdb/dev.go @@ -1,4 +1,4 @@ -//go:build dev +//go:build zgo_debug package zdb diff --git a/zdb/pool.go b/zdb/pool.go index f8f87c8..5b3b65d 100644 --- a/zdb/pool.go +++ b/zdb/pool.go @@ -204,7 +204,10 @@ func (d *Pool) sync() *Conn { } if d.Balance == BalanceRoundRobin { - return d.SrvSync[d.slavesIter.Add(1)%int64(len(d.SrvSync))] + conn := d.SrvSync[d.slavesIter.Add(1)%int64(len(d.SrvSync))] + logConnStat(conn) + + return conn } return d.least(d.SrvSync) @@ -223,7 +226,10 @@ func (d *Pool) async() *Conn { } if d.Balance == BalanceRoundRobin { - return d.SrvAsync[d.slavesAsyncIter.Add(1)%int64(len(d.SrvAsync))] + conn := d.SrvAsync[d.slavesAsyncIter.Add(1)%int64(len(d.SrvAsync))] + logConnStat(conn) + + return conn } return d.least(d.SrvAsync) diff --git a/zdb/prod.go b/zdb/prod.go index 168479d..ec895ff 100644 --- a/zdb/prod.go +++ b/zdb/prod.go @@ -1,4 +1,4 @@ -//go:build !dev +//go:build !zgo_debug package zdb -- GitLab