Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 48 for Seq (0.01 seconds)

  1. internal/grid/connection.go

    			// No need to return result
    			PutByteBuffer(b)
    			return
    		}
    		if debugReqs {
    			fmt.Println(m.MuxID, c.StringReverse(), "RESPONDING")
    		}
    		m = message{
    			MuxID: m.MuxID,
    			Seq:   m.Seq,
    			Op:    OpResponse,
    			Flags: FlagEOF,
    		}
    		if err != nil {
    			m.Flags |= FlagPayloadIsErr
    			m.Payload = []byte(*err)
    		} else {
    			m.Payload = b
    			m.setZeroPayloadFlag()
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

     *
     * <pre>{@code
     * class FIFOEntry<E extends Comparable<? super E>> implements Comparable<FIFOEntry<E>> {
     *   static final AtomicLong seq = new AtomicLong();
     *
     *   final long seqNum;
     *   final E entry;
     *
     *   public FIFOEntry(E entry) {
     *     seqNum = seq.getAndIncrement();
     *     this.entry = entry;
     *   }
     *
     *   public E getEntry() {
     *     return entry;
     *   }
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 19K bytes
    - Click Count (0)
  3. src/bytes/bytes_test.go

    	for i, v := range s {
    		result[i] = string(v)
    	}
    	return result
    }
    
    func collect(t *testing.T, seq iter.Seq[[]byte]) [][]byte {
    	out := slices.Collect(seq)
    	out1 := slices.Collect(seq)
    	if !slices.Equal(sliceOfString(out), sliceOfString(out1)) {
    		t.Fatalf("inconsistent seq:\n%s\n%s", out, out1)
    	}
    	return out
    }
    
    type LinesTest struct {
    	a string
    	b []string
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Mar 11 03:07:05 GMT 2026
    - 62.9K bytes
    - Click Count (0)
  4. api/go1.24.txt

    pkg go/types, method (*Interface) EmbeddedTypes() iter.Seq[Type] #66626
    pkg go/types, method (*Interface) ExplicitMethods() iter.Seq[*Func] #66626
    pkg go/types, method (*Interface) Methods() iter.Seq[*Func] #66626
    pkg go/types, method (*MethodSet) Methods() iter.Seq[*Selection] #66626
    pkg go/types, method (*Named) Methods() iter.Seq[*Func] #66626
    pkg go/types, method (*Scope) Children() iter.Seq[*Scope] #66626
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 17 21:28:29 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  5. src/bytes/iter.go

    func SplitAfterSeq(s, sep []byte) iter.Seq[[]byte] {
    	return splitSeq(s, sep, len(sep))
    }
    
    // FieldsSeq returns an iterator over subslices of s split around runs of
    // whitespace characters, as defined by [unicode.IsSpace].
    // The iterator yields the same subslices that would be returned by [Fields](s),
    // but without constructing a new slice containing the subslices.
    func FieldsSeq(s []byte) iter.Seq[[]byte] {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Sep 03 14:04:47 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  6. cmd/metrics-v2.go

    		metrics = append(metrics, getHealedItems(bgSeq)...)
    		metrics = append(metrics, getFailedItems(bgSeq)...)
    		return metrics
    	})
    	return mg
    }
    
    func getFailedItems(seq *healSequence) (m []MetricV2) {
    	items := seq.getHealFailedItemsMap()
    	m = make([]MetricV2, 0, len(items))
    	for k, v := range items {
    		m = append(m, MetricV2{
    			Description:    getHealObjectsFailTotalMD(),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  7. cmd/admin-heal-ops.go

    }
    
    // healSequence - state for each heal sequence initiated on the
    // server.
    type healSequence struct {
    	// bucket, and object on which heal seq. was initiated
    	bucket, object string
    
    	// Report healing progress
    	reportProgress bool
    
    	// time at which heal sequence was started
    	startTime time.Time
    
    	// time at which heal sequence has ended
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  8. internal/grid/msg_gen.go

    		err = msgp.ArrayError{Wanted: 7, Got: zb0001}
    		return
    	}
    	z.MuxID, err = dc.ReadUint64()
    	if err != nil {
    		err = msgp.WrapError(err, "MuxID")
    		return
    	}
    	z.Seq, err = dc.ReadUint32()
    	if err != nil {
    		err = msgp.WrapError(err, "Seq")
    		return
    	}
    	z.DeadlineMS, err = dc.ReadUint32()
    	if err != nil {
    		err = msgp.WrapError(err, "DeadlineMS")
    		return
    	}
    	{
    		var zb0002 uint8
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  9. api/go1.26.txt

    pkg reflect, method (Value) Methods() iter.Seq2[Method, Value] #66631
    pkg reflect, type Type interface, Fields() iter.Seq[StructField] #66631
    pkg reflect, type Type interface, Ins() iter.Seq[Type] #66631
    pkg reflect, type Type interface, Methods() iter.Seq[Method] #66631
    pkg reflect, type Type interface, Outs() iter.Seq[Type] #66631
    pkg testing, method (*B) ArtifactDir() string #71287
    pkg testing, method (*F) ArtifactDir() string #71287
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Dec 11 19:57:52 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  10. cmd/endpoint-ellipses.go

    	for _, ss := range setCounts {
    		var symmetry bool
    		for _, argPattern := range argPatterns {
    			for _, p := range argPattern {
    				if uint64(len(p.Seq)) > ss {
    					symmetry = uint64(len(p.Seq))%ss == 0
    				} else {
    					symmetry = ss%uint64(len(p.Seq)) == 0
    				}
    			}
    		}
    		// With no arg patterns, it is expected that user knows
    		// the right symmetry, so either ellipses patterns are
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
Back to Top