- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 98 for buffer_end (0.18 sec)
-
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) -
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) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheReport.kt
val decorate: (PropertyProblem, ProblemSeverity) -> DecoratedPropertyProblem ) : State() { private val hashingStream = HashingOutputStream(Hashing.md5(), spoolFile.outputStream().buffered()) private val writer = HtmlReportWriter(hashingStream.writer()) init { executor.submit {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 11.4K 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) -
src/net/textproto/reader.go
// Optimistically assume that we have started to buffer the next line // and it starts with an ASCII letter (the next header key), or a blank // line, so we can avoid copying that buffered data around in memory // and skipping over non-existent whitespace. if r.R.Buffered() > 1 { peek, _ := r.R.Peek(2) if len(peek) > 0 && (isASCIILetter(peek[0]) || peek[0] == '\n') || len(peek) == 2 && peek[0] == '\r' && peek[1] == '\n' {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 22.1K bytes - Viewed (0) -
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) -
src/encoding/xml/marshal.go
return depth == 0 && inquote == 0 && !incomment } // Flush flushes any buffered XML to the underlying writer. // See the [Encoder.EncodeToken] documentation for details about when it is necessary. func (enc *Encoder) Flush() error { return enc.p.w.Flush() } // Close the Encoder, indicating that no more data will be written. It flushes // any buffered XML to the underlying writer and returns an error if the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 18:46:41 UTC 2024 - 31.2K bytes - Viewed (0) -
android/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) -
src/net/net_fake.go
writeClosed bool // true if the writer of the queue has stopped writing; the reader sees either io.EOF or syscall.ECONNRESET when they have read all buffered packets noLinger bool // if true, the reader sees ECONNRESET instead of EOF } // A packetQueue is a set of 1-buffered channels implementing a FIFO queue // of packets. type packetQueue struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 19:24:21 UTC 2024 - 26.4K bytes - Viewed (0) -
src/compress/gzip/gzip.go
} // NewWriter returns a new [Writer]. // Writes to the returned writer are compressed and written to w. // // It is the caller's responsibility to call Close on the [Writer] when done. // Writes may be buffered and not flushed until Close. // // Callers that wish to set the fields in Writer.Header must do so before // the first call to Write, Flush, or Close. func NewWriter(w io.Writer) *Writer {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 6.2K bytes - Viewed (0)