- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 174 for IMMEDIATE (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* be transmitted until the web socket is open. * * * **Open:** the web socket has been accepted by the remote peer and is fully operational. * Messages in either direction are enqueued for immediate transmission. * * * **Closing:** one of the peers on the web socket has initiated a graceful shutdown. The web * socket will continue to transmit already-enqueued messages but will refuse to enqueue new * ones. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
src/time/tick_test.go
tim.Reset(1) assertTick() Sleep(sched) tim.Reset(10000 * Second) drainAsync() noTick() // Test that len sees an immediate tick arrive // for Reset of timer in heap. tim.Reset(1) assertLen() assertTick() // Test that len sees an immediate tick arrive // for Reset of timer NOT in heap. tim.Stop() drainAsync() tim.Reset(1) assertLen() assertTick() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath, DeleteOptions{ Recursive: false, Immediate: false, }) _ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath+".meta", DeleteOptions{ Recursive: false, Immediate: false, }) return nil }, index) } g.Wait() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
if (insertAt == -1) insertAt = futureTasks.size futureTasks.add(insertAt, task) // Impact the coordinator if we inserted at the front. return insertAt == 0 } /** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/_gen/S390X.rules
(RLL x (MOVDconst [c])) => (RLLconst x [uint8(c&31)]) // Signed 64-bit comparison with immediate. (CMP x (MOVDconst [c])) && is32Bit(c) => (CMPconst x [int32(c)]) (CMP (MOVDconst [c]) x) && is32Bit(c) => (InvertFlags (CMPconst x [int32(c)])) // Unsigned 64-bit comparison with immediate. (CMPU x (MOVDconst [c])) && isU32Bit(c) => (CMPUconst x [int32(c)])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 18:09:26 UTC 2023 - 74.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
var healthCheckError error if kmsPluginCloseGracePeriod < minKMSPluginCloseGracePeriod { kmsPluginCloseGracePeriod = minKMSPluginCloseGracePeriod } // really make sure that the immediate check does not hang var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Aug 26 07:33:25 UTC 2023 - 9K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
// Delete Kubernetes secret for ingress gateway c := t.Clusters().Default() var immediate int64 err := c.Kube().CoreV1().Secrets(systemNS.Name()).Delete(context.TODO(), credName, metav1.DeleteOptions{GracePeriodSeconds: &immediate}) if err != nil && !errors.IsNotFound(err) { t.Fatalf("Failed to delete secret (error: %s)", err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/mips.s
// { // outcode(int($1), &$2, int($4), &$6); // } SLL $4, R1, R2 // LSHW imm ',' rreg // { // outcode(int($1), &$2, 0, &$4); // } SLL $4, R1 // // move immediate: macro for lui+or, addi, addis, and other combinations // // LMOVW imm ',' rreg // { // outcode(int($1), &$2, 0, &$4); // } MOVW $1, R1 MOVW $1, R1 // LMOVW ximm ',' rreg // {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 08 12:17:12 UTC 2023 - 6.7K bytes - Viewed (0)