- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 104 for delete (0.13 sec)
-
cmd/os-reliable.go
i++ continue } } break } return err } // Wrapper functions to os.MkdirAll, which calls reliableMkdirAll // this is to ensure that if there is a racy parent directory // delete in between we can simply retry the operation. func mkdirAll(dirPath string, mode os.FileMode, baseDir string) (err error) { if dirPath == "" { return errInvalidArgument }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
} if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock return false, fmt.Errorf("Unlock attempted on a read locked entity: %s (%d read locks active)", args.Resources[0], locksHeld) } delete(l.lockMap, args.Resources[0]) // Remove the write lock return true, nil } const ReadLock = 1 func (l *lockServer) RLock(args *LockArgs) (reply bool, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/site-replication-utils_gen.go
return } if z.BucketStatuses == nil { z.BucketStatuses = make(map[string]ResyncStatusType, zb0002) } else if len(z.BucketStatuses) > 0 { for key := range z.BucketStatuses { delete(z.BucketStatuses, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 ResyncStatusType za0001, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 7.2K bytes - Viewed (0) -
cmd/bucket-encryption-handlers.go
var err error if _, err = objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Delete bucket encryption config from object layer updatedAt, err := globalBucketMetadataSys.Delete(ctx, bucket, bucketSSEConfig) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook.
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/namespace-lock.go
logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0")) } if n.lockMap[resource].ref == 0 { // Remove from the map if there are no more references. delete(n.lockMap, resource) } n.lockMapMutex.Unlock() } return } // Unlock the namespace resource. func (n *nsLockMap) unlock(volume string, path string, readLock bool) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
zb0004, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } if (*z) == nil { (*z) = make(DailyAllTierStats, zb0004) } else if len((*z)) > 0 { for key := range *z { delete((*z), key) } } var field []byte _ = field for zb0004 > 0 { zb0004-- var zb0001 string var zb0002 lastDayTierStats zb0001, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/etcd.go
} func deleteKeyEtcd(ctx context.Context, client *etcd.Client, key string) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
docs/bucket/lifecycle/DESIGN.md
### Expiry or removal events An object that is in transition tier will be deleted once the object hits expiry date or if removed via `mc rm` (`mc rm --vid` in the case of delete of a specific object version). Other rules specific to legal hold and object locking precede any lifecycle rules. ### Additional notes
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 4.3K bytes - Viewed (0) -
cmd/tier-sweeper.go
// 3. If bucket versioning is enabled and // a. version id is specified, remove its remote object. // b. version id is not specified, nothing to be done (a delete marker is added). delTier := false switch { case !os.Versioned, os.Suspended: // 1, 2.a, 2.b delTier = true case os.Versioned && os.VersionID != "": // 3.a delTier = true } if delTier {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/event/rulesmap.go
func (rulesMap RulesMap) Remove(rulesMap2 RulesMap) { for eventName, rules := range rulesMap { if nr := rules.Difference(rulesMap2[eventName]); len(nr) != 0 { rulesMap[eventName] = nr } else { delete(rulesMap, eventName) } } } // MatchSimple - returns true if matching object name and event name in rules map. func (rulesMap RulesMap) MatchSimple(eventName Name, objectName string) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.6K bytes - Viewed (0)