- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for wasn (0.17 sec)
-
cmd/iam-store.go
m = cache.iamSTSAccountsMap default: m = cache.iamUsersMap } err := store.loadUser(ctx, accessKey, userType, m) if err == errNoSuchUser { // User was deleted - we update the cache. delete(m, accessKey) // Since cache was updated, we update the timestamp. defer func() { cache.updatedAt = time.Now() }() // 1. Start with updating user-group memberships
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/xl-storage.go
if err == nil { dataDir := ver.getDataDir() if dataDir != "" && (xlMeta.SharedDataDirCountStr(reqVID, dataDir) == 0) { // Purge the destination path as we are not preserving anything // versioned object was not requested. res.OldDataDir = dataDir if healing { // if old destination path is same as new destination path // there is nothing to purge, this is true in case of healing
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/api-errors.go
Description: "The provided 'x-amz-content-sha256' header does not match what was computed.", HTTPStatusCode: http.StatusBadRequest, }, ErrContentChecksumMismatch: { Code: "XAmzContentChecksumMismatch", Description: "The provided 'x-amz-checksum' header does not match what was computed.", HTTPStatusCode: http.StatusBadRequest, }, // MinIO extensions.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/erasure-object.go
// Save the current part name and size. partSize := fi.Parts[partIndex].Size partLength := partSize - partOffset // partLength should be adjusted so that we don't write more data than what was requested. if partLength > (length - totalBytesRead) { partLength = length - totalBytesRead } tillOffset := erasure.ShardFileOffset(partOffset, partLength, partSize)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
if evt.Action.Delete() { globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_s3ListObjects) if !evt.Action.DeleteRestored() { // Skip entry if ILM action was DeleteVersionAction or DeleteAction return loi, nil } } } return loi, nil } if isErrBucketNotFound(err) { return loi, err } if contextCanceled(ctx) {
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) -
cmd/iam.go
collectedErrors = append(collectedErrors, fmt.Errorf("could not validate `%s` exists in LDAP directory: %w", parent, err)) continue } if validatedParent == "" || !isUnderBaseDN { err := fmt.Errorf("DN `%s` was not found in the LDAP directory", parent) collectedErrors = append(collectedErrors, err) continue } if validatedParent != parent { hasDiff = true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/batch-handlers.go
}) } _, err = api.CompleteMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, uploadedParts, opts) return err } // StartFromSource starts the batch replication job from remote source, resumes if there was a pending job via "job.ID" func (r *BatchJobReplicateV1) StartFromSource(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/admin-handlers-users.go
if err != nil { if err == errNoSuchUser || err == errNoSuchGroup { if globalIAMSys.LDAPConfig.Enabled() { // When LDAP is enabled, warn user that they are using the wrong // API. FIXME: error can be no such group as well - fix errNoSuchUserLDAPWarn writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errNoSuchUserLDAPWarn), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 77.5K bytes - Viewed (0) -
src/bufio/bufio_test.go
// All data should have been read. _, err := r.ReadByte() if err != io.EOF { t.Errorf("#%d: got error %v; want EOF", rno, err) } } } // Test that UnreadRune fails if the preceding operation was not a ReadRune. func TestUnreadRuneError(t *testing.T) { buf := make([]byte, 3) // All runes in this test are 3 bytes long r := NewReader(&StringReader{data: []string{"日本語日本語日本語"}}) if r.UnreadRune() == nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Feb 10 18:56:01 GMT 2023 - 51.5K bytes - Viewed (0) -
cmd/bucket-handlers.go
for _, deleteResult := range deleteResults { if deleteResult.errInfo.Code != "" { deleteErrors = append(deleteErrors, deleteResult.errInfo) } else { // All deletes on directory objects was with `nullVersionID`. // Remove it from response. if isDirObject(deleteResult.delInfo.ObjectName) && deleteResult.delInfo.VersionID == nullVersionID { deleteResult.delInfo.VersionID = "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0)