- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Req2 (0.04 sec)
-
src/test/java/jcifs/tests/OplockTests.java
SmbComNTCreateAndX req2 = new SmbComNTCreateAndX(sess.getConfig(), uncPath, flags, access, sharing, attrs, options, null); req2.addFlags0(0x2); // REQUEST_OPLOCK req2.setOverrideTimeout(1000); req2.setResponse(resp2); try { resp2 = tree.send(req2); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 6.1K bytes - Viewed (0) -
maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/RepositorySystemTest.java
req1.setArtifact(new DefaultArtifact("ut.simple:artifact:1.0")); req1.addRepository(newTestRepository()); ArtifactRequest req2 = new ArtifactRequest(); req2.setArtifact(new DefaultArtifact("ut.simple:artifact:zip:1.0")); req2.addRepository(newTestRepository()); ArtifactRequest req3 = new ArtifactRequest();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Apr 15 17:24:20 UTC 2023 - 9.2K bytes - Viewed (0) -
pilot/pkg/model/typed_xds_cache_test.go
test.SetForTest(t, &features.XDSCacheIndexClearInterval, 5*time.Millisecond) zeroTime := time.Time{} res := &discovery.Resource{Name: "test"} req1 := &PushRequest{Start: zeroTime.Add(time.Duration(1))} req2 := &PushRequest{Start: zeroTime.Add(time.Duration(2))} firstEntry := entry{ key: "key1", dependentTypes: []kind.Kind{kind.Service, kind.DestinationRule, kind.Gateway}, dependentConfigs: []ConfigHash{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 29 20:35:31 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
v1.ResourceMemory, v1.ResourceCPU, } for _, res := range priorityList { req1 := resource.GetResourceRequest(pod1, res) req2 := resource.GetResourceRequest(pod2, res) if req1 < req2 { return true } else if req1 > req2 { return false } } return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
@Test fun serverDisconnectsBeforeSecondRequestHttp1() { enableProtocol(Protocol.HTTP_1_1) server.enqueue(MockResponse(code = 200, body = "Req1")) server.enqueue(MockResponse(code = 200, body = "Req2")) val eventListener = object : EventListener() { var socket: SSLSocket? = null var closed = false override fun connectionAcquired( call: Call,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
counter.Add(1) cancel2() }() req2, idle2a := qs.StartRequest(ctx2, &fcrequest.WorkEstimate{InitialSeats: 1}, 2, "", "fs2", "test", "two", queueNoteFn(2)) if idle2a { t.Error("2nd StartRequest returned idle") } if req2 != nil { idle2b := req2.Finish(func() { t.Error("Executing req2") }) if idle2b { t.Error("2nd Finish returned idle")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
Labels: &structpb.Struct{ Fields: map[string]*structpb.Value{ "req1": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key1:val1)%"}}, "req2": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key2:val1)%"}}, "key1": {Kind: &structpb.Value_StringValue{StringValue: "%METADATA(CLUSTER:istio)%"}},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
src/cmd/go/internal/mvs/mvs_test.go
build M: M A1 B2 C2 req M: A1 B2 req M A: A1 B2 req M C: A1 C2 # Requirement minimization. name: req1 A: B1 C1 D1 E1 F1 B1: C1 E1 F1 req A: B1 D1 req A C: B1 C1 D1 name: req2 A: G1 H1 G1: H1 H1: G1 req A: G1 req A G: G1 req A H: H1 name: req3 M: A1 B1 A1: X1 B1: X2 X1: I1 X2: req M: A1 B1 name: reqnone M: Anone B1 D1 E1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 23 19:01:26 UTC 2023 - 11.5K bytes - Viewed (0) -
src/net/http/transport_test.go
go doReq("req1") <-preDial <-dialStarted // get req2 to waiting on conns per host to go down below max go doReq("req2") <-preDial select { case <-dialStarted: t.Error("req2 dial started while req1 dial in progress") return default: } // let req1 complete stallDial <- struct{}{} <-reqComplete // let req2 complete <-dialStarted stallDial <- struct{}{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/http/serve_test.go
var proxy *clientServerTest proxy = newClientServerTest(t, mode, HandlerFunc(func(rw ResponseWriter, req *Request) { req2, _ := NewRequest("POST", backend.ts.URL, req.Body) req2.ContentLength = bodySize cancel := make(chan struct{}) req2.Cancel = cancel bresp, err := proxy.c.Do(req2) if err != nil { t.Errorf("Proxy outbound request: %v", err) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0)