mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-15 10:57:42 +00:00
Code Activity

updated comments

Browse source
This commit is contained in:
postmannen 2022-06-22 14:50:26 +02:00
parent 4b0a156ae1
commit fb4cf5de79
4 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
errorkernel.go
View file

@ -199,9 +199,9 @@ const (
// errActionContinue is ment to be used when the a process // errActionContinue is ment to be used when the a process
// can just continue without taking any special care. // can just continue without taking any special care.
errActionContinue errorAction = iota errActionContinue errorAction = iota
// TODO: // TODO NOT IMPLEMENTED YET:
// errActionKill should log the error, // errActionKill should log the error,
// stop the current worker process, and spawn a new. // and f.ex. stop the current work, and restart from start?
// errActionKill errorAction = iota // errActionKill errorAction = iota
) )

1
requests.go
View file

@ -452,7 +452,6 @@ func newReplyMessage(proc process, message Message, outData []byte) {
// Create a new message for the reply, and put it on the // Create a new message for the reply, and put it on the
// ringbuffer to be published. // ringbuffer to be published.
// TODO: Check that we still got all the fields present that are needed here.
newMsg := Message{ newMsg := Message{
ToNode: message.FromNode, ToNode: message.FromNode,
// The ToNodes field is not needed since it is only a concept that exists when messages // The ToNodes field is not needed since it is only a concept that exists when messages

2
requests_test.go
View file

@ -37,7 +37,7 @@ func TestMain(m *testing.M) {
tstTempDir = os.TempDir() tstTempDir = os.TempDir()
} }
// TODO: Forcing this for now. // NB: Forcing this for now.
tstTempDir = "tmp" tstTempDir = "tmp"
tstNats = newNatsServerForTesting(42222) tstNats = newNatsServerForTesting(42222)

2
ringbuffer.go
View file

@ -300,7 +300,7 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, outCh chan samDB
case <-delivredCh: case <-delivredCh:
// OK. // OK.
case <-time.After(time.Second * 5): case <-time.After(time.Second * 5):
// TODO: Check out if more logic should be made here if messages are stuck etc. // TODO: Check if more logic should be made here if messages are stuck etc.
// Testing with a timeout here to figure out if messages are stuck // Testing with a timeout here to figure out if messages are stuck
// waiting for done signal. // waiting for done signal.
log.Printf("Error: *** message %v seems to be stuck, did not receive delivered signal from reading process\n", v.ID) log.Printf("Error: *** message %v seems to be stuck, did not receive delivered signal from reading process\n", v.ID)