Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 94 for modTimes (0.17 sec)

  1. internal/bucket/lifecycle/lifecycle.go

    func ExpectedExpiryTime(modTime time.Time, days int) time.Time {
    	if days == 0 {
    		return modTime
    	}
    	t := modTime.UTC().Add(time.Duration(days+1) * 24 * time.Hour)
    	return t.Truncate(24 * time.Hour)
    }
    
    // SetPredictionHeaders sets time to expiry and transition headers on w for a
    // given obj.
    func (lc Lifecycle) SetPredictionHeaders(w http.ResponseWriter, obj ObjectOpts) {
    	event := lc.eval(obj, time.Time{})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  2. cmd/untar.go

    						asyncErr = err
    					}
    					asyncErrMu.Unlock()
    				}
    			}(name, header.FileInfo(), b)
    			continue
    		}
    
    		// If zero or earlier modtime, set to current.
    		// Otherwise the resulting objects will be invalid.
    		if header.ModTime.UnixNano() <= 0 {
    			header.ModTime = time.Now()
    		}
    
    		// Sync upload.
    		rc := disconnectReader{r: tarReader}
    		if err := putObject(&rc, header.FileInfo(), name); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    		}
    		return
    	}
    
    	// New object info
    	fileObjInfo := ObjectInfo{
    		Bucket:      bucket,
    		Name:        object,
    		Size:        int64(file.UncompressedSize64),
    		ModTime:     zipObjInfo.ModTime,
    		ContentType: mime.TypeByExtension(filepath.Ext(object)),
    	}
    
    	var rc io.ReadCloser
    
    	if file.UncompressedSize64 > 0 {
    		// There may be number of header bytes before the content.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2-legacy.go

    		return
    	}
    	bts, err = msgp.ReadExactBytes(bts, (x.VersionID)[:])
    	if err != nil {
    		err = msgp.WrapError(err, "VersionID")
    		return
    	}
    	x.ModTime, bts, err = msgp.ReadInt64Bytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err, "ModTime")
    		return
    	}
    	{
    		var zb0002 uint8
    		zb0002, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err, "Type")
    			return
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  5. cmd/erasure-metadata_test.go

    	}
    	tests := []struct {
    		fis                 []FileInfo
    		modTime             time.Time
    		succmodTimes        []time.Time
    		expectedErr         error
    		expectedQuorum      int
    		expectedSuccModTime time.Time
    		expectedIsLatest    bool
    	}{
    		{
    			fis:            getNFInfo(16, 16, 1603863445, "36a21454-a2ca-11eb-bbaa-93a81c686f21", nil),
    			modTime:        time.Unix(1603863445, 0),
    			expectedErr:    nil,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v1_gen.go

    			}
    		case "ActualSize":
    			z.ActualSize, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "ActualSize")
    				return
    			}
    		case "ModTime":
    			z.ModTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "ModTime")
    				return
    			}
    		case "index":
    			z.Index, err = dc.ReadBytes(z.Index)
    			if err != nil {
    				err = msgp.WrapError(err, "Index")
    				return
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 40.2K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_test.go

    				}
    			}
    		})
    		t.Run(fmt.Sprintf("modtime-q%d", i), func(t *testing.T) {
    			// Mutate modtime, but rest is consistent.
    			vMod := make([][]xlMetaV2ShallowVersion, 0, len(vers))
    			for i, ver := range vers {
    				newVers := make([]xlMetaV2ShallowVersion, 0, len(ver))
    				for _, v := range ver {
    					v.header.ModTime += int64(i)
    					newVers = append(newVers, v)
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  8. internal/store/queuestore.go

    	sort.Slice(files, func(i, j int) bool {
    		ii, err := files[i].Info()
    		if err != nil {
    			return false
    		}
    		ji, err := files[j].Info()
    		if err != nil {
    			return true
    		}
    		return ii.ModTime().Before(ji.ModTime())
    	})
    
    	return files, nil
    }
    
    // Extension will return the file extension used
    // for the items stored in the queue.
    func (store *QueueStore[_]) Extension() string {
    	return store.fileExt
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  9. cmd/storage-datatypes_test.go

    func BenchmarkDecodeFileInfoMsgp(b *testing.B) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  10. cmd/metacache-entries_test.go

    					VersionID: [16]byte{},
    					ModTime:   baseTime.Add(60 * time.Minute).UnixNano(),
    					Signature: [4]byte{5, 1, 1, 1},
    					Type:      ObjectType,
    					Flags:     0,
    				}},
    			},
    		},
    		// Zero version, modtime newer..
    		6: {
    			versions: []xlMetaV2ShallowVersion{
    				{header: xlMetaV2VersionHeader{
    					VersionID: [16]byte{},
    					ModTime:   baseTime.Add(90 * time.Minute).UnixNano(),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 31.6K bytes
    - Viewed (0)
Back to top