Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 339 for chain (0.02 seconds)

  1. cmd/bucket-lifecycle.go

    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    	workers := make([]chan expiryOp, 0, n)
    	es.workers.Store(&workers)
    	es.ResizeWorkers(n)
    	return es
    }
    
    func (es *expiryState) getWorkerCh(h uint64) chan<- expiryOp {
    	w := es.workers.Load()
    	if w == nil || len(*w) == 0 {
    		return nil
    	}
    	workers := *w
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  2. cmd/grid.go

    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  3. internal/logger/target/http/http.go

    	name := newTgt.Name()
    
    	currentBuff, ok := logChBuffers[name]
    	if !ok {
    		logChBuffers[name] = make(chan any, requiredCap)
    		currentCap = requiredCap
    	} else {
    		currentCap = cap(currentBuff)
    		requiredCap += len(currentBuff)
    	}
    
    	if requiredCap > currentCap {
    		logChBuffers[name] = make(chan any, requiredCap)
    
    		if len(currentBuff) > 0 {
    		drain:
    			for {
    				select {
    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)
  4. CHANGELOG/CHANGELOG-1.22.md

    - Azurefile: Normalize share name to not include the capital letters ([#100731](https://github.com/kubernetes/kubernetes/pull/100731), [@kassarl](https://github.com/kassarl))
    - Chain the field manager creation calls in `newDefaultFieldManager` to be explicit about the order of operations. ([#101076](https://github.com/kubernetes/kubernetes/pull/101076), [@kevindelgado](https://github.com/kevindelgado))
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Tue Dec 13 12:43:45 GMT 2022
    - 454.1K bytes
    - Click Count (0)
  5. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableSet.java

     * limitations under the License.
     */
    
    package com.google.common.collect;
    
    import java.util.Collections;
    import java.util.Set;
    
    /**
     * GWT emulation of {@link RegularImmutableSet}.
     *
     * @author Hayward Chan
     */
    final class RegularImmutableSet<E> extends ForwardingImmutableSet<E> {
      static final RegularImmutableSet<Object> EMPTY =
          new RegularImmutableSet<Object>(Collections.emptySet());
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1K bytes
    - Click Count (0)
  6. guava-testlib/src/com/google/common/collect/testing/testers/Platform.java

     */
    
    package com.google.common.collect.testing.testers;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
    
      /** Format the template with args, only supports the placeholder {@code %s}. */
      static String format(String template, Object... args) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 1.3K bytes
    - Click Count (0)
  7. cmd/batch-expire.go

    	}
    
    	ctx, cancelCause := context.WithCancelCause(ctx)
    	defer cancelCause(nil)
    
    	results := make(chan itemOrErr[ObjectInfo], workerSize)
    	go func() {
    		prefixes := r.Prefix.F()
    		if len(prefixes) == 0 {
    			prefixes = []string{""}
    		}
    		for _, prefix := range prefixes {
    			prefixResultCh := make(chan itemOrErr[ObjectInfo], workerSize)
    			err := api.Walk(ctx, r.Bucket, prefix, prefixResultCh, WalkOptions{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java

    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Unit tests for any listenable future that chains other listenable futures. Unit tests need only
     * override buildChainingFuture and getSuccessfulResult, but they can add custom tests as needed.
     *
     * @author Nishant Thakkar
     */
    @NullUnmarked
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  9. cmd/perf-tests.go

    	defer n.Unlock()
    	n.RX = 0
    	n.RXSample = 0
    	n.lastToConnect = time.Time{}
    	n.firstToDisconnect = time.Time{}
    }
    
    // Reader to read random data.
    type netperfReader struct {
    	n   uint64
    	eof chan struct{}
    	buf []byte
    }
    
    func (m *netperfReader) Read(b []byte) (int, error) {
    	select {
    	case <-m.eof:
    		return 0, io.EOF
    	default:
    	}
    	n := copy(b, m.buf)
    	atomic.AddUint64(&m.n, uint64(n))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  10. cmd/consolelogger.go

    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    	if !sys.HasLogListeners() {
    		logger.AddSystemTarget(GlobalContext, sys)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top