File socket-activation-02-daemon.patch of Package containerd

Overview Repositories Revisions Requests Users Attributes Meta

File socket-activation-02-daemon.patch of Package containerd (Revision adf887824932e56178e88aee1cff1e85)

Currently displaying revision adf887824932e56178e88aee1cff1e85 , Show latest

From adda6600effdaa6905fbd8eb5572583b0b6779ec Mon Sep 17 00:00:00 2001
From: Aleksa Sarai <asarai@suse.de>
Date: Thu, 31 Mar 2016 14:23:54 +1100
Subject: [PATCH 2/3] containerd: use docker/listeners to create the GRPC
 socket

This allows for the use of socket activation with the flag `-l fd://`
and similar. The semantics are identical to Docker, but it's important
to note that the semantics of the --listen flag have changed to require
a proto://addr formatted string.

Signed-off-by: Aleksa Sarai <asarai@suse.de>
---
 containerd/main.go       | 32 ++++++++++++++++++++++----------
 containerd/main_linux.go |  3 +--
 2 files changed, 23 insertions(+), 12 deletions(-)

Index: containerd-0.1.0/containerd/main.go
===================================================================
--- containerd-0.1.0.orig/containerd/main.go
+++ containerd-0.1.0/containerd/main.go
@@ -2,9 +2,9 @@ package main
 
 import (
 	"fmt"
-	"net"
 	"os"
 	"os/signal"
+	"strings"
 	"sync"
 	"syscall"
 	"time"
@@ -18,6 +18,7 @@ import (
 	"github.com/docker/containerd/api/grpc/types"
 	"github.com/docker/containerd/osutils"
 	"github.com/docker/containerd/supervisor"
+	"github.com/docker/docker/docker/listeners"
 )
 
 const (
@@ -43,7 +44,7 @@ var daemonFlags = []cli.Flag{
 	cli.StringFlag{
 		Name:  "listen,l",
 		Value: defaultGRPCEndpoint,
-		Usage: "Address on which GRPC API will listen",
+		Usage: "proto://address on which the GRPC API will listen",
 	},
 	cli.StringFlag{
 		Name:  "runtime,r",
@@ -66,8 +67,16 @@ func main() {
 	setAppBefore(app)
 
 	app.Action = func(context *cli.Context) {
+		// Split the listen string of the form proto://addr
+		listenSpec := context.String("listen")
+		listenParts := strings.SplitN(listenSpec, "://", 2)
+		if len(listenParts) != 2 {
+			logrus.Fatalf("bad listen address format %s, expected proto://address", listenSpec)
+		}
+
 		if err := daemon(
-			context.String("listen"),
+			listenParts[0],
+			listenParts[1],
 			context.String("state-dir"),
 			10,
 			context.String("runtime"),
@@ -80,7 +89,7 @@ func main() {
 	}
 }
 
-func daemon(address, stateDir string, concurrency int, runtimeName string) error {
+func daemon(protocol, address, stateDir string, concurrency int, runtimeName string) error {
 	// setup a standard reaper so that we don't leave any zombies if we are still alive
 	// this is just good practice because we are spawning new processes
 	s := make(chan os.Signal, 2048)
@@ -101,7 +110,7 @@ func daemon(address, stateDir string, co
 	if err := sv.Start(); err != nil {
 		return err
 	}
-	server, err := startServer(address, sv)
+	server, err := startServer(protocol, address, sv)
 	if err != nil {
 		return err
 	}
@@ -119,14 +128,17 @@ func daemon(address, stateDir string, co
 	return nil
 }
 
-func startServer(address string, sv *supervisor.Supervisor) (*grpc.Server, error) {
-	if err := os.RemoveAll(address); err != nil {
-		return nil, err
-	}
-	l, err := net.Listen(defaultListenType, address)
+func startServer(protocol, address string, sv *supervisor.Supervisor) (*grpc.Server, error) {
+	// TODO: We should use TLS.
+	// TODO: Add an option for the SocketGroup.
+	sockets, err := listeners.Init(protocol, address, "", nil)
 	if err != nil {
 		return nil, err
 	}
+	if len(sockets) != 1 {
+		return nil, fmt.Errorf("incorrect number of listeners")
+	}
+	l := sockets[0]
 	s := grpc.NewServer()
 	types.RegisterAPIServer(s, server.NewServer(sv))
 	go func() {
Index: containerd-0.1.0/containerd/main_linux.go
===================================================================
--- containerd-0.1.0.orig/containerd/main_linux.go
+++ containerd-0.1.0/containerd/main_linux.go
@@ -19,8 +19,7 @@ import (
 
 const (
 	defaultStateDir     = "/run/containerd"
-	defaultListenType   = "unix"
-	defaultGRPCEndpoint = "/run/containerd/containerd.sock"
+	defaultGRPCEndpoint = "unix:///run/containerd/containerd.sock"
 )
 
 func appendPlatformFlags() {

Places

File socket-activation-02-daemon.patch of Package containerd (Revision adf887824932e56178e88aee1cff1e85)

Places