Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 106 for spool (0.03 sec)

  1. cmd/rebalstatus_string.go

    // Code generated by "stringer -type=rebalStatus -trimprefix=rebal erasure-server-pool-rebalance.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[rebalNone-0]
    	_ = x[rebalStarted-1]
    	_ = x[rebalCompleted-2]
    	_ = x[rebalStopped-3]
    	_ = x[rebalFailed-4]
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 795 bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
    	for pool := range globalLocalSetDrives {
    		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
    		for set := range globalLocalSetDrives[pool] {
    			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
    		}
    	}
    	for _, serverPool := range endpointServerPools {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  3. cmd/decommetric_string.go

    // Code generated by "stringer -type=decomMetric -trimprefix=decomMetric erasure-server-pool-decom.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[decomMetricDecommissionBucket-0]
    	_ = x[decomMetricDecommissionObject-1]
    	_ = x[decomMetricDecommissionRemoveObject-2]
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 10 19:46:45 UTC 2022
    - 830 bytes
    - Viewed (0)
  4. tests/test_inherited_custom_class.py

        def __str__(self):
            return self.uuid
    
        @property  # type: ignore
        def __class__(self):
            return uuid.UUID
    
        @property
        def __dict__(self):
            """Spoof a missing __dict__ by raising TypeError, this is how
            asyncpg.pgroto.pgproto.UUID behaves"""
            raise TypeError("vars() argument must have __dict__ attribute")
    
    
    @needs_pydanticv2
    def test_pydanticv2():
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:13:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. internal/grid/handlers.go

    				if rc, ok := any(r).(Recycler); ok {
    					rc.Recycle()
    				}
    			}
    		}
    	}
    	pool := sync.Pool{
    		New: func() interface{} {
    			return newRT()
    		},
    	}
    	return func() RT { return pool.Get().(RT) },
    		func(r RT) {
    			if r != rZero {
    				//nolint:staticcheck // SA6002 IT IS A GENERIC VALUE!
    				pool.Put(r)
    			}
    		}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  6. .github/workflows/run-mint.sh

    docker-compose -f minio-${MODE}.yaml up -d
    sleep 1m
    
    docker system prune -f || true
    docker volume prune -f || true
    docker volume rm $(docker volume ls -q -f dangling=true) || true
    
    # Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there
    [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2
    [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  7. internal/grid/grid.go

    	// Used if no deadline is provided on context.
    	defaultSingleRequestTimeout = time.Minute
    )
    
    var internalByteBuffer = sync.Pool{
    	New: func() any {
    		m := make([]byte, 0, defaultBufferSize)
    		return &m
    	},
    }
    
    var internal32KByteBuffer = sync.Pool{
    	New: func() any {
    		m := make([]byte, 0, biggerBufMin)
    		return &m
    	},
    }
    
    // GetByteBuffer can be replaced with a function that returns a small
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. ci/official/utilities/generate_index_html.sh

    cat > "$1" <<EOF
    <html>
    <head>
    <title>$(basename "$KOKORO_JOB_NAME")</title>
    </head>
    <body>
    <h1>TensorFlow Job Logs and Links</h1>
    <h2>Job Details</h2>
    <ul>
    <li>Job name: $KOKORO_JOB_NAME</li>
    <li>Job pool: $KOKORO_JOB_POOL</li>
    <li>Job ID: $KOKORO_BUILD_ID</li>
    <li>Current HEAD Piper Changelist, if any: cl/${KOKORO_PIPER_CHANGELIST:-not available}</li>
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Sep 29 20:26:13 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  10. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top