Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,036 for puts (0.02 sec)

  1. internal/store/queuestore_test.go

    	if err != nil {
    		t.Fatal("Failed to create a queue store ", err)
    	}
    	for i := 0; i < 5; i++ {
    		if _, err := store.Put(testItem); err != nil {
    			t.Fatal("Failed to put to queue store ", err)
    		}
    	}
    	// Should not allow 6th Put.
    	if _, err := store.Put(testItem); err == nil {
    		t.Fatalf("Expected to fail with %s, but passes", errLimitExceeded)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/HashBiMap.java

        return (entry == ABSENT) ? null : keys[entry];
      }
    
      @Override
      @CanIgnoreReturnValue
      @CheckForNull
      public V put(@ParametricNullness K key, @ParametricNullness V value) {
        return put(key, value, false);
      }
    
      @CheckForNull
      V put(@ParametricNullness K key, @ParametricNullness V value, boolean force) {
        int keyHash = Hashing.smearedHash(key);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 36.4K bytes
    - Viewed (0)
  3. cmd/bucket-stats.go

    	"github.com/minio/madmin-go/v3"
    )
    
    //go:generate msgp -file $GOFILE
    
    // ReplicationLatency holds information of bucket operations latency, such us uploads
    type ReplicationLatency struct {
    	// Single & Multipart PUTs latency
    	UploadHistogram LastMinuteHistogram
    }
    
    // Merge two replication latency into a new one
    func (rl ReplicationLatency) merge(other ReplicationLatency) (newReplLatency ReplicationLatency) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. internal/grid/types.go

    		return make([]T, 0, sz)
    	}
    	t2 := *t
    	return t2[:0]
    }
    
    func (p *ArrayOf[T]) putA(v []T) {
    	var zero T // nil
    	for i, t := range v {
    		//nolint:staticcheck // SA6002 IT IS A GENERIC VALUE!
    		p.ePool.Put(t)
    		v[i] = zero
    	}
    	if v != nil {
    		v = v[:0]
    		p.aPool.Put(&v)
    	}
    }
    
    func (p *ArrayOf[T]) newE() T {
    	return p.ePool.Get().(T)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

              proxy: Proxy,
            ) {
              // Let request1 proceed to make a connection.
              latch1.countDown()
              try {
                // Wait until request1 makes the connection and puts it in the connection pool.
                latch2.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
            }
    
            override fun connectionAcquired(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  6. docs/en/docs/python-types.md

    #### List
    
    For example, let's define a variable to be a `list` of `str`.
    
    //// tab | Python 3.9+
    
    Declare the variable, with the same colon (`:`) syntax.
    
    As the type, put `list`.
    
    As the list is a type that contains some internal types, you put them in square brackets:
    
    ```Python hl_lines="1"
    {!> ../../docs_src/python_types/tutorial006_py39.py!}
    ```
    
    ////
    
    //// tab | Python 3.8+
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 26 11:47:53 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

      /** Guard for waiting takes */
      private final Monitor.Guard notEmpty;
    
      /** Guard for waiting puts */
      private final Monitor.Guard notFull;
    
      // Internal helper methods
    
      /** Circularly increment i. */
      final int inc(int i) {
        return (++i == items.length) ? 0 : i;
      }
    
      /**
       * Inserts element at current put position, advances, and signals. Call only when occupying
       * monitor.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  8. docs/em/docs/python-types.md

    ```Python
    {!../../docs_src/python_types/tutorial001.py!}
    ```
    
    🤙 👉 📋 🔢:
    
    ```
    John Doe
    ```
    
    🔢 🔨 📄:
    
    * ✊ `first_name` &amp; `last_name`.
    * 🗜 🥇 🔤 🔠 1️⃣ ↖ 💼 ⏮️ `title()`.
    * <abbr title="Puts them together, as one. With the contents of one after the other.">🔢</abbr> 👫 ⏮️ 🚀 🖕.
    
    ```Python hl_lines="2"
    {!../../docs_src/python_types/tutorial001.py!}
    ```
    
    ### ✍ ⚫️
    
    ⚫️ 📶 🙅 📋.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.advanceUntil(540.ms)
        assertEvents(
          "plan 2 TCP connect canceled",
        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test puts several connections in flight that all fail at approximately the same time. It
       * confirms the fast fallback implements these invariants:
       *
       *  * if there's no TCP connect in flight, start one.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. architecture/ambient/ztunnel.md

    * Ensure traffic between mesh workloads is securely encrypted with an Istio identity.
    * Be lightweight enough to not limit adoption.
      * This puts a much tighter budget on CPU, memory, latency, and throughput requirements than traditional Istio sidecars.
    
    Ztunnel was not designed to be a feature-rich data plane.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 16.8K bytes
    - Viewed (0)
Back to top