Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 1,198 for maka (0.02 seconds)

  1. internal/logger/config.go

    func NewConfig() Config {
    	cfg := Config{
    		// Console logging is on by default
    		Console: Console{
    			Enabled: true,
    		},
    		HTTP:         make(map[string]http.Config),
    		AuditWebhook: make(map[string]http.Config),
    		AuditKafka:   make(map[string]kafka.Config),
    	}
    
    	return cfg
    }
    
    func getCfgVal(envName, key, defaultValue string) string {
    	if key != config.Default {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  2. docs/tuning/README.md

    # How to enable 'minio' performance profile with tuned?
    
    ## Prerequisites
    
    Please make sure the following packages are already installed via `dnf` or `apt`: 
    
    - `tuned`
    - `curl`
    
    ### Install `tuned.conf` performance profile
    
    #### Step 1 - download `tuned.conf` from the referenced link
    ```
    wget https://raw.githubusercontent.com/minio/minio/master/docs/tuning/tuned.conf
    ```
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 19 01:15:02 GMT 2024
    - 644 bytes
    - Click Count (0)
  3. cmd/object-api-utils.go

    	if len(md5sumCurr) == 0 {
    		// md5sumCurr is only empty when we are running
    		// in non-compatibility mode.
    		md5sumCurr = make([]byte, 16)
    		rand.Read(md5sumCurr)
    		appendHyphen = true
    	}
    	if p.sealMD5Fn != nil {
    		md5sumCurr = p.sealMD5Fn(md5sumCurr)
    	}
    	if appendHyphen {
    		// Make sure to return etag string upto 32 length, for SSE
    		// requests ETag might be longer and the code decrypting the
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        latch = new CountDownLatch(1);
        future = createListenableFuture(Boolean.TRUE, null, latch);
      }
    
      @Override
      protected void tearDown() throws Exception {
    
        // Make sure we have no waiting threads.
        latch.countDown();
      }
    
      /** Constructs a listenable future with a value available after the latch has counted down. */
      protected abstract <V> ListenableFuture<V> createListenableFuture(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

        }
    
        @Test
        void testLeastLoadedStrategy() {
            loadBalancer.setStrategy(LoadBalancingStrategy.LEAST_LOADED);
    
            // Add pending operations to channel1 to make it more loaded
            channel1.addPendingOperation(mockMessage);
    
            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)
  6. guava/src/com/google/common/collect/ImmutableBiMap.java

        }
    
        /**
         * Throws {@link UnsupportedOperationException}. This method is inherited from {@link
         * ImmutableMap.Builder}, but it does not make sense for bimaps.
         *
         * @throws UnsupportedOperationException always
         * @deprecated This method does not make sense for bimaps and should not be called.
         * @since 31.1
         */
        @DoNotCall
        @Deprecated
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 22.7K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

              latch2.countDown()
            }
          }
        val request2Listener: EventListener =
          object : EventListener() {
            override fun connectStart(
              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
              // Let request1 proceed to make a connection.
              latch1.countDown()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jun 19 11:44:16 GMT 2025
    - 19.1K bytes
    - Click Count (0)
  8. tests/lru_test.go

    	if lru.Cap() != 0 {
    		t.Errorf("Expected lru to be empty, but it was not")
    	}
    
    }
    
    func BenchmarkLRU_Rand_NoExpire(b *testing.B) {
    	l := lru.NewLRU[int64, int64](8192, nil, 0)
    
    	trace := make([]int64, b.N*2)
    	for i := 0; i < b.N*2; i++ {
    		trace[i] = getRand(b) % 32768
    	}
    
    	b.ResetTimer()
    
    	var hit, miss int
    	for i := 0; i < 2*b.N; i++ {
    		if i%2 == 0 {
    			l.Add(trace[i], trace[i])
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  9. cmd/utils.go

    	return path2BucketObjectWithBasePath("", s)
    }
    
    // cloneMSS will clone a map[string]string.
    // If input is nil an empty map is returned, not nil.
    func cloneMSS(v map[string]string) map[string]string {
    	r := make(map[string]string, len(v))
    	maps.Copy(r, v)
    	return r
    }
    
    // URI scheme constants.
    const (
    	httpScheme  = "http"
    	httpsScheme = "https"
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  10. docs/auditlog/auditlog-echo.md

    2. Configure audit logging in MinIO with for example:
    
    ```
    mc admin config set myminio audit_webhook enable=on endpoint=http://localhost:8080
    ```
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 447 bytes
    - Click Count (0)
Back to Top