Skip to content

Commit d383e70

Browse files
committed
Revert "[core] Do not loop forever on DCS global stream bad response"
This reverts commit 43a66db.
1 parent 48951df commit d383e70

File tree

1 file changed

+1
-12
lines changed

1 file changed

+1
-12
lines changed

core/integration/dcs/plugin.go

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,7 @@ import (
4646
"github.com/imdario/mergo"
4747
"github.com/spf13/viper"
4848
"google.golang.org/grpc"
49-
"google.golang.org/grpc/codes"
5049
"google.golang.org/grpc/connectivity"
51-
"google.golang.org/grpc/status"
5250
)
5351

5452
const (
@@ -144,16 +142,7 @@ func (p *Plugin) Init(instanceId string) error {
144142
break
145143
}
146144
if err != nil {
147-
if st, ok := status.FromError(err); ok {
148-
if st.Code() != codes.OK {
149-
log.WithError(err).
150-
WithField("code", st.Code().String()).
151-
Error("bad event from DCS service, disconnecting; fix DCS issue then restart ECS core")
152-
break
153-
}
154-
} else {
155-
log.WithError(err).Error("bad event from DCS service")
156-
}
145+
log.WithError(err).Error("bad event from DCS service")
157146
}
158147
log.WithField("event", ev.String()).Debug("received DCS event")
159148
}

0 commit comments

Comments
 (0)