Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for je (0.14 sec)

  1. cmd/tier-journal.go

    		case <-ctx.Done():
    			jd.Close()
    			return
    		}
    	}
    }
    
    func (jd *tierDiskJournal) addEntry(je jentry) error {
    	// Open journal if it hasn't been
    	err := jd.Open()
    	if err != nil {
    		return err
    	}
    
    	b, err := je.MarshalMsg(nil)
    	if err != nil {
    		return err
    	}
    
    	jd.Lock()
    	defer jd.Unlock()
    	_, err = jd.file.Write(b)
    	if err != nil {
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  2. cmd/tier-sweeper.go

    		}, true
    	}
    	return jentry{}, false
    }
    
    // Sweep removes the transitioned object if it's no longer referred to.
    func (os *objSweeper) Sweep() {
    	if je, ok := os.shouldRemoveRemoteObject(); ok {
    		globalExpiryState.enqueueTierJournalEntry(je)
    	}
    }
    
    type jentry struct {
    	ObjName   string
    	VersionID string
    	TierName  string
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    // non-versioned or version suspended buckets.
    func (es *expiryState) enqueueTierJournalEntry(je jentry) {
    	wrkr := es.getWorkerCh(je.OpHash())
    	if wrkr == nil {
    		es.stats.missedTierJournalTasks.Add(1)
    		return
    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- je:
    	default:
    		es.stats.missedTierJournalTasks.Add(1)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. cmd/tier-journal_test.go

    		b.Write(bs)
    	}
    
    	mr := msgp.NewReader(&b)
    	for i, item := range readOldToNewCases {
    		var je jentry
    		err := je.DecodeMsg(mr)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if je != item.exp {
    			t.Errorf("Case %d: Expected: %v Got: %v", i, item.exp, je)
    		}
    	}
    }
    
    // TestJEntryWriteNewToOldMix1 - tests that adding the RemoteVersionID parameter
    // to the jentry struct does not cause unexpected errors when writing. This
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jun 03 21:26:51 GMT 2021
    - 3.2K bytes
    - Viewed (0)
  5. cmd/tier-mem-journal.go

    		}
    	}
    }
    
    func (j *tierMemJournal) AddEntry(je jentry) error {
    	select {
    	case j.entries <- je:
    	default:
    		return fmt.Errorf("failed to remove tiered content at %s with version %s from tier %s, will be retried later.",
    			je.ObjName, je.VersionID, je.TierName)
    	}
    	return nil
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Aug 03 21:16:15 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  6. cmd/testdata/undeleteable-object.tgz

    §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘|ªPartASizes‘|¤Size|¥MTimeÓ É ¥— H§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ cfc3c55bdcdef4cf23f6¬content-typeªtext/plain¡v ίFwÆ ¤nullÄ2 w ´zrETç™ËÝÜÆà áÎÅFHM!…JE¼wu?ÐngConfiguration> multisitea/data/disterasure/xl3/.minio.sys/config/history/38a3dbcb-a58f-4811-bf09-3bc6b7fbee05.kv/xl.meta XL2 Æ w Ä$•Ä Ó É ¸í80Ä yÅ Y Å Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ‰ Z•`=A#µß ñN`áÚ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Viewed (0)
  7. cmd/testdata/xl-meta-consist.zip

    £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistš ¨CSumAlgo ¨PartNums‘ ©PartETags‘ ©PartSizes‘Ò 'ªPartASizes‘Ò '¤SizeÒ 'Â¥MTimeÓ ¿W '’žÉ§MetaSys ¼X-Minio-Internal-actual-sizeÄ 141250§MetaUsr‚¤etagÙ"51fe09d68bacc8c5a68a-1¬content-type¸application/octet-stream΢JE" 8/xl.meta XL2 Æ b ¨Versions‘‚¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÔLã°ê8EÒŸˆ”Ù Sé6¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistš ¨CSumAlgo ¨PartNums‘ ©PartETags‘ ©PartSizes‘Ò 'ªPartASizes‘Ò '¤SizeÒ 'Â¥MTimeÓ ¿W '’žÉ§MetaSys ¼X-Minio-Internal-actual-sizeÄ 14...
    ZIP Archive
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 19 18:48:00 GMT 2022
    - 4.1K bytes
    - Viewed (0)
Back to top