Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 351 - 360 of 1,279 for var0 (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/grid.go

    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  2. cmd/global-heal.go

    		}
    
    		healingLogIf(ctx, tracker.update(ctx))
    		close(quitting)
    	}()
    
    	var retErr error
    
    	// Heal all buckets with all objects
    	for _, bucket := range healBuckets {
    		if tracker.isHealed(bucket) {
    			continue
    		}
    
    		var forwardTo string
    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleJavadocsPlugin.java

                        "<script>" +
                        "(function() {" +
                        "var mql = window.matchMedia('(prefers-color-scheme: dark)');" +
                        "var hljsEl = document.getElementById('hljs-theme');" +
                        "function applyTheme(dark) {" +
                        "var t = dark ? 'dark' : 'light';" +
                        "document.documentElement.setAttribute('data-theme', t);" +
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Sun Mar 01 05:52:34 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  4. cmd/metacache-server-pool.go

    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    	allAtEOF := true
    	var inputs []chan metaCacheEntry
    	mu.Lock()
    	// Ask all sets and merge entries.
    	listCtx, cancelList := context.WithCancel(ctx)
    	defer cancelList()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  5. cmd/prepare-storage.go

    	"net/url"
    	"path/filepath"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    var printEndpointError = func() func(Endpoint, error, bool) {
    	var mutex sync.Mutex
    	printOnce := make(map[Endpoint]map[string]int)
    
    	return func(endpoint Endpoint, err error, once bool) {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  6. internal/event/target/kafka.go

    	EnvKafkaProducerCompressionCodec = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_CODEC"
    	EnvKafkaProducerCompressionLevel = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_LEVEL"
    )
    
    var codecs = map[string]sarama.CompressionCodec{
    	"none":   sarama.CompressionNone,
    	"gzip":   sarama.CompressionGZIP,
    	"snappy": sarama.CompressionSnappy,
    	"lz4":    sarama.CompressionLZ4,
    	"zstd":   sarama.CompressionZSTD,
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  7. schema/schema_helper_test.go

    						found = true
    					}
    				}
    
    				if !found {
    					var refs []string
    					for _, rf := range r.References {
    						var primaryKey, primaryKeySchema string
    						if rf.PrimaryKey != nil {
    							primaryKey, primaryKeySchema = rf.PrimaryKey.Name, rf.PrimaryKey.Schema.Name
    						}
    						refs = append(refs, fmt.Sprintf(
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Thu Aug 28 02:57:17 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  8. cmd/bucket-policy.go

    		}
    	}
    
    	authType := getRequestAuthType(r)
    	var signatureVersion string
    	switch authType {
    	case authTypeSignedV2, authTypePresignedV2:
    		signatureVersion = signV2Algorithm
    	case authTypeSigned, authTypePresigned, authTypeStreamingSigned, authTypePostPolicy:
    		signatureVersion = signV4Algorithm
    	}
    
    	var authtype string
    	switch authType {
    	case authTypePresignedV2, authTypePresigned:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  9. internal/crypto/key.go

    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/app/web/admin/log/AdminLogActionTest.java

            String sanitized1 = AdminLogAction.sanitizeFilename("../../../var/log/auth.log");
            assertEquals("/var/log/auth.log", sanitized1);
            assertTrue(AdminLogAction.isLogFilename(sanitized1));
    
            String sanitized2 = AdminLogAction.sanitizeFilename("....//....//var/log/syslog.log");
            assertEquals("/var/log/syslog.log", sanitized2);
            assertTrue(AdminLogAction.isLogFilename(sanitized2));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 10.5K bytes
    - Click Count (0)
Back to Top