- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,029 for Pread (0.03 sec)
-
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) -
src/main/java/jcifs/internal/smb2/Smb2TransformHeader.java
} bufferIndex += 4; // Read signature System.arraycopy(buffer, bufferIndex, header.signature, 0, 16); bufferIndex += 16; // Read nonce System.arraycopy(buffer, bufferIndex, header.nonce, 0, 16); bufferIndex += 16; // Read original message size header.originalMessageSize = SMBUtil.readInt4(buffer, bufferIndex);Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 9.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java
/** * Record start of a read request * * @param bytes number of bytes being requested */ public void recordReadRequest(int bytes) { // Track that a read was requested rdmaReads.incrementAndGet(); } /** * Record successful completion of a read request * * @param bytes number of bytes successfully readRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 10.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbConstants.java
int CAP_LEVEL_II_OPLOCKS = 0x0080; /** Lock and read capability */ int CAP_LOCK_AND_READ = 0x0100; /** NT find capability */ int CAP_NT_FIND = 0x0200; /** DFS capability */ int CAP_DFS = 0x1000; /** Extended security capability */ int CAP_EXTENDED_SECURITY = 0x80000000; // file attribute encoding /** Read-only file attribute */ int ATTR_READONLY = 0x01;Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 10.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2LockResponseTest.java
} @Test @DisplayName("Should throw exception with buffer too small to read structure size") void testReadBytesWireFormatInsufficientBufferForStructureSize() { // Given byte[] buffer = new byte[1]; // Too small to read 2-byte structure size // When & ThenRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotificationTest.java
byte[] expectedFileId = createTestData(16); System.arraycopy(expectedFileId, 0, buffer, bufferIndex, 16); // Read the buffer int bytesRead = notification.readBytesWireFormat(buffer, 0); // Verify the bytes read assertEquals(24, bytesRead); // Verify the fields were set correctly using reflection
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans2/Trans2FindFirst2Test.java
trans2FindFirst2 = new Trans2FindFirst2(mockConfig, "\\test", "*.*", 0x16, 10, 1024); byte[] buffer = new byte[100]; int read = trans2FindFirst2.readSetupWireFormat(buffer, 0, 100); assertEquals(0, read); } @Test @DisplayName("Test readParametersWireFormat returns 0") void testReadParametersWireFormat() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
*/ public File getTemporaryFile() { return tempFile; } /* * (non-Javadoc) * * @see java.io.InputStream#read() */ @Override public int read() throws IOException { return fileInputStream.read(); } @Override public int available() throws IOException { return fileInputStream.available(); } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 4.3K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
val derReader = DerReader(buffer) derReader.read("test") { header -> assertThat(header.tag).isEqualTo(16L) derReader.read("test") { header2 -> assertThat(header2.tag).isEqualTo(21L) assertThat(derReader.readOctetString()).isEqualTo("Smith".encodeUtf8()) } derReader.read("test") { header3 -> assertThat(header3.tag).isEqualTo(1L)Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 31.7K 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)