- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 459 for gooses (0.25 sec)
-
internal/dsync/dsync-client_test.go
u: u, rest: rest.NewClient(u, tr, nil), } } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
// Connection represents an upgraded HTTP connection. type Connection interface { // CreateStream creates a new Stream with the supplied headers. CreateStream(headers http.Header) (Stream, error) // Close resets all streams and closes the connection. Close() error // CloseChan returns a channel that is closed when the underlying connection is closed. CloseChan() <-chan bool // SetIdleTimeout sets the amount of time the connection may remain idle before
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/artifacts/TargetJvmVersionRulesTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 03 17:43:36 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BlockStore.java
public interface BlockStore { /** * Opens this store, calling the given action if the store is empty. */ void open(Runnable initAction, Factory factory); /** * Closes this store. */ void close(); /** * Discards all blocks from this store. */ void clear(); /** * Removes the given block from this store. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/cmd/cmd.go
package cmd import ( "flag" "os" "os/signal" "syscall" "github.com/spf13/cobra" "github.com/spf13/pflag" "istio.io/istio/pkg/log" ) // WaitSignal awaits for SIGINT or SIGTERM and closes the channel func WaitSignal(stop chan struct{}) { sigs := make(chan os.Signal, 1) signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM) <-sigs close(stop) _ = log.Sync() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/LatestModuleConflictResolverTest.groovy
class LatestModuleConflictResolverTest extends AbstractConflictResolverTest { def setup() { resolver = new LatestModuleConflictResolver(new DefaultVersionComparator(), new VersionParser()) } def "chooses latest module version #version for candidates #candidates"() { given: candidateVersions candidates when: resolveConflicts() then: selected version
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/MultiReader.java
@CheckForNull private Reader current; MultiReader(Iterator<? extends CharSource> readers) throws IOException { this.it = readers; advance(); } /** Closes the current reader and opens the next one, if any. */ private void advance() throws IOException { close(); if (it.hasNext()) { current = it.next().openStream(); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2.4K bytes - Viewed (0) -
guava/src/com/google/common/io/MultiReader.java
@CheckForNull private Reader current; MultiReader(Iterator<? extends CharSource> readers) throws IOException { this.it = readers; advance(); } /** Closes the current reader and opens the next one, if any. */ private void advance() throws IOException { close(); if (it.hasNext()) { current = it.next().openStream(); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2.4K bytes - Viewed (0) -
src/crypto/cipher/io.go
c := make([]byte, len(src)) w.S.XORKeyStream(c, src) n, err = w.W.Write(c) if n != len(src) && err == nil { // should never happen err = io.ErrShortWrite } return } // Close closes the underlying Writer and returns its Close return value, if the Writer // is also an io.Closer. Otherwise it returns nil. func (w StreamWriter) Close() error { if c, ok := w.W.(io.Closer); ok { return c.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
* <li>The client sends a {@link Finished} message once it has received the {@link Result} message. * It may no longer send any messages.</li> * <li>The client closes the connection.</li> * <li>The daemon closes the connection once it has received the {@link Finished} message.</li> * </ul> * * <p>To stop a daemon:</p> * * <ul> * <li>The client creates a connection to daemon.</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0)