Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for acquireTime (0.23 sec)

  1. src/runtime/sema.go

    		return
    	}
    	s, t0, tailtime := root.dequeue(addr)
    	if s != nil {
    		root.nwait.Add(-1)
    	}
    	unlock(&root.lock)
    	if s != nil { // May be slow or even yield, so unlock first
    		acquiretime := s.acquiretime
    		if acquiretime != 0 {
    			// Charge contention that this (delayed) unlock caused.
    			// If there are N more goroutines waiting beyond the
    			// one that's waking up, charge their delay as well, so that
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/coordination/v1/generated.pb.go

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.AcquireTime == nil {
    				m.AcquireTime = &v1.MicroTime{}
    			}
    			if err := m.AcquireTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 24K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/coordination/v1beta1/generated.pb.go

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.AcquireTime == nil {
    				m.AcquireTime = &v1.MicroTime{}
    			}
    			if err := m.AcquireTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  4. pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go

    		}
    	}
    
    	// 3. We're going to try to update. The leaderElectionRecord is set to it's default
    	// here. Let's correct it before updating.
    	if le.IsLeader() {
    		leaderElectionRecord.AcquireTime = oldLeaderElectionRecord.AcquireTime
    		leaderElectionRecord.LeaderTransitions = oldLeaderElectionRecord.LeaderTransitions
    	} else {
    		leaderElectionRecord.LeaderTransitions = oldLeaderElectionRecord.LeaderTransitions + 1
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 24 04:04:42 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  5. pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

    			}
    			if test.expectSuccess != le.tryAcquireOrRenew(context.Background()) {
    				t.Errorf("unexpected result of tryAcquireOrRenew: [succeeded=%v]", !test.expectSuccess)
    			}
    
    			le.observedRecord.AcquireTime = metav1.Time{}
    			le.observedRecord.RenewTime = metav1.Time{}
    			if le.observedRecord.HolderIdentity != test.outHolder {
    				t.Errorf("expected holder:\n\t%+v\ngot:\n\t%+v", test.outHolder, le.observedRecord.HolderIdentity)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 23 16:39:43 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  6. src/runtime/runtime2.go

    	// For channels, waitlink is only accessed by g.
    	// For semaphores, all fields (including the ones above)
    	// are only accessed when holding a semaRoot lock.
    
    	acquiretime int64
    	releasetime int64
    	ticket      uint32
    
    	// isSelect indicates g is participating in a select, so
    	// g.selectDone must be CAS'd to win the wake-up race.
    	isSelect bool
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  7. src/runtime/export_test.go

    type SemTable struct {
    	semTable
    }
    
    // Enqueue simulates enqueuing a waiter for a semaphore (or lock) at addr.
    func (t *SemTable) Enqueue(addr *uint32) {
    	s := acquireSudog()
    	s.releasetime = 0
    	s.acquiretime = 0
    	s.ticket = 0
    	t.semTable.rootFor(addr).queue(addr, s, false)
    }
    
    // Dequeue simulates dequeuing a waiter for a semaphore (or lock) at addr.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
Back to top