- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 277 for enqueue0 (0.2 sec)
-
src/internal/fuzz/queue_test.go
t.Fatalf("empty queue has len %d; want 0", n) } if n := q.cap(); n != 0 { t.Fatalf("empty queue has cap %d; want 0", n) } // As we add elements, len should grow. N := 32 for i := 0; i < N; i++ { q.enqueue(i) if n := q.len; n != i+1 { t.Fatalf("after adding %d elements, queue has len %d", i, n) } if v, ok := q.peek(); !ok { t.Fatalf("couldn't peek after adding %d elements", i) } else if v.(int) != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 02 17:58:51 UTC 2021 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherCleanupTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
klog.V(4).Infof("Adding %s", castObj.Name) c.enqueue(castObj) } func (c *KubernetesAPIApprovalPolicyConformantConditionController) updateCustomResourceDefinition(obj, _ interface{}) { castObj := obj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Updating %s", castObj.Name) c.enqueue(castObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* 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]. */ fun enqueue(response: MockResponse) = (dispatcher as QueueDispatcher).enqueueResponse(response) /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheCorruptionTest.kt
server.useHttps(handshakeCertificates.sslSocketFactory()) server.enqueue( MockResponse( headers = headersOf( "Last-Modified", formatDate(-1, TimeUnit.HOURS)!!, "Expires", formatDate(1, TimeUnit.HOURS)!!, ), body = "ABC.1", ), ) server.enqueue( MockResponse( headers = headersOf(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name) c.enqueue(castObj) } func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{}) { castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Updating customresourcedefinition %s", castNewObj.Name) c.enqueue(castNewObj) } func (c *Controller) deleteCustomResourceDefinition(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
castObj := obj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Adding %s", castObj.Name) c.enqueue(castObj) } func (c *ConditionController) updateCustomResourceDefinition(obj, _ interface{}) { castObj := obj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Updating %s", castObj.Name) c.enqueue(castObj) } func (c *ConditionController) deleteCustomResourceDefinition(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
if (op_names_size > kint32max) { return Status(absl::StatusCode::kInvalidArgument, "Enqueue ops to run cannot exceed kint32max"); } runs_ = static_cast<int>(op_names_size); if (runs_ == 0) { return Status(absl::StatusCode::kInvalidArgument, "Empty enqueue ops to run."); } close_op_name_ = queue_runner_def.close_op_name(); cancel_op_name_ = queue_runner_def.cancel_op_name();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocketChannelTest.kt
server.useHttps(serverSslSocketFactory) } else if (socketMode == Channel) { socketFactory(ChannelSocketFactory()) } } .build() server.enqueue(MockResponse(body = "abc")) @Suppress("HttpUrlsUsage") val url = if (socketMode is TlsInstance) { "https://$hostname:${server.port}/get" } else {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
rv.enqueue(svm) } func (rv *ResourceVersionController) updateSVM(logger klog.Logger, oldObj, newObj interface{}) { oldSVM := oldObj.(*svmv1alpha1.StorageVersionMigration) newSVM := newObj.(*svmv1alpha1.StorageVersionMigration) logger.V(4).Info("Updating", "svm", klog.KObj(oldSVM)) rv.enqueue(newSVM) } func (rv *ResourceVersionController) enqueue(svm *svmv1alpha1.StorageVersionMigration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0)