Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for IsLocal (0.03 sec)

  1. cmd/endpoint_test.go

    			Endpoint{URL: case4URLs[1], IsLocal: case4LocalFlags[1]},
    			Endpoint{URL: case4URLs[2], IsLocal: case4LocalFlags[2]},
    			Endpoint{URL: case4URLs[3], IsLocal: case4LocalFlags[3]},
    		}, DistErasureSetupType, nil},
    
    		{":9000", []string{case5Endpoint1, case5Endpoint2, case5Endpoint3, case5Endpoint4}, ":9000", Endpoints{
    			Endpoint{URL: case5URLs[0], IsLocal: case5LocalFlags[0]},
    			Endpoint{URL: case5URLs[1], IsLocal: case5LocalFlags[1]},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  2. cmd/endpoint.go

    type Node struct {
    	*url.URL
    	Pools    []int
    	IsLocal  bool
    	GridHost string
    }
    
    // Endpoint - any type of endpoint.
    type Endpoint struct {
    	*url.URL
    	IsLocal bool
    
    	PoolIdx, SetIdx, DiskIdx int
    }
    
    // Equal returns true if endpoint == ep
    func (endpoint Endpoint) Equal(ep Endpoint) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  3. cmd/admin-handlers-pools.go

    	// first node. The following is required to serialize (the effects of)
    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    			if proxyEp.Host == ep.Host {
    				if proxied, success := proxyRequestByNodeIndex(ctx, w, r, nodeIdx, false); proxied && success {
    					return
    				}
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  4. cmd/naughty-disk_test.go

    		return err == errDiskNotFound
    	}
    	return d.disk.IsOnline()
    }
    
    func (d *naughtyDisk) LastConn() time.Time {
    	return d.disk.LastConn()
    }
    
    func (d *naughtyDisk) IsLocal() bool {
    	return d.disk.IsLocal()
    }
    
    func (d *naughtyDisk) Endpoint() Endpoint {
    	return d.disk.Endpoint()
    }
    
    func (d *naughtyDisk) Hostname() string {
    	return d.disk.Hostname()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    			disk, format, err := connectEndpoint(endpoint)
    			if err != nil {
    				if endpoint.IsLocal && errors.Is(err, errUnformattedDisk) {
    					globalBackgroundHealState.pushHealLocalDisks(endpoint)
    				} else if !errors.Is(err, errDriveIsRoot) {
    					if log {
    						printEndpointError(endpoint, err, true)
    					}
    				}
    				return
    			}
    			if disk.IsLocal() {
    				h := disk.Healing()
    				if h != nil && !h.Finished {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  6. cmd/erasure.go

    			di := madmin.Disk{
    				Endpoint:  endpoints[index].String(),
    				PoolIndex: endpoints[index].PoolIdx,
    				SetIndex:  endpoints[index].SetIdx,
    				DiskIndex: endpoints[index].DiskIdx,
    				Local:     endpoints[index].IsLocal,
    			}
    			if disks[index] == OfflineDisk {
    				di.State = diskErrToDriveState(errDiskNotFound)
    				disksInfo[index] = di
    				return nil
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  7. cmd/local-locker.go

    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. src/archive/zip/reader.go

    }
    
    // OpenReader will open the Zip file specified by name and return a ReadCloser.
    //
    // If any file inside the archive uses a non-local name
    // (as defined by [filepath.IsLocal]) or a name containing backslashes
    // and the GODEBUG environment variable contains `zipinsecurepath=0`,
    // OpenReader returns the reader with an ErrInsecurePath error.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 28.4K bytes
    - Viewed (0)
  9. cmd/bucket-listobjects-handlers.go

    	if len(globalProxyEndpoints) == 0 {
    		return
    	}
    	if index < 0 || index >= len(globalProxyEndpoints) {
    		return
    	}
    	ep := globalProxyEndpoints[index]
    	if ep.IsLocal {
    		return
    	}
    	return true, proxyRequest(ctx, w, r, ep, returnErr)
    }
    
    // ListObjectsV1Handler - GET Bucket (List Objects) Version 1.
    // --------------------------
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 03 21:03:04 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  10. src/archive/tar/reader.go

    // Any remaining data in the current file is automatically discarded.
    // At the end of the archive, Next returns the error io.EOF.
    //
    // If Next encounters a non-local name (as defined by [filepath.IsLocal])
    // and the GODEBUG environment variable contains `tarinsecurepath=0`,
    // Next returns the header with an [ErrInsecurePath] error.
    // A future version of Go may introduce this behavior by default.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
Back to top