From c93fe189c6e4983f2293a14f4e4535291e2a3943 Mon Sep 17 00:00:00 2001 From: postmannen Date: Thu, 26 Aug 2021 07:02:36 +0200 Subject: [PATCH] removed no longer needed comments --- README.md | 2 -- read_socket_or_tcp_listener.go | 5 +---- server.go | 2 +- 3 files changed, 2 insertions(+), 7 deletions(-) diff --git a/README.md b/README.md index 26d5e04..5d66b72 100644 --- a/README.md +++ b/README.md @@ -648,8 +648,6 @@ For CliCommand message to a node named "ship1" of type Command and it wants an A ## TODO -Add metrics to buffers - ### nACK messages like hello messages should not be stored in db for retry if failed ### Error message should also contain subject diff --git a/read_socket_or_tcp_listener.go b/read_socket_or_tcp_listener.go index 7bea0eb..bf903bc 100644 --- a/read_socket_or_tcp_listener.go +++ b/read_socket_or_tcp_listener.go @@ -161,11 +161,8 @@ func (s *server) convertBytesToSAMs(b []byte) ([]subjectAndMessage, error) { return nil, fmt.Errorf("error: unmarshal of file failed: %#v", err) } - // -------------------- + // Check for toNode and toNodes field. MsgSlice = s.checkMessageToNodes(MsgSlice) - // -------------------- - - // TODO: Implement check for empty toNode field. sam := []subjectAndMessage{} diff --git a/server.go b/server.go index 8863f63..019f7c9 100644 --- a/server.go +++ b/server.go @@ -331,7 +331,7 @@ func (s *server) routeMessagesToProcess(dbFileName string) { // Prepare and start a new ring buffer const bufferSize int = 1000 rb := newringBuffer(s.metrics, *s.configuration, bufferSize, dbFileName, Node(s.nodeName), s.newMessagesCh) - // TODO: + ringBufferInCh := make(chan subjectAndMessage) ringBufferOutCh := make(chan samDBValueAndDelivered) // start the ringbuffer.