Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 115 for flushed (0.15 sec)

  1. src/runtime/mcache.go

    	// to avoid spilling mark bits into the *next* GC cycle.
    	sg := mheap_.sweepgen
    	flushGen := c.flushGen.Load()
    	if flushGen == sg {
    		return
    	} else if flushGen != sg-2 {
    		println("bad flushGen", flushGen, "in prepareForSweep; sweepgen", sg)
    		throw("bad flushGen")
    	}
    	c.releaseAll()
    	stackcache_clear(c)
    	c.flushGen.Store(mheap_.sweepgen) // Synchronizes with gcStart
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. src/text/tabwriter/tabwriter.go

    // complete for formatting purposes.
    func (b *Writer) Flush() error {
    	return b.flush()
    }
    
    // flush is the internal version of Flush, with a named return value which we
    // don't want to expose.
    func (b *Writer) flush() (err error) {
    	defer b.handlePanic(&err, "Flush")
    	b.flushNoDefers()
    	return nil
    }
    
    // flushNoDefers is like flush, but without a deferred handlePanic call. This
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Feb 29 16:46:34 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. internal/logger/logrotate.go

    // Write is blocking otherwise.
    func (w *Writer) Write(p []byte) (n int, err error) {
    	return w.pw.Write(p)
    }
    
    // Close closes the writer.
    // Any accepted writes will be flushed. Any new writes will be rejected.
    // Once Close() exits, files are synchronized to disk.
    func (w *Writer) Close() error {
    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. src/runtime/tracebuf.go

    //
    // Returns whether the buffer was flushed.
    func (w traceWriter) ensure(maxSize int) (traceWriter, bool) {
    	refill := w.traceBuf == nil || !w.available(maxSize)
    	if refill {
    		w = w.refill(traceNoExperiment)
    	}
    	return w, refill
    }
    
    // flush puts w.traceBuf on the queue of full buffers.
    func (w traceWriter) flush() traceWriter {
    	systemstack(func() {
    		lock(&trace.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. src/runtime/mwbbuf.go

    	// un-shaded stacks and flush after each stack scan.
    	gcw := &pp.gcw
    	pos := 0
    	for _, ptr := range ptrs {
    		if ptr < minLegalPointer {
    			// nil pointers are very common, especially
    			// for the "old" values. Filter out these and
    			// other "obvious" non-heap pointers ASAP.
    			//
    			// TODO: Should we filter out nils in the fast
    			// path to reduce the rate of flushes?
    			continue
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. src/runtime/mgc.go

    		trace.GCStart()
    		traceRelease(trace)
    	}
    
    	// Check that all Ps have finished deferred mcache flushes.
    	for _, p := range allp {
    		if fg := p.mcache.flushGen.Load(); fg != mheap_.sweepgen {
    			println("runtime: p", p.id, "flushGen", fg, "!= sweepgen", mheap_.sweepgen)
    			throw("p mcache not flushed")
    		}
    	}
    
    	gcBgMarkStartWorkers()
    
    	systemstack(gcResetMarkState)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
Back to top