- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for flushed (0.11 sec)
-
android/guava-tests/test/com/google/common/io/AppendableWriterTest.java
Writer writer = new AppendableWriter(spy); writer.write("Hello"); assertFalse(spy.flushed); assertFalse(spy.closed); writer.flush(); assertTrue(spy.flushed); assertFalse(spy.closed); writer.close(); assertTrue(spy.flushed); assertTrue(spy.closed); } public void testCloseIsFinal() throws IOException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.2K bytes - Viewed (0) -
src/runtime/tracestring.go
s = s[:maxTraceStringLen] } lock(&t.lock) w := unsafeTraceWriter(gen, t.buf) // Ensure we have a place to write to. var flushed bool w, flushed = w.ensure(2 + 2*traceBytesPerNumber + len(s) /* traceEvStrings + traceEvString + ID + len + string data */) if flushed { // Annotate the batch as containing strings. w.byte(byte(traceEvStrings)) } // Write out the string. w.byte(byte(traceEvString))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 2.4K bytes - Viewed (0) -
src/runtime/tracetype.go
// bound is pretty loose, but avoids counting // lots of varint sizes. // // Add 1 because we might also write a traceAllocFreeTypesBatch byte. var flushed bool w, flushed = w.ensure(1 + maxBytes) if flushed { // Annotate the batch as containing types. w.byte(byte(traceAllocFreeTypesBatch)) } // Emit type. w.varint(uint64(node.id)) w.varint(uint64(uintptr(unsafe.Pointer(typ))))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:31:27 UTC 2024 - 2.3K bytes - Viewed (0) -
src/net/http/httptest/recorder.go
if rw.HeaderMap == nil { rw.HeaderMap = make(http.Header) } rw.snapHeader = rw.HeaderMap.Clone() } // Flush implements [http.Flusher]. To test whether Flush was // called, see rw.Flushed. func (rw *ResponseRecorder) Flush() { if !rw.wroteHeader { rw.WriteHeader(200) } rw.Flushed = true } // Result returns the response generated by the handler. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7K bytes - Viewed (0) -
src/runtime/traceallocfree.go
func traceSnapshotMemory(gen uintptr) { assertWorldStopped() // Write a batch containing information that'll be necessary to // interpret the events. var flushed bool w := unsafeTraceExpWriter(gen, nil, traceExperimentAllocFree) w, flushed = w.ensure(1 + 4*traceBytesPerNumber) if flushed { // Annotate the batch as containing additional info. w.byte(byte(traceAllocFreeInfoBatch)) } // Emit info.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:32:51 UTC 2024 - 5.9K bytes - Viewed (0) -
src/runtime/tracecpu.go
} // Write out a trace event. w := unsafeTraceWriter(gen, trace.cpuBuf[gen%2]) // Ensure we have a place to write to. var flushed bool w, flushed = w.ensure(2 + 5*traceBytesPerNumber /* traceEvCPUSamples + traceEvCPUSample + timestamp + g + m + p + stack ID */) if flushed { // Annotate the batch as containing strings. w.byte(byte(traceEvCPUSamples)) } // Add the stack to the table.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/streams/ValueStore.java
/** * Writes the given value and returns an address for the written block. * The current thread performs the encoding. The implementation may perform some buffering and this may not necessarily be * flushed to the filesystem on completion of this method. */ BlockAddress write(T value); /** * Reads the contents of the given block. * The current thread performs the decoding. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/software/security/src/main/java/org/gradle/plugins/signing/signatory/Signatory.java
*/ @Internal String getName(); /** * Exhausts {@code toSign}, and writes the signature to {@code signatureDestination}. The caller is responsible for closing the streams, though the output WILL be flushed. * * @param toSign The source of the data to be signed * @param destination Where the signature will be written to */ void sign(InputStream toSign, OutputStream destination); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Oct 11 12:16:09 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/proxy/conntrack/conntrack.go
err := ct.exec(parameters...) if err != nil && !strings.Contains(err.Error(), noConnectionToDelete) { // TODO: Better handling for deletion failure. When failure occur, stale udp connection may not get flushed. // These stale udp connection will keep black hole traffic. Making this a best effort operation for now, since it // is expensive to baby-sit all udp connections to kubernetes services.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
10_000 * listener.onOutput(_) } def "background flush does nothing when events already flushed"() { def event1 = event('1') def event2 = event('2') def flush = new FlushOutputEvent() given: renderer.onOutput(event1) renderer.onOutput(event2) renderer.onOutput(flush) when: executor.runFixedScheduledActionsNow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0)