Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1321 - 1330 of 1,620 for whence (0.06 sec)

  1. src/main/java/jcifs/util/Hexdump.java

            return toHexString(data, 0, data.length);
        }
    
        /**
         * This is the same as {@link jcifs.util.Hexdump#toHexString(int val, int
         * size)} but provides a more practical form when trying to avoid {@link
         * java.lang.String} concatenation and {@link java.lang.StringBuffer}.
         *
         * @param val the integer value to convert to hexadecimal characters
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

     */
    package org.codelibs.fess.crawler.util;
    
    import java.io.IOException;
    import java.io.InputStream;
    
    /**
     * A wrapper for an {@link InputStream} that ignores the {@link #close()} method call.
     * This can be useful when you want to prevent the underlying input stream from being closed.
     *
     * <p>All other methods delegate to the wrapped input stream.</p>
     *
     */
    public class IgnoreCloseInputStream extends InputStream {
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. internal/lru/lru.go

    package lru
    
    // golang -lru
    // https://github.com/hashicorp/golang-lru
    import (
    	"sync"
    	"time"
    )
    
    // EvictCallback is used to get a callback when a cache entry is evicted
    type EvictCallback[K comparable, V any] func(key K, value V)
    
    // LRU implements a thread-safe LRU with expirable entries.
    type LRU[K comparable, V any] struct {
    	size      int
    	evictList *LruList[K, V]
    	items     map[K]*Entry[K, V]
    	onEvict   EvictCallback[K, V]
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

            .build(),
        )
        server.enqueue(MockResponse())
        assertFailsWith<SSLPeerUnverifiedException> {
          val response = execute(url)
          response.close()
        }
      }
    
      /** Can still coalesce when pinning is used if pins match.  */
      @Test
      fun coalescesWhenCertificatePinsMatch() {
        val pinner =
          CertificatePinner
            .Builder()
            .add("san.com", pin(certificate.certificate))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbSession.java

                    }
    
                    /* We explicitly set uid to 0 here to prevent a new
                     * SMB_COM_SESSION_SETUP_ANDX from having it's uid set to an
                     * old value when the session is re-established. Otherwise a
                     * "The parameter is incorrect" error can occur.
                     */
                    uid = 0;
    
                    do {
                        switch (state) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  6. src/bufio/bufio_test.go

    	}
    	if buffered := wr.Buffered(); buffered != wantBuffered {
    		t.Fatalf("Buffered = %v; want %v", buffered, wantBuffered)
    	}
    }
    
    func BenchmarkReaderCopyOptimal(b *testing.B) {
    	// Optimal case is where the underlying reader implements io.WriterTo
    	srcBuf := bytes.NewBuffer(make([]byte, 8192))
    	src := NewReader(srcBuf)
    	dstBuf := new(bytes.Buffer)
    	dst := onlyWriter{dstBuf}
    	for i := 0; i < b.N; i++ {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        for (Method method : FuturesTest.class.getDeclaredMethods()) {
          if (Modifier.isPublic(method.getModifiers())
              && method.getName().startsWith("test")
              /*
               * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on
               * AbstractFuture, since it declares methods that use that type in their signatures.
               */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. cmd/data-usage-utils.go

    	TotalCapacity     uint64 `json:"capacity,omitempty"`
    	TotalUsedCapacity uint64 `json:"usedCapacity,omitempty"`
    	TotalFreeCapacity uint64 `json:"freeCapacity,omitempty"`
    
    	// LastUpdate is the timestamp of when the data usage info was last updated.
    	// This does not indicate a full scan.
    	LastUpdate time.Time `json:"lastUpdate"`
    
    	// Objects total count across all buckets
    	ObjectsTotalCount uint64 `json:"objectsCount"`
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. cmd/leak-detect_test.go

    	initialStackSnapShot := NewLeakDetect()
    	return func() {
    		initialStackSnapShot.DetectLeak(t)
    	}
    }
    
    // list of functions to be ignored from the stack trace.
    // Leak detection is done when tests are run, should ignore the tests related functions,
    // and other runtime functions while identifying leaks.
    var ignoredStackFns = []string{
    	"",
    	// Below are the stacks ignored by the upstream leaktest code.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  10. docs/erasure/README.md

    Minio uses the largest possible EC set size which divides into the number of drives given. For example, *18 drives* are configured as *2 sets of 9 drives*, and *24 drives* are configured as *2 sets of 12 drives*.  This is true for scenarios when running MinIO as a standalone erasure coded deployment. In [distributed setup however node (affinity) based](https://docs.min.io/community/minio-object-store/operations/install-deploy-manage/deploy-minio-multi-node-multi-drive.html) erasure stripe...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.2K bytes
    - Viewed (0)
Back to top