- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 263 for flushed (0.28 sec)
-
src/runtime/mcheckmark.go
clear(bitmap.b[:]) } } // Enable checkmarking. useCheckmark = true } // endCheckmarks ends the checkmarks phase. func endCheckmarks() { if gcMarkWorkAvailable(nil) { throw("GC work not flushed") } useCheckmark = false } // setCheckmark throws if marking object is a checkmarks violation, // and otherwise sets obj's checkmark. It returns true if obj was // already checkmarked.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.8K bytes - Viewed (0) -
src/runtime/trace.go
// will be flushed in time for the new generation) or it will have flushed its // buffers before we snapshotted it to begin with. lock(&sched.lock) mToFlush := allm for mp := mToFlush; mp != nil; mp = mp.alllink { mp.trace.link = mp.alllink } for mp := sched.freem; mp != nil; mp = mp.freelink { mp.trace.link = mToFlush mToFlush = mp } unlock(&sched.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/util/documentation.go
// No trailing space is added to the flushed paragraph, // so that no empty line is placed between the old and the new paragraphs (a simple line break) output = append(output, strings.Join(paragraph, " ")) paragraph = []string{} } } } // The last paragraph is always unflushed, so flush it. // We don't add a trailing newline character, so that we won't have to strip the output.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 24 11:40:55 UTC 2019 - 4.4K bytes - Viewed (0) -
src/mime/quotedprintable/writer.go
w.line[w.i] = '=' w.i++ return w.insertCRLF() } func (w *Writer) insertCRLF() error { w.line[w.i] = '\r' w.line[w.i+1] = '\n' w.i += 2 return w.flush() } func (w *Writer) flush() error { if _, err := w.w.Write(w.line[:w.i]); err != nil { return err } w.i = 0 return nil } func isWhitespace(b byte) bool { return b == ' ' || b == '\t'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
operator/pkg/metrics/monitoring.go
"legacy_path_translation_total", "Number of times a legacy API path is translated", ) // CacheFlushTotal counts number of cache flushes. CacheFlushTotal = monitoring.NewSum( "cache_flush_total", "number of times operator cache was flushed", ) ) func init() { initOperatorCrdResourceMetrics() } func IncrementReconcileRequest(reason string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/AbstractDaemonLifecycleSpec.groovy
} void doDaemonContext(gradleHandle, Closure assertions) { // poll here since even though the daemon has been marked as busy in the registry, the context may not have been // flushed to the log yet. DaemonContext context poll(5) { context = DaemonContextParser.parseFromString(gradleHandle.standardOutput, GradleVersion.current()) } context.with(assertions)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:32:55 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/volume/util/fs/fs_windows_test.go
if _, err = tmpfile2.WriteString("just for testing"); err != nil { t.Fatalf("TestDiskUsage failed: %s", err.Error()) } // File creation is not atomic. If we're calculating the DiskUsage before the data is flushed, // we'd get zeroes for sizes, and fail with this error: // TestDiskUsage failed: expected 0, got -1 tmpfile1.Sync() tmpfile2.Sync() dirInfo1, err := os.Lstat(dir1) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/volume/fc/fc_util.go
out, err := exec.Command("multipath", "-f", dmDevice).CombinedOutput() if err != nil { return fmt.Errorf("failed to flush multipath device %s: %s\n%s", dmDevice, err, string(out)) } klog.V(4).Infof("Flushed multipath device: %s", dmDevice) return nil } func checkPathExists(path string) (bool, error) { if pathExists, pathErr := mount.PathExists(path); pathErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.8K bytes - Viewed (0) -
src/cmd/gofmt/internal.go
// into a function body. This handles expressions too. // Insert using a ';', not a newline, so that the line numbers // in fsrc match the ones in src. Add an extra '\n' before the '}' // to make sure comments are flushed before the '}'. fsrc := append(append([]byte("package p; func _() {"), src...), '\n', '\n', '}') file, err = parser.ParseFile(fset, filename, fsrc, parserMode) if err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 28 14:23:08 UTC 2020 - 5K bytes - Viewed (0) -
src/go/format/internal.go
// into a function body. This handles expressions too. // Insert using a ';', not a newline, so that the line numbers // in fsrc match the ones in src. Add an extra '\n' before the '}' // to make sure comments are flushed before the '}'. fsrc := append(append([]byte("package p; func _() {"), src...), '\n', '\n', '}') file, err = parser.ParseFile(fset, filename, fsrc, parserMode) if err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 28 14:23:08 UTC 2020 - 5K bytes - Viewed (0)