Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 474 for derer (0.03 sec)

  1. cmd/admin-handlers-users_test.go

    }()
    
    const (
    	EnvTestEtcdBackend = "_MINIO_ETCD_TEST_SERVER"
    )
    
    func (s *TestSuiteIAM) setUpEtcd(c *check, etcdServer string) {
    	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
    	defer cancel()
    
    	configCmds := []string{
    		"etcd",
    		"endpoints=" + etcdServer,
    		"path_prefix=" + mustGetUUID(),
    	}
    	_, err := s.adm.SetConfigKV(ctx, strings.Join(configCmds, " "))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher_test.go

    		PodName:      "pod-bingo",
    		PodNamespace: "funkyns",
    		IPs: []IPConfig{{
    			Address: *addr,
    		}},
    	}
    
    	setupLogging()
    	NodeName = "testnode"
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. cmd/post-policy-fan-out.go

    	objInfos := make([]ObjectInfo, len(fanOutEntries))
    
    	var wg sync.WaitGroup
    	for i, req := range fanOutEntries {
    		wg.Add(1)
    		go func(idx int, req minio.PutObjectFanOutEntry) {
    			defer wg.Done()
    
    			objInfos[idx] = ObjectInfo{Name: req.Key}
    
    			hopts := hash.Options{
    				Size:       int64(len(fanOutBuf)),
    				MD5Hex:     opts.MD5Hex,
    				SHA256Hex:  "",
    				ActualSize: -1,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. cmd/listen-notification-handlers.go

    			return
    		}
    		t := time.NewTicker(time.Duration(pingInterval) * time.Second)
    		defer t.Stop()
    		emptyEventTicker = t.C
    	} else {
    		// Deprecated Apr 2023
    		t := time.NewTicker(500 * time.Millisecond)
    		defer t.Stop()
    		keepAliveTicker = t.C
    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case ev := <-mergeCh:
    			_, err := w.Write(ev)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. src/cmd/asm/main.go

    	case "all", "ret":
    		ctxt.Retpoline = true
    	}
    
    	ctxt.Bso = bufio.NewWriter(os.Stdout)
    	defer ctxt.Bso.Flush()
    
    	architecture.Init(ctxt)
    
    	// Create object file, write header.
    	buf, err := bio.Create(*flags.OutputFile)
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer buf.Close()
    
    	if !*flags.SymABIs {
    		buf.WriteString(objabi.HeaderString())
    		fmt.Fprintf(buf, "!\n")
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    	s.Lock()
    	defer s.Unlock()
    
    	m := s.statusMap[opts.bucket]
    	st := m.TargetsMap[opts.arn]
    	st.LastUpdate = UTCNow()
    	st.ResyncStatus = status
    	m.TargetsMap[opts.arn] = st
    	m.LastUpdate = UTCNow()
    	s.statusMap[opts.bucket] = m
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    	saveResyncStatus(ctx, opts.bucket, m, objAPI)
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  7. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    		format := newFormatErasureV3(setCount, setDriveCount)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  8. internal/s3select/json/reader.go

    	// This ensures that Close will block until Read has completed.
    	// This allows another goroutine to close the reader.
    	pr.mu.Lock()
    	defer pr.mu.Unlock()
    	if pr.rc == nil {
    		return 0, io.EOF
    	}
    	return pr.rc.Read(p)
    }
    
    func (pr *syncReadCloser) Close() error {
    	pr.mu.Lock()
    	defer pr.mu.Unlock()
    	if pr.rc != nil {
    		err := pr.rc.Close()
    		pr.rc = nil
    		return err
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/site-replication.go

    		time.Sleep(duration)
    	}
    	c.RLock()
    	defer c.RUnlock()
    	if c.enabled {
    		logger.Info("Cluster replication initialized")
    	}
    	return nil
    }
    
    func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error {
    	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  10. internal/s3select/progress.go

    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top