- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 364 for resc (1.87 sec)
-
src/cmd/go/internal/cache/prog.go
return nil, err } select { case res := <-resc: if res.Err != "" { return nil, errors.New(res.Err) } return res, nil case <-ctx.Done(): return nil, ctx.Err() } } func (c *ProgCache) writeToChild(req *ProgRequest, resc chan<- *ProgResponse) (err error) { c.mu.Lock() c.nextID++ req.ID = c.nextID c.inFlight[req.ID] = resc c.mu.Unlock() defer func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 19:23:25 UTC 2023 - 11.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/tests/flatbuffer2mlir/lstm.mlir
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 09:41:17 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/peer-rest-client.go
resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS()) if err != nil || resp == nil { return nil, err } return *resp, nil } // LocalStorageInfo - fetch server information for a remote node. func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26.1K bytes - Viewed (0) -
maven-artifact/src/main/java/org/apache/maven/artifact/versioning/VersionRange.java
Restriction res1 = i1.next(); Restriction res2 = i2.next(); boolean done = false; while (!done) { if (res1.getLowerBound() == null || res2.getUpperBound() == null || res1.getLowerBound().compareTo(res2.getUpperBound()) <= 0) { if (res1.getUpperBound() == null
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 07:40:37 UTC 2024 - 18.9K bytes - Viewed (0) -
cmd/storage-rest-server.go
for update := range updates { resp := storageNSScannerRPC.NewResponse() resp.Update = &update out <- resp } }() ui, err := s.getStorage().NSScanner(ctx, *params.Cache, updates, madmin.HealScanMode(params.ScanMode), nil) wg.Wait() if err != nil { return grid.NewRemoteErr(err) } // Send final response. resp := storageNSScannerRPC.NewResponse() resp.Final = &ui out <- resp return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
t.Fatalf("unexpected response type %v. Expected dependent EDS response", resp.TypeUrl) } // we must NOT get the cluster back if resn := xdstest.ExtractResource(res.Resources); resn.Contains(updateCluster) || !resn.Contains(staticCluster) { t.Fatalf("unexpected resources: %v", resn) } // It should be removed if resn := sets.New(res.RemovedResources...); !resn.Contains(updateCluster) { t.Fatalf("unexpected remove resources: %v", resn)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
resp := ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{routeA}}) expectRoutes(resp, routeA) xds.AdsPushAll(s.Discovery) resp = ads.ExpectResponse(t) expectRoutes(resp, routeA) // Test update from A -> B resp = ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{routeB}}) expectRoutes(resp, routeB)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
} server := NewV1PodResourcesServer(providers) resp, err := server.List(context.TODO(), &podresourcesapi.ListPodResourcesRequest{}) if err != nil { t.Errorf("want err = %v, got %q", nil, err) } if !equalListResponse(tc.expectedResponse, resp) { t.Errorf("want resp = %s, got %s", tc.expectedResponse.String(), resp.String()) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
tests/create_test.go
res := DB.FirstOrCreate(&user, "name = ?", user.Name) if res.Error != nil || res.RowsAffected != 1 { t.Fatalf("first or create rows affect err:%v rows:%d", res.Error, res.RowsAffected) } res = DB.FirstOrCreate(&user, "name = ?", user.Name) if res.Error != nil || res.RowsAffected != 0 { t.Fatalf("first or create rows affect err:%v rows:%d", res.Error, res.RowsAffected) } }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Mar 19 03:50:28 UTC 2024 - 26.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
func (r *RequestScope) GetEquivalentResourceMapper() runtime.EquivalentResourceMapper { return r.EquivalentResourceMapper } // ConnectResource returns a function that handles a connect request on a rest.Storage object. func ConnectResource(connecter rest.Connecter, scope *RequestScope, admit admission.Interface, restPath string, isSubresource bool) http.HandlerFunc { return func(w http.ResponseWriter, req *http.Request) { if isDryRun(req.URL) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0)