- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 145 for Ticket (0.47 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockCommunicator.java
for (SocketAddress address : addresses) { DatagramPacket packet = new DatagramPacket(bytes, bytes.length); packet.setSocketAddress(address); LOGGER.debug("Confirming lock release to Gradle process at port {} for lock with id {}.", packet.getPort(), lockId); try { socket.send(packet); } catch (IOException e) { if (!stopped) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 5.9K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy
FileLockPacketPayload receivedPayload start { def packet = communicator.receive() receivedPayload = communicator.decode(packet) } poll { assert communicator.getPort() != -1 && receivedPayload == null } when: def socket = new DatagramSocket(0, addressFactory.getWildcardBindingAddress())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/dummy-handlers.go
// They are only defined to be used in this file alone. // GetBucketWebsite - GET bucket website, a dummy api func (api objectAPIHandlers) GetBucketWebsiteHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "GetBucketWebsite") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) vars := mux.Vars(r) bucket := vars["bucket"] objAPI := api.ObjectAPI() if objAPI == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/acl-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Before proceeding validate if bucket exists. _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } aclHeader := r.Header.Get(xhttp.AmzACL) if aclHeader == "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.4K bytes - Viewed (0) -
docs/bucket/replication/test_del_marker_proxying.sh
export MC_HOST_siteb=http://minio:minio123@127.0.0.1:9002 ./mc ready sitea ./mc ready siteb ./mc mb sitea/bucket ./mc version enable sitea/bucket ./mc mb siteb/bucket ./mc version enable siteb/bucket # Set bucket replication ./mc replicate add sitea/bucket --remote-bucket siteb/bucket # Run the test to make sure proxying of DEL marker doesn't happen loop_count=0 while true; do
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 11:38:26 UTC 2024 - 1.8K bytes - Viewed (0) -
docs/site-replication/run-ssec-object-replication-with-compression.sh
# Create bucket in source cluster echo "Create bucket in source MinIO instance" ./mc mb minio1/test-bucket --insecure # Load objects to source site echo "Loading objects to source MinIO instance" ./mc cp /tmp/data/plainfile minio1/test-bucket --insecure ./mc cp /tmp/data/encrypted minio1/test-bucket/encrypted --enc-c "minio1/test-bucket/encrypted=${TEST_MINIO_ENC_KEY}" --insecure
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
fallthrough case "forbidden": err = PrefixAccessDenied{ Bucket: bucket, Object: object, } case "invalid": err = BucketNameInvalid{ Bucket: bucket, } case "notFound": if object != "" { err = ObjectNotFound{ Bucket: bucket, Object: object, } break } err = BucketNotFound{Bucket: bucket} case "conflict":
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.9K bytes - Viewed (0) -
docs/bucket/replication/setup_2site_existing_replication.sh
./mc replicate add sitea/bucket/ \ --remote-bucket http://minio:minio123@127.0.0.1:9004/bucket remote_arn=$(./mc replicate ls sitea/bucket --json | jq -r .rule.Destination.Bucket) sleep 1 ./mc replicate resync start sitea/bucket/ --remote-bucket "${remote_arn}" sleep 30s ## sleep for 30s idea is that we give 300ms per object. ./mc ls -r --versions sitea/bucket >/tmp/sitea.txt ./mc ls -r --versions siteb/bucket >/tmp/siteb.txt
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/peer-s3-server.go
} // check dangling and delete bucket only if its not a meta bucket if !isMinioMetaBucketName(bucket) && !isAllBucketsNotFound(errs) && opts.Remove { g := errgroup.WithNErrs(len(localDrives)) for index := range localDrives { index := index g.Go(func() error { if localDrives[index] == nil { return errDiskNotFound } localDrives[index].DeleteVol(ctx, bucket, false) return nil }, index)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.4K 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)