本文整理汇总了Golang中github.com/docker/docker/pkg/reexec.Init函数的典型用法代码示例。如果您正苦于以下问题:Golang Init函数的具体用法?Golang Init怎么用?Golang Init使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Init函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: init
func init() {
reexec.Register("namespaced", namespaced)
if reexec.Init() {
os.Exit(0)
}
}
开发者ID:cloudfoundry,项目名称:guardian,代码行数:7,代码来源:main_linux.go
示例2: main
func main() {
if reexec.Init() {
return
}
// Set terminal emulation based on platform as required.
stdin, stdout, stderr := term.StdStreams()
logrus.SetOutput(stderr)
flag.Merge(flag.CommandLine, clientFlags.FlagSet, commonFlags.FlagSet)
flag.Usage = func() {
fmt.Fprint(os.Stdout, "Usage: docker [OPTIONS] COMMAND [arg...]\n"+daemonUsage+" docker [ -h | --help | -v | --version ]\n\n")
fmt.Fprint(os.Stdout, "A self-sufficient runtime for containers.\n\nOptions:\n")
flag.CommandLine.SetOutput(os.Stdout)
flag.PrintDefaults()
help := "\nCommands:\n"
for _, cmd := range dockerCommands {
help += fmt.Sprintf(" %-10.10s%s\n", cmd.name, cmd.description)
}
help += "\nRun 'docker COMMAND --help' for more information on a command."
fmt.Fprintf(os.Stdout, "%s\n", help)
}
flag.Parse()
if *flVersion {
showVersion()
return
}
clientCli := client.NewDockerCli(stdin, stdout, stderr, clientFlags)
// TODO: remove once `-d` is retired
handleGlobalDaemonFlag()
if *flHelp {
// if global flag --help is present, regardless of what other options and commands there are,
// just print the usage.
flag.Usage()
return
}
c := cli.New(clientCli, daemonCli)
if err := c.Run(flag.Args()...); err != nil {
if sterr, ok := err.(cli.StatusError); ok {
if sterr.Status != "" {
fmt.Fprintln(os.Stderr, sterr.Status)
os.Exit(1)
}
os.Exit(sterr.StatusCode)
}
fmt.Fprintln(os.Stderr, err)
os.Exit(1)
}
}
开发者ID:nilsotto,项目名称:docker,代码行数:60,代码来源:docker.go
示例3: main
func main() {
fmt.Println("test")
if reexec.Init() {
return
}
}
开发者ID:szqh97,项目名称:test,代码行数:7,代码来源:reexec_tt.go
示例4: TestMain
func TestMain(m *testing.M) {
reexec.Register("allocate", allocate)
if reexec.Init() {
return
}
os.Exit(m.Run())
}
开发者ID:fabiokung,项目名称:numballoc,代码行数:7,代码来源:allocator_test.go
示例5: TestMain
func TestMain(m *testing.M) {
reexec.Register("enqueue", reexecEnqueue)
if reexec.Init() {
return
}
os.Exit(m.Run())
}
开发者ID:fabiokung,项目名称:cqueue,代码行数:7,代码来源:cqueue_test.go
示例6: TestMain
func TestMain(m *testing.M) {
if reexec.Init() {
return
}
if err := createController(); err != nil {
os.Exit(1)
}
option := options.Generic{
"EnableIPForwarding": true,
}
genericOption := make(map[string]interface{})
genericOption[netlabel.GenericData] = option
err := controller.ConfigureNetworkDriver(bridgeNetType, genericOption)
if err != nil {
//m.Fatal(err)
os.Exit(1)
}
libnetwork.SetTestDataStore(controller, datastore.NewCustomDataStore(datastore.NewMockStore()))
os.Exit(m.Run())
}
开发者ID:hurrygeek,项目名称:libnetwork,代码行数:25,代码来源:libnetwork_test.go
示例7: init
func init() {
// Do not sure chroot to speed run time and allow archive
// errors or hangs to be debugged directly from the test process.
untar = archive.UntarUncompressed
graphdriver.ApplyUncompressedLayer = archive.ApplyUncompressedLayer
reexec.Init()
}
开发者ID:harche,项目名称:docker,代码行数:8,代码来源:overlay_test.go
示例8: init
func init() {
reexec.Init()
if dockerBin := os.Getenv("DOCKER_BINARY"); dockerBin != "" {
dockerBinary = dockerBin
}
var err error
dockerBinary, err = exec.LookPath(dockerBinary)
if err != nil {
fmt.Printf("ERROR: couldn't resolve full path to the Docker binary (%v)", err)
os.Exit(1)
}
if registryImage := os.Getenv("REGISTRY_IMAGE"); registryImage != "" {
registryImageName = registryImage
}
if registry := os.Getenv("REGISTRY_URL"); registry != "" {
privateRegistryURL = registry
}
workingDirectory, _ = os.Getwd()
// Deterministically working out the environment in which CI is running
// to evaluate whether the daemon is local or remote is not possible through
// a build tag.
//
// For example Windows to Linux CI under Jenkins tests the 64-bit
// Windows binary build with the daemon build tag, but calls a remote
// Linux daemon.
//
// We can't just say if Windows then assume the daemon is local as at
// some point, we will be testing the Windows CLI against a Windows daemon.
//
// Similarly, it will be perfectly valid to also run CLI tests from
// a Linux CLI (built with the daemon tag) against a Windows daemon.
if len(os.Getenv("DOCKER_REMOTE_DAEMON")) > 0 {
isLocalDaemon = false
} else {
isLocalDaemon = true
}
// TODO Windows CI. This are incorrect and need fixing into
// platform specific pieces.
// This is only used for a tests with local daemon true (Linux-only today)
// default is "/var/lib/docker", but we'll try and ask the
// /info endpoint for the specific root dir
dockerBasePath = "/var/lib/docker"
type Info struct {
DockerRootDir string
}
var i Info
status, b, err := sockRequest("GET", "/info", nil)
if err == nil && status == 200 {
if err = json.Unmarshal(b, &i); err == nil {
dockerBasePath = i.DockerRootDir
}
}
volumesConfigPath = dockerBasePath + "/volumes"
containerStoragePath = dockerBasePath + "/containers"
}
开发者ID:hustcat,项目名称:docker,代码行数:57,代码来源:docker_test_vars.go
示例9: Test
func Test(t *testing.T) {
reexec.Init() // This is required for external graphdriver tests
if !isLocalDaemon {
fmt.Println("INFO: Testing against a remote daemon")
} else {
fmt.Println("INFO: Testing against a local daemon")
}
check.TestingT(t)
}
开发者ID:FlyingShit-XinHuang,项目名称:docker,代码行数:11,代码来源:check_test.go
示例10: main
func main() {
if reexec.Init() {
return
}
// Set terminal emulation based on platform as required.
_, stdout, stderr := term.StdStreams()
logrus.SetOutput(stderr)
flag.Merge(flag.CommandLine, daemonCli.commonFlags.FlagSet)
flag.Usage = func() {
fmt.Fprint(stdout, "Usage: dockerd [ --help | -v | --version ]\n\n")
fmt.Fprint(stdout, "A self-sufficient runtime for containers.\n\nOptions:\n")
flag.CommandLine.SetOutput(stdout)
flag.PrintDefaults()
}
flag.CommandLine.ShortUsage = func() {
fmt.Fprint(stderr, "\nUsage:\tdockerd [OPTIONS]\n")
}
if err := flag.CommandLine.ParseFlags(os.Args[1:], false); err != nil {
os.Exit(1)
}
if *flVersion {
showVersion()
return
}
if *flHelp {
// if global flag --help is present, regardless of what other options and commands there are,
// just print the usage.
flag.Usage()
return
}
// On Windows, this may be launching as a service or with an option to
// register the service.
stop, err := initService()
if err != nil {
logrus.Fatal(err)
}
if !stop {
err = daemonCli.start()
notifyShutdown(err)
if err != nil {
logrus.Fatal(err)
}
}
}
开发者ID:CheggEng,项目名称:docker,代码行数:54,代码来源:docker.go
示例11: main
func main() {
if reexec.Init() {
return
}
_, stdout, stderr := term.StdStreams()
logrus.SetOutput(stderr)
err := dnetApp(stdout, stderr)
if err != nil {
os.Exit(1)
}
}
开发者ID:rcgoodfellow,项目名称:libnetwork,代码行数:13,代码来源:dnet.go
示例12: init
func init() {
var err error
reexec.Init() // This is required for external graphdriver tests
testEnv, err = environment.New()
if err != nil {
fmt.Println(err)
os.Exit(1)
}
assignGlobalVariablesFromTestEnv(testEnv)
}
开发者ID:jwhonce,项目名称:docker,代码行数:13,代码来源:check_test.go
示例13: TestMain
func TestMain(m *testing.M) {
if reexec.Init() {
return
}
if err := createController(); err != nil {
logrus.Errorf("Error creating controller: %v", err)
os.Exit(1)
}
x := m.Run()
controller.Stop()
os.Exit(x)
}
开发者ID:vdemeester,项目名称:libnetwork,代码行数:14,代码来源:libnetwork_test.go
示例14: Test
func Test(t *testing.T) {
reexec.Init() // This is required for external graphdriver tests
if !isLocalDaemon {
fmt.Println("INFO: Testing against a remote daemon")
} else {
fmt.Println("INFO: Testing against a local daemon")
}
if daemonPlatform == "linux" {
ensureFrozenImagesLinux(t)
}
check.TestingT(t)
}
开发者ID:movicha,项目名称:docker,代码行数:14,代码来源:check_test.go
示例15: main
func main() {
registerCmd("/init", osInit.MainInit)
registerCmd(config.SYSINIT_BIN, sysinit.Main)
registerCmd("/usr/bin/dockerlaunch", dockerlaunch.Main)
registerCmd("/usr/bin/user-docker", userdocker.Main)
registerCmd("/usr/bin/system-docker", systemdocker.Main)
registerCmd("/sbin/poweroff", power.PowerOff)
registerCmd("/sbin/reboot", power.Reboot)
registerCmd("/sbin/halt", power.Halt)
registerCmd("/sbin/shutdown", power.Main)
registerCmd("/usr/bin/respawn", respawn.Main)
registerCmd("/usr/bin/ros", control.Main)
registerCmd("/usr/bin/cloud-init", cloudinit.Main)
registerCmd("/usr/sbin/netconf", network.Main)
registerCmd("/usr/sbin/wait-for-network", waitfornetwork.Main)
registerCmd("/usr/sbin/wait-for-docker", wait.Main)
if !reexec.Init() {
reexec.Register(os.Args[0], control.Main)
if !reexec.Init() {
log.Fatalf("Failed to find an entry point for %s", os.Args[0])
}
}
}
开发者ID:carriercomm,项目名称:os,代码行数:24,代码来源:main.go
示例16: main
func main() {
if reexec.Init() {
return
}
graphc := cli.NewApp()
graphc.Name = "graphc"
graphc.Usage = "manage graphc storage"
graphc.Flags = []cli.Flag{
cli.StringFlag{
Name: "home",
Value: "/var/lib/docker",
Usage: "home directory for graphdriver storage operations",
EnvVar: "GRAPHDRIVER_HOME",
},
cli.StringFlag{
Name: "configdir",
Value: "/etc/docker",
Usage: "directory for docker configuration",
},
cli.StringFlag{
Name: "storage-driver, driver, s",
Value: "",
Usage: "storage driver to use",
EnvVar: "GRAPHDRIVER_BACKEND",
},
cli.StringSliceFlag{
Name: "storage-opt",
Value: &cli.StringSlice{},
Usage: "set storage driver options",
EnvVar: "GRAPHDRIVER_OPTIONS",
},
cli.StringFlag{
Name: "context, c",
Value: "",
Usage: "optional mountlabel (SELinux context)",
},
cli.BoolFlag{
Name: "debug, D",
Usage: "print debugging information",
},
}
graphc.EnableBashCompletion = true
graphc.Commands = commands
graphc.Run(os.Args)
os.Exit(0)
}
开发者ID:nalind,项目名称:graphc,代码行数:48,代码来源:graphc.go
示例17: main
func main() {
if reexec.Init() {
return
}
fnd := flag.Bool("nondaemon", false, "Not daemonize")
flDisableIptables := flag.Bool("noniptables", false, "Don't enable iptables rules")
flConfig := flag.String("config", "", "Config file for hyperd")
flHost := flag.String("host", "", "Host for hyperd")
flMirrors := flag.String("registry_mirror", "", "Prefered docker registry mirror")
flInsecureRegistries := flag.String("insecure_registry", "", "Enable insecure registry communication")
flHelp := flag.Bool("help", false, "Print help message for Hyperd daemon")
flag.Set("alsologtostderr", "true")
flag.Set("log_dir", "/var/log/hyper/")
os.MkdirAll("/var/log/hyper/", 0755)
flag.Usage = func() { printHelp() }
flag.Parse()
if *flHelp == true {
printHelp()
return
}
if !*fnd {
path, err := osext.Executable()
if err != nil {
fmt.Printf("cannot find self executable path for %s: %v\n", os.Args[0], err)
os.Exit(-1)
}
_, err = runvutils.ExecInDaemon(path, append([]string{os.Args[0], "--nondaemon"}, os.Args[1:]...))
if err != nil {
fmt.Println("faile to daemonize hyperd")
os.Exit(-1)
}
return
}
var opts = &Options{
DisableIptables: *flDisableIptables,
Config: *flConfig,
Hosts: *flHost,
Mirrors: *flMirrors,
InsecureRegistries: *flInsecureRegistries,
}
mainDaemon(opts)
}
开发者ID:m1911,项目名称:hyper,代码行数:48,代码来源:hyperd.go
示例18: TestMain
func TestMain(m *testing.M) {
if reexec.Init() {
return
}
if err := createController(); err != nil {
log.Errorf("Error creating controller: %v", err)
os.Exit(1)
}
//libnetwork.SetTestDataStore(controller, datastore.NewCustomDataStore(datastore.NewMockStore()))
x := m.Run()
controller.Stop()
os.Exit(x)
}
开发者ID:pirater,项目名称:os,代码行数:16,代码来源:libnetwork_test.go
示例19: main
func main() {
if reexec.Init() {
return
}
// Set terminal emulation based on platform as required.
_, stdout, stderr := term.StdStreams()
logrus.SetOutput(stderr)
cmd := newDaemonCommand()
cmd.SetOutput(stdout)
if err := cmd.Execute(); err != nil {
fmt.Fprintf(stderr, "%s\n", err)
os.Exit(1)
}
}
开发者ID:sebrandon1,项目名称:docker,代码行数:16,代码来源:docker.go
示例20: main
func main() {
if reexec.Init() {
return
}
if os.Geteuid() != 0 {
glog.Errorf("The Hyper daemon needs to be run as root")
return
}
// hyper needs Linux kernel 3.8.0+
if err := checkKernel(3, 8, 0); err != nil {
glog.Errorf(err.Error())
return
}
fnd := flag.Bool("nondaemon", false, "[deprecated flag]") // TODO: remove it when 0.8 is released
flDisableIptables := flag.Bool("noniptables", false, "Don't enable iptables rules")
flConfig := flag.String("config", "", "Config file for hyperd")
flHost := flag.String("host", "", "Host for hyperd")
flMirrors := flag.String("registry_mirror", "", "Prefered docker registry mirror")
flInsecureRegistries := flag.String("insecure_registry", "", "Enable insecure registry communication")
flHelp := flag.Bool("help", false, "Print help message for Hyperd daemon")
flag.Set("alsologtostderr", "true")
flag.Set("log_dir", "/var/log/hyper/")
os.MkdirAll("/var/log/hyper/", 0755)
flag.Usage = func() { printHelp() }
flag.Parse()
if *flHelp == true {
printHelp()
return
}
if *fnd {
fmt.Printf("flag --nondaemon is deprecated\n")
}
var opt = &Options{
DisableIptables: *flDisableIptables,
Config: *flConfig,
Hosts: *flHost,
Mirrors: *flMirrors,
InsecureRegistries: *flInsecureRegistries,
}
mainDaemon(opt)
}
开发者ID:juito,项目名称:hyper,代码行数:47,代码来源:hyperd.go
注:本文中的github.com/docker/docker/pkg/reexec.Init函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论