- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 47 for enqueuePdb (0.28 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
): RecordedRequest? = requestQueue.poll(timeout, unit) /** * Scripts [response] to be returned to a request made in sequence. The first request is * served by the first enqueued response; the second request by the second enqueued response; and * so on. * * @throws ClassCastException if the default dispatcher has been * replaced with [setDispatcher][dispatcher]. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
src/net/net_fake.go
} type packetQueueState struct { head, tail *packet // unqueued packets nBytes int // number of bytes enqueued in the packet buffers starting from head readBufferBytes int // soft limit on nbytes; no more packets may be enqueued when the limit is exceeded readClosed bool // true if the reader of the queue has stopped reading
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 19:24:21 UTC 2024 - 26.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
TF_CAPI_EXPORT extern TFE_Executor* TFE_NewExecutor( bool is_async, bool enable_streaming_enqueue, int in_flight_nodes_limit); // Deletes the eager Executor without waiting for enqueued nodes. Please call // TFE_ExecutorWaitForAllPendingNodes before calling this API if you want to // make sure all nodes are finished. TF_CAPI_EXPORT extern void TFE_DeleteExecutor(TFE_Executor*);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
} func (gc *GarbageCollector) runAttemptToDeleteWorker(ctx context.Context) { for gc.processAttemptToDeleteWorker(ctx) { } } var enqueuedVirtualDeleteEventErr = goerrors.New("enqueued virtual delete event") var namespacedOwnerOfClusterScopedObjectErr = goerrors.New("cluster-scoped objects cannot refer to namespaced owners")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
}), ) } else { c.statusController.Store(nil) } } // Reconcile takes in a current snapshot of the gateway-api configs, and regenerates our internal state. // Any status updates required will be enqueued as well. func (c *Controller) Reconcile(ps *model.PushContext) error { t0 := time.Now() defer func() { log.Debugf("reconcile complete in %v", time.Since(t0)) }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
newPVC, ok := new.(*v1.PersistentVolumeClaim) if !ok { return } newReq := newPVC.Spec.Resources.Requests[v1.ResourceStorage] newCap := newPVC.Status.Capacity[v1.ResourceStorage] // PVC will be enqueued under 2 circumstances // 1. User has increased PVC's request capacity --> volume needs to be expanded
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} } } } internal class CallReference( referent: RealCall, /** * Captures the stack trace at the time the Call is executed or enqueued. This is helpful for * identifying the origin of connection leaks. */ val callStackTrace: Any?, ) : WeakReference<RealCall>(referent)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_tpu_device.cc
// Also ideally this host callback should be on source stream rather than // destination stream, but when this function returns, the send requests // might not be enqueued to the stream yet, we put it on destination stream. TensorReference input_reference(*input); std::move(return_substream).release(); return dst_device_to_device_stream->DoHostCallback(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 28 22:53:47 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/xds/server.go
// initialization doesn't have dependencies that will block, there is no need to add any timeout // here. Prior to this explicit wait, we were implicitly waiting by receive() not sending to // reqChannel and the connection not being enqueued for pushes to pushChannel until the // initialization is complete. <-con.initialized for { // Go select{} statements are not ordered; the same channel can be chosen many times.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
// having its status updated with the newly available replica. if !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) && set.Spec.MinReadySeconds > 0 { logger.V(2).Info("StatefulSet will be enqueued after minReadySeconds for availability check", "statefulSet", klog.KObj(set), "minReadySeconds", set.Spec.MinReadySeconds) // Add a second to avoid milliseconds skew in AddAfter.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)