Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 141 for _shards (0.28 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        client.send(message4)
        serverListener.assertTextMessage(message4)
    
        // Server to client message that shares context with message1.
        val message5 = message1 + message1
        server.send(message5)
        clientListener.assertTextMessage(message5)
    
        // Client to server message that shares context with message2.
        val message6 = message2 + message2
        client.send(message6)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/HashMultisetTest.java

        assertEquals(2, copy.size());
        assertSame(copy, copy.iterator().next().member);
      }
    
      /*
       * The behavior of toString() and iteration is tested by LinkedHashMultiset,
       * which shares a lot of code with HashMultiset and has deterministic
       * iteration order.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. cmd/bitrot-whole.go

    	"hash"
    	"io"
    )
    
    // Implementation to calculate bitrot for the whole file.
    type wholeBitrotWriter struct {
    	disk      StorageAPI
    	volume    string
    	filePath  string
    	shardSize int64 // This is the shard size of the erasure logic
    	hash.Hash       // For bitrot hash
    }
    
    func (b *wholeBitrotWriter) Write(p []byte) (int, error) {
    	err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. cmd/notification.go

    	// To avoid these problems we must split the work at scale. With 1000 node
    	// setup becoming a reality we must try to shard the work properly such as
    	// pick 10 nodes that precisely can send those 100 requests the first node
    	// in the 10 node shard would coordinate between other 9 shards to get the
    	// rest of the `99*9` requests.
    	//
    	// This essentially splits the workload properly and also allows for network
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

        this.executorServiceOrNull = executorService
      }
    
      internal fun enqueue(call: AsyncCall) {
        synchronized(this) {
          readyAsyncCalls.add(call)
    
          // Mutate the AsyncCall so that it shares the AtomicInteger of an existing running call to
          // the same host.
          if (!call.call.forWebSocket) {
            val existingCall = findExistingCallWithHost(call.host)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  6. LICENSES/vendor/github.com/containerd/errdefs/pkg/LICENSE

          "control" means (i) the power, direct or indirect, to cause the
          direction or management of such entity, whether by contract or
          otherwise, or (ii) ownership of fifty percent (50%) or more of the
          outstanding shares, or (iii) beneficial ownership of such entity.
    
          "You" (or "Your") shall mean an individual or Legal Entity
          exercising permissions granted by this License.
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Mar 05 11:36:39 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  7. LICENSE.txt

          "control" means (i) the power, direct or indirect, to cause the
          direction or management of such entity, whether by contract or
          otherwise, or (ii) ownership of fifty percent (50%) or more of the
          outstanding shares, or (iii) beneficial ownership of such entity.
    
          "You" (or "Your") shall mean an individual or Legal Entity
          exercising permissions granted by this License.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 23 14:02:28 UTC 2012
    - 11.1K bytes
    - Viewed (0)
  8. LICENSES/vendor/github.com/containerd/ttrpc/LICENSE

          "control" means (i) the power, direct or indirect, to cause the
          direction or management of such entity, whether by contract or
          otherwise, or (ii) ownership of fifty percent (50%) or more of the
          outstanding shares, or (iii) beneficial ownership of such entity.
    
          "You" (or "Your") shall mean an individual or Legal Entity
          exercising permissions granted by this License.
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Fri May 08 04:49:00 UTC 2020
    - 11.2K bytes
    - Viewed (0)
  9. LICENSES/vendor/github.com/coreos/go-systemd/v22/LICENSE

    indirect, to cause the direction or management of such entity, whether by
    contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the
    outstanding shares, or (iii) beneficial ownership of such entity.
    
    "You" (or "Your") shall mean an individual or Legal Entity exercising
    permissions granted by this License.
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Jun 16 15:14:16 UTC 2021
    - 10.2K bytes
    - Viewed (0)
  10. LICENSE

          "control" means (i) the power, direct or indirect, to cause the
          direction or management of such entity, whether by contract or
          otherwise, or (ii) ownership of fifty percent (50%) or more of the
          outstanding shares, or (iii) beneficial ownership of such entity.
    
          "You" (or "Your") shall mean an individual or Legal Entity
          exercising permissions granted by this License.
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Mon Jan 11 04:26:17 UTC 2021
    - 11.1K bytes
    - Viewed (0)
Back to top