- Sort Score
- Result 10 results
- Languages All
Results 671 - 680 of 1,191 for differ (0.04 sec)
-
src/main/java/jcifs/internal/smb1/trans/nt/SmbComNtCancel.java
*/ @Override protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) { return 0; } /** * {@inheritDoc} * * @see jcifs.internal.smb1.ServerMessageBlock#readBytesWireFormat(byte[], int) */ @Override protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) { return 0; }Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/fscc/FileEndOfFileInformation.java
/** * {@inheritDoc} * * @see jcifs.Decodable#decode(byte[], int, int) */ @Override public int decode(final byte[] buffer, final int bufferIndex, final int len) throws SMBProtocolDecodingException { this.endOfFile = SMBUtil.readInt8(buffer, bufferIndex); return 8; } /** * {@inheritDoc} * * @see jcifs.Encodable#size() */ @OverrideRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/fscc/FileInternalInfo.java
/** * {@inheritDoc} * * @see jcifs.Decodable#decode(byte[], int, int) */ @Override public int decode(final byte[] buffer, final int bufferIndex, final int len) throws SMBProtocolDecodingException { this.indexNumber = SMBUtil.readInt8(buffer, bufferIndex); return 8; } /** * {@inheritDoc} * * @see jcifs.Encodable#size() */ @OverrideRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComFindClose2.java
return 0; } @Override protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) { return 0; } @Override protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) { return 0; } @Override public String toString() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/UploadProgress.java
BufferedSink bufferedSink = Okio.buffer(sink(sink)); delegate.writeTo(bufferedSink); bufferedSink.flush(); } public Sink sink(Sink sink) { return new ForwardingSink(sink) { private long totalBytesWritten = 0L; private boolean completed = false; @Override public void write(Buffer source, long byteCount) throws IOException {Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 4.2K bytes - Viewed (1) -
src/main/java/jcifs/internal/smb1/trans2/Trans2GetDfsReferral.java
} @Override protected int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; } @Override protected int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; } @Override protected int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; }Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ioctl/SrvRequestResumeKeyResponse.java
*/ @Override public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException { final int start = bufferIndex; if (len < 24) { throw new SMBProtocolDecodingException("Invalid resume key"); } this.resumeKey = new byte[24]; System.arraycopy(buffer, bufferIndex, this.resumeKey, 0, 24); bufferIndex += 24;Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransWaitNamedPipe.java
return 0; } @Override int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; } @Override int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) { return 0; } @Override public String toString() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 2.2K bytes - Viewed (0) -
src/arena/arena_test.go
a := arena.NewArena() defer a.Free() tt := arena.New[T1](a) tt.n = 1 ts := arena.MakeSlice[T1](a, 99, 100) if len(ts) != 99 { t.Errorf("Slice() len = %d, want 99", len(ts)) } if cap(ts) != 100 { t.Errorf("Slice() cap = %d, want 100", cap(ts)) } ts[1].n = 42 } func TestSmokeLarge(t *testing.T) { a := arena.NewArena() defer a.Free() for i := 0; i < 10*64; i++ {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed Oct 12 20:23:36 UTC 2022 - 742 bytes - Viewed (0) -
docs/contribute/concurrency.md
bytes arrive, the stream is closed, or a timeout elapses. If we get bytes but there's nobody asking for them, we buffer them. We don't consider bytes as delivered for flow control until they're consumed by the application. Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending more data on this stream. When the user unpauses...
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0)