- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for newProto (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)