- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,202 for Ticket (0.14 sec)
-
cmd/batch-handlers.go
defer ri.mu.Unlock() ri.Bucket = bucket ri.Object = info.Name ri.countItem(info.Size, info.DeleteMarker, success, attempt) } 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 { ri.Object = batch[i].Name
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
cmd/sftp-server-driver.go
case "Remove": bucket, object := path2BucketObject(r.Filepath) if bucket == "" { return errors.New("bucket name cannot be empty") } return clnt.RemoveObject(context.Background(), bucket, object, minio.RemoveObjectOptions{}) case "Mkdir": bucket, prefix := path2BucketObject(r.Filepath) if bucket == "" { return errors.New("bucket name cannot be empty") } if prefix == "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/erasure-object_test.go
testCases := []struct { bucket string object string expectedErr error }{ {".test", "dir/obj", BucketNameInvalid{Bucket: ".test"}}, {"----", "dir/obj", BucketNameInvalid{Bucket: "----"}}, {"bucket", "", ObjectNameInvalid{Bucket: "bucket", Object: ""}}, {"bucket", "doesnotexist", ObjectNotFound{Bucket: "bucket", Object: "doesnotexist"}},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
cmd/metrics-v3-api.go
} sentBytes := inOut.Out if sentBytes > 0 { m.Set(apiTrafficRecvBytes, float64(sentBytes), "bucket", bucket, "type", "s3") } httpStats := globalBucketHTTPStats.load(bucket) for k, v := range httpStats.currentS3Requests.Load(false) { m.Set(apiRequestsInFlightTotal, float64(v), "bucket", bucket, "name", k, "type", "s3") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/object-api-interface.go
// Bucket operations. MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
if err != nil { return err } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bucket) if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) { return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bucket) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
src/runtime/map.go
// If the bucket we're looking at hasn't been filled in yet (i.e. the old // bucket hasn't been evacuated) then we need to iterate through the old // bucket and only return the ones that will be migrated to this bucket. oldbucket := bucket & it.h.oldbucketmask() b = (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize))) if !evacuated(b) { checkBucket = bucket } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 57.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt
assertThat(attempt1).isNotNull() assertThat(attempt1!!.isTlsFallback).isTrue() socket.close() // COMPATIBLE_TLS is used here. socket = createSocketWithEnabledProtocols(*enabledSocketTlsVersions) connectionSpecs[attempt1.connectionSpecIndex].apply(socket, attempt1.isTlsFallback) assertEnabledProtocols(socket, TlsVersion.TLS_1_2, TlsVersion.TLS_1_1, TlsVersion.TLS_1_0)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/http-stats.go
// Increase S3 total input bytes for input bucket func (s *bucketConnStats) incS3InputBytes(bucket string, n int64) { s.Lock() defer s.Unlock() stats, ok := s.stats[bucket] if !ok { stats = &bucketS3RXTX{ s3InputBytes: uint64(n), } } else { stats.s3InputBytes += uint64(n) } s.stats[bucket] = stats } // Increase S3 total output bytes for input bucket
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/software/resources-gcs/src/integTest/groovy/org/gradle/integtests/resource/gcs/fixtures/GcsArtifact.groovy
GcsArtifact(GcsServer server, TestFile file, String repositoryPath, String bucket) { super(server, file, repositoryPath, bucket) } @Override String getName() { return file.name } @Override GcsResource getMd5() { return new GcsResource(server, file.parentFile.file(file.name + ".md5"), repositoryPath, bucket) } @Override GcsResource getSha1() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 1.6K bytes - Viewed (0)