Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 156 for sweeper (0.24 sec)

  1. cmd/tier-sweeper.go

    			ObjName:   os.RemoteObject,
    			VersionID: os.TransitionVersionID,
    			TierName:  os.TransitionTier,
    		}, true
    	}
    	return jentry{}, false
    }
    
    // Sweep removes the transitioned object if it's no longer referred to.
    func (os *objSweeper) Sweep() {
    	if je, ok := os.shouldRemoveRemoteObject(); ok {
    		globalExpiryState.enqueueTierJournalEntry(je)
    	}
    }
    
    type jentry struct {
    	ObjName   string
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. src/runtime/mgcsweep.go

    	// The span must be in our exclusive ownership until we update sweepgen,
    	// check for potential races.
    	if state := s.state.get(); state != mSpanInUse || s.sweepgen != sweepgen-1 {
    		print("mspan.sweep: state=", state, " sweepgen=", s.sweepgen, " mheap.sweepgen=", sweepgen, "\n")
    		throw("mspan.sweep: bad span state after sweep")
    	}
    	if s.sweepgen == sweepgen+1 || s.sweepgen == sweepgen+3 {
    		throw("swept cached span")
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:52:18 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  3. src/runtime/mcentral.go

    	}
    
    	sg := mheap_.sweepgen
    	stale := s.sweepgen == sg+1
    
    	// Fix up sweepgen.
    	if stale {
    		// Span was cached before sweep began. It's our
    		// responsibility to sweep it.
    		//
    		// Set sweepgen to indicate it's not cached but needs
    		// sweeping and can't be allocated from. sweep will
    		// set s.sweepgen to indicate s is swept.
    		atomic.Store(&s.sweepgen, sg-1)
    	} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. src/runtime/mfixalloc.go

    // Since assignments to mlink.next will result in a write barrier being performed
    // this cannot be used by some of the internal GC structures. For example when
    // the sweeper is placing an unmarked object on the free list it does not want the
    // write barrier to be called since that could result in the object being reachable.
    type mlink struct {
    	_    sys.NotInHeap
    	next *mlink
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 24 20:28:25 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. src/runtime/mcache.go

    	// visible to the background sweeper.
    	mheap_.central[spc].mcentral.fullSwept(mheap_.sweepgen).push(s)
    	s.limit = s.base() + size
    	s.initHeapBits(false)
    	return s
    }
    
    func (c *mcache) releaseAll() {
    	// Take this opportunity to flush scanAlloc.
    	scanAlloc := int64(c.scanAlloc)
    	c.scanAlloc = 0
    
    	sg := mheap_.sweepgen
    	dHeapLive := int64(0)
    	for i := range c.alloc {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. maven-core/src/test/resources/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    static String lowercaseFirstLetter(String); public static String addAndDeHump(String); } org/codehaus/plexus/util/SweeperPool$Sweeper.class package org.codehaus.plexus.util; synchronized class SweeperPool$Sweeper implements Runnable { private final transient SweeperPool pool; private transient boolean service; private final transient int sweepInterval; public void SweeperPool$Sweeper(SweeperPool, int); public void run(); public synchronized void start(); public synchronized void stop(); private final void...
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Oct 16 20:15:40 UTC 2007
    - 164.6K bytes
    - Viewed (0)
  7. src/runtime/arena.go

    	// Set up the range for allocation.
    	s.userArenaChunkFree = makeAddrRange(base, base+s.elemsize)
    
    	// Put the large span in the mcentral swept list so that it's
    	// visible to the background sweeper.
    	h.central[spc].mcentral.fullSwept(h.sweepgen).push(s)
    
    	// Set up an allocation header. Avoid write barriers here because this type
    	// is not a real type, and it exists in an invalid location.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:44:56 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  8. maven-api-impl/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    static String lowercaseFirstLetter(String); public static String addAndDeHump(String); } org/codehaus/plexus/util/SweeperPool$Sweeper.class package org.codehaus.plexus.util; synchronized class SweeperPool$Sweeper implements Runnable { private final transient SweeperPool pool; private transient boolean service; private final transient int sweepInterval; public void SweeperPool$Sweeper(SweeperPool, int); public void run(); public synchronized void start(); public synchronized void stop(); private final void...
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Thu May 02 15:10:38 UTC 2024
    - 164.6K bytes
    - Viewed (0)
  9. maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-utils/1.0.4/plexus-utils-1.0.4.jar

    , IllegalStateExceptio; public abstract void flush() throws java.io.IOException; } org/codehaus/plexus/util/SweeperPool$Sweeper.class package org.codehaus.plexus.util; synchronized class SweeperPool$Sweeper implements Runnable { private final transient SweeperPool pool; private transient boolean service; private final transient int sweepInterval; public void SweeperPool$Sweeper(SweeperPool, int); public void run(); public synchronized void start(); public synchronized void stop(); private final void...
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Sun Oct 02 08:41:25 UTC 2022
    - 160K bytes
    - Viewed (0)
  10. src/runtime/mgc.go

    		mProf_Flush()
    		return true
    	}
    
    	// Background sweep.
    	lock(&sweep.lock)
    	if sweep.parked {
    		sweep.parked = false
    		ready(sweep.g, 0, true)
    	}
    	unlock(&sweep.lock)
    	return false
    }
    
    // gcResetMarkState resets global state prior to marking (concurrent
    // or STW) and resets the stack scan state of all Gs.
    //
    // This is safe to do without the world stopped because any Gs created
    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