Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 838 for srcEnd (0.07 seconds)

  1. internal/event/target/kafka.go

    		config.Producer.CompressionLevel = args.Producer.CompressionLevel
    	}
    
    	config.Net.ReadTimeout = (5 * time.Second)
    	config.Net.DialTimeout = (5 * time.Second)
    	config.Net.WriteTimeout = (5 * time.Second)
    	config.Metadata.Retry.Max = 1
    	config.Metadata.Retry.Backoff = (1 * time.Second)
    	config.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	target.config = config
    
    	brokers := []string{}
    	for _, broker := range args.Brokers {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb1/net/TestSmbComTransactionResponseReader.java

            assertEquals((byte) 0xA1, encoded[0], "First byte of first character");
            assertEquals((byte) 0x00, encoded[1], "Second byte of first character");
            assertEquals((byte) 0xA2, encoded[2], "First byte of second character");
            assertEquals((byte) 0x00, encoded[3], "Second byte of second character");
        }
    
        @Test
        public void testAsciiEncoding() throws Exception {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. internal/dsync/drwmutex_test.go

    	if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	drwm2 := NewDRWMutex(ds, "simplelock")
    	ctx2, cancel2 := context.WithCancel(t.Context())
    	if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/base/Joiner.java

      @CanIgnoreReturnValue
      public final <A extends Appendable> A appendTo(
          A appendable, @Nullable Object first, @Nullable Object second, @Nullable Object... rest)
          throws IOException {
        return appendTo(appendable, iterable(first, second, rest));
      }
    
      /**
       * Appends the string representation of each of {@code parts}, using the previously configured
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  5. internal/dsync/dsync-client_test.go

    		ReadBufferSize:        32 << 10, // 32KiB moving up from 4KiB default
    		IdleConnTimeout:       15 * time.Second,
    		ResponseHeaderTimeout: 15 * time.Minute, // Set conservative timeouts for MinIO internode.
    		TLSHandshakeTimeout:   15 * time.Second,
    		ExpectContinueTimeout: 15 * time.Second,
    		// Go net/http automatically unzip if content-type is
    		// gzip disable this feature, as we are always interested
    		// in raw stream.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Click Count (0)
  6. api/maven-api-core/src/test/java/org/apache/maven/api/MonotonicClockTest.java

            Instant first = MonotonicClock.now();
            Thread.sleep(10); // Small delay
            Instant second = MonotonicClock.now();
            Thread.sleep(10); // Small delay
            Instant third = MonotonicClock.now();
    
            assertTrue(first.isBefore(second), "Time should progress forward between measurements");
            assertTrue(second.isBefore(third), "Time should progress forward between measurements");
        }
    
        @Test
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 15 06:28:29 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  7. docs/ru/docs/advanced/additional-responses.md

    ```Python
    old_dict = {
        "old key": "old value",
        "second old key": "second old value",
    }
    new_dict = {**old_dict, "new key": "new value"}
    ```
    
    Здесь `new_dict` будет содержать все пары ключ-значение из `old_dict` плюс новую пару ключ-значение:
    
    ```Python
    {
        "old key": "old value",
        "second old key": "second old value",
        "new key": "new value",
    }
    ```
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:56:20 GMT 2026
    - 12.2K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        lock2 = factory2.newReentrantLock(MyOrder.SECOND);
        lock3 = factory2.newReentrantLock(MyOrder.THIRD);
    
        CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory3 =
            newInstanceWithExplicitOrdering(OtherOrder.class, Policies.THROW);
        lock01 = factory3.newReentrantLock(OtherOrder.FIRST);
        lock02 = factory3.newReentrantLock(OtherOrder.SECOND);
        lock03 = factory3.newReentrantLock(OtherOrder.THIRD);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        lock2 = factory2.newReentrantLock(MyOrder.SECOND);
        lock3 = factory2.newReentrantLock(MyOrder.THIRD);
    
        CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory3 =
            newInstanceWithExplicitOrdering(OtherOrder.class, Policies.THROW);
        lock01 = factory3.newReentrantLock(OtherOrder.FIRST);
        lock02 = factory3.newReentrantLock(OtherOrder.SECOND);
        lock03 = factory3.newReentrantLock(OtherOrder.THIRD);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  10. internal/grid/benchmark_test.go

    	b.Run("bytes", func(b *testing.B) {
    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(b.Context(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    				b.ResetTimer()
    				t := time.Now()
    				var ops int64
    				var lat int64
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.5K bytes
    - Click Count (0)
Back to Top