Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 22 for Sequence (0.06 seconds)

  1. cmd/admin-heal-ops.go

    	// was this heal sequence force started?
    	forceStarted bool
    
    	// heal settings applied to this heal sequence
    	settings madmin.HealOpts
    
    	// current accumulated status of the heal sequence
    	currentStatus healSequenceStatus
    
    	// channel signaled by background routine when traversal has
    	// completed
    	traverseAndHealDoneCh chan error
    
    	// canceler to cancel heal sequence.
    	cancelCtx context.CancelFunc
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  2. src/bytes/bytes.go

    	return bytealg.LastIndexByte(s, c)
    }
    
    // IndexRune interprets s as a sequence of UTF-8-encoded code points.
    // It returns the byte index of the first occurrence in s of the given rune.
    // It returns -1 if rune is not present in s.
    // If r is [utf8.RuneError], it returns the first instance of any
    // invalid UTF-8 byte sequence.
    func IndexRune(s []byte, r rune) int {
    	const haveFastIndex = bytealg.MaxBruteForce > 0
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Sep 16 16:42:15 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  3. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiExtensionGeneratorFacade.kt

            isKotlinCollection && typeArguments.single().isJavaClass
    
    
    private
    fun candidatesForExtensionFrom(type: ApiType): Sequence<ApiFunction> =
        type.functions.filter(::isCandidateForExtension).asSequence()
    
    
    private
    fun Sequence<ApiFunction>.sortedWithTypeOfTakingFunctionsFirst() =
        sortedBy { f ->
            if (f.parameters.any { it.type.isGradleTypeOf }) 0
            else 1
        }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Mar 12 15:56:18 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  4. cmd/global-heal.go

    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/minio/pkg/v3/workers"
    )
    
    const (
    	bgHealingUUID = "0000-0000-0000-0000"
    )
    
    // NewBgHealSequence creates a background healing sequence
    // operation which scans all objects and heal them.
    func newBgHealSequence() *healSequence {
    	reqInfo := &logger.ReqInfo{API: "BackgroundHeal"}
    	ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  5. src/builtin/builtin.go

    // panicking goroutine. Executing a call to recover inside a deferred
    // function (but not any function called by it) stops the panicking sequence
    // by restoring normal execution and retrieves the error value passed to the
    // call of panic. If recover is called outside the deferred function it will
    // not stop a panicking sequence. In this case, or when the goroutine is not
    // panicking, recover returns nil.
    //
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 30 23:59:23 GMT 2024
    - 12.8K bytes
    - Click Count (0)
  6. internal/s3select/sql/parser.go

    // multOp  → unary ( ("/" | "*" | "%") unary )*
    // unary   → "-" unary | primary
    // primary → Value | Variable | "(" expression ")"
    //
    
    // An Operand is a single term followed by an optional sequence of
    // terms separated by +/-
    type Operand struct {
    	Left  *MultOp     `parser:"@@"`
    	Right []*OpFactor `parser:"(@@)*"`
    }
    
    // OpFactor represents the right-side of a +/- operation.
    type OpFactor struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.9K bytes
    - Click Count (0)
  7. internal/s3select/jstream/decoder.go

    		return "", d.mkError(ErrSyntax, "in unicode escape sequence")
    	}
    
    	// check for proceeding surrogate pair
    	c = d.next()
    	if !utf16.IsSurrogate(r) || c != '\\' {
    		d.scratch.addRune(r)
    		goto scan
    	}
    	if c = d.next(); c != 'u' {
    		d.scratch.addRune(r)
    		goto scan_esc
    	}
    
    	r2 := d.u4()
    	if r2 < 0 {
    		return "", d.mkError(ErrSyntax, "in unicode escape sequence")
    	}
    
    	// write surrogate pair
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  8. internal/grid/muxclient.go

    			return
    		case <-pingTimer:
    			errState = !m.doPing(errResp)
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxClient) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("MuxID: %d client, expected sequence %d, got %d\n", m.MuxID, m.RecvSeq, seq)
    		}
    		m.addResponse(Response{Err: ErrIncorrectSequence})
    		return false
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  9. src/bufio/scan_test.go

    		}
    	}
    }
    
    // Test that the rune splitter returns same sequence of runes (not bytes) as for range string.
    func TestScanRune(t *testing.T) {
    	for n, test := range scanTests {
    		buf := strings.NewReader(test)
    		s := NewScanner(buf)
    		s.Split(ScanRunes)
    		var i, runeCount int
    		var expect rune
    		// Use a string range loop to validate the sequence of runes.
    		for i, expect = range test {
    			if !s.Scan() {
    				break
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Sep 22 16:22:42 GMT 2023
    - 14.3K bytes
    - Click Count (0)
  10. cmd/signature-v2.go

    // are equal. The signatures are expected to be base64 encoded strings
    // according to the AWS S3 signature V2 spec.
    func compareSignatureV2(sig1, sig2 string) bool {
    	// Decode signature string to binary byte-sequence representation is required
    	// as Base64 encoding of a value is not unique:
    	// For example "aGVsbG8=" and "aGVsbG8=\r" will result in the same byte slice.
    	signature1, err := base64.StdEncoding.DecodeString(sig1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.2K bytes
    - Click Count (0)
Back to Top