Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 104 for stacked (0.23 sec)

  1. cmd/object-handlers.go

    		sha256hex = ""
    	}
    
    	var forceMD5 []byte
    	// Optimization: If SSE-KMS and SSE-C did not request Content-Md5. Use uuid as etag. Optionally enable this also
    	// for server that is started with `--no-compat`.
    	if !etag.ContentMD5Requested(r.Header) && (crypto.S3KMS.IsRequested(r.Header) || crypto.SSEC.IsRequested(r.Header) || !globalServerCtxt.StrictS3Compat) {
    		forceMD5 = mustGetUUIDBytes()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  2. cmd/iam.go

    // Init - initializes config system by reading entries from config/iam
    func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) {
    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    	s := globalServerConfig
    	globalServerConfigMu.RUnlock()
    
    	openidConfig, err := openid.LookupConfig(s,
    		NewHTTPTransport(), xhttp.DrainBody, globalSite.Region)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. internal/grid/grid_test.go

    				started := time.Now()
    				dl, _ := ctx.Deadline()
    				if testing.Verbose() {
    					fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl))
    				}
    				<-ctx.Done()
    				serverCanceled <- time.Since(started)
    				if testing.Verbose() {
    					fmt.Println(GetCaller(ctx).Name, "Server Context canceled with", ctx.Err(), "after", time.Since(started))
    				}
    				return nil
    			},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  4. cmd/leak-detect_test.go

    	"signal.signal_recv",
    	"sigterm.handler",
    	"runtime_mcall",
    	"goroutine in C code",
    }
    
    // Identify whether the stack trace entry is part of ignoredStackFn .
    func isIgnoredStackFn(stack string) (ok bool) {
    	ok = true
    	for _, stackFn := range ignoredStackFns {
    		if !strings.Contains(stack, stackFn) {
    			ok = false
    			continue
    		}
    		break
    	}
    	return ok
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  5. cmd/signature-v4-parser.go

    	// credElement is fetched first to skip replacing the space in access key.
    	credElement := strings.TrimPrefix(strings.Split(strings.TrimSpace(v4Auth), ",")[0], signV4Algorithm)
    	// Replace all spaced strings, some clients can send spaced
    	// parameters and some won't. So we pro-actively remove any spaces
    	// to make parsing easier.
    	v4Auth = strings.ReplaceAll(v4Auth, " ", "")
    	if v4Auth == "" {
    		return sv, ErrAuthHeaderEmpty
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	}
    	return p.Pools[idx].Decommission != nil
    }
    
    func (p *poolMeta) validate(pools []*erasureSets) (bool, error) {
    	type poolInfo struct {
    		position     int
    		completed    bool
    		decomStarted bool // started but not finished yet
    	}
    
    	rememberedPools := make(map[string]poolInfo)
    	for idx, pool := range p.Pools {
    		complete := false
    		decomStarted := false
    		if pool.Decommission != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  7. cmd/background-newdisks-heal-ops_gen.go

    				return
    			}
    		case "Endpoint":
    			z.Endpoint, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Endpoint")
    				return
    			}
    		case "Started":
    			z.Started, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "Started")
    				return
    			}
    		case "LastUpdate":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 17:05:40 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    				"(use force-start option to stop and start afresh). " +
    				fmt.Sprintf("The heal was started by IP %s at %s, token is %s",
    					h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken)
    			return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg
    		}
    	}
    
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	// Check if new heal sequence to be started overlaps with any
    	// existing, running sequence
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  9. docs/debugging/pprofgoparser/main.go

    		fmt.Println(profFName)
    		fmt.Println(strings.Repeat("=", len(profFName)))
    		fmt.Println("")
    
    		for t, stacks := range r {
    			if less != 0 && t >= less {
    				continue
    			}
    			if goTime == 0 || math.Abs(float64(t)-float64(goTime)) <= float64(margin) {
    				for _, stack := range stacks {
    					fmt.Println(stack)
    				}
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 06 11:43:16 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    		b, err := r.nextSplit(0, nil)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top