Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 111 for idempotent (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

            // 408's are rare in practice, but some servers like HAProxy use this response code. The
            // spec says that we may repeat the request without modifications. Modern browsers also
            // repeat the request (even non-idempotent ones.)
            if (!client.retryOnConnectionFailure) {
              // The application layer has directed us not to retry the request.
              return null
            }
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time_test.go

    		}
    		time := Time{}
    		if err := time.Unmarshal(data); err != nil {
    			t.Fatalf("Failed to unmarshal output: '%v': %v", input, err)
    		}
    		if !reflect.DeepEqual(input, time) {
    			t.Errorf("Marshal->Unmarshal is not idempotent: '%v' vs '%v'", input, time)
    		}
    	}
    }
    
    func TestTimeEqual(t *testing.T) {
    	t1 := NewTime(time.Now())
    	cases := []struct {
    		name   string
    		x      *Time
    		y      *Time
    		result bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:09 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. src/runtime/pinner.go

    			// resilient to an empty pinner being finalized, which is done
    			// by checking p.refs' length.
    			SetFinalizer(p.pinner, func(i *pinner) {
    				if len(i.refs) != 0 {
    					i.unpin() // only required to make the test idempotent
    					pinnerLeakPanic()
    				}
    			})
    		}
    	}
    	ptr := pinnerGetPtr(&pointer)
    	if setPinned(ptr, true) {
    		p.refs = append(p.refs, ptr)
    	}
    }
    
    // Unpin unpins all pinned objects of the [Pinner].
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 14:29:45 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. src/cmd/go/main.go

    	telemetry.Start() // Open the telemetry counter file so counters can be written to it.
    	handleChdirFlag()
    	toolchain.Select()
    
    	telemetry.StartWithUpload() // Run the upload process. Opening the counter file is idempotent.
    	flag.Usage = base.Usage
    	flag.Parse()
    	telemetry.Inc("go/invocations")
    	telemetry.CountFlags("go/flag:", *flag.CommandLine)
    
    	args := flag.Args()
    	if len(args) < 1 {
    		base.Usage()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:09:11 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/Range.java

       *
       * <p>The intersection exists if and only if the two ranges are {@linkplain #isConnected
       * connected}.
       *
       * <p>The intersection operation is commutative, associative and idempotent, and its identity
       * element is {@link Range#all}).
       *
       * @throws IllegalArgumentException if {@code isConnected(connectedRange)} is {@code false}
       */
      public Range<C> intersection(Range<C> connectedRange) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  6. pkg/kubelet/pod/pod_manager.go

    	pod, ok := pm.podByFullName[podFullName]
    	return pod, ok
    }
    
    func (pm *basicManager) TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID {
    	// It is safe to type convert to a resolved UID because type conversion is idempotent.
    	if uid == "" {
    		return kubetypes.ResolvedPodUID(uid)
    	}
    
    	pm.lock.RLock()
    	defer pm.lock.RUnlock()
    	if translated, ok := pm.translationByUID[kubetypes.MirrorPodUID(uid)]; ok {
    		return translated
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Range.java

       *
       * <p>The intersection exists if and only if the two ranges are {@linkplain #isConnected
       * connected}.
       *
       * <p>The intersection operation is commutative, associative and idempotent, and its identity
       * element is {@link Range#all}).
       *
       * @throws IllegalArgumentException if {@code isConnected(connectedRange)} is {@code false}
       */
      public Range<C> intersection(Range<C> connectedRange) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time_test.go

    		time := MicroTime{}
    		if err := time.Unmarshal(data); err != nil {
    			t.Fatalf("Failed to unmarshal output: '%v': %v", input, err)
    		}
    		if !reflect.DeepEqual(input, time) {
    			t.Errorf("Marshal->Unmarshal is not idempotent: '%v' vs '%v'", input, time)
    		}
    	}
    }
    
    func TestMicroTimeEqual(t *testing.T) {
    	t1 := NewMicroTime(time.Now())
    	cases := []struct {
    		name   string
    		x      *MicroTime
    		y      *MicroTime
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/syntax/parser_test.go

    	"path/filepath"
    	"regexp"
    	"runtime"
    	"strings"
    	"sync"
    	"testing"
    	"time"
    )
    
    var (
    	fast   = flag.Bool("fast", false, "parse package files in parallel")
    	verify = flag.Bool("verify", false, "verify idempotent printing")
    	src_   = flag.String("src", "parser.go", "source file to parse")
    	skip   = flag.String("skip", "", "files matching this regular expression are skipped by TestStdLib")
    )
    
    func TestParse(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 14 16:30:19 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    		return framework.AsStatus(err)
    	}
    	logger.V(5).Info("Success binding volumes for pod", "pod", klog.KObj(pod))
    	return nil
    }
    
    // Unreserve clears assumed PV and PVC cache.
    // It's idempotent, and does nothing if no cache found for the given pod.
    func (pl *VolumeBinding) Unreserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) {
    	s, err := getStateData(cs)
    	if err != nil {
    		return
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
Back to top