Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 92 for Immediate (0.04 sec)

  1. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
     * family. <b>Avoid</b> creating a mock or stub {@code Future}. Mock and stub implementations are
     * fragile because they assume that only certain methods will be called and because they often
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  2. docs/bucket/lifecycle/README.md

                    "NewerNoncurrentVersions": 5
                }
            }
        ]
    }
    ```
    Note: This rule has an implicit zero NoncurrentDays, which makes the expiry of those 'extra' noncurrent versions immediate.
    
    #### 3.2.b Automatic removal of all versions (MinIO only extension)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    					// appears in outDatedDisks.
    					tamperedIndex = index
    					dErr := erasureDisks[index].Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    					if dErr != nil {
    						t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr)
    					}
    					break
    				}
    			case corruptPart:
    				for index, err := range test.errs {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  4. docs/distributed/README.md

    _(existing_servers\*m)+(newly_added_servers\*m)_ drives. New object upload requests automatically start using the least used cluster. This expansion strategy works endlessly, so you can perpetually expand your clusters as needed.  When you restart, it is immediate and non-disruptive to the applications. Each group of servers in the command-line is called a pool. There are 2 server pools in this example. New objects are placed in server pools in proportion to the amount of free space in each pool. Within each...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java

            assertEquals(2, names.length);
            assertEquals("Store1", names[0]);
            assertEquals("Store2", names[1]);
            assertEquals(1, loadCount[0]);
    
            // Second immediate call should use cache
            names = testFactory.getDataStoreNames();
            assertEquals(2, names.length);
            assertEquals(1, loadCount[0]); // Should not increment
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    }
    
    func (s *xlStorage) cleanupTrashImmediateCallers(ctx context.Context) {
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case entry := <-s.immediatePurge:
    			// Add deadlines such that immediate purge is not
    			// perpetually hung here.
    			w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    			w.Run(func() error {
    				return removeAll(entry)
    			})
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  7. cmd/storage-rest_test.go

    		{"foo", "yourobject", false},
    	}
    
    	for i, testCase := range testCases {
    		err := storage.Delete(t.Context(), testCase.volumeName, testCase.objectName, DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. cmd/erasure-encode_test.go

    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  9. docs/SMB3_IMPLEMENTATION_PLAN.md

       - Persistent handles survive 99% of network interruptions
       - Witness protocol achieves <5 second failover time
    4. **Compatibility**: Works with Windows Server 2016+ and Azure Files
    
    ## Next Steps
    
    1. **Immediate Actions**:
       - Set up Windows Server test environment
       - Create detailed technical specifications for Phase 1
       - Identify and evaluate Java RDMA libraries
    
    2. **Phase 1 Kickoff**:
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/parse.go

    			if prefix != '$' {
    				p.errorf("floating-point constant must be an immediate")
    			}
    			a.Type = obj.TYPE_FCONST
    			a.Val = p.floatExpr()
    			// fmt.Printf("FCONST %s\n", obj.Dconv(&emptyProg, 0, a))
    			p.expectOperandEnd()
    			return
    		}
    		if p.have(scanner.String) {
    			if prefix != '$' {
    				p.errorf("string constant must be an immediate")
    				return
    			}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 14 15:13:11 UTC 2025
    - 37.3K bytes
    - Viewed (0)
Back to top