- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 815 for Threads (0.03 sec)
-
internal/http/request-recorder.go
buf bytes.Buffer // total bytes read including header size bytesRead int } // Close is a no operation closer func (r *RequestRecorder) Close() error { // no-op return nil } // Read reads from the internal reader and counts/save the body in the memory func (r *RequestRecorder) Read(p []byte) (n int, err error) { n, err = r.Reader.Read(p) r.bytesRead += n if r.LogBody { r.buf.Write(p[:n]) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 12 21:37:19 UTC 2023 - 1.8K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java
* implementations, supports add() under JDK8. This seems problematic, but I * didn't see that discussed in the review, which included many other * changes: https://mail.openjdk.org/pipermail/core-libs-dev/2013-May/thread.html#17367 * * TODO(cpovirk): decide what the best long-term action here is: force users * to suppress (as we do now), stop testing entrySet().add() at all, make
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 3.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/FakeTicker.java
* * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called: * see {@link #setAutoIncrementStep}. * * <p>This class is thread-safe. * * @author Jige Yu * @since 10.0 */ @NullMarked @GwtCompatible public class FakeTicker extends Ticker { private final AtomicLong nanos = new AtomicLong();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 3.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/MinimalIterable.java
* * <p>Note that although your APIs should be liberal in what they accept, your methods which * <i>return</i> iterables should make every attempt to return ones of the robust variety. * * <p>This testing utility is not thread-safe. * * @author Kevin Bourrillion */ @GwtCompatible public final class MinimalIterable<E extends @Nullable Object> implements Iterable<E> {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.1K bytes - Viewed (0) -
src/main/resources/fess_message_id.properties
errors.could_not_delete_logged_in_user=Anda tidak dapat menghapus pengguna yang sedang login. errors.unauthorized_request=Permintaan tidak sah. errors.failed_to_print_thread_dump=Gagal mencetak thread dump. errors.file_is_not_supported={0} tidak didukung. errors.plugin_file_is_not_found={0} tidak ditemukan. errors.failed_to_install_plugin=Gagal menginstal {0}.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 07 14:12:58 UTC 2025 - 11.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/ForwardingMultiset.java
* invoke methods, they invoke methods on the {@code ForwardingMultiset}. * * <p>The {@code standard} methods and any collection views they return are not guaranteed to be * thread-safe, even when all of the methods that they depend on are thread-safe. * * @author Kevin Bourrillion * @author Louis Wasserman * @since 2.0 */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 10.3K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
assertSetEquals( "seqno=$testCase.seqno", testCase.headersList, hpackReader.getAndResetHeaderList(), ) } } companion object { /** * Reads all stories in the folders provided, asserts if no story found. */ @JvmStatic protected fun createStories(interopTests: Array<String>): List<Any> { if (interopTests.isEmpty()) return listOf<Any>(Story.MISSING)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.2K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* @author Colin Decker * @since 1.0 */ @GwtIncompatible public final class ByteStreams { private static final int BUFFER_SIZE = 8192; /** Creates a new byte array for buffering reads or writes. */ static byte[] createBuffer() { return new byte[BUFFER_SIZE]; } /** * There are three methods to implement {@link FileChannel#transferTo(long, long, * WritableByteChannel)}: *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
impl/maven-core/src/test/java/org/apache/maven/project/AbstractMavenProjectTestCase.java
} protected static File getFileForClasspathResource(String resource) throws FileNotFoundException, URISyntaxException { ClassLoader cloader = Thread.currentThread().getContextClassLoader(); URL resourceUrl = cloader.getResource(resource); if (resourceUrl == null) { throw new FileNotFoundException("Unable to find: " + resource);Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jan 10 08:42:00 UTC 2025 - 7.2K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
// Retry after delay try { Thread.sleep(5000); } catch (InterruptedException ie) { Thread.currentThread().interrupt(); break; } } } } });Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0)