- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for rl (0.03 sec)
-
cmd/bucket-stats.go
return } func (rl *ReplicationLastMinute) addsize(n int64) { t := time.Now().Unix() rl.LastMinute.addAll(t-1, AccElem{Total: t - 1, Size: n, N: 1}) } func (rl *ReplicationLastMinute) String() string { t := rl.LastMinute.getTotal() return fmt.Sprintf("ReplicationLastMinute sz= %d, n=%d , dur=%d", t.Size, t.N, t.Total) } func (rl *ReplicationLastMinute) getTotal() AccElem {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 11:39:51 UTC 2024 - 13.4K bytes - Viewed (0) -
bin/diff_yaml.py
res = normalize_ports(res) res = normalize_configmap(res) return res def normalize(rl, args): for i in range(len(rl)): rl[i] = normalize_res(rl[i], args) return rl def compare(args): j0 = normalize(list(yaml.safe_load_all(open(args.orig))), args) j1 = normalize(list(yaml.safe_load_all(open(args.new))), args)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Mar 03 16:14:57 UTC 2021 - 4.5K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
func TestDRLocker(t *testing.T) { wl := NewLRWMutex() var rl sync.Locker wlocked := make(chan bool, 1) rlocked := make(chan bool, 1) rl = wl.DRLocker() n := 10 go func() { for i := 0; i < n; i++ { rl.Lock() rl.Lock() rlocked <- true wl.Lock() wlocked <- true } }() for i := 0; i < n; i++ { <-rlocked rl.Unlock() select { case <-wlocked:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } for _, rl := range lcCfg.Rules { updRule, ok := updatedRules[rl.ID] // original rule had expiry that is no longer in the new config, // or rule is present but missing expiration flags if (!rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull()) &&
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
} rl = nextCommand != 0 ? nextCommand : size; if ( log.isDebugEnabled() ) { log.debug(String.format("Compound next command %d read size %d remain %d", nextCommand, rl, size)); } cur.setReadSize(rl); readn(this.in, buffer, Smb2Constants.SMB2_HEADER_LENGTH, rl - Smb2Constants.SMB2_HEADER_LENGTH);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
if err := xml.Unmarshal(meta.LifecycleConfigXML, &lcCfg); err != nil { return updatedAt, err } // find a single expiry rule set the flag for _, rl := range lcCfg.Rules { if !rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull() { expiryRuleRemoved = true break } } } // Form empty ILM details with `ExpiryUpdatedAt` field and save
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/site-replication.go
return []byte{}, err } for _, rl := range cfg.Rules { newRMap[rl.ID] = rl } xmlName = cfg.XMLName } // check if current expiry rules are there in new one. if not remove the expiration // part of rule as they may have been removed from latest updated one for id, rl := range rMap { if !rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
internal/config/certs_test.go
8f+2K4oIOlhv9RuRpI4wHwUCgYB8OjaMyn1NEsy4k2qBt4U+jhcdyEv1pbWqi/U1 qYm5FTgd44VvWVDHBGdQoMv9h28iFCJpzrU2Txv8B4y7v9Ujg+ZLIAFL7j0szt5K wTZpWvO9Q0Qb98Q2VgL2lADRiyIlglrMJnoRfiisNfOfGKE6e+eGsxI5qUxmN5e5 JQvoiQKBgQCqgyuUBIu/Qsb3qUED/o0S5wCel43Yh/Rl+mxDinOUvJfKJSW2SyEk +jDo0xw3Opg6ZC5Lj2V809LA/XteaIuyhRuqOopjhHIvIvrYGe+2O8q9/Mv40BYW 0BhJ/Gdseps0C6Z5mTT5Fee4YVlGZuyuNKmKTd4JmqInfBV3ncMWQg== -----END RSA PRIVATE KEY-----`, certificate: `-----BEGIN CERTIFICATE-----
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 21.6K bytes - Viewed (0) -
okhttp/src/main/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.gz
grondar.za grong.no grosseto.it groundhandling.aero group group.aero grozny.ru grozny.su grp.lk gru.br grue.no gs gs.aa.no gs.ah.no gs.bu.no gs.cn gs.fm.no gs.hl.no gs.hm.no gs.jan-mayen.no gs.mr.no gs.nl.no gs.nt.no gs.of.no gs.ol.no gs.oslo.no gs.rl.no gs.sf.no gs.st.no gs.svalbard.no gs.tm.no gs.tr.no gs.va.no gs.vf.no gsj.bz gsm.pl gt gu gu.us guam.gu guardian gub.uy gucci guernsey.museum guge guide guitars gujarat.in gujo.gifu.jp gulen.no gunma.jp guovdageaidnu.no guru gushikami.okinawa.jp gv.ao...
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 40.4K bytes - Viewed (1) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
nl.no nt.no of.no ol.no oslo.no rl.no sf.no st.no svalbard.no tm.no tr.no va.no vf.no // primary and lower secondary schools per county gs.aa.no gs.ah.no gs.bu.no gs.fm.no gs.hl.no gs.hm.no gs.jan-mayen.no gs.mr.no gs.nl.no gs.nt.no gs.of.no gs.ol.no gs.oslo.no gs.rl.no gs.sf.no gs.st.no gs.svalbard.no
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 240.3K bytes - Viewed (0)