| 38 | ) |
| 39 | |
| 40 | func startDaemon() { |
| 41 | ctx := context.Background() |
| 42 | ctx, cancel := context.WithTimeout(ctx, 10*time.Second) |
| 43 | defer cancel() |
| 44 | |
| 45 | errC := make(chan error, 1) |
| 46 | |
| 47 | go func() { |
| 48 | defer close(errC) |
| 49 | |
| 50 | srvconfig := &config.Config{ |
| 51 | Version: version.ConfigVersion, |
| 52 | Root: defaultRoot, |
| 53 | State: defaultState, |
| 54 | Debug: config.Debug{ |
| 55 | Level: "debug", |
| 56 | }, |
| 57 | Plugins: map[string]any{ |
| 58 | "io.containerd.server.v1.grpc": map[string]any{ |
| 59 | "address": defaultAddress, |
| 60 | "max_recv_message_size": defaults.DefaultMaxRecvMsgSize, |
| 61 | "max_send_message_size": defaults.DefaultMaxSendMsgSize, |
| 62 | }, |
| 63 | }, |
| 64 | DisabledPlugins: []string{}, |
| 65 | RequiredPlugins: []string{}, |
| 66 | } |
| 67 | |
| 68 | server, err := server.New(ctx, srvconfig) |
| 69 | if err != nil { |
| 70 | errC <- err |
| 71 | return |
| 72 | } |
| 73 | |
| 74 | defer server.Stop() |
| 75 | if err := server.Start(ctx); err != nil { |
| 76 | errC <- err |
| 77 | return |
| 78 | } |
| 79 | |
| 80 | server.Wait() |
| 81 | }() |
| 82 | |
| 83 | var err error |
| 84 | select { |
| 85 | case err = <-errC: |
| 86 | case <-ctx.Done(): |
| 87 | err = ctx.Err() |
| 88 | } |
| 89 | |
| 90 | if err != nil { |
| 91 | panic(err) |
| 92 | } |
| 93 | } |