Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for IsLocal (0.08 seconds)

  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]},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.9K bytes
    - Click Count (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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  3. cmd/erasure-common.go

    	// Based on the random shuffling return back randomized disks.
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for _, i := range r.Perm(len(disks)) {
    		if disks[i] != nil && disks[i].IsLocal() {
    			newDisks = append(newDisks, disks[i])
    		}
    	}
    
    	return newDisks
    }
    
    func (er erasureObjects) getLocalDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java

                return !(isLocal(url.getHost()) || url.getProtocol().equals("file"));
            } catch (MalformedURLException e) {
                // bad url just skip it here. It should have been validated already, but the wagon lookup will deal with it
                return false;
            }
        }
    
        private static boolean isLocal(String host) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 8K bytes
    - Click Count (0)
  5. cmd/lock-rest-client.go

    // IsOnline - returns whether REST client failed to connect or not.
    func (c *lockRESTClient) IsOnline() bool {
    	return c.connection.State() == grid.StateConnected
    }
    
    // Not a local locker
    func (c *lockRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close - marks the client as closed.
    func (c *lockRESTClient) Close() error {
    	return nil
    }
    
    // String - returns the remote host of the connection.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 29 18:10:04 GMT 2024
    - 3.3K bytes
    - Click Count (0)
  6. internal/dsync/locker.go

    	Close() error
    
    	// Is the underlying connection online? (is always true for any local lockers)
    	IsOnline() bool
    
    	// Is the underlying locker local to this server?
    	IsLocal() bool
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java

                return !(isLocal(url.getHost()) || url.getProtocol().equals("file"));
            } catch (MalformedURLException e) {
                // bad url just skip it here. It should have been validated already, but the wagon lookup will deal with it
                return false;
            }
        }
    
        private static boolean isLocal(String host) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Feb 07 00:45:02 GMT 2025
    - 33.5K bytes
    - Click Count (0)
  8. cmd/storage-interface.go

    	// if it has a "format.json" then is it correct "format.json" or not.
    	IsOnline() bool
    
    	// Returns the last time this disk (re)-connected
    	LastConn() time.Time
    
    	// Indicates if disk is local or not.
    	IsLocal() bool
    
    	// Returns hostname if disk is remote.
    	Hostname() string
    
    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    	// Close the disk, mark it purposefully closed, only implemented for remote disks.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  9. internal/dsync/dsync-client_test.go

    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) Close() error {
    	return nil
    }
    
    var (
    	errLockConflict = errors.New("lock conflict")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Click Count (0)
  10. 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()
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
Back to Top