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

disabled reaming code with allowedReceivers

Browse source
This commit is contained in:
postmannen 2021-09-20 12:22:34 +02:00
parent 6e43364839
commit 71f4007e31
3 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
process.go
View file

@ -43,7 +43,7 @@ type process struct {
errorCh chan errProcess
processKind processKind
// Who are we allowed to receive from ?
allowedReceivers map[Node]struct{}
// allowedReceivers map[Node]struct{}
// methodsAvailable
methodsAvailable MethodsAvailable
// Helper or service function that can do some kind of work

2
processes.go
View file

@ -345,7 +345,7 @@ func (p *processes) printProcessesMap() {
p.mu.Lock()
for _, vSub := range p.active {
for _, vID := range vSub {
log.Printf("* proc - : %v, id: %v, name: %v, allowed from: %v\n", vID.processKind, vID.processID, vID.subject.name(), vID.allowedReceivers)
log.Printf("* proc - : %v, id: %v, name: %v\n", vID.processKind, vID.processID, vID.subject.name())
}
}
p.mu.Unlock()

4
requests.go
View file

@ -375,7 +375,7 @@ func (m methodREQOpCommand) handler(proc process, message Message, nodeName stri
// be returned in the reply message.
for _, idMap := range proc.processes.active {
for _, v := range idMap {
s := fmt.Sprintf("%v, proc: %v, id: %v, name: %v, allowed from: %s\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v.processKind, v.processID, v.subject.name(), v.allowedReceivers)
s := fmt.Sprintf("%v, proc: %v, id: %v, name: %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v.processKind, v.processID, v.subject.name())
sb := []byte(s)
out = append(out, sb...)
}
@ -529,7 +529,7 @@ func (m methodREQOpProcessList) handler(proc process, message Message, node stri
// be returned in the reply message.
for _, idMap := range proc.processes.active {
for _, v := range idMap {
s := fmt.Sprintf("%v, process: %v, id: %v, name: %v, allowed from: %s\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v.processKind, v.processID, v.subject.name(), v.allowedReceivers)
s := fmt.Sprintf("%v, process: %v, id: %v, name: %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v.processKind, v.processID, v.subject.name())
sb := []byte(s)
out = append(out, sb...)
}