- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 90 for buffer_end (0.33 sec)
-
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/kryo/KryoBackedDecoder.java
} return value; } /** * Returns the total number of bytes consumed by this decoder. Some additional bytes may also be buffered by this decoder but have not been consumed. */ public long getReadPosition() { return input.total() + extraSkipped; } @Override public void close() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 7.3K bytes - Viewed (0) -
src/text/tabwriter/tabwriter.go
} b.write0(b.buf[pos : pos+c.size]) pos += c.size } } } if i+1 == len(b.lines) { // last buffered line - we don't have a newline, so just write // any outstanding buffered data b.write0(b.buf[pos : pos+b.cell.size]) pos += b.cell.size } else { // not the last line - write newline b.write0(newline) } } return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 16:46:34 UTC 2024 - 17.8K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
* helpful predefined constants * @return the buffered reader */ public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException { checkNotNull(file); checkNotNull(charset); return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset)); } /** * Returns a buffered writer that writes to a file using the given character set. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 33.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/ForkingGradleHandle.java
requireStdinPipeFor("cancelWithEOT()"); try { stdinPipe.write(4); if (isDaemon) { // When running a test in a daemon executer, the input is buffered until a // newline char is received stdinPipe.write(getPlatformLineSeparator().getBytes()); } } catch (IOException e) { throw new UncheckedIOException(e);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9K bytes - Viewed (0) -
src/image/gif/writer.go
) var log2Lookup = [8]int{2, 4, 8, 16, 32, 64, 128, 256} func log2(x int) int { for i, v := range log2Lookup { if x <= v { return i } } return -1 } // writer is a buffered writer. type writer interface { Flush() error io.Writer io.ByteWriter } // encoder encodes an image to the GIF format. type encoder struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:38:09 UTC 2024 - 11.9K bytes - Viewed (0) -
src/runtime/chan.go
// blocked on it for both sending and receiving using a select statement, // in which case the length of c.sendq and c.recvq is limited only by the // size of the select statement. // // For buffered channels, also: // c.qcount > 0 implies that c.recvq is empty. // c.qcount < c.dataqsiz implies that c.sendq is empty. import ( "internal/abi" "internal/runtime/atomic" "runtime/internal/math" "unsafe"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// that happens, then we will have buffered bytes that are needed by the SSLSocket! // This check is imperfect: it doesn't tell us whether a handshake will succeed, just // that it will almost certainly fail because the proxy has sent unexpected data. if (source?.buffer?.exhausted() == false || sink?.buffer?.exhausted() == false) { throw IOException("TLS tunnel buffered too many bytes!") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
src/mime/multipart/multipart.go
// or we find a reason to stop (boundary or read error). for p.n == 0 && p.err == nil { peek, _ := br.Peek(br.Buffered()) p.n, p.err = scanUntilBoundary(peek, p.mr.dashBoundary, p.mr.nlDashBoundary, p.total, p.readErr) if p.n == 0 && p.err == nil { // Force buffered I/O to read more into buffer. _, p.readErr = br.Peek(len(peek) + 1) if p.readErr == io.EOF { p.readErr = io.ErrUnexpectedEOF }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
guava/src/com/google/common/io/FileBackedOutputStream.java
} } /** * Calls {@link #close} if not already closed, and then resets this object back to its initial * state, for reuse. If data was buffered to a file, it will be deleted. * * @throws IOException if an I/O error occurred while deleting the file buffer */ public synchronized void reset() throws IOException { try { close();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 8.2K bytes - Viewed (0)