- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 2,006 for happen (0.12 sec)
-
cmd/speedtest.go
Err: errStr, }) totalUploadTimes = append(totalUploadTimes, throughputHighestResults[i].UploadTimes...) totalDownloadTimes = append(totalDownloadTimes, throughputHighestResults[i].DownloadTimes...) totalDownloadTTFB = append(totalDownloadTTFB, throughputHighestResults[i].DownloadTTFB...) } result.PUTStats.Response = totalUploadTimes.Measure() result.GETStats.Response = totalDownloadTimes.Measure()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/metrics-v3-types.go
labels := make([]string, 0, len(metric.VariableLabels)*2) for k, v := range metric.VariableLabels { if newLabel, ok := renameLabels[k]; ok { labels = append(labels, newLabel, v) } else { labels = append(labels, k, v) } } labels = append(labels, extraLabels...) // If valid non zero value set the metrics if metric.Value > 0 { m.Set(name, metric.Value, labels...) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 15.1K bytes - Viewed (0) -
src/time/tick_test.go
// for Reset of timer NOT in heap. tim.Stop() drainAsync() tim.Reset(1) assertLen() assertTick() } // Sleep long enough that a second tick must happen if this is a ticker. // Test that Reset does not lose the tick that should have happened. Sleep(sched) tim.Reset(10000 * Second) drainAsync() noTick() notDone := func(done chan bool) { t.Helper() select { default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/runtime/signal_unix.go
// This can only happen if non-Go code calls sigaltstack to disable the // signal stack. func noSignalStack(sig uint32) { println("signal", sig, "received on thread with no signal stack") throw("non-Go code disabled sigaltstack") } // This is called if we receive a signal when there is a signal stack // but we are not on it. This can only happen if non-Go code called
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/kubeletfinalize.go
kubeconfig, err := clientcmd.LoadFromFile(kubeconfigPath) if err != nil { return errors.Wrapf(err, "could not load %q", kubeconfigPath) } // Perform basic validation. The errors here can only happen if the kubelet.conf was corrupted. if len(kubeconfig.CurrentContext) == 0 { return errors.Errorf("the file %q does not have current context set", kubeconfigPath) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:54:51 UTC 2024 - 6.8K bytes - Viewed (0) -
docs/en/docs/tutorial/background-tasks.md
# Background Tasks You can define background tasks to be run *after* returning a response. This is useful for operations that need to happen after a request, but that the client doesn't really have to be waiting for the operation to complete before receiving the response. This includes, for example: * Email notifications sent after performing an action:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 23:43:13 UTC 2024 - 5.6K bytes - Viewed (0) -
src/crypto/internal/nistec/p256_asm.go
// rather than happen on the heap. var out [p256UncompressedLength]byte return p.bytes(&out) } func (p *P256Point) bytes(out *[p256UncompressedLength]byte) []byte { // The proper representation of the point at infinity is a single zero byte. if p.isInfinity() == 1 { return append(out[:0], 0) } x, y := new(p256Element), new(p256Element)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 21.4K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
ev := it.extra[0] it.extra = it.extra[1:] if len(it.extra) == 0 { it.extra = it.extraArr[:0] } // Two events aren't allowed to fall on the same timestamp in the new API, // but this may happen when we produce EvGoStatus events if ev.base.time <= it.lastTs { ev.base.time = it.lastTs + 1 } it.lastTs = ev.base.time return ev, nil } oev, ok := it.events.Pop() if !ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/internal/dag/parse.go
return nil, err } // TODO: Add line numbers to errors. var errors []string errorf := func(format string, a ...any) { errors = append(errors, fmt.Sprintf(format, a...)) } for _, r := range rules { if r.op == "!<" { disallowed = append(disallowed, r) continue } for _, def := range r.def { if def == "NONE" { errorf("NONE cannot be a predecessor") continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/xds/server.go
w.DeleteWatchedResource(request.TypeUrl) return false, emptyResourceDelta } previousInfo := w.GetWatchedResource(request.TypeUrl) // This can happen in two cases: // 1. When Envoy starts for the first time, it sends an initial Discovery request to Istiod. // 2. When Envoy reconnects to a new Istiod that does not have information about this typeUrl
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0)