mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-01-20 22:52:13 +00:00
Code Activity

commented out some logging

Browse source
This commit is contained in:
postmannen 2021-08-25 16:17:33 +02:00
parent 2a182e78a2
commit 82e9477b18
2 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
message_and_subject.go
View file

@ -12,8 +12,10 @@ import (
// --- Message // --- Message
type Message struct { type Message struct {
// The node to send the message to // The node to send the message to.
ToNode Node `json:"toNode" yaml:"toNode"` ToNode Node `json:"toNode" yaml:"toNode"`
// ToNodes to specify several hosts to send message to.
ToNodes []Node `json:"toNodes,omitempty" yaml:"toNodes,omitempty"`
// The Unique ID of the message // The Unique ID of the message
ID int `json:"id" yaml:"id"` ID int `json:"id" yaml:"id"`
// The actual data in the message // The actual data in the message

10
ringbuffer.go
View file

@ -289,11 +289,11 @@ func (r *ringBuffer) processBufferMessages(samValueBucket string, outCh chan sam
r.permStore <- fmt.Sprintf("%v : %+v\n", time.Now().UTC(), v) r.permStore <- fmt.Sprintf("%v : %+v\n", time.Now().UTC(), v)
// REMOVE: Dump the whole KV store // TODO: REMOVE: Dump the whole KV store
err := r.printBucketContent(samValueBucket) // err := r.printBucketContent(samValueBucket)
if err != nil { // if err != nil {
log.Printf("* Error: dump of db failed: %v\n", err) // log.Printf("* Error: dump of db failed: %v\n", err)
} // }
}(v) }(v)
} }