- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 1,168 for Buffer (0.06 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
private val minimumDeflateSize: Long, ) : Closeable { /** This holds outbound data for compression and masking. */ private val messageBuffer = Buffer() /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */ private val sinkBuffer: Buffer = sink.buffer private var writerClosed = false /** Lazily initialized on first use. */ private var messageDeflater: MessageDeflater? = nullRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/io/Smb2ReadResponse.java
/** * Constructs a SMB2 read response with the specified configuration and output buffer * * @param config * the configuration to use for this response * @param outputBuffer * the buffer to receive the read data * @param outputBufferOffset * the offset in the output buffer to start writing data */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComSessionSetupAndXResponse.java
return 0; } @Override int readParameterWordsWireFormat(final byte[] buffer, int bufferIndex) { final int start = bufferIndex; isLoggedInAsGuest = ((buffer[bufferIndex] & 0x01) == 0x01) == true; bufferIndex += 2; if (extendedSecurity) { final int blobLength = readInt2(buffer, bufferIndex); bufferIndex += 2; blob = new byte[blobLength]; }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/BufferCache.java
/** * Internal API for managing reusable buffers * * @author mbechler * * <p>This interface is intended for internal use.</p> */ public interface BufferCache { /** * Gets a buffer from the cache or creates a new one if the cache is empty. * * @return a buffer from the cache, or a new one */ byte[] getBuffer(); /** * Return a buffer to the cache *Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndXResponse.java
protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) { this.supportSearchBits = (buffer[bufferIndex] & SMB_SUPPORT_SEARCH_BITS) == SMB_SUPPORT_SEARCH_BITS; this.shareIsInDfs = (buffer[bufferIndex] & SMB_SHARE_IS_IN_DFS) == SMB_SHARE_IS_IN_DFS; return 2; } @Override protected int readBytesWireFormat(final byte[] buffer, int bufferIndex) { final int start = bufferIndex;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.1K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // data to be written into buffer. data := "1234567890" // seed the random number generator once. rand.Seed(3) // generate a random number between 13 and 200. randInt := getRandomRange(13, 200, -1) // write into buffer till length of the buffer is greater than the generated random number. for i := 0; i <= randInt; i += 10 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponse.java
@Override protected int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; } @Override protected int readParametersWireFormat(final byte[] buffer, int bufferIndex, final int len) { this.available = SMBUtil.readInt2(buffer, bufferIndex); bufferIndex += 2; SMBUtil.readInt2(buffer, bufferIndex); bufferIndex += 2;Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.3K bytes - Viewed (0) -
src/test/java/jcifs/tests/persistent/DurableHandleContextTest.java
assertEquals("DHnQ", new String(request.getName())); assertTrue(request.size() > 0); // Test encoding byte[] buffer = new byte[request.size()]; int encoded = request.encode(buffer, 0); assertEquals(request.size(), encoded); } @Test public void testDurableHandleV2Request() {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 4.6K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/InfoTest.java
writeLong(buffer, 0, (create + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L); writeLong(buffer, 8, (lastAccess + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L); writeLong(buffer, 16, (lastWrite + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L); writeLong(buffer, 24, (change + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L); writeShort(buffer, 32, attributes);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans2/Trans2GetDfsReferralTest.java
} @Test @DisplayName("writeParametersWireFormat with mock request buffer") void testWriteParametersWireFormatWithMock() throws Exception { // Given String filename = "\\\\server\\share"; trans2GetDfsReferral = new Trans2GetDfsReferral(mockConfig, filename); // Mock the request buffer DfsReferralRequestBuffer mockRequest = mock(DfsReferralRequestBuffer.class);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11K bytes - Viewed (0)