Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 702 for cdone (0.02 seconds)

  1. src/cmd/api/testdata/src/pkg/p4/p4.go

    	return Pair[T1, T2]{f1: v1, f2: v2}
    }
    
    func (p Pair[X1, _]) First() X1 {
    	return p.f1
    }
    
    func (p Pair[_, X2]) Second() X2 {
    	return p.f2
    }
    
    // Deprecated: Use something else.
    func Clone[S ~[]T, T any](s S) S {
    	return append(S(nil), s...)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 552 bytes
    - Click Count (0)
  2. compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java

                parent = parent.clone();
                parent.setPomFile(null);
                child = child.clone();
                child.setPomFile(null);
            }
    
            SimpleProblemCollector problems = new SimpleProblemCollector();
    
            Model assembled = child.clone();
            assembler.assembleModelInheritance(assembled, parent, null, problems);
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  3. internal/grid/muxclient.go

    	for !errState {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    			m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx))
    			errState = true
    			continue
    		case <-pingTimer:
    			if !m.doPing(errResp) {
    				errState = true
    				continue
    			}
    		case req, ok := <-requests:
    			if !ok {
    				// Done send EOF
    				if debugPrint {
    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)
  4. cmd/os_other.go

    		maxEntries = opts.count
    	}
    
    	done := false
    	remaining := opts.count
    
    	for !done {
    		// Read up to max number of entries.
    		fis, err := d.Readdir(maxEntries)
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return nil, osErrToFileErr(err)
    		}
    		if opts.count > -1 {
    			if remaining <= len(fis) {
    				fis = fis[:remaining]
    				done = true
    			}
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Sep 13 15:14:36 GMT 2023
    - 4K bytes
    - Click Count (0)
  5. impl/maven-core/src/test/java/org/apache/maven/internal/MultilineMessageHelperTest.java

            msgs.add("* but aggregator Mojos require exclusive access to reactor to   *");
            msgs.add("* prevent race conditions. This mojo execution will be blocked  *");
            msgs.add("* until the aggregator work is done.                            *");
            msgs.add("*****************************************************************");
    
            assertEquals(
                    msgs,
                    MultilineMessageHelper.format(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  6. cmd/tier.go

    	config.RLock()
    	defer config.RUnlock()
    
    	var tierCfgs []madmin.TierConfig
    	for _, tier := range config.Tiers {
    		// This makes a local copy of tier config before
    		// passing a reference to it.
    		tier := tier.Clone()
    		tierCfgs = append(tierCfgs, tier)
    	}
    	return tierCfgs
    }
    
    // Edit replaces the credentials of the remote tier specified by tierName with creds.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  7. docs/site-replication/run-sse-kms-object-replication.sh

    echo "done"
    
    if [ ! -f ./mc ]; then
    	echo -n "Downloading MinIO client ..."
    	wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc &&
    		chmod +x mc
    	echo "done"
    fi
    
    export MC_HOST_minio1=https://minio:minio123@localhost:9001
    export MC_HOST_minio2=https://minio:minio123@localhost:9002
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 10 06:49:55 GMT 2024
    - 11.5K bytes
    - Click Count (0)
  8. docs/resiliency/resiliency-initial-script.sh

    		echo retry: timeout while running: mc alias set
    		exit 1
    	fi
    	eval ./mc alias set "${ALIAS_NAME}" "${MINIO_SERVER_URL}" minioadmin minioadmin && break
    	TIMEOUT=$((TIMEOUT - 1))
    	sleep 1
    done
    
    ./mc ready "${ALIAS_NAME}"
    
    ./mc mb "${ALIAS_NAME}"/"${BUCKET}"
    rm -rf "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}" && mkdir -p "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}"
    for idx in {1..10}; do
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  9. internal/hash/crc.go

    		}
    		len2 >>= 1
    
    		// if no more bits set, then done
    		if len2 == 0 {
    			break
    		}
    
    		// another iteration of the loop with odd and even swapped
    		gf2MatrixSquare(odd, even)
    		if len2&1 != 0 {
    			crc1n = gf2MatrixTimes(odd, crc1n)
    		}
    		len2 >>= 1
    
    		// if no more bits set, then done
    		if len2 == 0 {
    			break
    		}
    	}
    
    	// return combined crc
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  10. cmd/utils.go

    }
    
    func ptr[T any](a T) *T {
    	return &a
    }
    
    // sleepContext sleeps for d duration or until ctx is done.
    func sleepContext(ctx context.Context, d time.Duration) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case <-time.After(d):
    	}
    	return nil
    }
    
    // helper type to return either item or error.
    type itemOrErr[V any] struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
Back to Top