Skip to content

Commit

Permalink
Merge pull request #50 from milanbhagwat/master
Browse files Browse the repository at this point in the history
commenting the redundant logs
  • Loading branch information
abhide-tibco authored Jul 27, 2022
2 parents 93b16e5 + 79bb76b commit 694407f
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions flow-state/server/rest/endpoints.go
Original file line number Diff line number Diff line change
Expand Up @@ -695,9 +695,9 @@ func (se *ServiceEndpoints) popFromStepSlice() []byte {
firstItem, se.stepSlice = se.stepSlice[0], se.stepSlice[1:]
return firstItem
} else {
se.logger.Infof("StepSlice is Empty so going to wait")
// se.logger.Infof("StepSlice is Empty so going to wait")
se.muc.Wait() // wait for condition to have non empty slice
se.logger.Infof("Received signal, came out of wait")
// se.logger.Infof("Received signal, came out of wait")
}
}
return nil
Expand Down Expand Up @@ -743,7 +743,7 @@ func (se *ServiceEndpoints) saveStep(response http.ResponseWriter, request *http

func saveStepWorker(se *ServiceEndpoints) {
for { // infinite loop for getting work from channel
se.logger.Infof("pop from slice")
// se.logger.Infof("pop from slice")
content := se.popFromStepSlice()
if content != nil {
se.logger.Info("content received from slice.")
Expand All @@ -759,7 +759,7 @@ func saveStepWorker(se *ServiceEndpoints) {
se.logger.Errorf("Endpoint[POST:/instances/steps] : Error saving step - %v", err)
}
} else {
se.logger.Infof("**** Should never get here, StepSlice is Empty")
// se.logger.Infof("**** Should never get here, StepSlice is Empty")
/* se.muc.L.Lock()
se.logger.Infof("StepSlice is Empty so going to wait")
se.muc.Wait()
Expand Down

0 comments on commit 694407f

Please sign in to comment.