Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 1,103 for differ (0.09 sec)

  1. cmd/bootstrap-peer-server.go

    			go func(clnt *bootstrapRESTClient) {
    				defer wg.Done()
    
    				if clnt.gridConn.State() != grid.StateConnected {
    					mu.Lock()
    					offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected))
    					mu.Unlock()
    					return
    				}
    
    				ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
    				defer cancel()
    
    				err := clnt.Verify(ctx, srcCfg)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/bucket-replication-handlers.go

    func (api objectAPIHandlers) PutBucketReplicationConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketReplicationConfig")
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    	}
    
    	z.poolMetaMutex.Lock()
    	defer z.poolMetaMutex.Unlock()
    
    	z.poolMeta = meta
    	return nil
    }
    
    func (z *erasureServerPools) DecommissionCancel(ctx context.Context, idx int) (err error) {
    	if idx < 0 {
    		return errInvalidArgument
    	}
    
    	if z.SinglePool() {
    		return errInvalidArgument
    	}
    
    	z.poolMetaMutex.Lock()
    	defer z.poolMetaMutex.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  4. internal/cachevalue/cache.go

    	if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 {
    		if t.updating.TryLock() {
    			go func() {
    				defer t.updating.Unlock()
    				t.update(context.Background())
    			}()
    		}
    		return *v, nil
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    	defer t.updating.Unlock()
    
    	if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. internal/config/policy/opa/config.go

    	if a.AuthToken != "" {
    		req.Header.Set("Authorization", a.AuthToken)
    	}
    
    	client := &http.Client{Transport: a.Transport}
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer a.CloseRespFn(resp.Body)
    
    	return nil
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (a *Args) UnmarshalJSON(data []byte) error {
    	// subtype to avoid recursive call to UnmarshalJSON()
    	type subArgs Args
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. cni/pkg/plugin/sidecar_iptables_linux.go

    		return err
    	}
    	defer netNs.Close()
    
    	return netNs.Do(func(_ ns.NetNS) error {
    		// Important: run within the pod network namespace since some attributes are namespace specific
    		if err := cfg.FillConfigFromEnvironment(); err != nil {
    			return err
    		}
    		log.Infof("============= Start iptables configuration for %v =============", podName)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Jun 29 01:24:47 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. cmd/metacache-server-pool.go

    	listCtx, cancelList := context.WithCancel(ctx)
    	defer cancelList()
    	for _, pool := range z.serverPools {
    		for _, set := range pool.sets {
    			wg.Add(1)
    			innerResults := make(chan metaCacheEntry, 100)
    			inputs = append(inputs, innerResults)
    			go func(i int, set *erasureObjects) {
    				defer wg.Done()
    				err := set.listPath(listCtx, o, innerResults)
    				mu.Lock()
    				defer mu.Unlock()
    				if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. internal/s3select/select.go

    }
    
    func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error {
    	switch s3Select.Output.format {
    	case csvFormat:
    		// Use bufio Writer to prevent csv.Writer from allocating a new buffer.
    		bufioWriter := bufioWriterPool.Get().(*bufio.Writer)
    		defer func() {
    			bufioWriter.Reset(xioutil.Discard)
    			bufioWriterPool.Put(bufioWriter)
    		}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/escape/UnicodeEscaper.java

     *
     * @author David Beaumont
     * @since 15.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public abstract class UnicodeEscaper extends Escaper {
      /** The amount of padding (chars) to use when growing the escape buffer. */
      private static final int DEST_PAD = 32;
    
      /** Constructor for use by subclasses. */
      protected UnicodeEscaper() {}
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 18 20:55:09 UTC 2022
    - 13.2K bytes
    - Viewed (0)
  10. cmd/update.go

    		if err != nil {
    			return nil, nil, err
    		}
    	} else {
    		return nil, nil, fmt.Errorf("unsupported protocol scheme: %s", u.Scheme)
    	}
    	defer xhttp.DrainBody(reader)
    
    	b := bytebufferpool.Get()
    	bc := bytebufferpool.Get()
    	defer func() {
    		b.Reset()
    		bc.Reset()
    
    		bytebufferpool.Put(b)
    		bytebufferpool.Put(bc)
    	}()
    
    	w, err := zstd.NewWriter(bc)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top