Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 980 for waitlink (0.14 sec)

  1. src/runtime/select.go

    	// We singly-linked up the SudoGs in lock order.
    	casi = -1
    	cas = nil
    	caseSuccess = false
    	sglist = gp.waiting
    	// Clear all elem before unlinking from gp.waiting.
    	for sg1 := gp.waiting; sg1 != nil; sg1 = sg1.waitlink {
    		sg1.isSelect = false
    		sg1.elem = nil
    		sg1.c = nil
    	}
    	gp.waiting = nil
    
    	for _, casei := range lockorder {
    		k = &scases[casei]
    		if k.c.timer != nil {
    			unblockTimerChan(k.c)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. src/runtime/sema.go

    				t.next = nil
    				t.waittail = nil
    			} else {
    				// Add s to end of t's wait list.
    				if t.waittail == nil {
    					t.waitlink = s
    				} else {
    					t.waittail.waitlink = s
    				}
    				t.waittail = s
    				s.waitlink = nil
    				if t.waiters+1 != 0 {
    					t.waiters++
    				}
    			}
    			return
    		}
    		last = t
    		if uintptr(unsafe.Pointer(addr)) < uintptr(t.elem) {
    			pt = &t.prev
    		} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. src/runtime/stack.go

    	// might be in the stack.
    	for s := gp.waiting; s != nil; s = s.waitlink {
    		adjustpointer(adjinfo, unsafe.Pointer(&s.elem))
    	}
    }
    
    func fillstack(stk stack, b byte) {
    	for p := stk.lo; p < stk.hi; p++ {
    		*(*byte)(unsafe.Pointer(p)) = b
    	}
    }
    
    func findsghi(gp *g, stk stack) uintptr {
    	var sghi uintptr
    	for sg := gp.waiting; sg != nil; sg = sg.waitlink {
    		p := uintptr(sg.elem) + uintptr(sg.c.elemsize)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  4. src/runtime/chan.go

    	mysg.releasetime = 0
    	if t0 != 0 {
    		mysg.releasetime = -1
    	}
    	// No stack splits between assigning elem and enqueuing mysg
    	// on gp.waiting where copystack can find it.
    	mysg.elem = ep
    	mysg.waitlink = nil
    	mysg.g = gp
    	mysg.isSelect = false
    	mysg.c = c
    	gp.waiting = mysg
    	gp.param = nil
    	c.sendq.enqueue(mysg)
    	// Signal to anyone trying to shrink our stack that we're about
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  5. src/runtime/runtime2.go

    	success bool
    
    	// waiters is a count of semaRoot waiting list other than head of list,
    	// clamped to a uint16 to fit in unused space.
    	// Only meaningful at the head of the list.
    	// (If we wanted to be overly clever, we could store a high 16 bits
    	// in the second entry in the list.)
    	waiters uint16
    
    	parent   *sudog // semaRoot binary tree
    	waitlink *sudog // g.waiting list or semaRoot
    	waittail *sudog // semaRoot
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  6. src/runtime/proc.go

    	}
    	if s.next != nil {
    		throw("runtime: sudog with non-nil next")
    	}
    	if s.prev != nil {
    		throw("runtime: sudog with non-nil prev")
    	}
    	if s.waitlink != nil {
    		throw("runtime: sudog with non-nil waitlink")
    	}
    	if s.c != nil {
    		throw("runtime: sudog with non-nil c")
    	}
    	gp := getg()
    	if gp.param != nil {
    		throw("runtime: releaseSudog with non-nil gp.param")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  7. cmd/background-heal-ops.go

    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    	const waitTick = 100 * time.Millisecond
    
    	tmpMaxWait := maxWait
    
    	for currentIO() >= maxIO {
    		if tmpMaxWait > 0 {
    			if tmpMaxWait < waitTick {
    				time.Sleep(tmpMaxWait)
    				return
    			}
    			time.Sleep(waitTick)
    			tmpMaxWait -= waitTick
    		}
    		if tmpMaxWait <= 0 {
    			return
    		}
    	}
    }
    
    func currentHTTPIO() int {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go

    }
    
    // conditionalProgressRequester will request progress notification if there
    // is a request waiting for watch cache to be fresh.
    type conditionalProgressRequester struct {
    	clock                TickerFactory
    	requestWatchProgress WatchProgressRequester
    	contextMetadata      metadata.MD
    
    	mux     sync.Mutex
    	cond    *sync.Cond
    	waiting int
    	stopped bool
    }
    
    func (pr *conditionalProgressRequester) Run(stopCh <-chan struct{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 09:56:38 UTC 2024
    - 3K bytes
    - Viewed (0)
  9. testing/internal-integ-testing/src/test/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServerTest.groovy

            e.causes.message == [
                'Failed to handle GET /a due to a timeout waiting to be released. Waiting for 0 further requests, received [GET /a, GET /b], released [], not yet received [GET /c]',
                'Failed to handle GET /b due to a timeout waiting to be released. Waiting for 0 further requests, received [GET /a, GET /b], released [], not yet received [GET /c]'
            ]
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  10. src/runtime/start_line_amd64_test.go

    // copies of this function.
    func TestStartLineAsm(t *testing.T) {
    	startlinetest.CallerStartLine = callerStartLine
    
    	const wantLine = 23
    	got := startlinetest.AsmFunc()
    	if got != wantLine {
    		t.Errorf("start line got %d want %d", got, wantLine)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Dec 22 04:34:33 UTC 2022
    - 647 bytes
    - Viewed (0)
Back to top