Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for spool (0.06 sec)

  1. cmd/bucket-replication.go

    		priority:        priority,
    		maxWorkers:      maxWorkers,
    		maxLWorkers:     maxLWorkers,
    	}
    
    	pool.ResizeLrgWorkers(maxLWorkers, 0)
    	pool.ResizeWorkers(workers, 0)
    	pool.ResizeFailedWorkers(failedWorkers)
    	go pool.resyncer.PersistToDisk(ctx, o)
    	go pool.processMRF()
    	go pool.persistMRF()
    	return pool
    }
    
    // AddMRFWorker adds a pending/failed replication worker to handle requests that could not be queued
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  2. 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)
  3. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    `he's perfectly idiotic!'  And she opened the door and went in.
    
      The door led right into a large kitchen, which was full of
    smoke from one end to the other:  the Duchess was sitting on a
    three-legged stool in the middle, nursing a baby; the cook was
    leaning over the fire, stirring a large cauldron which seemed to
    be full of soup.
    
      `There's certainly too much pepper in that soup!' Alice said to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 29 21:35:03 UTC 2012
    - 145.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CallTest.kt

            .build()
        assertThat(client.retryOnConnectionFailure).isTrue()
        executeSynchronously("/").assertBody("seed connection pool")
        executeSynchronously("/").assertBody("retry success")
    
        // The call that seeds the connection pool.
        listener.removeUpToEvent(CallEnd::class.java)
    
        // The ResponseFailed event is not necessarily fatal!
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

              .build(),
          )
        }
      }
    
      private fun testServerClosesOutput(socketPolicy: SocketPolicy) {
        server.enqueue(
          MockResponse(
            body = "This connection won't pool properly",
            socketPolicy = socketPolicy,
          ),
        )
        val responseAfter = MockResponse(body = "This comes after a busted connection")
        server.enqueue(responseAfter)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  6. api/go1.3.txt

    pkg regexp/syntax, method (InstOp) String() string
    pkg runtime/debug, func SetPanicOnFault(bool) bool
    pkg runtime/debug, func WriteHeapDump(uintptr)
    pkg sync, method (*Pool) Get() interface{}
    pkg sync, method (*Pool) Put(interface{})
    pkg sync, type Pool struct
    pkg sync, type Pool struct, New func() interface{}
    pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error
    pkg syscall (darwin-386), func Mlock([]uint8) error
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jun 02 02:45:00 UTC 2014
    - 117K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    		metrics = append(metrics, MetricV2{
    			Description: getClusterHealthStatusMD(),
    			Value:       float64(health),
    		})
    
    		for _, h := range result.ESHealth {
    			labels := map[string]string{
    				"pool": strconv.Itoa(h.PoolID),
    				"set":  strconv.Itoa(h.SetID),
    			}
    			metrics = append(metrics, MetricV2{
    				Description:    getClusterErasureSetReadQuorumMD(),
    				VariableLabels: labels,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.4.md

    * azure: add PrimaryAvailabilitySet to config, only use nodes in that set in the loadbalancer pool ([#34526](https://github.com/kubernetes/kubernetes/pull/34526), [@colemickens](https://github.com/colemickens))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.5.md

    * azure: add PrimaryAvailabilitySet to config, only use nodes in that set in the loadbalancer pool ([#34526](https://github.com/kubernetes/kubernetes/pull/34526), [@colemickens](https://github.com/colemickens))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
  10. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    camdvr.org
    freeddns.org
    mywire.org
    webredirect.org
    myddns.rocks
    blogsite.xyz
    
    // dynv6 : https://dynv6.com
    // Submitted by Dominik Menke <******@****.***>
    dynv6.net
    
    // E4YOU spol. s.r.o. : https://e4you.cz/
    // Submitted by Vladimir Dudr <******@****.***>
    e4.cz
    
    // Easypanel : https://easypanel.io
    // Submitted by Andrei Canta <******@****.***>
    easypanel.app
    easypanel.host
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 240.3K bytes
    - Viewed (0)
Back to top