- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 263 for flushed (0.32 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* `HttpURLConnection` who flushes more bytes to the output stream than the connection's write * window will block. * * Zero [byteCount] writes are not subject to flow control and will not block. The only use case * for zero [byteCount] is closing a flushed output stream. */ @Throws(IOException::class) fun writeData( streamId: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:52:29 UTC 2024 - 48.6K bytes - Viewed (0) -
src/bufio/bufio_test.go
w.Reset(&buf2) // and not flushed w.WriteString("bar") w.Flush() if buf1.String() != "" { t.Errorf("buf1 = %q; want empty", buf1.String()) } if buf2.String() != "bar" { t.Errorf("buf2 = %q; want bar", buf2.String()) } *w = Writer{} // zero out the Writer w.Reset(&buf3) // and not flushed w.WriteString("bar") w.Flush() if buf1.String() != "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 10 18:56:01 UTC 2023 - 51.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
natChains.Write(utiliptables.MakeChainLine(chain)) // flush natRules.Write("-X", chainString) // delete } } // Hunt for service and endpoint chains. for chain := range existingNATChains { chainString := string(chain) if isServiceChainName(chainString) { natChains.Write(utiliptables.MakeChainLine(chain)) // flush natRules.Write("-X", chainString) // delete }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
{bucketNames[0], objectNames[0], uploadIDs[0], inputParts[3].parts, s3MD5, nil, true}, // The other parts will be flushed after a successful CompletePart (Test number 18). // the case above successfully completes CompleteMultipartUpload, the remaining Parts will be flushed. // Expecting to fail with Invalid UploadID.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
// have been executed. Note that "execution" here refers to kernel execution / // scheduling of copies, etc. Similar to sync execution, it doesn't guarantee // that lower level device queues (like GPU streams) have been flushed. // // This call may not block for execution of ops enqueued concurrently with this // call. TF_CAPI_EXPORT extern void TFE_ExecutorWaitForAllPendingNodes( TFE_Executor*, TF_Status* status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
// Cause the size to grow to 12 should evict 'A'. set("c", "c", "c") cache.flush() assertThat(cache.size()).isEqualTo(8) assertAbsent("a") assertValue("b", "bb", "bbbb") assertValue("c", "c", "c") // Causing the size to grow to 10 should evict nothing. set("d", "d", "d") cache.flush() assertThat(cache.size()).isEqualTo(10) assertAbsent("a")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
src/net/http/server.go
n += n0 if err != nil || n0 < sniffLen { return n, err } } w.w.Flush() // get rid of any previous writes w.cw.flush() // make sure Header is written; flush data to rwc // Now that cw has been flushed, its chunking field is guaranteed initialized. if !w.cw.chunking && w.bodyAllowed() { n0, err := rf.ReadFrom(src) n += n0 w.written += n0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/emoji.go
"flight_departure": "\U0001f6eb", "flipper": "\U0001f42c", "floppy_disk": "\U0001f4be", "flower_playing_cards": "\U0001f3b4", "flushed": "\U0001f633", "fly": "\U0001fab0", "flying_disc": "\U0001f94f", "flying_saucer": "\U0001f6f8",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 107.7K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi_util.go
} } // Flush any multipath device maps for mpathDevice := range mpathDevices { _, err = c.exec.Command("multipath", "-f", mpathDevice).CombinedOutput() if err != nil { klog.Warningf("Warning: Failed to flush multipath device map: %s\nError: %v", mpathDevice, err) // Fall through -- keep deleting the block devices } klog.V(4).Infof("Flushed multipath device: %s", mpathDevice) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0)