- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 145 for timediv (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
// this error must be ignored by the WithPanicRecovery handler // it is thrown by WithTimeoutForNonLongRunningRequests handler when a response has been already sent to the client and the handler timed out // panicking with http.ErrAbortHandler also suppresses logging of a stack trace to the server's error log and closes the underlying connection w.Write([]byte("hello from the handler")) panic(http.ErrAbortHandler) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/utils/lstm_utils.cc
auto go_backwards_attr = func_op->getAttrOfType<BoolAttr>("tf.go_backwards"); if (go_backwards_attr != nullptr && go_backwards_attr.getValue()) { int time_dim = time_majored ? 0 : 1; final_inputs = Reverse(builder, final_inputs, time_dim, final_input_type, func_op.getLoc()); } int64_t batch = time_majored ? final_input_type.getDimSize(1)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 36.2K bytes - Viewed (0) -
src/internal/trace/base.go
// has 5 arguments and needs to smuggle in a 6th. Figure out a way to // shrink this in the future. const maxArgs = 6 // timedEventArgs is an array that is able to hold the arguments for any // timed event. type timedEventArgs [maxArgs - 1]uint64 // baseEvent is the basic unprocessed event. This serves as a common // fundamental data structure across. type baseEvent struct { typ event.Type time Time
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
logger.Info("Starting storage version garbage collector") if !cache.WaitForCacheSync(ctx.Done(), c.leasesSynced, c.storageVersionSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // Identity lease deletion and storageversion update don't happen too often. Start one // worker for each of them.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
src/syscall/exec_unix_test.go
defer timer.Stop() for { select { case sig := <-ch1: t.Errorf("unexpected signal %v", sig) case <-ch2: // Success. return case <-timer.C: t.Fatal("timed out waiting for child process") } } } // Test a couple of cases that SysProcAttr can't handle. Issue 29458. func TestInvalidExec(t *testing.T) { t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 04:41:27 UTC 2024 - 7.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
val readTimeout = soTimeout try { soTimeout = 1 !source.exhausted() } finally { soTimeout = readTimeout } } catch (_: SocketTimeoutException) { true // Read timed out; socket is good. } catch (_: IOException) { false // Couldn't read; socket is closed. } } internal inline fun threadName( name: String, block: () -> Unit, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 10.7K bytes - Viewed (0) -
src/net/net.go
Err string // description of the error Name string // name looked for Server string // server used IsTimeout bool // if true, timed out; not all timeouts set this IsTemporary bool // if true, error is temporary; not all errors set this // IsNotFound is set to true when the requested name does not
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
deviceState operationexecutor.DeviceMountState unmountDeviceCallCount int volumeName string supportRemount bool }{ { name: "timed out operations should result in device marked as uncertain", deviceState: operationexecutor.DeviceMountUncertain, unmountDeviceCallCount: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue_test.go
result <- con }() select { case got := <-result: if got != expected { t.Fatalf("Expected proxy %v, got %v", expected, got) } case <-time.After(time.Millisecond * 500): t.Fatalf("Timed out") } } func TestProxyQueue(t *testing.T) { proxies := make([]*Connection, 0, 100) for p := 0; p < 100; p++ { conn := newConnection("", nil) conn.SetID(fmt.Sprintf("proxy-%d", p))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
klog.Infof("Starting OpenAPI controller") c.staticSpec = staticSpec c.openAPIService = openAPIService if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // create initial spec to avoid merging once per CRD on startup crds, err := c.crdLister.List(labels.Everything()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0)