Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 55 for roundTrip (0.19 sec)

  1. internal/grid/muxclient.go

    		LastPong:           time.Now().UnixNano(),
    		BaseFlags:          parent.baseFlags,
    		clientPingInterval: parent.clientPingInterval,
    	}
    }
    
    // roundtrip performs a roundtrip, returning the first response.
    // This cannot be used concurrently.
    func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) {
    	if m.init {
    		return nil, errors.New("mux client already used")
    	}
    	m.init = true
    	m.singleResp = true
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. pkg/api/testing/serialization_test.go

    	"reflect"
    	"testing"
    
    	"github.com/google/go-cmp/cmp"
    
    	appsv1 "k8s.io/api/apps/v1"
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/apitesting/fuzzer"
    	"k8s.io/apimachinery/pkg/api/apitesting/roundtrip"
    	apiequality "k8s.io/apimachinery/pkg/api/equality"
    	"k8s.io/apimachinery/pkg/api/meta"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/conversion"
    	"k8s.io/apimachinery/pkg/runtime"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  3. pkg/api/testing/defaulting_test.go

    	"sort"
    	"testing"
    
    	"github.com/google/go-cmp/cmp"
    	fuzz "github.com/google/gofuzz"
    
    	apiv1 "k8s.io/api/core/v1"
    	extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
    	"k8s.io/apimachinery/pkg/api/apitesting/roundtrip"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/kubernetes/pkg/api/legacyscheme"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  4. internal/grid/handlers.go

    }
    
    // RoundTripper provides an interface for type roundtrip serialization.
    type RoundTripper interface {
    	msgp.Unmarshaler
    	msgp.Marshaler
    	msgp.Sizer
    
    	comparable
    }
    
    // SingleHandler is a type safe handler for single roundtrip requests.
    type SingleHandler[Req, Resp RoundTripper] struct {
    	id            HandlerID
    	sharedResp    bool
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  5. src/net/http/clientserver_test.go

    	}))
    
    	// Set ExpectContinueTimeout non-zero so RoundTrip won't try to write it.
    	cst.tr.ExpectContinueTimeout = 10 * time.Second
    
    	req, err := NewRequest("POST", cst.ts.URL, testErrorReader{t})
    	if err != nil {
    		t.Fatal(err)
    	}
    	req.ContentLength = 0 // so transport is tempted to sniff it
    	req.Header.Set("Expect", "100-continue")
    	res, err := cst.tr.RoundTrip(req)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 46.6K bytes
    - Viewed (0)
  6. src/net/http/httputil/reverseproxy.go

    		outreq.Body = nil // Issue 16036: nil Body for http.Transport retries
    	}
    	if outreq.Body != nil {
    		// Reading from the request body after returning from a handler is not
    		// allowed, and the RoundTrip goroutine that reads the Body can outlive
    		// this handler. This can lead to a crash if the handler panics (see
    		// Issue 46866). Although calling Close doesn't guarantee there isn't
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 23:37:42 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go

    	}
    }
    
    type panicOnNonReuseTransport struct {
    	Transport   http.RoundTripper
    	gotConnSeen bool
    }
    
    func (t *panicOnNonReuseTransport) RoundTrip(req *http.Request) (*http.Response, error) {
    	return t.Transport.RoundTrip(req)
    }
    
    func (t *panicOnNonReuseTransport) GotConn(info httptrace.GotConnInfo) {
    	if !t.gotConnSeen {
    		t.gotConnSeen = true
    		return
    	}
    	if !info.Reused {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  8. src/math/big/ratconv_test.go

    			continue
    		}
    
    		// 2. Check f is best approximation to r.
    		if !checkIsBestApprox32(t, f, r) {
    			// Append context information.
    			t.Errorf("(input was %q)", input)
    		}
    
    		// 3. Check f->R->f roundtrip is non-lossy.
    		checkNonLossyRoundtrip32(t, f)
    
    		// 4. Check exactness using slow algorithm.
    		if wasExact := new(Rat).SetFloat64(float64(f)).Cmp(r) == 0; wasExact != exact {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 15 22:16:34 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  9. tensorflow/compiler/mlir/lite/tests/flatbuffer2mlir/constants_offset.mlir

    // RUN: flatbuffer_translate -mlir-to-tflite-flatbuffer --use-buffer-offset %s -o - | flatbuffer_translate --tflite-flatbuffer-to-mlir - -o - | FileCheck %s
    // Ensure constants roundtrip exactly
    
    func.func @bool() -> tensor<4xi1> {
      // CHECK-LABEL: @bool
      // CHECK: value = dense<[false, true, true, false]> : tensor<4xi1>
      %0 = "tfl.pseudo_const"() { value = dense<[false, true, true, false]> : tensor<4xi1> } : () -> tensor<4xi1>
      func.return %0 : tensor<4xi1>
    }
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 02 09:41:17 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/lite/tests/flatbuffer2mlir/constants.mlir

    // RUN: flatbuffer_translate -mlir-to-tflite-flatbuffer %s -o - | flatbuffer_translate --tflite-flatbuffer-to-mlir - -o - | FileCheck %s
    // Ensure constants roundtrip exactly
    
    func.func @bool() -> tensor<4xi1> {
      // CHECK-LABEL: @bool
      // CHECK: value = dense<[false, true, true, false]> : tensor<4xi1>
      %0 = "tfl.pseudo_const"() { value = dense<[false, true, true, false]> : tensor<4xi1> } : () -> tensor<4xi1>
      func.return %0 : tensor<4xi1>
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 02 09:41:17 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top