- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 41 for IsLocal (0.08 seconds)
-
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) -
cmd/endpoint.go
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) -
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) -
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) -
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) -
internal/dsync/locker.go
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) -
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) -
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) -
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) -
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)