- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 114 for closeFn (0.52 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/DefaultServiceRegistryConcurrencyTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 4K bytes - Viewed (0) -
src/net/unixsock_posix.go
return newUnixConn(fd), nil } func (ln *UnixListener) close() error { // The operating system doesn't clean up // the file that announcing created, so // we have to clean it up ourselves. // There's a race here--we can't know for // sure whether someone else has come along // and replaced our socket name already-- // but this sequence (remove then close) // is at least compatible with the auto-remove
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
subprojects/build-events/src/integTest/groovy/org/gradle/build/event/BuildEventsParallelIntegrationTest.groovy
noExceptionThrown() } @Issue("https://github.com/gradle/gradle/issues/24887") @Issue("https://github.com/gradle/gradle/issues/27099") def "build events listener service handles all events before it is closed"() { buildFile """ import ${BuildEventsListenerRegistry.name} import ${OperationCompletionListener.name} import ${FinishEvent.name} import ${TaskFinishEvent.name}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/grid/muxserver.go
} } func (m *muxServer) unblockSend(seq uint32) { if !m.checkSeq(seq) { return } m.recvMu.Lock() defer m.recvMu.Unlock() if m.outBlock == nil { // Closed return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxServer) ping(seq uint32) pongMsg {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
} if valueCount > 0.0 { return valueCount, nil } return 0, fmt.Errorf("value not found") } // Close implements io.Closer. func (c *kubeComponent) Close() error { for _, forwarder := range c.forwarder { forwarder.Close() } return nil } type Query struct { Metric string Aggregation string Labels map[string]string }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/service-provider/src/main/java/org/gradle/internal/service/scopes/GradleModuleServices.java
/** * 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. * * <p>Global services are visible to all other services.</p> * * @see Scope.Global */ void registerGlobalServices(ServiceRegistration registration);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.3K bytes - Viewed (0) -
platforms/core-runtime/files/src/main/java/org/gradle/api/internal/file/archive/ZipEntry.java
/** * Declare an action to be run against this ZipEntry's content as a {@link InputStream}. * The {@link InputStream} passed to the {@link IoFunction#apply(Object)} will * be closed right after the action's return. * * This method or {@link #getContent()} may or may not support being called more than once per entry. * Use {@link #canReopen()} to determine if more than one call is supported.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:00 UTC 2024 - 2.5K bytes - Viewed (0) -
platforms/software/version-control/src/test/groovy/org/gradle/vcs/git/internal/GitVersionControlSystemSpec.groovy
GitFileRepository submoduleRepo2 = new GitFileRepository("submodule2", tmpDir.testDirectory) // Directory clean up needs to happen after all of the repos have closed @Rule RuleChain rules = RuleChain.outerRule(tmpDir).around(repo).around(repo2).around(submoduleRepo).around(submoduleRepo2) def setup() { gitVcs = new GitVersionControlSystem()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 13:11:16 UTC 2024 - 8.4K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/driver/driver.go
// If addr is not zero, Symbols restricts the list to symbols // containing that address. Symbols(r *regexp.Regexp, addr uint64) ([]*Sym, error) // Close closes the file, releasing associated resources. Close() error } // A Frame describes a single line in a source file. type Frame struct { Func string // name of function File string // source file name
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 9.8K bytes - Viewed (0) -
manifests/addons/dashboards/lib/queries.libsonnet
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 7.7K bytes - Viewed (0)