Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for barrier (0.18 sec)

  1. cmd/xl-storage.go

    	// bigFileThreshold is the point where we add readahead to put operations.
    	bigFileThreshold = 128 * humanize.MiByte
    
    	// XL metadata file carries per object metadata.
    	xlStorageFormatFile = "xl.meta"
    
    	// XL metadata file backup file carries previous per object metadata.
    	xlStorageFormatFileBackup = "xl.meta.bkp"
    )
    
    var alignedBuf []byte
    
    func init() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    }
    
    // PutObject - creates an object upon reading from the input stream
    // until EOF, erasure codes the data across all disk and additionally
    // writes `xl.meta` which carries the necessary metadata for future
    // object operations.
    func (er erasureObjects) PutObject(ctx context.Context, bucket string, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. internal/bucket/lifecycle/lifecycle_test.go

    		NumVersions: 4,
    	}
    
    	event := lc.eval(opts, time.Time{})
    	if event.Action != TransitionAction {
    		t.Fatalf("Expected %v action but got %v", TransitionAction, event.Action)
    	}
    	// The earlier upcoming lifecycle event must be picked, i.e rule with id "Transition-10"
    	if exp := ExpectedExpiryTime(opts.ModTime, 10); exp != event.Due {
    		t.Fatalf("Expected due %v but got %v, ruleID=%v", exp, event.Due, event.RuleID)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  4. istioctl/pkg/describe/describe.go

    	possibleDests := len(vs.Spec.Http) + len(vs.Spec.Tls) + len(vs.Spec.Tcp)
    	if matches < possibleDests {
    		// We've printed the match conditions.  We can't say for sure that matching
    		// traffic will reach this pod, because an earlier match condition could have captured it.
    		fmt.Fprintf(writer, "%s%d additional destination(s) that will not reach this pod\n",
    			printSpaces(initPrintNum+printLevel1), possibleDests-matches)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    				Kind:     kind,
    				KeyID:    keyID,
    				KmsCtx:   kmsCtx,
    				Checksum: checksum,
    			}
    		}
    	}
    
    	if len(fanOutEntries) > 0 {
    		// Fan-out requires no copying, and must be carried from original source
    		// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream
    		// is always going to be in-memory as we cannot re-read from what we
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    }
    
    // xlMetaV2Version describes the journal entry, Type defines
    // the current journal entry type other types might be nil based
    // on what Type field carries, it is imperative for the caller
    // to verify which journal type first before accessing rest of the fields.
    type xlMetaV2Version struct {
    	Type             VersionType           `json:"Type" msg:"Type"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
Back to top