- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 452 for resps (0.04 sec)
-
cmd/erasure-common.go
func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) { resps := make([]chan ReadMultipleResp, len(disks)) for i := range resps { resps[i] = make(chan ReadMultipleResp, len(req.Files)) } g := errgroup.WithNErrs(len(disks)) // Read files in parallel across disks. for index := range disks { index := index
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
if err != nil { aggErr = multierror.Append(aggErr, err) continue } resps = append(resps, out.Responses...) } if aggErr.ErrorOrNil() != nil { return echo.CallResult{}, aggErr } return echo.CallResult{ From: c, Opts: opts, Responses: resps, }, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
}) resp.Mounts = append(resp.Mounts, &pluginapi.Mount{ ContainerPath: "/container_dir1/file2", HostPath: "host_dir1/file2", ReadOnly: true, }) resp.Envs["key1"] = "val1" } } resps := new(pluginapi.AllocateResponse) resps.ContainerResponses = append(resps.ContainerResponses, resp) return resps, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
return false } return reflect.DeepEqual(a, b) } func equalAllocatableResourcesResponse(respA, respB *podresourcesapi.AllocatableResourcesResponse) bool { if !equalInt64s(respA.CpuIds, respB.CpuIds) { return false } return equalContainerDevices(respA.Devices, respB.Devices) } func equalGetResponse(ResA, ResB *podresourcesapi.GetPodResourcesResponse) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
ads := s.ConnectADS().WithType(v3.ClusterType) resp1 := ads.RequestResponseAck(t, nil) fullPush(s) resp2 := ads.ExpectResponse(t) if !(resp1.VersionInfo < resp2.VersionInfo) { t.Fatalf("version should be incrementing: %v -> %v", resp1.VersionInfo, resp2.VersionInfo) } if resp1.Nonce == resp2.Nonce { t.Fatalf("nonce should change %v -> %v", resp1.Nonce, resp2.Nonce) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
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) -
internal/grid/handlers.go
if r != h.nilResp { h.respPool.Put(r) } } // NewResponse creates a new response. // Handlers can use this to create a reusable response. func (h *StreamTypeHandler[Payload, Req, Resp]) NewResponse() Resp { return h.respPool.Get().(Resp) } func newStreamHandler[Payload, Req, Resp RoundTripper](h HandlerID) *StreamTypeHandler[Payload, Req, Resp] {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
forward(resp) } func forwardDeltaToEnvoy(con *ProxyConnection, resp *discovery.DeltaDiscoveryResponse) { if !model.IsEnvoyType(resp.TypeUrl) && resp.TypeUrl != model.WorkloadType { proxyLog.Errorf("Skipping forwarding type url %s to Envoy as is not a valid Envoy type", resp.TypeUrl) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
Trans2GetDfsReferralResponse resp = new Trans2GetDfsReferralResponse(); ipc.send( new Trans2GetDfsReferral( path ), resp ); if (resp.numReferrals == 0) { return null; } else if (rn == 0 || resp.numReferrals < rn) { rn = resp.numReferrals; } DfsReferral dr = new DfsReferral();
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 31.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/AsciiBenchmark.java
} @Benchmark int asciiStringToUpperCase(int reps) { String string = noWorkToDo ? Ascii.toUpperCase(testString) : testString; int dummy = 0; for (int i = 0; i < reps; i++) { dummy += Ascii.toUpperCase(string).length(); } return dummy; } @Benchmark int asciiCharSequenceToUpperCase(int reps) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.8K bytes - Viewed (0)