- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 297 for existed (1.57 sec)
-
guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
* consider <a href="https://github.com/lukas-krecan/future-converter">Future Converter</a>. * * @author Sven Mawson * @since 10.0 (replacing {@code Futures.makeListenable}, which existed in 1.0) */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class JdkFutureAdapters { /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
pilot/pkg/xds/workload.go
reqAddresses := addresses if full { reqAddresses = nil } addrs, removed := e.Server.Env.ServiceDiscovery.AddressInformation(reqAddresses) // Note: while "removed" is a weird name for a resource that never existed, this is how the spec works: // https://www.envoyproxy.io/docs/envoy/latest/api-docs/xds_protocol#id2 have := sets.New[string]() haveAliases := sets.New[string]() for _, addr := range addrs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
switch { case errors.IsNotFound(err): // no-op case err != nil: return errors.NewInternalError(err) default: exists = true } if exists { klog.V(4).InfoS("Namespace existed in cache after waiting", "namespace", klog.KRef("", a.GetNamespace())) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 8.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/artifacts/configurations/RoleBasedConfigurationContainerInternal.java
/** * If a configuration with the given name already exists, verify its usage matches the expected role and return it. * Otherwise, create a new configuration as defined by the given {@code request}. * * @param request information about the desired configuration * @return the configuration that was created or already existed * @throws GradleException if the request cannot be fulfilled */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 20:25:05 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
// will be closed. Services that are new will be opened. Service that // existed and are in the new set will be left alone. The value of the map // is the healthcheck-port to listen on. SyncServices(newServices map[types.NamespacedName]uint16) error // Make the new set of endpoints be active. Endpoints for services that do // not exist will be dropped. The value of the map is the number of // endpoints the service has on this node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go
hashPool *sync.Pool } type cache interface { // given a key, return the record, and whether or not it existed get(key string) (value *cacheRecord, exists bool) // caches the record for the key set(key string, value *cacheRecord, ttl time.Duration) // removes the record for the key remove(key string) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 9.8K bytes - Viewed (0) -
src/crypto/x509/cert_pool.go
// where a failure is likely; the func is meant to lazily // parse/decompress data that is already known to be good. The // error in the signature primarily is meant for use in the // case where a cert file existed on local disk when the program // started up is deleted later before it's read. getCert func() (*Certificate, error) } // NewCertPool returns a new, empty CertPool. func NewCertPool() *CertPool { return &CertPool{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 19:41:40 UTC 2023 - 8.9K bytes - Viewed (0) -
docs/pt/docs/tutorial/body-multiple-params.md
Ele executará a validação dos dados compostos e irá documentá-los de maneira compatível com o esquema OpenAPI e documentação automática. ## Valores singulares no corpo Assim como existem uma `Query` e uma `Path` para definir dados adicionais para parâmetros de consulta e de rota, o **FastAPI** provê o equivalente para `Body`.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup_test.go
n := 16 wg1.Add(n) wg2.Add(n) exited := make(chan bool, n) for i := 0; i != n; i++ { go func(i int) { wg1.Done() wg2.Wait() exited <- true }(i) } wg1.Wait() for i := 0; i != n; i++ { select { case <-exited: t.Fatal("SafeWaitGroup released group too soon") default: } wg2.Done() } for i := 0; i != n; i++ { <-exited // Will block if barrier fails to unlock someone.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 13 05:42:40 UTC 2017 - 1.4K bytes - Viewed (0) -
src/os/exec_plan9.go
pid int // The process's id. status *syscall.Waitmsg // System-dependent status info. } // Pid returns the process id of the exited process. func (p *ProcessState) Pid() int { return p.pid } func (p *ProcessState) exited() bool { return p.status.Exited() } func (p *ProcessState) success() bool { return p.status.ExitStatus() == 0 } func (p *ProcessState) sys() any {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 3.4K bytes - Viewed (0)