- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,168 for read (0.01 sec)
-
docs/en/docs/how-to/general.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 2.6K bytes - Viewed (0) -
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 infoRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 35.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/HashingInputStreamTest.java
HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer); byte[] buf = new byte[100]; int numOfByteRead = in.read(buf, 0, buf.length); assertEquals(-1, in.read()); // additional read assertEquals(4, numOfByteRead); assertEquals(expectedHash, in.hash()); } public void testHash_hashesCorrectlyForSkipping() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 5K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/HashingInputStreamTest.java
HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer); byte[] buf = new byte[100]; int numOfByteRead = in.read(buf, 0, buf.length); assertEquals(-1, in.read()); // additional read assertEquals(4, numOfByteRead); assertEquals(expectedHash, in.hash()); } public void testHash_hashesCorrectlyForSkipping() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 5K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
assertThat(inputStream!!.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo('D'.code) assertThat(inputStream.read()).isEqualTo('E'.code) assertThat(inputStream.read()).isEqualTo('F'.code) assertThat(inputStream.read()).isEqualTo(-1)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Aug 03 22:38:00 UTC 2025 - 28K bytes - Viewed (0) -
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.");Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.5K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileInputStreamTest.java
byte[] buf = new byte[16]; // Skip advances internal file pointer; next read should use this offset in.skip(2); // Act int n = in.readDirect(buf, 0, 5); // Assert assertEquals(3, n, "Should report bytes read from SMB2 response"); // Verify the request offset equals the skip value (2)Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 12.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/io/Smb2ReadResponse.java
import jcifs.internal.util.SMBUtil; import jcifs.smb.NtStatus; /** * SMB2 Read response message. * * This response contains the data that was read from the file * along with information about the read operation. * * @author mbechler */ public class Smb2ReadResponse extends ServerMessageBlock2Response { /** * Protocol overhead size for SMB2 read response */Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
else -> source.read(sink, limit) } } } override fun timeout(): Timeout = timeout } /** * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source] * in the current part. If this returns 0 the current part is exhausted; otherwise it has at * least one byte left to read. */Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt
@Throws(IOException::class) override fun read( sink: Buffer, byteCount: Long, ): Long { val buffer = Buffer() val read = delegate.read(buffer, byteCount) if (read != -1L) { sink.write(buffer.readByteString().toAsciiUppercase()) } return read } } }Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.8K bytes - Viewed (0)