- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 110 for blocky (0.15 sec)
-
internal/disk/stat_linux_32bit.go
s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - s.Bavail info = Info{ Total: uint64(s.Frsize) * (s.Blocks - reservedBlocks), Free: uint64(s.Frsize) * s.Bavail, Files: s.Files, Ffree: s.Ffree, FSType: getFSType(s.Type), } // Check for overflows. // https://github.com/minio/minio/issues/8035
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 2.6K bytes - Viewed (0) -
cmd/lock-rest-client.go
err = errLockNotInitialized default: err = errors.New(r.Err) } return ok, err } // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
Klaus Post <******@****.***> 1700528975 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
internal/lock/lock_windows_test.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package lock import ( "strings" "testing" ) func TestFixLongPath(t *testing.T) { // 248 is long enough to trigger the longer-than-248 checks in // fixLongPath, but short enough not to make a path component
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 2.2K bytes - Viewed (0) -
internal/s3select/json/reader.go
func (pr *syncReadCloser) Read(p []byte) (n int, err error) { // This ensures that Close will block until Read has completed. // This allows another goroutine to close the reader. pr.mu.Lock() defer pr.mu.Unlock() if pr.rc == nil { return 0, io.EOF } return pr.rc.Read(p) } func (pr *syncReadCloser) Close() error { pr.mu.Lock() defer pr.mu.Unlock() if pr.rc != nil { err := pr.rc.Close() pr.rc = nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/pubsub/pubsub.go
} ps.Lock() defer ps.Unlock() sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter} ps.subs = append(ps.subs, sub) // We hold a lock, so we are safe to update combined := Mask(atomic.LoadUint64(&ps.types)) combined.Merge(Mask(mask.Mask())) atomic.StoreUint64(&ps.types, uint64(combined)) go func() { <-doneCh ps.Lock() defer ps.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/local-locker.go
TimeLastRefresh time.Time // Timestamp for last lock refresh. Source string // Contains line, function and filename requesting the lock. Group bool // indicates if it was a group lock. Owner string // Owner represents the UUID of the owner who originally requested the lock. Quorum int // Quorum represents the quorum required for this lock to be active.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/erasure-coding.go
return nil, err } if err = e.encoder().Encode(encoded); err != nil { return nil, err } return encoded, nil } // DecodeDataBlocks decodes the given erasure-coded data. // It only decodes the data blocks but does not verify them. // It returns an error if the decoding failed. func (e *Erasure) DecodeDataBlocks(data [][]byte) error { isZero := 0 for _, b := range data { if len(b) == 0 { isZero++ break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 8.6K bytes - Viewed (0) -
internal/fips/api.go
// It does not require any specific security criteria for those // high-level protocols. FIPS 140 focuses only on the implementation // and usage of the most low-level cryptographic building blocks. // // [1]: https://en.wikipedia.org/wiki/FIPS_140 package fips import ( "crypto/tls" "github.com/minio/sio" ) // Enabled indicates whether cryptographic primitives,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 30 19:37:07 GMT 2022 - 5.1K bytes - Viewed (0) -
internal/color/color.go
return fmt.Sprintf }() BgYellow = func() func(format string, a ...interface{}) string { if IsTerminal() { return color.New(color.BgYellow).SprintfFunc() } return fmt.Sprintf }() Black = func() func(format string, a ...interface{}) string { if IsTerminal() { return color.New(color.FgBlack).SprintfFunc() } return fmt.Sprintf }() FgRed = func() func(a ...interface{}) string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.8K bytes - Viewed (0)