- Sort Score
- Num 10 results
- Language All
Results 451 - 460 of 902 for stat1 (0.02 seconds)
-
tests/test_get_model_definitions_formfeed_escape.py
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Feb 04 14:34:02 GMT 2026 - 6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
// 3. Process each step (schedule or skip based on reactor failure behavior) plan.sortedNodes().stream() // 1. Filter steps that are in CREATED state .filter(BuildStep::isCreated) // 2. Check if all predecessors are in a terminal state
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 55.1K bytes - Click Count (0) -
helm/minio/templates/_helper_create_bucket.txt
STATUS=$? done set -e # reset `e` as active return 0 } # checkBucketExists ($bucket) # Check if the bucket exists, by using the exit code of `mc ls` checkBucketExists() { BUCKET=$1 CMD=$(${MC} stat myminio/$BUCKET >/dev/null 2>&1) return $? } # createBucket ($bucket, $policy, $purge) # Ensure bucket exists, purging if asked to createBucket() { BUCKET=$1 POLICY=$2 PURGE=$3 VERSIONING=$4
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 07 09:47:02 GMT 2025 - 3.5K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
func (h *Target) Endpoint() string { return "kafka" } // String - kafka string func (h *Target) String() string { return "kafka" } // Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages),
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
// from being reused. Otherwise we're still obligated to transmit the request body to // leave the connection in a consistent state. exchange.noNewExchangesOnConnection() } } } else { exchange.noRequestBody() } if (requestBody == null || !requestBody.isDuplex()) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 7.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java
} @Test void testZeroScoreChannels() { loadBalancer.setStrategy(LoadBalancingStrategy.WEIGHTED_RANDOM); // Create channels with zero scores (failed state) channel1.setState(ChannelState.FAILED); channel2.setState(ChannelState.FAILED); when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.7K bytes - Click Count (0) -
cmd/metrics.go
prometheus.GaugeValue, float64(stat.ReplicationStats.ReplicatedSize), bucket, ) ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName("bucket", "replication", "received_size"), "Total capacity replicated to this instance", []string{"bucket"}, nil), prometheus.GaugeValue, float64(stat.ReplicationStats.ReplicaSize), bucket, )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
completed.assertCompletionExpected(); assertEquals(Thread.State.TERMINATED, thread.getState()); } void joinSuccessfully(long timeoutMillis) { Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); completed.assertCompletionExpected(); assertEquals(Thread.State.TERMINATED, thread.getState()); } void joinUnsuccessfully(long timeoutMillis) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/admin/user/admin_user_details.jsp
<tr> <th><la:message key="labels.user_state"/></th> <td>${f:h(attributes.state)}<la:hidden property="attributes.state"/></td> </tr> <tr> <th><la:message key="labels.user_employeeType"/></th>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 17.9K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* {@link Cache#stats} will return zero for all statistics. Note that recording stats requires * bookkeeping to be performed with each operation, and thus imposes a performance penalty on * cache operation. * * @return this {@code CacheBuilder} instance (for chaining) * @since 12.0 (previously, stats collection was automatic) */ @CanIgnoreReturnValueCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 51.7K bytes - Click Count (0)