dead - Code Search

docs/smb3-features/05-rdma-smb-direct-design.md

        // Allocate buffer for read data
        ByteBuffer readBuffer = bufferManager.allocateBuffer(request.getLength());
        RdmaMemoryRegion readRegion = provider.registerMemory(readBuffer, 
            EnumSet.of(RdmaAccess.LOCAL_WRITE, RdmaAccess.REMOTE_WRITE));
        
        try {
            // Create SMB2 Read request with RDMA read channel info

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 16 02:53:50 GMT 2025

- 35.9K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/io/ByteSource.java

 *       block indefinitely or fail if the source creates an infinite stream.
 *   <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
 *       bytes of the source as they are read from it. A source that provides such streams will not
 *       be reusable, and operations that read from the stream (including {@link #size()}, in some

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Sep 08 18:35:13 GMT 2025

- 25.7K bytes

- Click Count (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/jar/JarFileUtil.java

    }

    private static final Logger logger = Logger.getLogger(JarFileUtil.class);

    /**
     * Creates and returns a <code>JarFile</code> to read the specified JAR file.
     *
     * @param file the file path (must not be {@literal null})
     * @return a <code>JarFile</code> to read the specified JAR file
     */
    public static JarFile create(final String file) {
        assertArgumentNotNull("file", file);

        try {

Created: Fri Apr 03 20:58:12 GMT 2026

- Last Modified: Thu Jul 31 08:16:49 GMT 2025

- 4.9K bytes

- Click Count (0)

github.com/golang/go

src/bufio/bufio.go

			return n - remain, b.readErr()
		}
	}
}

// Read reads data into p.
// It returns the number of bytes read into p.
// The bytes are taken from at most one Read on the underlying [Reader],
// hence n may be less than len(p).
// To read exactly len(p) bytes, use io.ReadFull(b, p).
// If the underlying [Reader] can return a non-zero count with io.EOF,
// then this Read method can do so as well; see the [io.Reader] docs.

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Fri Feb 06 17:28:40 GMT 2026

- 22K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/Curl.java

    }

    /**
     * Creates a new CurlRequest with the HTTP HEAD method for the specified URL.
     *
     * @param url the URL to which the HEAD request is to be made
     * @return a CurlRequest object configured with the HEAD method and the specified URL
     */
    public static CurlRequest head(final String url) {
        return new CurlRequest(Method.HEAD, url);
    }

    /**

Created: Thu Apr 02 15:34:12 GMT 2026

- Last Modified: Thu Nov 20 13:34:13 GMT 2025

- 5.9K bytes

- Click Count (0)

github.com/google/guava

guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java

  }

  // Not specifying KNOWN_ORDER for PriorityQueue and PriorityBlockingQueue
  // even though they do have it, because our tests interpret KNOWN_ORDER to
  // also mean that the iterator returns the head element first, which those
  // don't.

  public Test testsForPriorityBlockingQueue() {
    return QueueTestSuiteBuilder.using(
            new TestStringQueueGenerator() {
              @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Feb 12 16:28:01 GMT 2025

- 9.5K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/ntlmssp/NtlmMessageTest.java

        // Test with zero
        buffer.putInt(0, 0);
        assertEquals(0, NtlmMessage.readULong(data, 0), "Should read zero ULong correctly.");

        // Test with max int value (unsigned interpretation)
        buffer.putInt(0, 0xFFFFFFFF);
        assertEquals(0xFFFFFFFF, NtlmMessage.readULong(data, 0), "Should read max ULong correctly.");

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 12.5K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/sereq/admin_sereq.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
	<head>
	<meta charset="UTF-8">
	<title><la:message key="labels.admin_brand_title" /> | <la:message
			key="labels.sereq_configuration" /></title>
	<jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
	<div class="wrapper">

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Mon Feb 23 08:03:44 GMT 2026

- 2.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java

      if (i == 0) {
        head = chain;
      }
    }
  }

  @SuppressWarnings("GuardedBy")
  @Benchmark
  int time(int reps) {
    int dummy = 0;
    for (int i = 0; i < reps; i++) {
      // TODO(b/145386688): This access should be guarded by 'this.segment', which is not currently
      // held
      segment.removeEntryFromChain(chain, head);
      dummy += segment.count;
    }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 2.1K bytes

- Click Count (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", args.Resources[0])
	}
	if locksHeld > ReadLock {
		l.lockMap[args.Resources[0]] = locksHeld - ReadLock // Remove one of the read locks held
	} else {
		delete(l.lockMap, args.Resources[0]) // Remove the (last) read lock
	}
	return reply, nil
}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 8.3K bytes

- Click Count (0)

Search Options