diff options
Diffstat (limited to 'agreement/service.go')
| -rw-r--r-- | agreement/service.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/agreement/service.go b/agreement/service.go index 433a17d5c..d8ec84b92 100644 --- a/agreement/service.go +++ b/agreement/service.go @@ -1,4 +1,4 @@ -// Copyright (C) 2019-2023 Algorand, Inc. +// Copyright (C) 2019-2024 Algorand, Inc. // This file is part of go-algorand // // go-algorand is free software: you can redistribute it and/or modify @@ -19,6 +19,7 @@ package agreement //go:generate dbgen -i agree.sql -p agreement -n agree -o agreeInstall.go -h ../scripts/LICENSE_HEADER import ( "context" + "io" "time" "github.com/algorand/go-algorand/config" @@ -178,6 +179,11 @@ func (s *Service) Shutdown() { s.persistenceLoop.Quit() } +// DumpDemuxQueues dumps the demux queues to the given writer. +func (s *Service) DumpDemuxQueues(w io.Writer) { + s.demux.dumpQueues(w) +} + // demuxLoop repeatedly executes pending actions and then requests the next event from the Service.demux. func (s *Service) demuxLoop(ctx context.Context, input chan<- externalEvent, output <-chan []action, ready <-chan externalDemuxSignals) { for a := range output { |