- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 363 for told (0.25 sec)
-
src/net/sendfile_unix_alt.go
// Darwin, FreeBSD, DragonFly and Solaris use 0 as the "until EOF" value. // If you pass in more bytes than the file contains, it will // loop back to the beginning ad nauseam until it's sent // exactly the number of bytes told to. As such, we need to // know exactly how many bytes to send. var remain int64 = 0 lr, ok := r.(*io.LimitedReader) if ok { remain, r = lr.N, lr.R if remain <= 0 { return 0, nil, true } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
} // wait until we're told to stop <-stopCh } // WaitForInitialSync blocks until the initial set of CRD resources has been processed func (c *crdRegistrationController) WaitForInitialSync() { <-c.syncedInitialSet } func (c *crdRegistrationController) runWorker() { // hot loop until we're told to stop. processNextWorkItem will automatically wait until there's work
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
_ = wait.PollImmediateUntil(1*time.Minute, func() (bool, error) { c.queue.Add(keyFn()) return false, nil }, ctx.Done()) // wait until we're told to stop <-ctx.Done() } func (c *Controller) runWorker() { // hot loop until we're told to stop. processNextWorkItem will automatically wait until there's work // available, so we don't worry about secondary waits for c.processNextWorkItem() { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/templates/deployment.yaml
fieldRef: apiVersion: v1 fieldPath: spec.serviceAccountName - name: KUBECONFIG value: /var/run/secrets/remote/config # If you explicitly told us where ztunnel lives, use that. # Otherwise, assume it lives in our namespace # Also, check for an explicit ENV override (legacy approach) and prefer that # if present
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 30 20:24:06 UTC 2024 - 9K bytes - Viewed (0) -
src/crypto/internal/hpke/hpke.go
nonce := s.seqNum.bytes()[16-s.aead.NonceSize():] for i := range s.baseNonce { nonce[i] ^= s.baseNonce[i] } // Message limit is, according to the RFC, 2^95+1, which // is somewhat confusing, but we do as we're told. if s.seqNum.bitLen() >= (s.aead.NonceSize()*8)-1 { panic("message limit reached") } s.seqNum = s.seqNum.addOne() return nonce } func (s *Sender) Seal(aad, plaintext []byte) ([]byte, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:33 UTC 2024 - 7K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
// one (because the call to getComponentConfigVersionStates requires the currently installed version). // This also makes the KubernetesVersion value returned for `upgrade plan` consistent as that command // allows to not specify a target version in which case KubernetesVersion will always hold the currently // installed one. initCfg.KubernetesVersion = newK8sVersion
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// Unlike the other cases, we actually want to use the "old" event for terminated job pods // - kubernetes will (weirdly) issue a new status to the pod with no IP on termination, meaning // our check of `pod.status` will fail for (some) termination events. // // We will get subsequent events that append a new status with the IP put back, but it's simpler // and safer to just check the old pod status for the IP.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
src/go/build/read.go
r.readImport() } r.nextByte(false) } else { r.readImport() } } info.header = r.buf // If we stopped successfully before EOF, we read a byte that told us we were done. // Return all but that last byte, which would cause a syntax error if we let it through. if r.err == nil && !r.eof { info.header = r.buf[:len(r.buf)-1] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 14.1K bytes - Viewed (0) -
docs/en/docs/tutorial/query-params-str-validations.md
## Use `Annotated` in the type for the `q` parameter Remember I told you before that `Annotated` can be used to add metadata to your parameters in the [Python Types Intro](../python-types.md#type-hints-with-metadata-annotations){.internal-link target=_blank}? Now it's the time to use it with FastAPI. 🚀
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri May 31 02:38:05 UTC 2024 - 25.8K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
if reservedFor.APIGroup == "" && reservedFor.Resource == "pods" { // A pod falls into one of three categories: // - we have it in our cache -> don't remove it until we are told that it got removed // - we don't have it in our cache anymore, but we have seen it before -> it was deleted, remove it // - not in our cache, not seen -> double-check with API server before removal keepEntry := true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0)