summaryrefslogtreecommitdiff
path: root/txnsync/logger.go
diff options
context:
space:
mode:
Diffstat (limited to 'txnsync/logger.go')
-rw-r--r--txnsync/logger.go88
1 files changed, 0 insertions, 88 deletions
diff --git a/txnsync/logger.go b/txnsync/logger.go
deleted file mode 100644
index 802387168..000000000
--- a/txnsync/logger.go
+++ /dev/null
@@ -1,88 +0,0 @@
-// Copyright (C) 2019-2021 Algorand, Inc.
-// This file is part of go-algorand
-//
-// go-algorand is free software: you can redistribute it and/or modify
-// it under the terms of the GNU Affero General Public License as
-// published by the Free Software Foundation, either version 3 of the
-// License, or (at your option) any later version.
-//
-// go-algorand is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU Affero General Public License for more details.
-//
-// You should have received a copy of the GNU Affero General Public License
-// along with go-algorand. If not, see <https://www.gnu.org/licenses/>.
-
-package txnsync
-
-import (
- "github.com/algorand/go-algorand/config"
- "github.com/algorand/go-algorand/data/basics"
- "github.com/algorand/go-algorand/logging"
-)
-
-// make a local alias of the type so that we can refer to it without '.'
-type algodlogger = logging.Logger
-
-type msgStats struct {
- sequenceNumber uint64
- round basics.Round
- transactions int
- offsetModulator requestParams
- bloomSize int
- nextMsgMinDelay uint64
- peerAddress string
-}
-
-type msgLogger interface {
- outgoingMessage(mstat msgStats)
- incomingMessage(mstat msgStats)
-}
-
-// Logger is go-algorand/logging.Logger with some private additions for txnsync
-type Logger interface {
- logging.Logger
- msgLogger
-}
-
-type basicMsgLogger struct {
- algodlogger
- config *config.Local
-}
-
-func wrapLogger(l logging.Logger, config *config.Local) Logger {
- if ll, ok := l.(Logger); ok {
- return ll
- }
- out := &basicMsgLogger{
- algodlogger: l,
- config: config,
- }
- return out
-}
-
-func (l *basicMsgLogger) logMessage(mstat msgStats, mode, tofrom string) {
- if !l.config.EnableVerbosedTransactionSyncLogging {
- return
- }
- l.Infof(
- "%s Txsync #%d round %d transactions %d request [%d/%d] bloom %d nextTS %d %s '%s'",
- mode,
- mstat.sequenceNumber,
- mstat.round,
- mstat.transactions,
- mstat.offsetModulator.Offset,
- mstat.offsetModulator.Modulator,
- mstat.bloomSize,
- mstat.nextMsgMinDelay,
- tofrom,
- mstat.peerAddress,
- )
-}
-func (l *basicMsgLogger) outgoingMessage(mstat msgStats) {
- l.logMessage(mstat, "Outgoing", "to")
-}
-func (l *basicMsgLogger) incomingMessage(mstat msgStats) {
- l.logMessage(mstat, "Incoming", "from")
-}