Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 481 - 490 of 954 for stat1 (0.1 seconds)

  1. 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)
  2. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/Cleanup.kt

    import java.io.File
    
    
    private
    val dirVersionPattern = "\\d+\\.\\d+(\\.\\d+)?(-\\w+)*(-\\d{14}[+-]\\d{4})?".toRegex()
    
    
    val logger = Logging.getLogger("gradlebuild.cleanup")
    
    
    /**
     * Removes state for versions that we're unlikely to ever need again, such as old snapshot versions.
     */
    @Suppress("LoopWithTooManyJumpStatements")
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Jun 28 08:29:28 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  3. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt

                (candidateVersion.isSnapshot && candidateVersion < gradleVersion)
                    || candidateVersion.version.endsWith("-snapshot-1")
            }
    
            // Remove state for old versions of Gradle that we're unlikely to ever require again
            fileSystemOperations.removeOldVersionsFromDir(workerDir.dir("caches"), expireDistributionCache)
    
            // Remove scripts caches
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Jun 28 08:29:28 GMT 2024
    - 4.2K bytes
    - Click Count (1)
  4. 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)
  5. 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)
  6. 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)
  7. src/main/java/jcifs/smb/SmbTransportImpl.java

            }
            this.sessions.add(ssn);
            return ssn;
        }
    
        boolean matches(final Address addr, final int prt, final InetAddress laddr, final int lprt, String hostName) {
            if (this.state == 5 || this.state == 6) {
                // don't reuse disconnecting/disconnected transports
                return false;
            }
            if (hostName == null) {
                hostName = addr.getHostName();
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/auth/chain/AuthenticationChainTest.java

            } catch (RuntimeException e) {
                assertEquals("Load failed", e.getMessage());
            }
    
            assertEquals(1, chain.loadCalls.size());
        }
    
        // Test implementation state tracking
        @Test
        public void test_implementation_stateTracking() {
            TestAuthenticationChain chain = new TestAuthenticationChain();
            User user1 = createTestUser("user1", "User One");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 14.8K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/smb1/NtStatus.java

        /** The requested pipe instance is not available */
        int NT_STATUS_INSTANCE_NOT_AVAILABLE = 0xC00000ab;
        /** The pipe is not available */
        int NT_STATUS_PIPE_NOT_AVAILABLE = 0xC00000ac;
        /** The pipe state is invalid for the requested operation */
        int NT_STATUS_INVALID_PIPE_STATE = 0xC00000ad;
        /** All pipe instances are busy */
        int NT_STATUS_PIPE_BUSY = 0xC00000ae;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            // Act
            TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig);
    
            // Assert
            assertNotNull(testResponse);
        }
    
        @Test
        @DisplayName("Test state changes after reading parameters")
        void testStateAfterReadingParameters() {
            // Arrange
            byte[] buffer = new byte[10];
            SMBUtil.writeInt2(1500, buffer, 0);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.8K bytes
    - Click Count (0)
Back to Top