Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for karen (0.15 sec)

  1. internal/bucket/lifecycle/lifecycle.go

    	var events []Event
    	if obj.ModTime.IsZero() {
    		return Event{}
    	}
    
    	// Handle expiry of restored object; NB Restored Objects have expiry set on
    	// them as part of RestoreObject API. They aren't governed by lifecycle
    	// rules.
    	if !obj.RestoreExpires.IsZero() && now.After(obj.RestoreExpires) {
    		action := DeleteRestoredAction
    		if !obj.IsLatest {
    			action = DeleteRestoredVersionAction
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 17K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    // sizeHistogram
    func (h *sizeHistogram) mergeV1(v sizeHistogramV1) {
    	var oidx, nidx int
    	for oidx < len(v) {
    		intOld, intNew := ObjectsHistogramIntervalsV1[oidx], ObjectsHistogramIntervals[nidx]
    		// skip intervals that aren't common to both histograms
    		if intOld.start != intNew.start || intOld.end != intNew.end {
    			nidx++
    			continue
    		}
    		h[nidx] += v[oidx]
    		oidx++
    		nidx++
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  3. src/cmd/asm/internal/asm/expr_test.go

    	{"3>>(1<<63)", "negative right shift count"},
    	{"(1<<63)>>2", "right shift of value with high bit set"},
    	{"(1<<62)>>2", ""},
    	{`'\x80'`, "illegal UTF-8 encoding for character constant"},
    	{"(23*4", "missing closing paren"},
    	{")23*4", "unexpected ) evaluating expression"},
    	{"18446744073709551616", "value out of range"},
    }
    
    func TestBadExpr(t *testing.T) {
    	for i, test := range badExprTests {
    		err := runBadTest(i, test, t)
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	}
    	return b, noError, ""
    }
    
    // PopHealStatusJSON - Called by heal-status API. It fetches the heal
    // status results from global state and returns its JSON
    // representation. The clientToken helps ensure there aren't
    // conflicting clients fetching status.
    func (ahs *allHealState) PopHealStatusJSON(hpath string,
    	clientToken string) ([]byte, APIErrorCode,
    ) {
    	// fetch heal state for given path
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  5. src/cmd/cgo/gcc.go

    			n.Kind = "not-type"
    		}
    		needType = append(needType, n)
    	}
    	if nerrors > 0 {
    		// Check if compiling the preamble by itself causes any errors,
    		// because the messages we've printed out so far aren't helpful
    		// to users debugging preamble mistakes. See issue 8442.
    		preambleErrors := p.gccErrors([]byte(builtinProlog + f.Preamble))
    		if len(preambleErrors) > 0 {
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Thu Nov 02 16:43:23 GMT 2023
    - 97K bytes
    - Viewed (0)
  6. internal/grid/handlers.go

    // AllowCallRequestPool indicates it is safe to reuse the request
    // on the client side, meaning the request is recycled/pooled when a request is sent.
    // CAREFUL: This should only be used when there are no pointers, slices that aren't freshly constructed.
    func (h *SingleHandler[Req, Resp]) AllowCallRequestPool(b bool) *SingleHandler[Req, Resp] {
    	h.callReuseReq = b
    	return h
    }
    
    // IgnoreNilConn will ignore nil connections when calling.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.9K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    	// Wait for existing to exit
    	c.handleMsgWg.Wait()
    }
    
    func (c *Connection) updateState(s State) {
    	c.connChange.L.Lock()
    	defer c.connChange.L.Unlock()
    
    	// We may have reads that aren't locked, so update atomically.
    	gotState := atomic.LoadUint32((*uint32)(&c.state))
    	if gotState == StateShutdown || State(gotState) == s {
    		return
    	}
    	if s == StateConnected {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    	}
    
    	var wg sync.WaitGroup
    	// Remove buckets that are in DNS for this server, but aren't local
    	for bucket, records := range dnsBuckets {
    		if bucketsSet.Contains(bucket) {
    			continue
    		}
    
    		if globalDomainIPs.Intersection(set.CreateStringSet(getHostsSlice(records)...)).IsEmpty() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  9. cmd/xl-storage-meta-inline.go

    		if err != nil {
    			return keys, err
    		}
    	}
    	return keys, nil
    }
    
    // serialize will serialize the provided keys and values.
    // The function will panic if keys/value slices aren't of equal length.
    // Payload size can give an indication of expected payload size.
    // If plSize is <= 0 it will be calculated.
    func (x *xlMetaInlineData) serialize(plSize int, keys [][]byte, vals [][]byte) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/parse.go

    			p.expectOperandEnd()
    			return
    		}
    		// fmt.Printf("offset %d \n", a.Offset)
    	}
    
    	// Register indirection: (reg) or (index*scale). We are on the opening paren.
    	p.registerIndirect(a, prefix)
    	// fmt.Printf("DONE %s\n", p.arch.Dconv(&emptyProg, 0, a))
    
    	p.expectOperandEnd()
    	return
    }
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Wed Feb 21 14:34:57 GMT 2024
    - 36.9K bytes
    - Viewed (0)
Back to top