Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 198 for spool (0.02 sec)

  1. docs/changelogs/changelog_4x.md

        of unacknowledged data per stream and no per-connection limit.
    
     *  Fix: Don't operate on a connection after it's been returned to the pool. This race occurred
        on failed web socket connection attempts.
    
     *  Upgrade: [Okio 3.6.0][okio_3_6_0].
    
     *  Upgrade: [Kotlin 1.8.21][kotlin_1_8_21].
    
    
    ## Version 4.11.0
    
    _2023-04-22_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test causes two connections to become available simultaneously, one from a TCP connect and
       * one from the pool. We must take the pooled connection because by taking it from the pool, we've
       * fully acquired it.
       *
       * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
       * particular, we set up this sequence of events:
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) // return the disks belonging to pool and set.
    	SetDriveCounts() []int                              // list of erasure stripe size for each pool in order.
    
    	// Healing operations.
    	HealFormat(ctx context.Context, dryRun bool) (madmin.HealResultItem, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. docs/logging/README.md

    NOTE:
    
    - `timeToFirstByte` and `timeToResponse` will be expressed in Nanoseconds.
    - Additionally in the case of the erasure coded setup `tags.objectLocation` provides per object details about
      - Pool number the object operation was performed on.
      - Set number the object operation was performed on.
      - The list of drives participating in this operation belong to the set.
    
    ```json
    {
      "version": "1",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 17:15:03 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. internal/pubsub/pubsub.go

    package pubsub
    
    import (
    	"bytes"
    	"encoding/json"
    	"fmt"
    	"sync"
    	"sync/atomic"
    )
    
    // GetByteBuffer returns a byte buffer from the pool.
    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    	filter func(entry T) bool
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. okhttp/src/main/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) {
                return connectResult.plan.handleSuccess()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. istioctl/pkg/xds/google.go

    	systemRoots, err := x509.SystemCertPool()
    	if err != nil {
    		return nil, fmt.Errorf("failed to get system cert pool: %w", err)
    	}
    	gcpCreds, err := oauth.NewApplicationDefault(ctx)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get application default credentials: %w", err)
    	}
    
    	return []grpc.DialOption{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Nov 14 20:23:34 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    			// No ellipses pattern. Anonymize host name from every pool arg
    			pools := strings.Fields(poolsArgs)
    			anonPools = make([]string, len(pools))
    			for index, arg := range pools {
    				anonPools[index] = anonAddr(arg)
    			}
    			return cmdLineWithoutPools + strings.Join(anonPools, " ")
    		}
    
    		// Ellipses pattern in pool args. Regex groups:
    		// 1 - server prefix
    		// 2 - number sequence for servers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	}
    }
    
    type auditObjectOp struct {
    	Name string `json:"name"`
    	Pool int    `json:"poolId"`
    	Set  int    `json:"setId"`
    }
    
    func (op auditObjectOp) String() string {
    	// Flatten the auditObjectOp
    	return fmt.Sprintf("name=%s,pool=%d,set=%d", op.Name, op.Pool, op.Set)
    }
    
    // Add erasure set information to the current context
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  10. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      // A sequence of thread wrappers, one per device, for executing operations in
      // parallel.
      //
      // Conceptually this is a thread pool with one thread per device. It requires
      // less synchronization than a thread pool would for this task, since Execute
      // acquires each thread in order (and so only one Execute will schedule
      // blocking collective operations at a time), and avoids some dynamic
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
Back to top