diff --git a/pkg/loxinet/rules.go b/pkg/loxinet/rules.go index b4905817..fe0c323f 100644 --- a/pkg/loxinet/rules.go +++ b/pkg/loxinet/rules.go @@ -3011,7 +3011,7 @@ func (r *ruleEnt) LB2DP(work DpWorkT) int { return -1 } - if !nWork.ServiceIP.IsUnspecified() { + if !nWork.ServiceIP.IsUnspecified() || nWork.BlockNum != 0 { mh.dp.ToDpCh <- nWork r.VIP2DP(nWork.Work) } diff --git a/pkg/loxinet/xsync_server.go b/pkg/loxinet/xsync_server.go index 98d070e6..ae4c7b70 100644 --- a/pkg/loxinet/xsync_server.go +++ b/pkg/loxinet/xsync_server.go @@ -20,15 +20,15 @@ import ( "context" "errors" "fmt" + opts "github.com/loxilb-io/loxilb/options" + tk "github.com/loxilb-io/loxilib" + "google.golang.org/grpc" "io" "net" "net/http" "net/rpc" "os" "runtime/debug" - opts "github.com/loxilb-io/loxilb/options" - tk "github.com/loxilb-io/loxilib" - "google.golang.org/grpc" ) // DpWorkOnBlockCtAdd - Add block CT entries from remote goRPC client