- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 566 for Closest (0.13 sec)
-
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) -
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) -
android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java
* lies outside that, then {@link #escapeUnsafe} is called, otherwise no escaping is performed. * * @param replacementMap a map of characters to their escaped representations * @param safeMin the lowest character value in the safe range * @param safeMax the highest character value in the safe range */ protected ArrayBasedCharEscaper( Map<Character, String> replacementMap, char safeMin, char safeMax) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jan 18 20:55:09 UTC 2022 - 6.3K 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) -
src/internal/bytealg/count_s390x.s
VSUMB V_VAL, V_ZERO, V_VAL // [16]byte{x0, x1, ..., x14, x15} → [4]uint32{x0+x1+x2+x3, ..., x12+x13+x14+x15} VSUMQF V_VAL, V_ZERO, V_CNT // [4]uint32{x0, x1, x2, x3} → [1]uint128{x0+x1+x2+x3} // Return rightmost (lowest) 64-bit part of accumulator. VSTEG $1, V_CNT, (R_RET) RET vxchunks: // Load 0x01 into every byte element in the 16-byte mask vector. VREPIB $1, V_MASK // V_MASK = [16]byte{1, 1, ..., 1, 1}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 15 21:04:43 UTC 2019 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/text/StreamingStyledTextOutput.java
closeable = target instanceof Closeable ? (Closeable) target : null; } @Override protected void doAppend(String text) { listener.onOutput(text); } /** * Closes the target object if it implements {@link java.io.Closeable}. */ @Override public void close() throws IOException { if (closeable != null) { closeable.close(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 2.1K bytes - Viewed (0) -
platforms/software/resources-http/src/main/java/org/gradle/internal/resource/transport/http/JavaSystemPropertiesHttpTimeoutSettings.java
/** * The default time in milliseconds for an idle connection to remain open. * <a href="https://azure.microsoft.com/en-us/blog/new-configurable-idle-timeout-for-azure-load-balancer/">Microsoft Azure closes idle connections after 4 min</a>, * so we set our default to be below that. */ public static final int DEFAULT_IDLE_CONNECTION_TIMEOUT = (int) Duration.ofMinutes(3).toMillis();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3.2K bytes - Viewed (0) -
src/internal/trace/gc.go
c.mmu(window, &acc) return acc.mmu } // Examples returns n specific examples of the lowest mutator // utilization for the given window size. The returned windows will be // disjoint (otherwise there would be a huge number of // mostly-overlapping windows at the single lowest point). There are // no guarantees on which set of disjoint windows this returns.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r24/BuildInvocationsCrossVersionSpec.groovy
import org.gradle.tooling.model.gradle.BuildInvocations class BuildInvocationsCrossVersionSpec extends ToolingApiSpecification { def "set task selector description taken from task with path that has lowest ordering"() { temporaryFolder.createFile('settings.gradle') << ''' rootProject.name = 'TestProject' include 'sub' ''' temporaryFolder.createFile('build.gradle') << '''
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.1K bytes - Viewed (0)