- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,006 for finishes (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight_test.go
if err := expectHTTPPost(server.URL+"/dontwait", http.StatusOK); err != nil { t.Error(err) } // Let all hanging requests finish block.Done() // Show that we recover from being blocked up. // Too avoid flakyness we need to wait until at least one of the requests really finishes. responses.Wait() if err := expectHTTPGet(server.URL, http.StatusOK); err != nil { t.Error(err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 10.2K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelBuildOperationsIntegrationTest.groovy
doLast { submitWorkItem("workTask") } } // Wait for dependent task, to ensure that work task finishes first slowTask.doLast { ${blockingHttpServer.callFromBuild("slowTask2")} } project(':childProject') { task dependsOnWorkTask(type: MultipleWorkItemTask) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 6.9K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/zdsapi/zds.proto
- will send all the existing payloads (that it has in its cache) to the ztunnel using AddWorkload message. - the ztunnel will send an ack for each payload (which the CNI will wait for before sending the next one). - when the CNI finishes sending the content of its current cache, a SnapshotSent message will be sent. - the ztunnel will then remove any entries from its cache that were not sent up to this point (as these entries do not exist in the CNI
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/waitgroup.go
) // RequestWaitGroup helps with the accounting of request(s) that are in // flight: the caller is expected to invoke Add(1) before executing the // request handler and then invoke Done() when the handler finishes. // NOTE: implementations must ensure that it is thread-safe // when invoked from multiple goroutines. type RequestWaitGroup interface { // Add adds delta, which may be negative, similar to sync.WaitGroup.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 10 21:18:55 UTC 2023 - 3.7K bytes - Viewed (0) -
subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultRootBuildStateTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 6.3K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
// Requests that the worker thread execute the specified operation. Blocks // until the previously pending operation (a StartExecute without a Join) has // finished, if any. // // `cancellation_manager` must live until after `Join` finishes and pending // `is_async` operations finish. In addition to allowing the caller to cancel // the operation, its `StartCancel` method will be called if op execution
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 07:47:20 UTC 2024 - 25.4K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath.go
// // CleanupAction must be called immediately after the container with given // subpath starts. On the other hand, Interface.CleanSubPaths must be called // when the pod finishes. PrepareSafeSubpath(subPath Subpath) (newHostPath string, cleanupAction func(), err error) // SafeMakeDir creates subdir within given base. It makes sure that the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 27 02:59:53 UTC 2019 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationRunnerTest.groovy
timeProvider, new DefaultBuildOperationIdFactory(), { listener }) def setup() { currentBuildOperationRef.clear() } def "fires events when wrap-around operation starts and finishes successfully with '#defaultParent' parent"() { setup: def buildOperation = Mock(BuildOperation) def details = Mock(Object)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:56:07 UTC 2024 - 29.3K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdater.java
* since watched directories can't be deleted on Windows. * * The build root directories are discovered as included builds are encountered at the start of a build, and then they are removed when the build finishes. * * This is the lifecycle for the watchable hierarchies: * - During a build, there will be various calls to {@link FileWatcherUpdater#registerWatchableHierarchy(File, SnapshotHierarchy)},
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 6.9K bytes - Viewed (0)