- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 159 for adts (0.31 sec)
-
pilot/pkg/xds/ads.go
} con := newConnection(peerAddr, stream) con.ids = ids con.s = s return xds.Stream(con) } // update the node associated with the connection, after receiving a packet from envoy, also adds the connection // to the tracking map. func (s *DiscoveryServer) initConnection(node *core.Node, con *Connection, identities []string) error { // Setup the initial proxy metadata proxy, err := s.initProxyMetadata(node)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/translate/export_graphdef.h
const GraphExportConfig& configs, std::unique_ptr<Graph>* graph, FunctionLibraryDefinition* flib_def); // Converts an MLIR function and adds it to a FunctionLibraryDefinition. Status ConvertMlirFunctionToFunctionLibraryDef(mlir::func::FuncOp func, const GraphExportConfig& configs,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 22:19:26 UTC 2024 - 3.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/tf_executor_to_graph.cc
#include "absl/status/status.h" #include "absl/strings/str_cat.h" #include "absl/strings/string_view.h" #include "absl/types/optional.h" #include "llvm/ADT/ArrayRef.h" #include "llvm/ADT/DenseSet.h" #include "llvm/ADT/STLExtras.h" #include "llvm/ADT/SmallVector.h" #include "llvm/ADT/StringRef.h" #include "llvm/Support/Casting.h" #include "mlir/Dialect/Func/IR/FuncOps.h" // from @llvm-project
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 06 23:04:51 UTC 2024 - 35.2K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.ClusterType) ads.RequestResponseAck(nil) } func TestDeltaAdsClusterUpdate(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.EndpointType) nonce := "" sendEDSReqAndVerify := func(add, remove, expect []string) { t.Helper() res := ads.RequestResponseAck(&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) -
JavadocStyleGuide.md
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 15:43:07 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/kubelet/config/config.go
seenBefore := s.sourcesSeen.Has(source) adds, updates, deletes, removes, reconciles := s.merge(source, change) firstSet := !seenBefore && s.sourcesSeen.Has(source) // deliver update notifications switch s.mode { case PodConfigNotificationIncremental: if len(removes.Pods) > 0 { s.updates <- *removes } if len(adds.Pods) > 0 { s.updates <- *adds } if len(updates.Pods) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/config/sources.go
type SourcesReadyFn func(sourcesSeen sets.Set[string]) bool // SourcesReady tracks the set of configured sources seen by the kubelet. type SourcesReady interface { // AddSource adds the specified source to the set of sources managed. AddSource(source string) // AllReady returns true if the currently configured sources have all been seen. AllReady() bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/artifacts/ModuleDependency.java
* <p> * For examples on configuring the exclude rules please refer to {@link #exclude(java.util.Map)}. */ public interface ModuleDependency extends Dependency, HasConfigurableAttributes<ModuleDependency> { /** * Adds an exclude rule to exclude transitive dependencies of this dependency. * <p> * Excluding a particular transitive dependency does not guarantee that it does not show up * in the dependencies of a given configuration.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 16:14:52 UTC 2024 - 8.6K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// even though Nonce match and it looks like an ACK. if alwaysRespond { deltaLog.Infof("ADS:%s: FORCE RESPONSE %s for warming.", stype, con.ID()) return true } deltaLog.Debugf("ADS:%s: ACK %s %s", stype, con.ID(), request.ResponseNonce) return false } deltaLog.Debugf("ADS:%s: RESOURCE CHANGE previous resources: %v, new resources: %v %s %s", stype,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultDependencyResolverResult.java
dispatchedPaths.computeIfAbsent(type, (t) -> new ArrayList<>()).add(path); } /** * Adds main and test output directories to the result. This method adds the main output directory * to the module-path if it contains a {@code module-info.class}, or to the class-path otherwise. * For the test output directory, the rules are more complex and are governed by the fact that
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 14.6K bytes - Viewed (0)