- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 505 for buffer (2.13 seconds)
-
android/guava-testlib/test/com/google/common/testing/FreshValueGeneratorTest.java
import java.io.StringReader; import java.io.StringWriter; import java.io.Writer; import java.lang.reflect.Method; import java.lang.reflect.Type; import java.math.BigDecimal; import java.math.BigInteger; import java.nio.Buffer; import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.nio.DoubleBuffer; import java.nio.FloatBuffer; import java.nio.IntBuffer; import java.nio.LongBuffer; import java.nio.ShortBuffer;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 17.4K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Sep 03 15:06:05 GMT 2025 - 66.8K bytes - Click Count (0) -
internal/grid/connection.go
gridLogIf(ctx, fmt.Errorf("ws write: %w", err)) } return false } if buf.Cap() > writeBufferSize*8 { // Reset buffer if it gets too big, so we don't keep it around. buf = bytes.Buffer{} } buf.Reset() return true } // Merge buffer to keep between calls merged := make([]byte, 0, writeBufferSize) for { var toSend []byte select { case <-ctx.Done():
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
internal/handlers/forwarder.go
} return f } type bufPool struct { sz int pool bpool.Pool[*[]byte] } func (b *bufPool) Put(buf []byte) { if cap(buf) < b.sz || cap(buf) > b.sz*2 { // Buffer too small or will likely leak memory after being expanded. // Drop it. return } b.pool.Put(&buf) } func (b *bufPool) Get() []byte { bufp := b.pool.Get() if bufp == nil || cap(*bufp) < b.sz {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.7K bytes - Click Count (0) -
internal/s3select/json/record.go
return r.SelectFormat, r.KVS } // WriteJSON - encodes to JSON data. func (r *Record) WriteJSON(writer io.Writer) error { return json.NewEncoder(writer).Encode(r.KVS) } // Replace the underlying buffer of json data. func (r *Record) Replace(k any) error { v, ok := k.(jstream.KVS) if !ok { return fmt.Errorf("cannot replace internal data in json record with type %T", k) } r.KVS = v return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/s3select/simdj/record.go
if err != nil { return err } n, err := writer.Write(b) if err != nil { return err } if n != len(b) { return io.ErrShortWrite } return nil } // Replace the underlying buffer of json data. func (r *Record) Replace(k any) error { v, ok := k.(simdjson.Object) if !ok { return fmt.Errorf("cannot replace internal data in simd json record with type %T", k) } r.object = v return nilCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.4K bytes - Click Count (0) -
cmd/encryption-v1.go
if len(data) == 0 { return data } var buffer bytes.Buffer mac := hmac.New(sha256.New, key[:]) mac.Write([]byte(baseKey)) if _, err := sio.Encrypt(&buffer, bytes.NewReader(data), sio.Config{Key: mac.Sum(nil)}); err != nil { logger.CriticalIf(context.Background(), errors.New("unable to encrypt using object key")) } return buffer.Bytes() } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 38K bytes - Click Count (0) -
src/cmd/asm/internal/asm/endtoend_test.go
architecture.Init(ctxt) lexer := lex.NewLexer(input) parser := NewParser(ctxt, architecture, lexer) pList := new(obj.Plist) var ok bool testOut = new(strings.Builder) // The assembler writes test output to this buffer. ctxt.Bso = bufio.NewWriter(os.Stdout) ctxt.IsAsm = true defer ctxt.Bso.Flush() failed := false ctxt.DiagFunc = func(format string, args ...any) { failed = true t.Errorf(format, args...) }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Dec 23 18:45:48 GMT 2025 - 12.5K bytes - Click Count (0) -
src/bytes/reader.go
"io" "unicode/utf8" ) // A Reader implements the [io.Reader], [io.ReaderAt], [io.WriterTo], [io.Seeker], // [io.ByteScanner], and [io.RuneScanner] interfaces by reading from // a byte slice. // Unlike a [Buffer], a Reader is read-only and supports seeking. // The zero value for Reader operates like a Reader of an empty slice. type Reader struct { s []byte i int64 // current reading index
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Jul 16 18:17:37 GMT 2024 - 3.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt
import okhttp3.internal.Tags import okhttp3.internal.http.GzipRequestBody import okhttp3.internal.http.HttpMethod import okhttp3.internal.isProbablyUtf8 import okhttp3.internal.isSensitiveHeader import okio.Buffer /** * An HTTP request. Instances of this class are immutable if their [body] is null or itself * immutable. */ class Request internal constructor( builder: Builder, ) { @get:JvmName("url")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 14.7K bytes - Click Count (1)