Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Op (0.12 sec)

  1. cni/test/install_cni.go

    func checkBinDir(t *testing.T, tempCNIBinDir, op string, files ...string) error {
    	t.Helper()
    	for _, f := range files {
    		if _, err := os.Stat(tempCNIBinDir + "/" + f); !os.IsNotExist(err) {
    			if op == "add" {
    				t.Logf("PASS: File %v was added to %v", f, tempCNIBinDir)
    				return nil
    			} else if op == "del" {
    				return fmt.Errorf("FAIL: File %v was not removed from %v", f, tempCNIBinDir)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  2. cni/pkg/util/pluginutil.go

    	}, nil
    }
    
    func watchFiles(watcher *fsnotify.Watcher, fileModified chan struct{}, errChan chan error) {
    	for {
    		select {
    		case event, ok := <-watcher.Events:
    			if !ok {
    				return
    			}
    			if event.Op&(fsnotify.Create|fsnotify.Write|fsnotify.Remove) != 0 {
    				log.Infof("file modified: %v", event.Name)
    				fileModified <- struct{}{}
    			}
    		case err, ok := <-watcher.Errors:
    			if !ok {
    				return
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/fakes_test.go

    	fs.FileInfo
    }
    
    func (f *fakeFileFakeFI) Sys() any {
    	return &syscall.Stat_t{Ino: 1}
    }
    
    // Open opens the named file.
    // When Open returns an error, it should be of type *PathError
    // with the Op field set to "open", the Path field set to name,
    // and the Err field describing the problem.
    //
    // Open should reject attempts to open names that do not satisfy
    // ValidPath(name), returning a *PathError with Err set to
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. cni/pkg/cmd/root.go

    			}
    
    			ambientAgent.Start()
    			defer ambientAgent.Stop()
    
    			log.Info("Ambient node agent started, starting installer...")
    
    		} else {
    			// Ambient not enabled, so this readiness flag is no-op'd
    			watchServerReady.Store(true)
    		}
    
    		installer := install.NewInstaller(&cfg.InstallConfig, installDaemonReady)
    
    		repair.StartRepair(ctx, cfg.RepairConfig)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.5K bytes
    - Viewed (0)
Back to top