Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for newProto (0.15 sec)

  1. pkg/adsc/delta.go

    	}
    	if event == EventAdd {
    		if r.Resource == nil {
    			return fmt.Errorf("trigged by EventAdd,but be added resource object is nil")
    		}
    		entity := newProto(typeURL)
    		if entity == nil {
    			return fmt.Errorf("new resource entity by typeURL: %s error", entity)
    		}
    		if err := r.Resource.UnmarshalTo(entity); err != nil {
    			return err
    		}
    		res = &Resource{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 09:32:41 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/WatchableHierarchies.java

            Invalidator invalidator
        ) {
            SnapshotHierarchy newRoot = root;
            newRoot = removeWatchedHierarchiesOverLimit(newRoot, isWatchedHierarchy, maximumNumberOfWatchedHierarchies, invalidator);
            newRoot = removeUnwatchableFileSystems(newRoot, unsupportedFileSystems, invalidator);
            newRoot = removeUnwatchedSnapshots(newRoot, invalidator);
            watchableHierarchiesSinceLastBuildFinish.clear();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 17:02:39 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystem.java

                SnapshotHierarchy newRoot = updateFunction.update(diffListener);
                return withWatcherChangeErrorHandling(newRoot, () -> diffListener.publishSnapshotDiff((removedSnapshots, addedSnapshots) ->
                    watchRegistry.virtualFileSystemContentsChanged(removedSnapshots, addedSnapshots, newRoot)
                ));
            }
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Feb 02 16:22:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  4. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdater.java

            SnapshotHierarchy newRoot = watchableHierarchies.removeUnwatchableContentOnBuildStart(root, createInvalidator(), watchMode, unsupportedFileSystems);
            newRoot = invalidateMovedDirectoriesOnBuildStarted(newRoot);
            if (root != newRoot) {
                update(newRoot);
            }
            return newRoot;
        }
    
        @CheckReturnValue
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 17:02:39 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. pkg/ledger/smt_test.go

    	ch = make(chan result, 1)
    	smt.update(root, newKeys, newValues, nil, 0, smt.trieHeight, false, true, ch)
    	res = <-ch
    	newRoot := res.update
    	if bytes.Equal(root, newRoot) {
    		t.Fatal("trie not updated")
    	}
    	for i, newKey := range newKeys {
    		newValue, _ := smt.get(newRoot, newKey, nil, 0, smt.trieHeight)
    		if !bytes.Equal(newValues[i], newValue) {
    			t.Fatal("failed to get value")
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 16:43:05 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. subprojects/core/src/testFixtures/groovy/org/gradle/api/internal/file/TestVirtualFileSystem.java

            return updateFunction.update(SnapshotHierarchy.NodeDiffListener.NOOP);
        }
    
        public void setRoot(SnapshotHierarchy newRoot) {
            updateRootUnderLock(root -> newRoot);
        }
    
        public SnapshotHierarchy getRoot() {
            return root;
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jun 08 14:17:29 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  7. pkg/test/cert/ca/root.go

    	ConfFile string
    
    	// CSRFile used to generate the cert.
    	CSRFile string
    
    	// CertFile the cert for the root CA.
    	CertFile string
    }
    
    // NewRoot generates the files for a new self-signed Root CA files under the given directory.
    func NewRoot(workDir string) (Root, error) {
    	root := Root{
    		KeyFile:  filepath.Join(workDir, "root-key.pem"),
    		ConfFile: filepath.Join(workDir, "root-ca.conf"),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 03 18:09:59 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/TreeMultiset.java

          AvlNode<E> newRoot = new AvlNode<>(element, occurrences);
          successor(header, newRoot, header);
          rootReference.checkAndSet(root, newRoot);
          return 0;
        }
        int[] result = new int[1]; // used as a mutable int reference to hold result
        AvlNode<E> newRoot = root.add(comparator(), element, occurrences, result);
        rootReference.checkAndSet(root, newRoot);
        return result[0];
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 34.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/TreeMultiset.java

          AvlNode<E> newRoot = new AvlNode<>(element, occurrences);
          successor(header, newRoot, header);
          rootReference.checkAndSet(root, newRoot);
          return 0;
        }
        int[] result = new int[1]; // used as a mutable int reference to hold result
        AvlNode<E> newRoot = root.add(comparator(), element, occurrences, result);
        rootReference.checkAndSet(root, newRoot);
        return result[0];
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go

    	}
    	newRoot, err := cfg.Complete(nil).New("newRootServer", delegate)
    	assert.NoError(err)
    	if len(newRoot.MuxAndDiscoveryCompleteSignals()) != 1 {
    		assert.Error(fmt.Errorf("unexpected signals %v registered in the newRoot server", newRoot.MuxAndDiscoveryCompleteSignals()))
    	}
    	newRoot.RegisterMuxAndDiscoveryCompleteSignal("newRootTestSignal", make(chan struct{}))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 23.2K bytes
    - Viewed (0)
Back to top