Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 111 for setObject (0.07 sec)

  1. cmd/global-heal.go

    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    			forwardTo = tracker.getObject()
    		}
    		if b != "" {
    			// Reset to where last bucket ended if resuming.
    			tracker.resume()
    		}
    		tracker.setObject("")
    		tracker.setBucket(bucket)
    		// Heal current bucket again in case if it is failed
    		// in the beginning of erasure set healing
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/util/WebApiUtil.java

        }
    
        /**
         * Sets an object in the current request attributes.
         *
         * @param name The attribute name
         * @param value The attribute value
         */
        public static void setObject(final String name, final Object value) {
            LaRequestUtil.getOptionalRequest().ifPresent(req -> req.setAttribute(name, value));
        }
    
        /**
         * Gets an object from the current request attributes.
         *
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Bucket = bucket
    }
    
    func (h *healingTracker) getObject() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Object
    }
    
    func (h *healingTracker) setObject(object string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  4. cmd/http-tracer_test.go

    		go func(id int) {
    			defer wg.Done()
    			bucketName := "test-bucket"
    
    			for range opsPerGoroutine {
    				bucketStats.updateHTTPStats(bucketName, "GetObject", nil)
    				recorder := &xhttp.ResponseRecorder{}
    				bucketStats.updateHTTPStats(bucketName, "GetObject", recorder)
    				_ = bucketStats.load(bucketName)
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	stats := bucketStats.load("test-bucket")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

            assertSame(component, pooledObject.getObject());
        }
    
        /**
         * Test wrap with null object
         */
        public void test_wrap_nullObject() {
            PooledObject<TestComponent> pooledObject = factory.wrap(null);
    
            assertNotNull(pooledObject);
            assertNull(pooledObject.getObject());
        }
    
        /**
         * Test destroyObject without listener
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 13:07:01 UTC 2025
    - 36.7K bytes
    - Viewed (0)
  6. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/RemoteSnapshotMetadataGenerator.java

        private final Integer buildNumber;
    
        RemoteSnapshotMetadataGenerator(RepositorySystemSession session, DeployRequest request) {
            timestamp = (Date) ConfigUtils.getObject(session, new Date(), "maven.startTime");
            Object bn = ConfigUtils.getObject(session, null, "maven.buildNumber");
            if (bn instanceof Integer integer) {
                this.buildNumber = integer;
            } else if (bn instanceof String string) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jan 10 08:42:00 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    }
    
    // GetObject - TODO(aead): This function just acts as an adapter for GetObject tests and benchmarks
    // since the GetObject method of the ObjectLayer interface has been removed. Once, the
    // tests are adjusted to use GetObjectNInfo this function can be removed.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. cmd/object_api_suite_test.go

    		}
    	}
    
    	for key, value := range objects {
    		var byteBuffer bytes.Buffer
    		err = GetObject(context.Background(), obj, "bucket", key, 0, int64(len(value)), &byteBuffer, "", opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if !bytes.Equal(byteBuffer.Bytes(), value) {
    			t.Errorf("%s: Mismatch of GetObject data with the expected one.", instanceType)
    		}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  9. docs/extensions/s3zip/README.md

    - ListObjectsV2 can only list the most recent ZIP archive version of your object, applicable only for versioned buckets.
    - ListObjectsV2 API calls must be used to list zip file content.
    - Range requests for GetObject/HeadObject for individual files from zip is not supported.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 10 16:28:27 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users_test.go

       "Effect": "Allow",
       "Action": [
        "s3:ListBucket"
       ],
       "Resource": [
        "arn:aws:s3:::%s"
       ]
      },
      {
       "Effect": "Allow",
       "Action": [
        "s3:PutObject",
        "s3:GetObject"
       ],
       "Resource": [
        "arn:aws:s3:::%s/*"
       ]
      }
     ]
    }`, bucket, bucket)
    	err = s.adm.AddCannedPolicy(ctx, policy, policyBytes)
    	if err != nil {
    		c.Fatalf("policy add error: %v", err)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 50.6K bytes
    - Viewed (0)
Back to top