Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 219 for pinner (0.05 sec)

  1. cmd/server-startup-msg.go

    	return "%" + formatStr
    }
    
    // Prints the formatted startup message.
    func printStartupMessage(apiEndpoints []string, err error) {
    	banner := strings.Repeat("-", len(MinioBannerName))
    	if globalIsDistErasure {
    		logger.Startup(color.Bold(banner))
    	}
    	logger.Startup(color.Bold(MinioBannerName))
    	if err != nil {
    		if globalConsoleSys != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/SmbComSessionSetupAndXTest.java

        private SmbComSessionSetupAndX setupAndX;
    
        @BeforeEach
        void setUp() throws Exception {
            MockitoAnnotations.openMocks(this);
    
            // Create a real ServerData instance as it's not mockable (inner class)
            SmbTransport.ServerData serverData = mockTransport.new ServerData();
            serverData.security = ServerMessageBlock.SECURITY_USER;
            serverData.encryptedPasswords = true;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt

            .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor()))
            .build()
    
        executor = newVirtualThreadPerTaskExecutor()
    
        // Capture non-deterministic but probable sysout warnings of pinned threads
        // https://docs.oracle.com/en/java/javase/21/core/virtual-threads.html
        System.setOut(PrintStream(capturedOut))
      }
    
      @AfterEach
      fun checkForPinning() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.7K bytes
    - Viewed (1)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/io/FaultyFileSystem.kt

      ): Sink = FaultySink(super.appendingSink(file, mustExist), file)
    
      override fun sink(
        file: Path,
        mustCreate: Boolean,
      ): Sink = FaultySink(super.sink(file, mustCreate), file)
    
      inner class FaultySink(
        sink: Sink,
        private val file: Path,
      ) : ForwardingSink(sink) {
        override fun write(
          source: Buffer,
          byteCount: Long,
        ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/graph/GraphConstants.java

      static final int EXPECTED_DEGREE = 2;
    
      static final int DEFAULT_NODE_COUNT = 10;
      static final int DEFAULT_EDGE_COUNT = DEFAULT_NODE_COUNT * EXPECTED_DEGREE;
    
      // Load factor and capacity for "inner" (i.e. per node/edge element) hash sets or maps
      static final float INNER_LOAD_FACTOR = 1.0f;
      static final int INNER_CAPACITY = 2; // ceiling(EXPECTED_DEGREE / INNER_LOAD_FACTOR)
    
      // Error messages
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/RelatedQueryHelper.java

        /**
         * Map storing related queries organized by virtual host key and search term.
         * The outer map key is the virtual host key, the inner map key is the search term
         * (in lowercase), and the value is an array of related query strings.
         */
        protected volatile Map<String, Map<String, String[]>> relatedQueryMap = Collections.emptyMap();
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              // We have a connected TCP connection. Cancel and defer the racing connects that all lost.
              cancelInFlightConnects()
    
              // Finish connecting. We won't have to if the winner is from the connection pool.
              if (!connectResult.plan.isReady) {
                connectResult = connectResult.plan.connectTlsEtc()
              }
    
              if (connectResult.isSuccess) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. .teamcity/src/main/kotlin/model/PerformanceTestSpec.kt

                            listOf("async-profiler", "async-profiler-heap")
                        }.map { FlameGraphGenerationBuildSpec(scenario, os, arch, it) }
                    }
                }
    
        inner class FlameGraphGenerationBuildSpec(
            val performanceScenario: PerformanceScenario,
            override val os: Os,
            override val arch: Arch,
            val profiler: String,
        ) : PerformanceTestBuildSpec {
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/exception/StorageExceptionTest.java

            assertTrue(exception instanceof Throwable);
        }
    
        public void test_stackTraceWithCause() {
            // Test that stack trace is properly preserved with cause
            String innerMessage = "Inner exception";
            String outerMessage = "Outer exception";
            RuntimeException innerException = new RuntimeException(innerMessage);
            StorageException exception = new StorageException(outerMessage, innerException);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 7K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

      /**
       * A source that reads the incoming data frames of a stream. Although this class uses
       * synchronization to safely receive incoming data frames, it is not intended for use by multiple
       * readers.
       */
      inner class FramingSource internal constructor(
        /** Maximum number of bytes to buffer before reporting a flow control error. */
        private val maxByteCount: Long,
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top