- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Didn (0.15 sec)
-
cmd/admin-handlers-pools.go
if byID { var err error idx, err = strconv.Atoi(pool) if err != nil { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } } else { idx = globalEndpoints.GetPoolIdx(pool) if idx == -1 { // We didn't find any matching pools, invalid input
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
wlocked <- true } }() for i := 0; i < n; i++ { <-rlocked rl.Unlock() select { case <-wlocked: t.Fatal("RLocker() didn't read-lock it") default: } rl.Unlock() <-wlocked select { case <-rlocked: t.Fatal("RLocker() didn't respect the write lock") default: } wl.Unlock() } } // Borrowed from rwmutex_test.go func TestUnlockPanic(t *testing.T) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/metacache-set.go
continue } // If exact match, we agree. if _, ok := current.matches(&entry, true); ok { topEntries[i] = entry agree++ continue } // If only the name matches we didn't agree, but add it for resolution. if entry.name == current.name { topEntries[i] = entry continue } // We got different entries if entry.name > current.name { continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/prepare-storage.go
files, _ := filepath.Glob(filepath.Join(diskPath, ".writable-check-*.tmp")) for _, file := range files { go removeAll(file) } // Remove the entire folder in case there are leftovers that didn't get cleaned up before restart. go removeAll(pathJoin(diskPath, minioMetaTmpBucket+"-old")) // Renames and schedules for purging all bucket metacache. go renameAllBucketMetacache(diskPath) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
internal/bpool/bpool.go
} // Put returns the given Buffer to the BytePool. func (bp *BytePoolCap) Put(b []byte) { if bp == nil { return } select { case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
cmd/namespace-lock_test.go
// 1) lk3 or lk4 need to advance and increment the ref on the existing resource, // successfully acquiring the lock. // 2) lk2 then needs to advance and remove the resource from lockMap. // 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates // a new entry in lockMap and acquires a lock for the same resource. <-lk2ch lk3ok := <-lk3ch lk4ok := <-lk4ch if lk3ok && lk4ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
cmd/bucket-handlers.go
return } for i := range errs { // DeleteMarkerVersionID is not used specifically to avoid // lookup errors, since DeleteMarkerVersionID is only // created during DeleteMarker creation when client didn't // specify a versionID. objToDel := ObjectToDelete{ ObjectV: ObjectV{ ObjectName: decodeDirObject(dObjects[i].ObjectName), VersionID: dObjects[i].VersionID, },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cmd/net.go
u, err := url.Parse(hostAddr) if err != nil { return "", "", err } addr = u.Host scheme = u.Scheme // Use the given parameter again if url.Parse() // didn't return any useful result. if addr == "" { addr = hostAddr scheme = "http" } // At this point, addr can be one of the following form: // ":9000" // "localhost:9000"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
} } } msg := `Cross-device mounts detected on path (%s) at following locations %s. Export path should not have any sub-mounts, refusing to start.` if len(crossMounts) > 0 { // if paths didn't match then we do have cross-device mount. return fmt.Errorf(msg, path, crossMounts) } return nil } // readProcMounts reads the given mountFilePath (normally /proc/mounts) and produces a hash
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.7K bytes - Viewed (0) -
cmd/storage-datatypes.go
} // InlineData returns true if object contents are inlined alongside its metadata. func (fi FileInfo) InlineData() bool { _, ok := fi.Metadata[ReservedMetadataPrefixLower+"inline-data"] // Earlier MinIO versions didn't reset "x-minio-internal-inline-data" // from fi.Metadata when the object was tiered. So, tiered objects // would return true for InlineData() in these versions even though the // object isn't inlined in xl.meta
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0)