Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 408 for chain (0.04 sec)

  1. cmd/data-scanner_test.go

    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	es := newExpiryState(context.Background(), objAPI, 0)
    	workers := []chan expiryOp{make(chan expiryOp)}
    	es.workers.Store(&workers)
    	globalExpiryState = es
    	var wg sync.WaitGroup
    	wg.Add(1)
    	expired := make([]ObjectToDelete, 0, 5)
    	go func() {
    		defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableList.java

    import static java.util.Collections.singletonList;
    
    import java.util.List;
    
    /**
     * GWT emulated version of {@link SingletonImmutableList}.
     *
     * @author Hayward Chan
     */
    @ElementTypesAreNonnullByDefault
    final class SingletonImmutableList<E> extends ForwardingImmutableList<E> {
    
      final transient List<E> delegate;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 23 18:43:40 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver.go

    }
    
    type updateRequest struct {
    	Update []byte
    	Fd     *int
    
    	Resp chan updateResponse
    }
    
    type ZtunnelConnection struct {
    	u       *net.UnixConn
    	Updates chan updateRequest
    }
    
    func newZtunnelConnection(u *net.UnixConn) *ZtunnelConnection {
    	return &ZtunnelConnection{u: u, Updates: make(chan updateRequest, 100)}
    }
    
    func (z *ZtunnelConnection) Close() {
    	z.u.Close()
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/Platform.java

    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * Methods factored out so that they can be emulated differently in GWT.
     *
     * <p>This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
      static <T> T[] clone(T[] array) {
        return array.clone();
      }
    
      // Class.cast is not supported in GWT.  This method is a no-op in GWT.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Aug 04 01:39:13 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/DelegatingLocalArtifactRepository.java

    import org.apache.maven.artifact.repository.MavenArtifactRepository;
    import org.apache.maven.artifact.repository.layout.ArtifactRepositoryLayout;
    
    /**
     * Delegating local artifact repository chains the reactor, IDE workspace
     * and user local repository.
     */
    @Deprecated
    public class DelegatingLocalArtifactRepository extends MavenArtifactRepository {
        private LocalArtifactRepository buildReactor;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. internal/logger/target/http/http.go

    	name := newTgt.Name()
    
    	currentBuff, ok := logChBuffers[name]
    	if !ok {
    		logChBuffers[name] = make(chan interface{}, requiredCap)
    		currentCap = requiredCap
    	} else {
    		currentCap = cap(currentBuff)
    		requiredCap += len(currentBuff)
    	}
    
    	if requiredCap > currentCap {
    		logChBuffers[name] = make(chan interface{}, requiredCap)
    
    		if len(currentBuff) > 0 {
    		drain:
    			for {
    				select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java

    import java.util.Map;
    import java.util.Map.Entry;
    
    /**
     * Generators of various {@link com.google.common.collect.BiMap}s and derived collections.
     *
     * @author Jared Levy
     * @author Hayward Chan
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public class BiMapGenerators {
      public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator {
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. 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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  9. 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
     */
    @ElementTypesAreNonnullByDefault
    final class RegularImmutableSet<E> extends ForwardingImmutableSet<E> {
      static final RegularImmutableSet<Object> EMPTY =
          new RegularImmutableSet<Object>(Collections.emptySet());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 23 18:43:40 UTC 2024
    - 1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/ForwardingMultimapTest.java

    import com.google.common.testing.EqualsTester;
    import com.google.common.testing.ForwardingWrapperTester;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link ForwardingMultimap}.
     *
     * @author Hayward Chan
     */
    public class ForwardingMultimapTest extends TestCase {
    
      @SuppressWarnings("rawtypes")
      public void testForwarding() {
        new ForwardingWrapperTester()
            .testForwarding(
                Multimap.class,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 20:09:59 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top