Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 502 for earliest (0.17 sec)

  1. src/cmd/vendor/golang.org/x/telemetry/internal/upload/reports.go

    			continue
    		}
    
    		if end.Before(thisInstant) {
    			expiry := end.Format(dateFormat)
    			countFiles[expiry] = append(countFiles[expiry], f)
    			if earliest[expiry].IsZero() || earliest[expiry].After(begin) {
    				earliest[expiry] = begin
    			}
    		}
    	}
    	for expiry, files := range countFiles {
    		if notNeeded(expiry, *todo) {
    			u.logger.Printf("Files for %s not needed, deleting %v", expiry, files)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 14:52:56 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. src/net/dial.go

    	}
    	return b
    }
    
    // deadline returns the earliest of:
    //   - now+Timeout
    //   - d.Deadline
    //   - the context's deadline
    //
    // Or zero, if none of Timeout, Deadline, or context's deadline is set.
    func (d *Dialer) deadline(ctx context.Context, now time.Time) (earliest time.Time) {
    	if d.Timeout != 0 { // including negative, for historical reasons
    		earliest = now.Add(d.Timeout)
    	}
    	if d, ok := ctx.Deadline(); ok {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt

     * task should not be executed again. Otherwise it returns a delay until the next execution.
     *
     * A task has at most one next execution. If the same task instance is scheduled multiple times, the
     * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and
     * those implied by the returned execution delay.
     *
     * Cancellation
     * ------------
     *
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. pkg/test/loadbalancersim/loadbalancer/edf.go

    // Pop implements heap.Interface for popping an item from the heap
    func (pq *priorityQueue) Pop() any {
    	old := *pq
    	n := len(old)
    	entry := old[n-1]
    	*pq = old[0 : n-1]
    	return entry
    }
    
    // EDF implements the Earliest Deadline First scheduling algorithm
    type EDF struct {
    	pq              *priorityQueue
    	currentIndex    int64
    	currentDeadline float64
    }
    
    // Add a new entry for load balance
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 20 19:13:32 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  5. pkg/test/loadbalancersim/timer/queue.go

    	q.mutex.Lock()
    	handlers := q.heap.advanceTo(time.Now())
    	q.mutex.Unlock()
    
    	// Call the expired timer handlers.
    	for _, h := range handlers {
    		h()
    	}
    
    	// Reset the timer based on the earliest deadline.
    	q.resetTimer()
    }
    
    type entry struct {
    	deadline time.Time
    	handler  func()
    	index    int
    }
    
    type timerHeap []*entry
    
    func (h timerHeap) peek() *entry {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 20 19:13:32 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  6. doc/godebug.md

    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    This setting may be removed in a future release, Go 1.27 at the earliest.
    
    Go 1.23 changed the mode bits reported by [`os.Lstat`](/pkg/os#Lstat) and [`os.Stat`](/pkg/os#Stat)
    for reparse points, which can be controlled with the `winsymlink` setting.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  7. src/cmd/cgo/internal/test/stubtest_linux_ppc64le.S

    //   TOC -> NOTOC (R2 is preserved, st_other==0): A special case where a call stub is not needed.
    
    // This test requires a binutils with power10 and ELFv2 1.5 support. This is earliest verified version.
    .if .gasversion. >= 23500
    
    // A function which does not guarantee R2 is preserved.
    // R2 is clobbered here to ensure the stubs preserve it.
    	.globl	notoc_nor2_func
    	.type	notoc_nor2_func, @function
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 22 15:06:17 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  8. pkg/scheduler/util/utils_test.go

    						Name: "pod2",
    					},
    					Spec: v1.PodSpec{
    						Priority: &priority,
    					},
    				},
    			},
    			expectedStartTime: &metav1.Time{Time: currentTime.Add(-time.Second)},
    		},
    		{
    			name: "Pod with earliest start time last in the list",
    			pods: []*v1.Pod{
    				newPriorityPodWithStartTime("pod1", 1, currentTime.Add(time.Second)),
    				newPriorityPodWithStartTime("pod2", 2, currentTime.Add(time.Second)),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 14.5K bytes
    - Viewed (0)
  9. pkg/scheduler/util/utils.go

    		return pod.Status.StartTime
    	}
    	// Assumed pods and bound pods that haven't started don't have a StartTime yet.
    	return &metav1.Time{Time: time.Now()}
    }
    
    // GetEarliestPodStartTime returns the earliest start time of all pods that
    // have the highest priority among all victims.
    func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time {
    	if len(victims.Pods) == 0 {
    		// should not reach here.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  10. src/cmd/trace/jsontrace.go

    			}
    			// This mode is goroutine-oriented.
    			opts.mode = traceviewer.ModeGoroutineOriented
    			opts.setTask(parsed, task)
    
    			// Pick the goroutine to orient ourselves around by just
    			// trying to pick the earliest event in the task that makes
    			// any sense. Though, we always want the start if that's there.
    			var firstEv *trace.Event
    			if task.Start != nil {
    				firstEv = task.Start
    			} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top