mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

removed debug printing from ringbuffer

Browse source
This commit is contained in:
postmannen 2023-06-21 12:08:17 +02:00
parent 1c7f47ffff
commit 1f95151da0
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ringbuffer.go
View file

@ -321,7 +321,7 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, ringBufferOutCh
if r.configuration.RingBufferPersistStore { if r.configuration.RingBufferPersistStore {
select { select {
case <-v.SAM.done: case <-v.SAM.done:
fmt.Printf("---\n DONE with\n---\n") // fmt.Printf("---\n DONE with\n---\n")
case <-ticker.C: case <-ticker.C:
log.Printf("----------------------------------------------\n") log.Printf("----------------------------------------------\n")
log.Printf("Error: ringBuffer message id: %v, subject: %v seems to be stuck, did not receive done signal from publishAMessage process, exited on ticker\n", v.SAM.ID, v.SAM.Subject) log.Printf("Error: ringBuffer message id: %v, subject: %v seems to be stuck, did not receive done signal from publishAMessage process, exited on ticker\n", v.SAM.ID, v.SAM.Subject)