Skip to content

Commit 69a30ad

Browse files
authored
Merge pull request #5378 from Iceber/check-flag
runtime/shim: check the namespace flag first
2 parents 3e59ee0 + 34780d6 commit 69a30ad

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

runtime/v2/shim/shim.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -175,30 +175,30 @@ func run(id string, initFunc Init, config Config) error {
175175
return nil
176176
}
177177

178+
if namespaceFlag == "" {
179+
return fmt.Errorf("shim namespace cannot be empty")
180+
}
181+
178182
setRuntime()
179183

180184
signals, err := setupSignals(config)
181185
if err != nil {
182186
return err
183187
}
188+
184189
if !config.NoSubreaper {
185190
if err := subreaper(); err != nil {
186191
return err
187192
}
188193
}
189194

190195
ttrpcAddress := os.Getenv(ttrpcAddressEnv)
191-
192196
publisher, err := NewPublisher(ttrpcAddress)
193197
if err != nil {
194198
return err
195199
}
196-
197200
defer publisher.Close()
198201

199-
if namespaceFlag == "" {
200-
return fmt.Errorf("shim namespace cannot be empty")
201-
}
202202
ctx := namespaces.WithNamespace(context.Background(), namespaceFlag)
203203
ctx = context.WithValue(ctx, OptsKey{}, Opts{BundlePath: bundlePath, Debug: debugFlag})
204204
ctx = log.WithLogger(ctx, log.G(ctx).WithField("runtime", id))
@@ -207,6 +207,7 @@ func run(id string, initFunc Init, config Config) error {
207207
if err != nil {
208208
return err
209209
}
210+
210211
switch action {
211212
case "delete":
212213
logger := logrus.WithFields(logrus.Fields{

0 commit comments

Comments
 (0)