Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 244 for ROUND (0.05 sec)

  1. pkg/kubelet/preemption/preemption.go

    func getPodsToPreemptByDistance(pods []*v1.Pod, requirements admissionRequirementList) ([]*v1.Pod, error) {
    	podsToEvict := []*v1.Pod{}
    	// evict pods by shortest distance from remaining requirements, updating requirements every round.
    	for len(requirements) > 0 {
    		if len(pods) == 0 {
    			return nil, fmt.Errorf("no set of running pods found to reclaim resources: %v", requirements.toString())
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 16:53:19 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  2. src/archive/tar/writer.go

    			tw.hdr.Typeflag = TypeReg
    		}
    	}
    
    	// Round ModTime and ignore AccessTime and ChangeTime unless
    	// the format is explicitly chosen.
    	// This ensures nominal usage of WriteHeader (without specifying the format)
    	// does not always result in the PAX format being chosen, which
    	// causes a 1KiB increase to every header.
    	if tw.hdr.Format == FormatUnknown {
    		tw.hdr.ModTime = tw.hdr.ModTime.Round(time.Second)
    		tw.hdr.AccessTime = time.Time{}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

          )
    
        assertFailsWith<EOFException> {
          parts.nextPart()
        }
      }
    
      /** Confirm that [MultipartBody] and [MultipartReader] can work together. */
      @Test fun `multipart round trip`() {
        val body =
          MultipartBody.Builder("boundary")
            .setType(MultipartBody.PARALLEL)
            .addPart("Quick".toRequestBody("text/plain".toMediaType()))
            .addFormDataPart("color", "Brown")
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go

    	if deadline, hasDeadline := ctx.Deadline(); hasDeadline {
    		// compute the timeout
    		if timeout := time.Until(deadline); timeout > 0 {
    			// if it's not an even number of seconds, round up to the nearest second
    			if truncated := timeout.Truncate(time.Second); truncated != timeout {
    				timeout = truncated + time.Second
    			}
    			// set the timeout
    			r.Timeout(timeout)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 20:24:12 UTC 2023
    - 13K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/podtopologyspread/scoring.go

    				pair := topologyPair{key: c.TopologyKey, value: tpVal}
    				cnt = *s.TopologyPairToPodCounts[pair]
    			}
    			score += scoreForCount(cnt, c.MaxSkew, s.TopologyNormalizingWeight[i])
    		}
    	}
    	return int64(math.Round(score)), nil
    }
    
    // NormalizeScore invoked after scoring all nodes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/version/version_test.go

    	version    string
    	unparsed   string
    	equalsPrev bool
    }
    
    func testOne(v *Version, item, prev testItem) error {
    	str := v.String()
    	if item.unparsed == "" {
    		if str != item.version {
    			return fmt.Errorf("bad round-trip: %q -> %q", item.version, str)
    		}
    	} else {
    		if str != item.unparsed {
    			return fmt.Errorf("bad unparse: %q -> %q, expected %q", item.version, str, item.unparsed)
    		}
    	}
    
    	if prev.version != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 18 19:25:29 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  7. src/encoding/json/decode.go

    // can be set to nil.
    func indirect(v reflect.Value, decodingNull bool) (Unmarshaler, encoding.TextUnmarshaler, reflect.Value) {
    	// Issue #24153 indicates that it is generally not a guaranteed property
    	// that you may round-trip a reflect.Value by calling Value.Addr().Elem()
    	// and expect the value to still be settable for values derived from
    	// unexported embedded struct fields.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:55 UTC 2024
    - 35.3K bytes
    - Viewed (0)
  8. pkg/controller/cronjob/utils.go

    	// minute - 59, hour - 23, dom - 31, month - 2, and dow is optional, clearly 31 is invalid
    	// In this case the timeBetweenTwoSchedules will be 0, and we error out the invalid schedule
    	timeBetweenTwoSchedules := int64(t2.Sub(t1).Round(time.Second).Seconds())
    	if timeBetweenTwoSchedules < 1 {
    		return earliestTime, nil, missedSchedules, fmt.Errorf("time difference between two schedules is less than 1 second")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity.go

    	// of an amount.  Arguably, this should be inf.RoundHalfUp (normal rounding), but that would have
    	// the side effect of rounding values < .5n to zero.
    	if v, ok := amount.Unscaled(); v != int64(0) || !ok {
    		amount.Round(amount, Nano.infScale(), inf.RoundUp)
    	}
    
    	// The max is just a simple cap.
    	// TODO: this prevents accumulating quantities greater than int64, for instance quota across a cluster
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  10. pkg/kubelet/images/image_gc_manager_test.go

    	require.NoError(t, err)
    	require.Equal(t, len(images), 1)
    	// Simulate pod having just used this image, but having been GC'd
    	images[0].lastUsed = fakeClock.Now()
    
    	// First GC round should not GC remaining image, as it was used too recently.
    	assert := assert.New(t)
    	oldStartTime := fakeClock.Now()
    	images, err = manager.freeOldImages(ctx, images, oldStartTime, oldStartTime)
    	require.NoError(t, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 15:38:20 UTC 2024
    - 29.2K bytes
    - Viewed (0)
Back to top