- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 2,656 for ONCE (0.03 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency_test.go
w := httptest.NewRecorder() wrapped.ServeHTTP(w, testRequest) if handlerCallCount != 1 { t.Errorf("expected the given handler to be invoked once, but was actually invoked %d times", handlerCallCount) } if actionCallCount != 1 { t.Errorf("expected the action callback to be invoked once, but was actually invoked %d times", actionCallCount) } if filterRecordGot == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/volume/metrics_cached.go
md.once.cache(func() error { md.resultMetrics, md.resultError = md.wrapped.GetMetrics() return md.resultError }) return md.resultMetrics, md.resultError } // Copied from sync.Once but we don't want to cache the results if there is an // error type cacheOnce struct { m sync.Mutex done uint32 } // Copied from sync.Once but we don't want to cache the results if there is an
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/service-provider/src/main/java/org/gradle/internal/service/scopes/GradleModuleServices.java
*/ @ServiceScope(Scope.Global.class) public interface GradleModuleServices extends ServiceRegistrationProvider { /** * Called once per process, to register any globally scoped services. These services are reused across builds in the same process. * The services are closed when the process finishes. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.3K bytes - Viewed (0) -
test/fixedbugs/bug474.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 419 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
Wait() } type initializationSignal struct { once sync.Once done chan struct{} } func NewInitializationSignal() InitializationSignal { return &initializationSignal{ once: sync.Once{}, done: make(chan struct{}), } } func (i *initializationSignal) Signal() { i.once.Do(func() { close(i.done) }) } func (i *initializationSignal) Wait() { <-i.done
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/testing/openapi.go
// parse only once and then return the same copy everytime. type Fake struct { Path string once sync.Once document *openapi_v2.Document err error } // OpenAPISchema returns the openapi document and a potential error. func (f *Fake) OpenAPISchema() (*openapi_v2.Document, error) { f.once.Do(func() { _, err := os.Stat(f.Path) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 14:34:26 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/capabilities/capabilities.go
HostIPCSources []string } var capInstance struct { once sync.Once lock sync.Mutex capabilities *Capabilities } // Initialize the capability set. This can only be done once per binary, subsequent calls are ignored. func Initialize(c Capabilities) { // Only do this once capInstance.once.Do(func() { capInstance.capabilities = &c }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 12:51:16 UTC 2019 - 3K bytes - Viewed (0) -
src/io/pipe.go
if err == nil { err = ErrClosedPipe } p.rerr.Store(err) p.once.Do(func() { close(p.done) }) return nil } func (p *pipe) write(b []byte) (n int, err error) { select { case <-p.done: return 0, p.writeCloseError() default: p.wrMu.Lock() defer p.wrMu.Unlock() } for once := true; once || len(b) > 0; once = false { select { case p.wrCh <- b: nw := <-p.rdCh b = b[nw:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/crypto/x509/root.go
// // Do not remove or change the type signature. // See go.dev/issue/67401. // //go:linkname systemRoots var ( once sync.Once systemRootsMu sync.RWMutex systemRoots *CertPool systemRootsErr error fallbacksSet bool ) func systemRootsPool() *CertPool { once.Do(initSystemRoots) systemRootsMu.RLock() defer systemRootsMu.RUnlock() return systemRoots } func initSystemRoots() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/go/internal/vcweb/fossil.go
import ( "fmt" "log" "net/http" "net/http/cgi" "os" "os/exec" "path/filepath" "sync" ) type fossilHandler struct { once sync.Once fossilPath string fossilPathErr error } func (h *fossilHandler) Available() bool { h.once.Do(func() { h.fossilPath, h.fossilPathErr = exec.LookPath("fossil") }) return h.fossilPathErr == nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 17:47:26 UTC 2023 - 1.3K bytes - Viewed (0)