Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for immediate (0.08 sec)

  1. cmd/erasure-healing_test.go

    		}
    
    		for i := 0; i < nfi.Erasure.ParityBlocks; i++ {
    			erasureDisks[i].Delete(context.Background(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    		}
    
    		// Try healing now, it should heal the content properly.
    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    			t.Fatal(err)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/xl-storage_test.go

    			Recursive: false,
    			Immediate: false,
    		}); err != errFileAccessDenied {
    			t.Errorf("expected: %s, got: %s", errFileAccessDenied, err)
    		}
    	}
    
    	// TestXLStorage for delete on an removed disk.
    	// should fail with disk not found.
    	err = xlStorageDeletedStorage.Delete(context.Background(), "del-vol", "my-file", DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != errDiskNotFound {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    			err = removeAll(filePath)
    		} else {
    			err = Remove(filePath)
    		}
    		return err // Avoid the immediate purge since not needed
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if !immediatePurge && s.diskAlmostFilled() {
    		immediatePurge = true
    	}
    
    	// immediately purge the target
    	if immediatePurge {
    		for _, target := range []string{
    			targetPath,
    			targetPath2,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

                            .setOpType(OpType.CREATE).execute().actionGet(fessConfig.getIndexIndexTimeout());
                } else {
                    // create or update
                    final IndexRequestBuilder builder = client.prepareIndex().setIndex(index).setId(id).setSource(new DocMap(source))
                            .setRefreshPolicy(RefreshPolicy.IMMEDIATE).setOpType(OpType.INDEX);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/asm/testdata/arm.s

    	TST	$0xffffffad, R4     // TST $4294967213, R4       // 52b0e0e30b0014e1
    	TEQ	$0xffffffae, R5     // TEQ $4294967214, R5       // 51b0e0e30b0035e1
    
    // immediate decomposition
    	ADD	$0xff0000ff, R0, R1 // ADD $4278190335, R0, R1 // ff1080e2ff1481e2
    	EOR	$0xff0000ff, R0, R1 // EOR $4278190335, R0, R1 // ff1020e2ff1421e2
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 15 20:51:01 UTC 2023
    - 69K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_3x.md

        This class is in the `logging-interceptor` artifact.
     *  New: `Headers.Builder.addUnsafeNonAscii()` allows non-ASCII values to be added without an
        immediate exception.
     *  New: Headers can be redacted in `HttpLoggingInterceptor`.
     *  New: `Headers.Builder` now accepts dates.
     *  New: OkHttp now accepts `java.time.Duration` for timeouts on Java 8+ and Android 26+.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/asm/testdata/amd64enc_extra.s

    	SHA256MSG2 (BX), X11     // 440f38cd1b
    	SHA256MSG2 (R11), X11    // 450f38cd1b
    	SHA256MSG2 X2, X11       // 440f38cdda
    	SHA256MSG2 X11, X11      // 450f38cddb
    	// Test VPERMQ with both uint8 and int8 immediate args
    	VPERMQ $-40, Y8, Y8 // c443fd00c0d8
    	VPERMQ $216, Y8, Y8 // c443fd00c0d8
    	// Test that VPERMPD that shares ytab list with VPERMQ continues to work too.
    	VPERMPD $-40, Y7, Y7 // c4e3fd01ffd8
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Apr 11 18:32:50 UTC 2023
    - 57.6K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    		index := index
    		g.Go(func() error {
    			if disks[index] == nil {
    				return nil
    			}
    			return disks[index].Delete(ctx, bucket, prefix, DeleteOptions{
    				Recursive: true,
    				Immediate: true,
    			})
    		}, index)
    	}
    
    	// return errors if any during deletion
    	return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/testdata/arm64.s

    	TST	R1>>22, R2                          // 5f5841ea
    	TST	R1<<33, R2                          // 5f8401ea
    	TST	$0x22220000, R3                     // TST $572653568, R3           // 5b44a4d27f001bea
    
    // move an immediate to a Rn.
    	MOVD	$0x3fffffffc000, R0           // MOVD	$70368744161280, R0         // e07f72b2
    	MOVW	$1000000, R4                  // 04488852e401a072
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jul 24 18:45:14 UTC 2024
    - 95.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

      }
    
      /**
       * Returns a {@code ListenableFuture} which has an exception set immediately upon construction.
       *
       * <p>The returned {@code Future} can't be cancelled, and its {@code isDone()} method always
       * returns {@code true}. Calling {@code get()} will immediately throw the provided {@code
       * Throwable} wrapped in an {@code ExecutionException}.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
Back to top