@@ -310,7 +310,7 @@ func (s *service) serveFCControl() error {
310
310
return nil
311
311
}
312
312
313
- func (s * service ) StartShim (shimCtx context.Context , containerID , containerdBinary , containerdAddress , containerdTTRPCAddress string ) (string , error ) {
313
+ func (s * service ) StartShim (shimCtx context.Context , opts shim. StartOpts ) (string , error ) {
314
314
// In the shim start routine, we can assume that containerd provided a "log" FIFO in the current working dir.
315
315
// We have to use that instead of stdout/stderr because containerd reads the stdio pipes of shim start to get
316
316
// either the shim address or the error returned here.
@@ -321,7 +321,7 @@ func (s *service) StartShim(shimCtx context.Context, containerID, containerdBina
321
321
322
322
logrus .SetOutput (logFifo )
323
323
324
- log := log .G (shimCtx ).WithField ("task_id" , containerID )
324
+ log := log .G (shimCtx ).WithField ("task_id" , opts . ID )
325
325
log .Debug ("StartShim" )
326
326
327
327
// If we are running a shim start routine, we can safely assume our current working
@@ -362,7 +362,7 @@ func (s *service) StartShim(shimCtx context.Context, containerID, containerdBina
362
362
exitAfterAllTasksDeleted = true
363
363
}
364
364
365
- client , err := ttrpcutil .NewClient (containerdTTRPCAddress )
365
+ client , err := ttrpcutil .NewClient (opts . TTRPCAddress )
366
366
if err != nil {
367
367
return "" , err
368
368
}
@@ -396,7 +396,7 @@ func (s *service) StartShim(shimCtx context.Context, containerID, containerdBina
396
396
}
397
397
log .WithField ("vmID" , s .vmID ).Infof ("successfully started shim (git commit: %s).%s" , revision , str )
398
398
399
- return shim .SocketAddress (shimCtx , containerdAddress , s .vmID )
399
+ return shim .SocketAddress (shimCtx , opts . Address , s .vmID )
400
400
}
401
401
402
402
func logPanicAndDie (logger * logrus.Entry ) {
0 commit comments