- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for rlock (0.14 sec)
-
cmd/batch-handlers.go
if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() ri.Bucket = bucket ri.Object = info.Name ri.countItem(info.Size, info.DeleteMarker, success) } func (ri *batchJobInfo) trackCurrentBucketBatch(bucket string, batch []ObjectInfo) { if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() ri.Bucket = bucket for i := range batch {
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) -
internal/logger/logger.go
API: "SYSTEM", RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()), } } req.RLock() defer req.RUnlock() API := "SYSTEM" switch { case req.API != "": API = req.API case subsystem != "": API += "." + subsystem } // Copy tags. We hold read lock already. tags := make(map[string]interface{}, len(req.tags)) for _, entry := range req.tags {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/erasure-object.go
nsUnlocker() } }() // Acquire lock if !opts.NoLock { lock := er.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() // Release lock when the metadata is verified, and reader // is ready to be read. // // This is possible to be lock free because
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/api-errors.go
ErrObjectLockConfigurationNotFound: { Code: "ObjectLockConfigurationNotFoundError", Description: "Object Lock configuration does not exist for this bucket", HTTPStatusCode: http.StatusNotFound, }, ErrObjectLockConfigurationNotAllowed: { Code: "InvalidBucketState", Description: "Object Lock configuration cannot be enabled on existing buckets", HTTPStatusCode: http.StatusConflict, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
cmd/object-api-errors.go
return "No bucket tags found for bucket: " + e.Bucket } // BucketObjectLockConfigNotFound - no bucket object lock config found type BucketObjectLockConfigNotFound GenericError func (e BucketObjectLockConfigNotFound) Error() string { return "No bucket object lock configuration found for bucket: " + e.Bucket } // BucketQuotaConfigNotFound - no bucket quota config found.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Delete(context.Background(), name, metav1.DeleteOptions{}); err != nil { if errors.IsNotFound(err) { fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v not found\n", namespace, name) } else { mu.Lock() multiErr = multierror.Append(multiErr, err) mu.Unlock() } } else { fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v deleted\n", namespace, name) } }(name) } wg.Wait()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
Makefile.core.mk
init: $(TARGET_OUT)/istio_is_init init-ztunnel-rs @mkdir -p ${TARGET_OUT}/logs @mkdir -p ${TARGET_OUT}/release # I tried to make this dependent on what I thought was the appropriate # lock file, but it caused the rule for that file to get run (which # seems to be about obtaining a new version of the 3rd party libraries). $(TARGET_OUT)/istio_is_init: bin/init.sh istio.deps | $(TARGET_OUT)
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 20:25:15 GMT 2024 - 22.5K bytes - Viewed (0) -
cmd/common-main.go
if err != nil { return tls.Certificate{}, fmt.Errorf("Unable to decrypt KES client private key as specified by the shell environment: %v", err) } keyBytes = pem.EncodeToMemory(&pem.Block{Type: privateKeyPEM.Type, Bytes: keyBytes}) } certificate, err := tls.X509KeyPair(certBytes, keyBytes) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
go.sum
github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2/go.mod h1:WaHUgvxTVq04UNunO+XhnAqY/wQc+bxr74GqbsZ/Jqw= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 21:52:58 GMT 2024 - 109K bytes - Viewed (0)