Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 815 for Threads (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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
     */
    @GwtCompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top