- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 546 for Initialize (0.18 sec)
-
cmd/post-policy_test.go
objectName := "config/x" // This exploit needs browser to be enabled. if !globalBrowserEnabled { globalBrowserEnabled = true defer func() { globalBrowserEnabled = false }() } // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
src/text/scanner/scanner.go
s.srcPos = 0 s.srcEnd = 0 // initialize source position s.srcBufOffset = 0 s.line = 1 s.column = 0 s.lastLineLen = 0 s.lastCharLen = 0 // initialize token text buffer // (required for first call to next()). s.tokPos = -1 // initialize one character look-ahead s.ch = -2 // no char read yet, not EOF // initialize public fields s.Error = nil s.ErrorCount = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 20.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
} // return empty read without blocking until we are initialized return 0, nil } func (u *tunnelingWebsocketUpgraderConn) Write(b []byte) (n int, err error) { u.lock.RLock() defer u.lock.RUnlock() if u.conn != nil { return u.conn.Write(b) } if u.err != nil { return 0, u.err } return 0, fmt.Errorf("Write called before Initialize") } func (u *tunnelingWebsocketUpgraderConn) Close() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/xds/server.go
close(conn.stop) } func (conn *Connection) MarkInitialized() { close(conn.initialized) } // ConnectionContext is used by the RPC event loop to respond to requests and pushes. type ConnectionContext interface { XdsConnection() *Connection Watcher() Watcher // Initialize checks the first request. Initialize(node *core.Node) error // Close discards the connection. Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
err := nim.InitializeCSINodeWithAnnotation() if err != nil { kvh.SetKubeletError(fmt.Errorf("failed to initialize CSINode: %v", err)) klog.Errorf("Failed to initialize CSINode: %v", err) return false, nil } // Successfully initialized drivers, allow Kubelet to post Ready kvh.SetKubeletError(nil) return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
tensorflow/compiler/aot/compile.cc
} else { return ReadBinaryProto(Env::Default(), fname, proto); } } static absl::once_flag targets_init; static void InitializeTargets() { // Initialize all LLVM targets so we can cross compile. #if TF_LLVM_AARCH32_AVAILABLE LLVMInitializeARMTarget(); LLVMInitializeARMTargetInfo(); LLVMInitializeARMTargetMC(); LLVMInitializeARMAsmParser();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 08:28:57 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
// Only used for test func ResetConnectionNumberForTest() { atomic.StoreInt64(&connectionNumber, 0) } // initProxyMetadata initializes just the basic metadata of a proxy. This is decoupled from // initProxyState such that we can perform authorization before attempting expensive computations to // fully initialize the proxy. func (s *DiscoveryServer) initProxyMetadata(node *core.Node) (*model.Proxy, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/reference/ci-systems/github-actions.adoc
* A local Gradle installation, to initialize a new Gradle project * A GitHub account == Setup a Gradle project on GitHub If you have an existing Gradle project hosted on GitHub, then you can skip this step and move directly to <<#sec:configure_github_actions,Configure GitHub Actions>>. If not, follow these step to initialize a new Gradle project on GitHub.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 08 14:41:08 UTC 2024 - 11.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/CallInterceptingMetaClass.java
return adaptee; } @Override public void setAdaptee(MetaClass metaClass) { adaptee = metaClass; } @Override public synchronized void initialize() { this.adaptee.initialize(); } @Override public Object invokeMissingMethod(Object instance, String methodName, Object[] arguments) { return adaptee.invokeMissingMethod(instance, methodName, arguments);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:46:35 UTC 2024 - 21.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
type Multicluster struct { // serverID of this pilot instance used for leader election serverID string // options to use when creating kube controllers opts Options // client for reading remote-secrets to initialize multicluster registries client kubernetes.Interface s server.Instance serviceEntryController *serviceentry.Controller configController model.ConfigStoreController XDSUpdater model.XDSUpdater
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0)