Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,293 for Seamon (0.39 sec)

  1. br/pkg/streamhelper/advancer_daemon.go

    	tick := time.NewTicker(ad.adv.cfg.TickDuration)
    	loop := func() {
    		log.Info("begin advancer daemon loop", zap.String("id", ad.manager.ID()))
    		for {
    			select {
    			case <-ctx.Done():
    				log.Info("advancer loop exits", zap.String("id", ad.manager.ID()))
    				return
    			case <-tick.C:
    				log.Debug("deamon tick start", zap.Bool("is-owner", ad.manager.IsOwner()))
    				if ad.manager.IsOwner() {
    					metrics.AdvancerOwner.Set(1.0)
    Go
    - Registered: 2022-09-22 09:02
    - Last Modified: 2022-08-11 04:50
    - 2.1K bytes
    - Viewed (0)
  2. feature-detects/network/beacon.js

    /*!
    {
      "name": "Beacon API",
      "notes": [{
        "name": "MDN Docs",
        "href": "https://developer.mozilla.org/en-US/docs/Web/API/navigator.sendBeacon"
      }, {
        "name": "W3C Spec",
        "href": "https://w3c.github.io/beacon/"
      }],
      "property": "beacon",
      "caniuse": "beacon",
      "tags": ["beacon", "network"],
      "authors": ["Cătălin Mariș"]
    }
    !*/
    /* DOC
    JavaScript
    - Registered: 2022-09-26 20:07
    - Last Modified: 2020-04-17 15:43
    - 582 bytes
    - Viewed (0)
  3. lib/Daemon.js

        that.pub.emit(event, Utility.clone(data_v));
        data_v = null;
      });
    };
    
    if (require.main === module) {
      process.title = process.env.PM2_DAEMON_TITLE || 'PM2 v' + pkg.version + ': God Daemon (' + process.env.PM2_HOME + ')';
    
      var daemon = new Daemon();
    
      daemon.start();
    JavaScript
    - Registered: 2022-09-21 09:50
    - Last Modified: 2022-01-20 10:28
    - 12.6K bytes
    - Viewed (1)
  4. daemon/daemon.go

    func (daemon *Daemon) StoreHosts(hosts []string) {
    	if daemon.hosts == nil {
    		daemon.hosts = make(map[string]bool)
    	}
    	for _, h := range hosts {
    		daemon.hosts[h] = true
    	}
    }
    
    // HasExperimental returns whether the experimental features of the daemon are enabled or not
    func (daemon *Daemon) HasExperimental() bool {
    	return daemon.configStore != nil && daemon.configStore.Experimental
    }
    Go
    - Registered: 2022-09-21 12:04
    - Last Modified: 2022-09-06 16:49
    - 48.2K bytes
    - Viewed (1)
  5. cmd/dockerd/daemon.go

    		GetSysInfo: func() *sysinfo.SysInfo {
    			return opts.daemon.RawSysInfo()
    		},
    	}
    
    	routers := []router.Router{
    		// we need to add the checkpoint router before the container router or the DELETE gets masked
    		checkpointrouter.NewRouter(opts.daemon, decoder),
    		container.NewRouter(opts.daemon, decoder, opts.daemon.RawSysInfo().CgroupUnified),
    		image.NewRouter(
    			opts.daemon.ImageService(),
    			opts.daemon.ReferenceStore,
    Go
    - Registered: 2022-09-21 12:04
    - Last Modified: 2022-08-18 12:57
    - 25K bytes
    - Viewed (0)
  6. integration-cli/daemon/daemon.go

    package daemon // import "github.com/docker/docker/integration-cli/daemon"
    
    import (
    	"fmt"
    	"strings"
    	"testing"
    	"time"
    
    	"github.com/docker/docker/testutil/daemon"
    	"github.com/pkg/errors"
    	"gotest.tools/v3/assert"
    	"gotest.tools/v3/icmd"
    )
    
    // Daemon represents a Docker daemon for the testing framework.
    type Daemon struct {
    	*daemon.Daemon
    	dockerBinary string
    }
    
    Go
    - Registered: 2022-09-14 12:04
    - Last Modified: 2022-02-15 11:50
    - 4.1K bytes
    - Viewed (0)
  7. daemon/daemon_unix.go

    		}
    	}
    	return sysinfo.New(siOpts...)
    }
    
    func (daemon *Daemon) initLibcontainerd(ctx context.Context) error {
    	var err error
    	daemon.containerd, err = remote.NewClient(
    		ctx,
    		daemon.containerdCli,
    		filepath.Join(daemon.configStore.ExecRoot, "containerd"),
    		daemon.configStore.ContainerdNamespace,
    		daemon,
    	)
    	return err
    }
    
    func recursiveUnmount(target string) error {
    Go
    - Registered: 2022-09-21 12:04
    - Last Modified: 2022-08-24 18:59
    - 62.8K bytes
    - Viewed (0)
  8. integration/daemon/daemon_test.go

    package daemon // import "github.com/docker/docker/integration/daemon"
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"net/http/httptest"
    	"os"
    	"os/exec"
    	"path/filepath"
    	"runtime"
    	"strings"
    	"syscall"
    	"testing"
    
    	"github.com/docker/docker/api/types"
    	"github.com/docker/docker/daemon/config"
    	"github.com/docker/docker/testutil/daemon"
    	"gotest.tools/v3/assert"
    	is "gotest.tools/v3/assert/cmp"
    	"gotest.tools/v3/skip"
    )
    Go
    - Registered: 2022-09-14 12:04
    - Last Modified: 2022-05-28 10:12
    - 13.3K bytes
    - Viewed (0)
  9. daemon/daemon_linux.go

    	// `info.Root` here is the root mountpoint of the passed in path (`daemon.root`).
    	// The ony cases that need to be cleaned up is when the daemon has performed a
    	//   `mount --bind /daemon/root /daemon/root && mount --make-shared /daemon/root`
    	// This is only done when the daemon is started up and `/daemon/root` is not
    	// already on a shared mountpoint.
    	if !shouldUnmountRoot(daemon.root, info[0]) {
    		return nil
    	}
    
    Go
    - Registered: 2022-09-21 12:04
    - Last Modified: 2022-05-29 14:28
    - 3.9K bytes
    - Viewed (0)
  10. cmd/dockerd/daemon_windows.go

    func getDaemonConfDir(root string) (string, error) {
    	return filepath.Join(root, "config"), nil
    }
    
    // preNotifyReady sends a message to the host when the API is active, but before the daemon is
    func preNotifyReady() {
    	// start the service now to prevent timeouts waiting for daemon to start
    	// but still (eventually) complete all requests that are sent after this
    	if service != nil {
    		err := service.started()
    		if err != nil {
    			logrus.Fatal(err)
    Go
    - Registered: 2022-09-21 12:04
    - Last Modified: 2022-08-11 15:30
    - 2.4K bytes
    - Viewed (0)
Back to top