Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 78 for dopts (0.03 sec)

  1. cmd/object-api-utils.go

    				}
    				oi.Size = decLength
    			}
    			// Decompression reader.
    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    	downloadsCtx, downloadsCancel := context.WithTimeout(ctx, opts.duration)
    	defer downloadsCancel()
    
    	gopts := minio.GetObjectOptions{}
    	gopts.Set(globalObjectPerfUserMetadata, "true") // Bypass S3 API freeze
    
    	var downloadTimes madmin.TimeDurations
    	var downloadTTFB madmin.TimeDurations
    	wg.Add(opts.concurrency)
    
    	c := minio.Core{Client: clnt}
    	for i := 0; i < opts.concurrency; i++ {
    		go func(i int) {
    			defer wg.Done()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    		return
    	}
    
    	// Validate pre-conditions if any.
    	opts.CheckPrecondFn = func(oi ObjectInfo) bool {
    		if _, err := DecryptObjectInfo(&oi, r); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return true
    		}
    
    		return checkPreconditions(ctx, w, r, oi, opts)
    	}
    
    	zipObjInfo, err := getObjectInfo(ctx, bucket, zipPath, opts)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (info DiskInfo, err error) {
    			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			defer cancel()
    
    			nopts := DiskInfoOptions{DiskID: *client.diskID.Load(), Metrics: true}
    			infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &nopts)
    			if err != nil {
    				return info, toStorageErr(err)
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle.go

    	}
    	gopts := WarmBackendGetOpts{}
    
    	// get correct offsets for object
    	if off >= 0 && length >= 0 {
    		gopts.startOffset = off
    		gopts.length = length
    	}
    
    	timeTierAction := auditTierActions(ctx, oi.TransitionedObject.Tier, length)
    	reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts)
    	if err != nil {
    		return nil, err
    	}
    	closer := func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    	if b > 0 && b == a {
    		opts.Error = fmt.Sprintf("unable to heal %d missing blocks on drives", b)
    	}
    
    	opts.Tags = map[string]string{
    		"healObject": auditObjectOp{
    			Name: opts.Object,
    			Pool: er.poolIndex + 1,
    			Set:  er.setIndex + 1,
    		}.String(),
    	}
    
    	auditLogInternal(ctx, opts)
    }
    
    // Heals an object by re-writing corrupt/missing erasure blocks.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    				idxCb = compressionIndexEncrypter(objectEncryptionKey, idxCb)
    			}
    			opts.EncryptFn = metadataEncrypter(objectEncryptionKey)
    		}
    	}
    	opts.IndexCB = idxCb
    
    	opts.ReplicationRequest = sourceReplReq
    	putObjectPart := objectAPI.PutObjectPart
    
    	partInfo, err := putObjectPart(ctx, bucket, object, uploadID, partID, pReader, opts)
    	if err != nil {
    		// Verify if the underlying error is signature mismatch.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. cmd/notification.go

    		if report == nil || report.BucketStats == nil {
    			continue
    		}
    		for opts := range report.BucketStats {
    			d, ok := consolidatedReport.BucketStats[opts]
    			if !ok {
    				d = bandwidth.Details{
    					LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond,
    				}
    			}
    			dt, ok := report.BucketStats[opts]
    			if ok {
    				d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  9. tensorflow/c/BUILD

        srcs = ["tf_shape.cc"],
        hdrs = ["tf_shape.h"],
        copts = tf_copts(),
        visibility = ["//visibility:public"],
        deps = [
            ":c_api_macros",
            ":tf_shape_internal",
            "//tensorflow/core:framework",
        ],
    )
    
    cc_library(
        name = "tf_shape_internal",
        hdrs = ["tf_shape_internal.h"],
        copts = tf_copts(),
        visibility = ["//tensorflow:internal"],
        deps = [
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Oct 24 19:09:45 UTC 2024
    - 30.4K bytes
    - Viewed (0)
  10. cmd/object-api-options.go

    	opts, err = getDefaultOpts(hdr, false, metadata)
    	if err != nil {
    		return opts, err
    	}
    
    	opts.MTime = mtime
    	opts.ReplicationSourceLegalholdTimestamp = lholdtimestmp
    	opts.ReplicationSourceRetentionTimestamp = retaintimestmp
    	opts.ReplicationSourceTaggingTimestamp = taggingtimestmp
    	opts.PreserveETag = etag
    	opts.WantChecksum = wantCRC
    
    	return opts, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top