- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 201 for IMMEDIATE (0.12 sec)
-
src/net/http/cgi/integration_test.go
t.Errorf("got a Content-Type of %q; expected it to start with %q", got, tt.wantCT) } }) } } // golang.org/issue/7198 func Test500WithNoHeaders(t *testing.T) { want500Test(t, "/immediate-disconnect") } func Test500WithNoContentType(t *testing.T) { want500Test(t, "/no-content-type") } func Test500WithEmptyHeaders(t *testing.T) { want500Test(t, "/empty-headers") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 18:42:44 UTC 2023 - 5.5K bytes - Viewed (0) -
tensorflow/c/eager/gradients.h
tensorflow::DataType GetDType() const; AbstractTensorHandle* ZerosLike() const; AbstractTensorHandle* GetHandle() const; private: AbstractTensorHandle* handle_; }; // A tracing/immediate-execution agnostic tape. // // Gradient functions defined for this tape must support handling null incoming // gradients. class Tape : protected eager::GradientTape<AbstractTensorHandle,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Sep 26 10:27:05 UTC 2022 - 6.9K bytes - Viewed (0) -
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) -
pkg/wasm/httpfetcher_test.go
wantNumRequest: 5, wantErrorRegex: "wasm module download failed after 5 attempts, last error: wasm module download request failed: status code 500", }, { name: "download is never tried by immediate context timeout", handler: func(w http.ResponseWriter, r *http.Request, num int) { w.WriteHeader(http.StatusInternalServerError) }, timeout: 0, // Immediately timeout in the context level.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 7.5K 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) -
android/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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K 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) -
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) -
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) -
futures/listenablefuture1/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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0)