Search Options

Results per page
Sort
Preferred Languages
Advance

Results 881 - 890 of 966 for concurrency (0.09 sec)

  1. cmd/batch-handlers.go

    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts)
    				success := true
    				if err := r.ReplicateFromSource(ctx, api, core, oi, retry); err != nil {
    					// object must be deleted concurrently, allow these failures but do not count them
    					if isErrVersionNotFound(err) || isErrObjectNotFound(err) {
    						return
    					}
    					stopFn(oi, err)
    					batchLogIf(ctx, err)
    					success = false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    		// Initiate ticker after body has been read.
    		ticker := time.NewTicker(time.Second * 10)
    		defer ticker.Stop()
    
    		for {
    			select {
    			case <-ticker.C:
    				// The done() might have been called
    				// concurrently, check for it before we
    				// write the filler byte.
    				select {
    				case err := <-doneCh:
    					if err != nil {
    						write([]byte{1})
    						write([]byte(err.Error()))
    					} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/core/io/TraversalUtil.java

    import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;
    
    import java.io.File;
    import java.net.URL;
    import java.util.Iterator;
    import java.util.List;
    import java.util.Set;
    import java.util.concurrent.ConcurrentMap;
    import java.util.jar.JarFile;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    import org.codelibs.core.jar.JarFileUtil;
    import org.codelibs.core.lang.ClassLoaderUtil;
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/DfsImpl.java

     */
    
    package jcifs.smb;
    
    
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.concurrent.ConcurrentHashMap;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.DfsReferralData;
    import jcifs.DfsResolver;
    import jcifs.SmbTransport;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:07:29 UTC 2023
    - 29.1K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/testing/NullPointerTester.java

    import java.lang.reflect.Modifier;
    import java.lang.reflect.ParameterizedType;
    import java.lang.reflect.Type;
    import java.lang.reflect.TypeVariable;
    import java.util.Arrays;
    import java.util.List;
    import java.util.concurrent.ConcurrentMap;
    import junit.framework.Assert;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A test utility that verifies that your methods and constructors throw {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  6. go.sum

    github.com/moby/term v0.5.0/go.mod h1:8FzsFHVUBGZdbDsJw/ot+X+d5HLUbvklYLJ9uGfcI3Y=
    github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
    github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
    github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 06:23:25 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

    import java.lang.reflect.Method;
    import java.lang.reflect.Modifier;
    import java.lang.reflect.ParameterizedType;
    import java.lang.reflect.Type;
    import java.util.Arrays;
    import java.util.List;
    import java.util.concurrent.ConcurrentMap;
    import junit.framework.Assert;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A test utility that verifies that your methods and constructors throw {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  8. api/maven-api-plugin/src/main/mdo/plugin.mdo

              <name>threadSafe</name>
              <version>1.0.0/1.1.0</version>
              <type>boolean</type>
              <description>
                Marks this Mojo as being thread-safe, i.e. the Mojo safely supports concurrent execution during parallel
                builds. Mojos without this annotation will make Maven output a warning when used during a parallel build
                session.
                @since Maven 3.0.
              </description>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Aug 16 14:16:22 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    			}
    		}
    	}
    	onlineDisks = shuffleDisks(onlineDisks, fi.Erasure.Distribution)
    
    	// Need a unique name for the part being written in minioMetaBucket to
    	// accommodate concurrent PutObjectPart requests
    
    	partSuffix := fmt.Sprintf("part.%d", partID)
    	// Random UUID and timestamp for temporary part file.
    	tmpPart := fmt.Sprintf("%sx%d", mustGetUUID(), time.Now().UnixNano())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/ImmutableList.java

       * {@code ImmutableList.of(list)} returns an {@code ImmutableList<List<String>>} containing one
       * element (the given list itself).
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws NullPointerException if {@code elements} contains a null element
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 27.7K bytes
    - Viewed (0)
Back to top