mirror of
https://github.com/postmannen/ctrl.git
synced 2025-03-15 10:57:42 +00:00
removed no longer needed comments
This commit is contained in:
parent
79803600de
commit
c93fe189c6
3 changed files with 2 additions and 7 deletions
|
@ -648,8 +648,6 @@ For CliCommand message to a node named "ship1" of type Command and it wants an A
|
||||||
|
|
||||||
## TODO
|
## TODO
|
||||||
|
|
||||||
Add metrics to buffers
|
|
||||||
|
|
||||||
### nACK messages like hello messages should not be stored in db for retry if failed
|
### nACK messages like hello messages should not be stored in db for retry if failed
|
||||||
|
|
||||||
### Error message should also contain subject
|
### Error message should also contain subject
|
||||||
|
|
|
@ -161,11 +161,8 @@ func (s *server) convertBytesToSAMs(b []byte) ([]subjectAndMessage, error) {
|
||||||
return nil, fmt.Errorf("error: unmarshal of file failed: %#v", err)
|
return nil, fmt.Errorf("error: unmarshal of file failed: %#v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// --------------------
|
// Check for toNode and toNodes field.
|
||||||
MsgSlice = s.checkMessageToNodes(MsgSlice)
|
MsgSlice = s.checkMessageToNodes(MsgSlice)
|
||||||
// --------------------
|
|
||||||
|
|
||||||
// TODO: Implement check for empty toNode field.
|
|
||||||
|
|
||||||
sam := []subjectAndMessage{}
|
sam := []subjectAndMessage{}
|
||||||
|
|
||||||
|
|
|
@ -331,7 +331,7 @@ func (s *server) routeMessagesToProcess(dbFileName string) {
|
||||||
// Prepare and start a new ring buffer
|
// Prepare and start a new ring buffer
|
||||||
const bufferSize int = 1000
|
const bufferSize int = 1000
|
||||||
rb := newringBuffer(s.metrics, *s.configuration, bufferSize, dbFileName, Node(s.nodeName), s.newMessagesCh)
|
rb := newringBuffer(s.metrics, *s.configuration, bufferSize, dbFileName, Node(s.nodeName), s.newMessagesCh)
|
||||||
// TODO:
|
|
||||||
ringBufferInCh := make(chan subjectAndMessage)
|
ringBufferInCh := make(chan subjectAndMessage)
|
||||||
ringBufferOutCh := make(chan samDBValueAndDelivered)
|
ringBufferOutCh := make(chan samDBValueAndDelivered)
|
||||||
// start the ringbuffer.
|
// start the ringbuffer.
|
||||||
|
|
Loading…
Add table
Reference in a new issue