- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for reached (0.04 sec)
-
guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(); /** * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more * than the given time. * * @param timeout the maximum time to wait * @throws TimeoutException if the service has not reached the given state within the deadline * @throws IllegalStateException if the service reaches a state from which it is not possible to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java
fp = 0L; } /** * Reads a single byte from the file at the current file pointer position. * * @return the byte read as an integer (0-255), or -1 if end of file is reached * @throws SmbException if an I/O error occurs */ public int read() throws SmbException { if (read(tmp, 0, 1) == -1) { return -1; } return tmp[0] & 0xFF;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 14.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
/** * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more * than the given time. * * @param timeout the maximum time to wait * @param unit the time unit of the timeout argument * @throws TimeoutException if the service has not reached the given state within the deadline * @throws IllegalStateException if the service reaches a state from which it is not possible to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* @throws EOFException if this stream reaches the end before reading all the bytes. * @throws IOException if an I/O error occurs. */ public static void readFully(InputStream in, byte[] b, int off, int len) throws IOException { int read = read(in, b, off, len); if (read != len) { throw new EOFException( "reached end of stream after reading " + read + " bytes; " + len + " bytes expected");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
* * This returns null if: * * * The stream is exhausted. * * We've read all of the bytes of an object whose length is known. * * We've reached the [DerHeader.TAG_END_OF_CONTENTS] of an object whose length is unknown. */ fun peekHeader(): DerHeader? { var result = peekedHeader if (result == null) { result = readHeader()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 10.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
/** * Waits for the {@link ServiceManager} to become {@linkplain #isHealthy() healthy}. The manager * will become healthy after all the component services have reached the {@linkplain State#RUNNING * running} state. * * @throws IllegalStateException if the service manager reaches a state from which it cannot * become {@linkplain #isHealthy() healthy}. */ public void awaitHealthy() { state.awaitHealthy(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (1) -
src/test/java/jcifs/smb/SmbTransportPoolImplTest.java
void testSessionLimitPreventsReuse() throws Exception { // Given: Config with session limit of 1 when(config.getSessionLimit()).thenReturn(1); // Create first connection SmbTransportImpl first = pool.getSmbTransport(ctx, address, 445, false); // Mock that session limit is reached
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 19.2K bytes - Viewed (0) -
cmd/metacache-stream.go
_, err := r.peek() if err != nil { r.err = err return r.err == io.EOF } return false } // forwardTo will forward to the first entry that is >= s. // Will return io.EOF if end of stream is reached without finding any. func (r *metacacheReader) forwardTo(s string) error { r.checkInit() if r.err != nil { return r.err } if s == "" { return nil } if r.current.name != "" {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 19.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Strings.java
* which case the input string is always returned. * @param padChar the character to insert at the beginning of the result until the minimum length * is reached * @return the padded string */ public static String padStart(String string, int minLength, char padChar) { checkNotNull(string); // eager for GWT. if (string.length() >= minLength) { return string;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 27 17:53:41 UTC 2025 - 12.2K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
LastFailedCount uint64 `json:"failedCount_last5min"` // Count of unreplicated entries that were dropped after MRF retry limit reached since cluster start. TotalDroppedCount uint64 `json:"droppedCount_since_uptime"` // Bytes of unreplicated entries that were dropped after MRF retry limit reached since cluster start. TotalDroppedBytes uint64 `json:"droppedBytes_since_uptime"` } // SMA struct for calculating simple moving average
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 14.2K bytes - Viewed (0)