mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-05 23:06:47 +00:00
Code Activity

changed error messages

Browse source
This commit is contained in:
postmannen 2021-08-09 09:34:05 +02:00
parent 898f299e71
commit 1a3e310cd1
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ringbuffer.go
View file

@ -107,7 +107,7 @@ func (r *ringBuffer) fillBuffer(inCh chan subjectAndMessage, samValueBucket stri
func() { func() {
s, err := r.dumpBucket(samValueBucket) s, err := r.dumpBucket(samValueBucket)
if err != nil { if err != nil {
er := fmt.Errorf("error: fillBuffer: retreival of values from k/v store failed, probaly empty database so we don't have any previos entries in db: %v", err) er := fmt.Errorf("info: fillBuffer: retreival of values from k/v store failed, probaly empty database, and no previos entries in db to process: %v", err)
log.Printf("%v\n", er) log.Printf("%v\n", er)
return return
//sendErrorLogMessage(r.newMessagesCh, node(r.nodeName), er) //sendErrorLogMessage(r.newMessagesCh, node(r.nodeName), er)
@ -356,8 +356,8 @@ func (r *ringBuffer) getIndexValue(indexBucket string) int {
} }
index, err := strconv.Atoi(string(indexB)) index, err := strconv.Atoi(string(indexB))
if err != nil { if err != nil && string(indexB) == "" {
log.Printf("error: getIndexValue: strconv.Atoi : %v\n", err) log.Printf("info: getIndexValue: no index value found : %v\n", err)
} }
// fmt.Printf("\n**** ringBuffer.getIndexValue: got index value = %v\n\n", index) // fmt.Printf("\n**** ringBuffer.getIndexValue: got index value = %v\n\n", index)

2
steward_test.go
View file

@ -44,6 +44,8 @@ func TestSteward(t *testing.T) {
s.Start() s.Start()
s.Stop()
// Shutdown services // Shutdown services
ns.Shutdown() ns.Shutdown()