- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for buffer_end (0.14 sec)
-
src/os/user/cgo_lookup_unix.go
g := &Group{ Gid: strconv.Itoa(int(_C_gr_gid(grp))), Name: _C_GoString(_C_gr_name(grp)), } return g } type bufferKind _C_int var ( userBuffer = bufferKind(_C__SC_GETPW_R_SIZE_MAX) groupBuffer = bufferKind(_C__SC_GETGR_R_SIZE_MAX) ) func (k bufferKind) initialSize() _C_size_t { sz := _C_sysconf(_C_int(k)) if sz == -1 { // DragonFly and FreeBSD do not have _SC_GETPW_R_SIZE_MAX.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:08:14 UTC 2024 - 5.2K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
// Package deadlineconn implements net.Conn wrapper with configured deadlines. package deadlineconn import ( "net" "time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/readwriter.go
type normWriter struct { rb reorderBuffer w io.Writer buf []byte } // Write implements the standard write interface. If the last characters are // not at a normalization boundary, the bytes will be buffered for the next // write. The remaining bytes will be written on close. func (w *normWriter) Write(data []byte) (n int, err error) { // Process data in pieces to keep w.buf size bounded. const chunk = 4000
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/events/InteractiveEvent.java
* limitations under the License. */ package org.gradle.internal.logging.events; /** * A marker interface to indicate that the event should be handled as quickly as possible, and not buffered or throttled. */ public interface InteractiveEvent {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 21 03:20:23 UTC 2024 - 830 bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/FlushableEncoder.java
/** * Represents an {@link Encoder} that buffers encoded data prior to writing to the backing stream. */ public interface FlushableEncoder extends Encoder, Flushable { /** * Ensures that all buffered data has been written to the backing stream. Does not flush the backing stream. */ @Override void flush() throws IOException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 1K bytes - Viewed (0) -
src/cmd/dist/testjson.go
for len(b) > 0 { nl := bytes.IndexByte(b, '\n') if nl < 0 { f.lineBuf.Write(b) break } var line []byte if f.lineBuf.Len() > 0 { // We have buffered data. Add the rest of the line from b and // process the complete line. f.lineBuf.Write(b[:nl+1]) line = f.lineBuf.Bytes() } else { // Process a complete line from b. line = b[:nl+1] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 4.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt
val requestBody: BufferedSource val responseBody: BufferedSink /** * Terminate the stream so that no further data is transmitted or received. Note that * [requestBody] may return data after this call; that is the buffered data received before this * stream was canceled. * * This does nothing if [requestBody] and [responseBody] are already closed. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/ByteInput.java
*/ public long getBytesRead() { return countingInputStream.getCount(); } /** * Finishes reading, resetting any buffered state. */ public void done() { countingInputStream = null; } private static class ResettableBufferedInputStream extends BufferedInputStream {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/ByteOutput.java
*/ public long getBytesWritten() { return countingOutputStream.getCount(); } /** * Finishes writing, flushing and resetting any buffered state */ public void done() throws IOException { countingOutputStream.flush(); countingOutputStream = null; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 2.4K bytes - Viewed (0) -
internal/ringbuffer/README.md
If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe). Regular Reads will block until data is available, but not wait for a full buffer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0)