- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,315 for stops (0.04 sec)
-
src/cmd/cgo/internal/testcarchive/testdata/libgo3/libgo3.go
// CatchSIGIO starts catching SIGIO signals. // //export CatchSIGIO func CatchSIGIO() { sigioChan = make(chan os.Signal, 1) signal.Notify(sigioChan, syscall.SIGIO) } // ResetSIGIO stops catching SIGIO signals. // //export ResetSIGIO func ResetSIGIO() { signal.Reset(syscall.SIGIO) } // SawSIGIO reports whether we saw a SIGIO. // //export SawSIGIO func SawSIGIO() C.int { select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1020 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/fifo_list.go
// otherwise `nil`. type removeFromFIFOFunc func() *request // walkFunc is called for each request in the list in the // oldest -> newest order. // ok: if walkFunc returns false then the iteration stops immediately. // walkFunc may remove the given request from the fifo, // but may not mutate the fifo in any othe way. type walkFunc func(*request) (ok bool) // Internal interface to abstract out the implementation details
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 16:05:53 UTC 2021 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/StreamsHandler.java
/** * Disconnects from the process without waiting for further work. */ void disconnect(); /** * Stops doing work with the process's streams. Should block until no further asynchronous work is happening on the streams. */ @Override void stop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientCancellationHandler.java
import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; import java.util.concurrent.atomic.AtomicBoolean; /** * A handler that stops all worker daemons when the build is cancelled. */ @ServiceScope(Scope.BuildSession.class) @NonNullApi public class WorkerDaemonClientCancellationHandler implements Stoppable {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:57:50 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServerConnector.java
*/ Address start(IncomingConnectionHandler handler, Runnable connectionErrorHandler); /** * Stops accepting new connections, and blocks until all active connections close. */ @Override public void stop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/import_known_versions.go
limitations under the License. */ // Package app imports the API groups that the client will support // TODO: Remove this file when namespace controller and garbage collector // stops using legacyscheme.Registry.RESTMapper() package app import ( // These imports are the API groups the client will support. _ "k8s.io/kubernetes/pkg/apis/apps/install"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 10 19:23:50 UTC 2022 - 1.6K bytes - Viewed (0) -
pkg/kubelet/util/ioutils/ioutils.go
*/ package ioutils import "io" // LimitWriter is a copy of the standard library ioutils.LimitReader, // applied to the writer interface. // LimitWriter returns a Writer that writes to w // but stops with EOF after n bytes. // The underlying implementation is a *LimitedWriter. func LimitWriter(w io.Writer, n int64) io.Writer { return &LimitedWriter{w, n} } // A LimitedWriter writes to W but limits the amount of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 1.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/ForwardStdinStreamsHandler.java
There's a potential problem here in that DisconnectableInputStream reads from input in the background. This won't automatically stop when the process is over. Therefore, if input is not closed then this thread will run forever. It would be better to ensure that this thread stops when the process does. */ InputStream instr = new DisconnectableInputStream(input);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/test/groovy/org/gradle/caching/internal/controller/DefaultBuildCacheControllerTest.groovy
true } when: controller.load(key, cacheableEntity) then: 0 * local.storeLocally(key, _) } def "stops calling through after read error"() { local = null when: def controller = getController() controller.load(key, cacheableEntity) controller.load(key, cacheableEntity)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 8.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientConnectionTest.groovy
final connection = new DaemonClientConnection(delegate, daemon, staleAddressDetector) def "stops"() { when: connection.stop() then: 1 * delegate.stop() 0 * staleAddressDetector._ } def "dispatches messages"() { def message = Stub(Message) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.8K bytes - Viewed (0)