- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for downes (0.31 sec)
-
cmd/admin-handlers_test.go
} return toUniqLock(b.LockEntries[i]) < toUniqLock(b.LockEntries[j]) } func TestTopLockEntries(t *testing.T) { locksHeld := make(map[string][]lockRequesterInfo) var owners []string for i := 0; i < 4; i++ { owners = append(owners, fmt.Sprintf("node-%d", i)) } // Simulate DeleteObjects of 10 objects in a single request. i.e same lock // request UID, but 10 different resource names associated with it.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 23 17:26:21 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
return } } case "Source": z.Source, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Source") return } case "Owner": z.Owner, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Owner") return } case "Quorum": z.Quorum, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Quorum") return } default:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
cmd/local-locker.go
// or last read lock) // UID and optionally owner must match for entries to be deleted. func (l *localLocker) removeEntry(name string, args dsync.LockArgs, lri *[]lockRequesterInfo) bool { // Find correct entry to remove based on uid. for index, entry := range *lri { if entry.UID == args.UID && (args.Owner == "" || entry.Owner == args.Owner) { if len(*lri) == 1 { // Remove the write lock.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/admin-handlers-users.go
ConditionValues: getConditionValues(r, "", cred), IsOwner: owner, ObjectName: "", Claims: cred.Claims, }) { wr = true } return rd, wr } bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func() (DataUsageInfo, error) { ctx, done := context.WithTimeout(context.Background(), 2*time.Second) defer done()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 77.3K bytes - Viewed (0) -
tests/update_test.go
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Dec 04 03:50:58 GMT 2023 - 30.3K bytes - Viewed (0) -
cmd/admin-handlers-idp-ldap.go
objectAPI := newObjectLayerFn() if objectAPI == nil || globalNotificationSys == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return } cred, owner, s3Err := validateAdminSignature(ctx, r, "") if s3Err != ErrNone { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL) return } userDN := r.Form.Get("userDN")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 13.3K bytes - Viewed (0) -
src/archive/tar/common.go
Size int64 // Logical file size in bytes Mode int64 // Permission and mode bits Uid int // User ID of owner Gid int // Group ID of owner Uname string // User name of owner Gname string // Group name of owner // If the Format is unspecified, then Writer.WriteHeader rounds ModTime // to the nearest second and ignores the AccessTime and ChangeTime fields. //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24.7K bytes - Viewed (2) -
cmd/post-policy_test.go
retStr := "{" retStr = retStr + expirationStr + "," retStr += conditionStr retStr += "}" return []byte(retStr) } // newPostPolicyBytesV4 - creates a bare bones postpolicy string with key and bucket matches. func newPostPolicyBytesV4(credential, bucketName, objectKey string, expiration time.Time) []byte { t := UTCNow() // Add the expiration date.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/erasure-sets.go
timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval()) defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: var wg sync.WaitGroup for _, set := range s.sets { wg.Add(1) go func(set *erasureObjects) { defer wg.Done() if set == nil { return } set.cleanupDeletedObjects(ctx) }(set) } wg.Wait()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5)