- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,064 for readn (0.09 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
@Throws(IOException::class) override fun read( sink: Buffer, byteCount: Long, ): Long { while (left == 0) { source.skip(padding.toLong()) padding = 0 if (flags and FLAG_END_HEADERS != 0) return -1L readContinuationHeader() // TODO: test case for empty continuation header? } val read = source.read(sink, minOf(byteCount, left.toLong()))
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 19.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbRandomAccessFileTest.java
} @Test @DisplayName("read(byte[],off,0): returns 0 without I/O") void read_lenZero_returnsZero() throws Exception { SmbRandomAccessFile raf = newInstance("r", false, false, false); byte[] buf = new byte[4]; assertEquals(0, raf.read(buf, 0, 0)); } @Test @DisplayName("read(): returns -1 when underlying read reports EOF")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 17.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java
/** * This class will allow a Java program to read and write data to Named * Pipes and Transact NamedPipes. * * <p>There are three Win32 function calls provided by the Windows SDK * that are important in the context of using jCIFS. They are: * * <ul> * <li> <code>CallNamedPipe</code> A message-type pipe call that opens, * writes to, reads from, and closes the pipe in a single operation.
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 8.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java
@Nested @DisplayName("Integration Tests") class IntegrationTests { @Test @DisplayName("Should maintain state after multiple reads") void testMultipleReads() throws SMBProtocolDecodingException { // First read byte[] buffer1 = createValidWriteResponse(1024, 512); response.readBytesWireFormat(buffer1, 0); assertEquals(1024, response.getCount());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.9K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/SmbInfoAllocationTest.java
offset += 2; // Decode int bytesDecoded = smbInfoAllocation.decode(buffer, 0, buffer.length); // Verify - actual implementation reads 20 bytes (4 + 4 + 4 + 4 + 4) // bytesPerSect is read as Int2 but advances by 4 bytes (padding) assertEquals(20, bytesDecoded); // Verify capacity calculation: alloc * sectPerAlloc * bytesPerSect
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
} }); } ``` ### 5.3 Read/Write Operations with Multi-Channel ```java // In SmbFile.java public void optimizedLargeRead(byte[] buffer, long offset, int length) throws IOException { if (!session.isMultiChannelEnabled() || length < 1048576) { // 1MB threshold // Use single channel for small reads normalRead(buffer, offset, length); return; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* [Call.request] is a redirect to a different address. * * Prior to OkHttp 4.3 this was incorrectly invoked when the client was ready to read headers. * This was misleading for tracing because it was too early. */ open fun responseHeadersStart(call: Call) { } /** * Invoked immediately after receiving response headers. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 17.4K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt
readStory(story00) result.add(path.name) } catch (ignored: IOException) { // Skip this path. } } return result.toTypedArray<String>() } /** * Reads stories named "story_xx.json" from the folder provided. */ fun readStories(testFolderName: String): List<Story> { val result = mutableListOf<Story>() var i = 0 while (true) { // break after last test.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.3K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
*/ public static byte[] toByteArray(File file) throws IOException { return asByteSource(file).read(); } /** * Reads all characters from a file into a {@link String}, using the given character set. * * @param file the file to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for * helpful predefined constants
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0)