- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 360 for resps (0.05 sec)
-
pilot/pkg/xds/delta_test.go
ResourceNamesSubscribe: []string{"outbound|80||test-1.default"}, }) resp := ads.ExpectResponse() if len(resp.Resources) != 1 || resp.Resources[0].Name != "outbound|80||test-1.default" { t.Fatalf("received unexpected eds resource %v", resp.Resources) } if len(resp.RemovedResources) != 0 { t.Fatalf("received unexpected removed eds resource %v", resp.RemovedResources) } ads.Request(&discovery.DeltaDiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/hash/ChecksumBenchmark.java
// CRC32C @Benchmark byte crc32cHashFunction(int reps) { return runHashFunction(reps, Hashing.crc32c()); } // Adler32 @Benchmark byte adler32HashFunction(int reps) { return runHashFunction(reps, Hashing.adler32()); } @Benchmark byte adler32Checksum(int reps) throws Exception { byte result = 0x01; for (int i = 0; i < reps; i++) { Adler32 checksum = new Adler32();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 13 16:19:15 UTC 2023 - 2.9K bytes - Viewed (0) -
internal/grid/grid_test.go
}() var n int err = stream.Results(func(resp *testResponse) error { // t.Logf("got resp: %+v", *resp.Msg) const wantString = testPayload + testPayload if resp.OrgString != testPayload+testPayload { t.Errorf("want %q, got %q", wantString, resp.OrgString) } if resp.OrgNum != n+1 { t.Errorf("want %d, got %d", n+1, resp.OrgNum) } handler.PutResponse(resp) n++ return nil })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
func assertHealthIsOk(t *testing.T, httpURL string) { resp, err := http.Get(httpURL) if err != nil { t.Fatalf("Got error GETing: %v", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { t.Errorf("expected status code %d, got %d", http.StatusOK, resp.StatusCode) } body, readErr := io.ReadAll(resp.Body) if readErr != nil { // copying the response body did not work
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
ServerMessageBlock2Response resp = (ServerMessageBlock2Response) response; synchronized ( resp ) { if ( resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0 ) { resp.setAsyncHandled(true); boolean first = !req.isAsync(); req.setAsyncId(resp.getAsyncId());
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/hash/ChecksumBenchmark.java
// CRC32C @Benchmark byte crc32cHashFunction(int reps) { return runHashFunction(reps, Hashing.crc32c()); } // Adler32 @Benchmark byte adler32HashFunction(int reps) { return runHashFunction(reps, Hashing.adler32()); } @Benchmark byte adler32Checksum(int reps) throws Exception { byte result = 0x01; for (int i = 0; i < reps; i++) { Adler32 checksum = new Adler32();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 13 16:19:15 UTC 2023 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
select { case <-time.After(a.timeout): a.t.Fatalf("did not get response in time") case resp := <-a.responses: if resp == nil { a.t.Fatalf("expected response") } if resp != nil && (len(resp.RemovedResources) > 0 || len(resp.Resources) > 0) { a.t.Fatalf("expected empty response. received %v", resp) } return resp case err := <-a.error: a.t.Fatalf("got error: %v", err) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/lock-rest-server.go
func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err) } // LockHandler - Acquires a lock.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/registry/authentication/tokenreview/storage.go
if resp != nil && resp.User != nil { tokenReview.Status.User = authentication.UserInfo{ Username: resp.User.GetName(), UID: resp.User.GetUID(), Groups: resp.User.GetGroups(), Extra: map[string]authentication.ExtraValue{}, } for k, v := range resp.User.GetExtra() { tokenReview.Status.User.Extra[k] = authentication.ExtraValue(v) } tokenReview.Status.Audiences = resp.Audiences }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 3.7K bytes - Viewed (0) -
pkg/volume/csi/fake/fake_client.go
func (f *NodeClient) SetNextError(err error) { f.nextErr = err } func (f *NodeClient) SetNodeGetInfoResp(resp *csipb.NodeGetInfoResponse) { f.nodeGetInfoResp = resp } func (f *NodeClient) SetNodeVolumeStatsResp(resp *csipb.NodeGetVolumeStatsResponse) { f.nodeVolumeStatsResp = resp } // GetNodePublishedVolumes returns node published volumes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 16K bytes - Viewed (0)