- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,212 for notified (0.17 sec)
-
pkg/kubelet/certificate/kubelet.go
keyFile string dynamicCertificateContent *dynamiccertificates.DynamicCertKeyPairContent currentTLSCertificate atomic.Pointer[tls.Certificate] } // Enqueue implements the functions to be notified when the serving cert content changes. func (m *kubeletServerCertificateDynamicFileManager) Enqueue() { certContent, keyContent := m.dynamicCertificateContent.CurrentCertKeyContent()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/provider/KotlinScriptEvaluator.kt
} @Synchronized override fun onReuse() { scope?.let { // Recreate the script scope and ClassLoader, so that things that use scopes are notified that the scope exists it.onReuse() require(loadedClass!!.classLoader == it.localClassLoader) } } private fun prepareClassLoaderScope() =
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 10:23:24 UTC 2024 - 17.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
// the client sees an interrupted response but the server doesn't log // an error, panic with the value ErrAbortHandler. // // We are throwing http.ErrAbortHandler deliberately so that a client is notified and to suppress a not helpful stacktrace in the logs panic(http.ErrAbortHandler) } } func (tw *baseTimeoutWriter) CloseNotify() <-chan bool { tw.mu.Lock() defer tw.mu.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/DefaultScriptCompilationHandler.java
} @Override public void onReuse() { if (scriptClass != null) { // Recreate the script scope and ClassLoader, so that things that use scopes are notified that the scope exists scope.onReuse(); assert scriptClass.getClassLoader() == scope.getLocalClassLoader(); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 20.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
return ExecutionResult.maybeFailing(() -> buildListener.buildFinished(buildResult)); }); } /** * <p>Adds a listener to this build instance. The listener is notified of events which occur during the execution of the build. * See {@link org.gradle.api.invocation.Gradle#addListener(Object)} for supported listener types.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/invocation/Gradle.java
*/ @Deprecated void buildFinished(Action<? super BuildResult> action); /** * Adds a {@link BuildListener} to this Build instance. * * The listener is notified of events which occur during the execution of the build. * * @param buildListener The listener to add. */ void addBuildListener(BuildListener buildListener); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 26 22:53:34 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
} // CreateStackedEtcdStaticPodManifestFile will write local etcd static pod manifest file // for an additional etcd member that is joining an existing local/stacked etcd cluster. // Other members of the etcd cluster will be notified of the joining node in beforehand as well.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* assume that connectivity has been lost. When this happens on a web socket the connection is * canceled and its listener is [notified][WebSocketListener.onFailure]. When it happens on an * HTTP/2 connection the connection is closed and any calls it is carrying * [will fail with an IOException][java.io.IOException]. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller_test.go
initialObjects []runtime.Object // Whether not to insert the content of initialObjects into the // informers before the test starts. Set it to true to simulate the case // where informers have not been notified yet of certain API objects. informersAreLate bool // Optional client reactors. reactors []reaction // PVC event to simulate. This PVC will be automatically added to // initialObjects.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 15.5K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
// mode. Level triggering means we have to keep track of a few things // ourselves. After we receive an event for a file descriptor, // it's our responsibility to ask again to be notified for future // events for that descriptor. When doing this we must keep track of // what kind of events the goroutines are currently interested in, // for example a fd may be open both for reading and writing. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0)