- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 733 for Buffers (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java
StringBuilder buffer = new StringBuilder(256); buffer.append("'parent.relativePath'"); if (childModel != problems.getRootModel()) { buffer.append(" of POM ").append(ModelProblemUtils.toSourceHint(childModel)); } buffer.append(" points at ").append(groupId).append(':').append(artifactId);
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sun Mar 30 23:08:08 GMT 2025 - 55.3K bytes - Click Count (0) -
internal/http/response-recorder.go
ttfbBody time.Duration StartTime time.Time // number of bytes written bytesWritten int // number of bytes of response headers written headerBytesWritten int // Internal recording buffer headers bytes.Buffer body bytes.Buffer // Indicate if headers are written in the log headersLogged bool } // Hijack - hijacks the underlying connection func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
import okio.BufferedSink import okio.ByteString import okio.ByteString.Companion.encodeUtf8 import okio.FileSystem import okio.Path import okio.Path.Companion.toPath import okio.buffer /** * Downloads the public suffix list from https://publicsuffix.org/list/public_suffix_list.dat and * transforms the file into an efficient format used by OkHttp. * *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Aug 06 05:33:11 GMT 2025 - 6.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
* attempting to add new elements onto the queue and it is full. This queue orders elements FIFO * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e., * cyclic buffer or ring buffer). * * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a * full queue, the queue automatically removes its head element. This is different from conventional
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4.6K bytes - Click Count (0) -
guava/src/com/google/common/hash/SipHashFunction.java
} @Override protected void process(ByteBuffer buffer) { b += CHUNK_SIZE; processM(buffer.getLong()); } @Override protected void processRemaining(ByteBuffer buffer) { b += buffer.remaining(); for (int i = 0; buffer.hasRemaining(); i += 8) { finalM ^= (buffer.get() & 0xFFL) << i; } } @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 5.3K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/com/SmbComWriteAndXResponse.java
return 0; } @Override protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) { this.count = SMBUtil.readInt2(buffer, bufferIndex) & 0xFFFFL; return 8; } @Override protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) { return 0; } @Override public String toString() {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.3K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
* limitations under the License. */ package okhttp3 import assertk.assertThat import assertk.assertions.containsExactly import java.net.InetAddress import java.net.UnknownHostException import okio.Buffer class FakeDns : Dns { private val hostAddresses: MutableMap<String, List<InetAddress>> = mutableMapOf() private val requestedHosts: MutableList<String> = mutableListOf()Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2.5K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/NtTransQuerySecurityDesc.java
return 0; } @Override int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) { 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; } @OverrideCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 2.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/HashTestUtils.java
for (PrimitiveSink sink : sinks) { ByteBuffer buffer = ByteBuffer.wrap(value); Java8Compatibility.position(buffer, pos); Java8Compatibility.limit(buffer, limit); sink.putBytes(buffer); assertEquals(limit, buffer.limit()); assertEquals(limit, buffer.position()); } } }, PUT_STRING() { @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 25.6K bytes - Click Count (0) -
lib/wasm/wasm_exec.js
const n = this.mem.getInt32(sp + 24, true); fs.writeSync(fd, new Uint8Array(this._inst.exports.mem.buffer, p, n)); }, // func resetMemoryDataView() "runtime.resetMemoryDataView": (sp) => { sp >>>= 0; this.mem = new DataView(this._inst.exports.mem.buffer); }, // func nanotime1() int64 "runtime.nanotime1": (sp) => { sp >>>= 0;
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Sun Dec 08 15:34:47 GMT 2024 - 16.6K bytes - Click Count (0)