- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for plane (0.14 sec)
-
internal/disk/directio_unix.go
//go:build !windows && !darwin && !openbsd && !plan9 // +build !windows,!darwin,!openbsd,!plan9 // Copyright (c) 2015-2023 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 17 14:31:36 GMT 2023 - 1.6K bytes - Viewed (0) -
internal/lock/lock_nix.go
//go:build !windows && !plan9 && !solaris // +build !windows,!plan9,!solaris // Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 2.8K bytes - Viewed (0) -
cmd/os-instrumented.go
default: defer updateOSMetrics(osMetricOpenFileR, name)(err) } return os.OpenFile(name, flag, perm) } // Access captures time taken to call syscall.Access() // on windows, plan9 and solaris syscall.Access uses // os.Lstat() func Access(name string) (err error) { defer updateOSMetrics(osMetricAccess, name)(err) return access(name) } // Open captures time taken to call os.Open
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/storage-errors.go
return string(h) } // Collection of basic errors. var baseErrs = []error{ errDiskNotFound, errFaultyDisk, errFaultyRemoteDisk, } var baseIgnoredErrs = baseErrs // Is a one place function which converts all os.PathError // into a more FS object layer friendly form, converts // known errors into their typed form for top level // interpretation. func osErrToFileErr(err error) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/untar.go
f: formatBZ2, }, } type untarOptions struct { ignoreDirs bool ignoreErrs bool prefixAll string } // disconnectReader will ensure that no reads can take place on // the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/object-handlers.go
proxytgts := getProxyTargets(ctx, bucket, object, opts) if !proxytgts.Empty() { globalReplicationStats.incProxy(bucket, getObjectAPI, false) // proxy to replication target if active-active replication is in place. reader, proxy, perr = proxyGetToReplicationTarget(ctx, bucket, object, rs, r.Header, opts, proxytgts) if perr != nil { globalReplicationStats.incProxy(bucket, getObjectAPI, true)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return z.serverPools[poolIdx].CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts) } // Destination is not versioned and source version ID is empty // perform an in-place update. if !dstOpts.Versioned && srcOpts.VersionID == "" { return z.serverPools[poolIdx].CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/config/subnet/config.go
} if c.APIKey != "" { os.Setenv("CONSOLE_SUBNET_API_KEY", c.APIKey) } if c.Proxy != "" { os.Setenv("CONSOLE_SUBNET_PROXY", c.Proxy) } os.Setenv("CONSOLE_SUBNET_URL", c.BaseURL) } // Update - in-place update with new license and registration information. func (c *Config) Update(ncfg Config, isDevEnv bool) { configLock.Lock() defer configLock.Unlock() c.License = ncfg.License c.APIKey = ncfg.APIKey
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/bucket-replication.go
go globalReplicationStats.trackEWMA() } type proxyResult struct { Proxy bool Err error } // get Reader from replication target if active-active replication is in place and // this node returns a 404
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/metacache-server-pool.go
if err == nil { c.error = "no longer used" c.status = scanStateError rpc.UpdateMetacacheListing(ctx, *c) } } }() o.ID = "" } // Do listing in-place. // Create output for our results. // Create filter for results. o.debugln("Raw List", o) filterCh := make(chan metaCacheEntry, o.Limit) listCtx, cancelList := context.WithCancel(ctx)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0)