- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for immediate (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/cmd/asm/internal/asm/testdata/arm64.s
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Jul 24 18:45:14 UTC 2024 - 95.2K bytes - Viewed (0) -
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)