- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 849 for flushF (0.19 sec)
-
src/runtime/mwbbuf.go
start := uintptr(unsafe.Pointer(&b.buf[0])) b.next = start if testSmallBuf { // For testing, make the buffer smaller but more than // 1 write barrier's worth, so it tests both the // immediate flush and delayed flush cases. b.end = uintptr(unsafe.Pointer(&b.buf[wbMaxEntriesPerCall+1])) } else { b.end = start + uintptr(len(b.buf))*unsafe.Sizeof(b.buf[0]) } if (b.end-b.next)%unsafe.Sizeof(b.buf[0]) != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
guava/src/com/google/common/io/Flushables.java
* method * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws * an {@code IOException}. * @see Closeables#close */ public static void flush(Flushable flushable, boolean swallowIOException) throws IOException { try { flushable.flush(); } catch (IOException e) { if (swallowIOException) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/scheduler/metrics/metric_recorder.go
bufferCh chan *metric // if bufferSize is reached, incoming metrics will be discarded. bufferSize int // how often the recorder runs to flush the metrics. interval time.Duration // stopCh is used to stop the goroutine which periodically flushes metrics. stopCh <-chan struct{} // IsStoppedCh indicates whether the goroutine is stopped. It's used in tests only to make sure
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 16 07:27:08 UTC 2023 - 4.4K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
} func (wr outerWithCloseNotifyAndFlush) Flush() { if flusher, ok := wr.UserProvidedDecorator.(http.Flusher); ok { flusher.Flush() return } wr.InnerCloseNotifierFlusher.Flush() } //lint:file-ignore SA1019 Keep supporting deprecated http.CloseNotifier var _ http.CloseNotifier = outerWithCloseNotifyFlushAndHijack{} var _ http.Flusher = outerWithCloseNotifyFlushAndHijack{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Flushables.java
* method * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws * an {@code IOException}. * @see Closeables#close */ public static void flush(Flushable flushable, boolean swallowIOException) throws IOException { try { flushable.flush(); } catch (IOException e) { if (swallowIOException) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go
counter *counter } func (fw *fakeResponseWriterDecorator) Unwrap() http.ResponseWriter { return fw.ResponseWriter } func (fw *fakeResponseWriterDecorator) Flush() { if fw.counter != nil { fw.counter.FlushInvoked++ } fw.ResponseWriter.(http.Flusher).Flush() } func (fw *fakeResponseWriterDecorator) Hijack() (net.Conn, *bufio.ReadWriter, error) { if fw.counter != nil { fw.counter.HijackInvoked++ }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:53 UTC 2021 - 8.1K bytes - Viewed (0) -
src/net/http/httptest/recorder_test.go
check( hasStatus(200), hasContents("hi first"), hasFlush(false), hasHeader("Content-Type", "text/plain; charset=utf-8"), ), }, { "flush", func(w http.ResponseWriter, r *http.Request) { w.(http.Flusher).Flush() // also sends a 200 w.WriteHeader(201) }, check(hasStatus(200), hasFlush(true), hasContentLength(-1)), }, { "Content-Type detection",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 23:17:38 UTC 2022 - 9.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FlushablesTest.java
.when(mockFlushable) .flush(); } } // Flush the flushable using the Flushables, passing in the swallowException // parameter. expectThrown determines whether we expect an exception to // be thrown by Flushables.flush; private void doFlush(Flushable flushable, boolean swallowException, boolean expectThrown) throws IOException { try { Flushables.flush(flushable, swallowException);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.3K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
if err != nil { return } if len(mergeCh) == 0 { // Flush if nothing is queued w.(http.Flusher).Flush() } grid.PutByteBuffer(ev) case <-emptyEventTicker: if err := enc.Encode(struct{ Records []event.Event }{}); err != nil { return } w.(http.Flusher).Flush() case <-keepAliveTicker: if _, err := w.Write([]byte(" ")); err != nil { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0)