logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-07 15:23:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

[validation] Use label for break

Browse Source
This commit is contained in:
Edgar Aroutiounian 2020-05-12 23:34:24 -07:00 committed by vyzo
parent 04e971fa0d
commit 9de0241df1
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
validation.go
View File

@ -270,12 +270,13 @@ func (v *validation) validate(vals []*topicVal, src peer.ID, msg *Message) {
// apply inline (synchronous) validators // apply inline (synchronous) validators
result := ValidationAccept result := ValidationAccept
loop:
for _, val := range inline { for _, val := range inline {
switch val.validateMsg(v.p.ctx, src, msg) { switch val.validateMsg(v.p.ctx, src, msg) {
case ValidationAccept: case ValidationAccept:
case ValidationReject: case ValidationReject:
result = ValidationReject result = ValidationReject
break break loop
case ValidationIgnore: case ValidationIgnore:
result = ValidationIgnore result = ValidationIgnore
} }
@ -377,12 +378,13 @@ func (v *validation) validateTopic(vals []*topicVal, src peer.ID, msg *Message)
} }
result := ValidationAccept result := ValidationAccept
loop:
for i := 0; i < rcount; i++ { for i := 0; i < rcount; i++ {
switch <-rch { switch <-rch {
case ValidationAccept: case ValidationAccept:
case ValidationReject: case ValidationReject:
result = ValidationReject result = ValidationReject
return result break loop
case ValidationIgnore: case ValidationIgnore:
// throttled validation has the same effect, but takes precedence over Ignore as it is not // throttled validation has the same effect, but takes precedence over Ignore as it is not
// known whether the throttled validator would have signaled rejection. // known whether the throttled validator would have signaled rejection.