Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for mseq (0.02 seconds)

  1. android/guava/src/com/google/common/io/CharSequenceReader.java

    @GwtIncompatible
    final class CharSequenceReader extends Reader {
    
      private @Nullable CharSequence seq;
      private int pos;
      private int mark;
    
      /** Creates a new reader wrapping the given character sequence. */
      public CharSequenceReader(CharSequence seq) {
        this.seq = checkNotNull(seq);
      }
    
      private void checkOpen() throws IOException {
        if (seq == null) {
          throw new IOException("reader closed");
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  2. 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)
  3. internal/grid/muxserver.go

    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq)
    		}
    		m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false)
    		return false
    	}
    	m.RecvSeq++
    	return true
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  4. src/main/java/jcifs/pac/kerberos/KerberosApRequest.java

         *
         * @param seq the ASN.1 sequence containing the AP-REQ
         * @param keys the Kerberos keys for decryption
         * @throws PACDecodingException if the sequence cannot be decoded
         */
        public KerberosApRequest(ASN1Sequence seq, KerberosKey[] keys) throws PACDecodingException {
            Enumeration<?> fields = seq.getObjects();
            while (fields.hasMoreElements()) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  5. buildscripts/verify-healing.sh

    GOPATH=/tmp/gopath
    
    function start_minio_3_node() {
    	for i in $(seq 1 3); do
    		rm "${WORK_DIR}/dist-minio-server$i.log"
    	done
    
    	export MINIO_ROOT_USER=minio
    	export MINIO_ROOT_PASSWORD=minio123
    	export MINIO_ERASURE_SET_DRIVE_COUNT=6
    	export MINIO_CI_CD=1
    
    	first_time=$(find ${WORK_DIR}/ | grep format.json | wc -l)
    
    	start_port=$1
    	args=""
    	for d in $(seq 1 3 5); do
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 4K bytes
    - Click Count (0)
  6. buildscripts/verify-build.sh

    	(cd "$WORK_DIR" && "$FUNCTIONAL_TESTS")
    	rv=$?
    
    	pkill minio
    	sleep 3
    
    	if [ "$rv" -ne 0 ]; then
    		for i in $(seq 0 1); do
    			echo "server$i log:"
    			cat "$WORK_DIR/pool-minio-900$i.log"
    		done
    	fi
    
    	for i in $(seq 0 1); do
    		rm -f "$WORK_DIR/pool-minio-900$i.log"
    	done
    
    	return "$rv"
    }
    
    function run_test_pool_erasure_sets_ipv6() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 19:28:51 GMT 2024
    - 6.7K bytes
    - Click Count (0)
  7. buildscripts/verify-healing-with-root-disks.sh

    	unset MINIO_CI_CD
    	unset CI
    
    	args=()
    	for i in $(seq 1 4); do
    		args+=("http://localhost:$((start_port + i))${WORK_DIR}/mnt/disk$i/ ")
    	done
    
    	for i in $(seq 1 4); do
    		"${MINIO[@]}" --address ":$((start_port + i))" ${args[@]} 2>&1 >"${WORK_DIR}/server$i.log" &
    	done
    
    	# Wait until all nodes return 403
    	for i in $(seq 1 4); do
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 26 05:07:25 GMT 2023
    - 2.2K bytes
    - Click Count (0)
  8. docs/bucket/replication/sio-error.sh

    export MINIO_KMS_SECRET_KEY="my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw="
    
    NODES=4
    
    args1=()
    args2=()
    for i in $(seq 1 $NODES); do
    	args1+=("http://localhost:$((9000 + i))/tmp/xl/1/$i ")
    	args2+=("http://localhost:$((9100 + i))/tmp/xl/2/$i ")
    done
    
    for i in $(seq 1 $NODES); do
    	./minio server --address "127.0.0.1:$((9000 + i))" ${args1[@]} & # | tee /tmp/minio/node.$i &
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat May 18 18:19:01 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  9. internal/grid/msg.go

    type Flags uint8
    
    func (m message) String() string {
    	var res []string
    	if m.MuxID != 0 {
    		res = append(res, fmt.Sprintf("MuxID: %v", m.MuxID))
    	}
    	if m.Seq != 0 {
    		res = append(res, fmt.Sprintf("Seq: %v", m.Seq))
    	}
    	if m.DeadlineMS != 0 {
    		res = append(res, fmt.Sprintf("Deadline: %vms", m.DeadlineMS))
    	}
    	if m.Handler != handlerInvalid {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jul 25 21:07:21 GMT 2024
    - 7.6K bytes
    - Click Count (0)
  10. buildscripts/verify-healing-empty-erasure-set.sh

    function start_minio_3_node() {
    	export MINIO_ROOT_USER=minio
    	export MINIO_ROOT_PASSWORD=minio123
    	export MINIO_ERASURE_SET_DRIVE_COUNT=6
    	export MINIO_CI_CD=1
    
    	start_port=$1
    	args=""
    	for i in $(seq 1 3); do
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 3.7K bytes
    - Click Count (0)
Back to Top