- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,272 for emptied (0.19 sec)
-
src/runtime/mfinal.go
return true } } return false } // blockUntilEmptyFinalizerQueue blocks until either the finalizer // queue is emptied (and the finalizers have executed) or the timeout // is reached. Returns true if the finalizer queue was emptied. // This is used by the runtime and sync tests. func blockUntilEmptyFinalizerQueue(timeout int64) bool { start := nanotime() for nanotime()-start < timeout {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
cmd/metacache-entries.go
} // mergeEntryChannels will merge entries from in and return them sorted on out. // To signify no more results are on an input channel, close it. // The output channel will be closed when all inputs are emptied. // If file names are equal, compareMeta is called to select which one to choose. // The entry not chosen will be discarded. // If the context is canceled the function will return the error,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
t.Fatalf("%s: expected exactly 1 retry, got %d", job.Name, retries) } // await for the actual requeue after processing of the pending queue is done awaitForQueueLen(ctx, t, manager, 1) // the queue is emptied on success fakePodControl.Err = nil manager.processNextWorkItem(context.TODO()) verifyEmptyQueue(ctx, t, manager) } var _ workqueue.TypedRateLimitingInterface[string] = &fakeRateLimitingQueue{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// zero are frames not associated with a specific stream. zero http2writeQueue // sq contains the stream-specific queues, keyed by stream ID. // When a stream is idle, closed, or emptied, it's deleted // from the map. sq map[uint32]*http2writeQueue // pool of empty queues for reuse. queuePool http2writeQueuePool }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
platforms/core-runtime/functional/src/main/java/org/gradle/internal/collect/package-info.java
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ @org.gradle.api.NonNullApi
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 09:38:51 UTC 2024 - 681 bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/exceptions/NonGradleCauseExceptionsHolder.java
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.exceptions; public interface NonGradleCauseExceptionsHolder {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 747 bytes - Viewed (0) -
platforms/core-runtime/instrumentation-agent-services/src/main/java/org/gradle/internal/instrumentation/agent/package-info.java
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ @org.gradle.api.NonNullApi
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 695 bytes - Viewed (0) -
.teamcity/src/main/kotlin/common/JvmVersion.kt
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package common enum class JvmVersion(val major: Int) { java7(7), java8(8),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 06:42:07 UTC 2024 - 767 bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/NodeIdentifier.java
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.api.internal.artifacts; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 765 bytes - Viewed (0) -
platforms/core-runtime/instrumentation-agent-services/src/main/java/org/gradle/internal/instrumentation/agent/DisabledAgentStatus.java
* * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.instrumentation.agent; class DisabledAgentStatus implements AgentStatus {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 817 bytes - Viewed (0)