Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 378 for cancels (0.13 sec)

  1. src/builtin/builtin.go

    // any is an alias for interface{} and is equivalent to interface{} in all ways.
    type any = interface{}
    
    // comparable is an interface that is implemented by all comparable types
    // (booleans, numbers, strings, pointers, channels, arrays of comparable types,
    // structs whose fields are all comparable types).
    // The comparable interface may only be used as a type parameter constraint,
    // not as the type of a variable.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Apr 11 20:22:45 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/FilesTest.java

    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.PrintWriter;
    import java.io.RandomAccessFile;
    import java.nio.ByteBuffer;
    import java.nio.MappedByteBuffer;
    import java.nio.channels.FileChannel.MapMode;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Random;
    import junit.framework.TestSuite;
    
    /**
     * Unit test for {@link Files}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    					if err := healFreshDisk(ctx, z, disk); err != nil {
    						globalBackgroundHealState.setDiskHealingStatus(disk, false)
    						timedout := OperationTimedOut{}
    						if !errors.Is(err, context.Canceled) && !errors.As(err, &timedout) && !errors.Is(err, errRetryHealing) {
    							printEndpointError(disk, err, false)
    						}
    						return
    					}
    					// Only upon success pop the healed disk.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    				resultsMu.Unlock()
    				return
    			}()
    			continue
    		}
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second)
    			defer cancel()
    			result := perfNetRequest(
    				ctx,
    				info.DeploymentID,
    				adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf,
    				nil,
    			)
    			resultsMu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/FilesTest.java

    import java.io.FileNotFoundException;
    import java.io.IOException;
    import java.io.PrintWriter;
    import java.io.RandomAccessFile;
    import java.nio.ByteBuffer;
    import java.nio.MappedByteBuffer;
    import java.nio.channels.FileChannel.MapMode;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Random;
    import junit.framework.TestSuite;
    
    /**
     * Unit test for {@link Files}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            synchronized ( this.LOCK ) {
    
                /*
                 * Yes, there is the potential to drop packets
                 * because we might close the socket during a
                 * request. However the chances are slim and the
                 * retry code should ensure the overall request
                 * is serviced. The alternative complicates things
                 * more than I think is worth it.
                 */
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/Ascii.java

       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
      /**
       * Cancel: A control character used to indicate that the data with which it is sent is in error or
       * is to be disregarded.
       *
       * @since 8.0
       */
      public static final byte CAN = 24;
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  8. cmd/server_test.go

    }
    
    func (s *TestSuiteCommon) RestartTestServer(c *check) {
    	// Shutdown.
    	s.testServer.cancel()
    	s.testServer.Server.Close()
    	s.testServer.Obj.Shutdown(context.Background())
    
    	// Restart.
    	ctx, cancel := context.WithCancel(context.Background())
    
    	s.testServer.cancel = cancel
    	s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths)
    	if s.secure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  9. docs/pt/docs/async.md

    Ainda, em ambas as situações, as chances são que o **FastAPI** será [ainda mais rápido](index.md#performance){.internal-link target=_blank} do que (ou ao menos comparável a) seus frameworks antecessores.
    
    ### Dependências
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        val connectionClose = CountDownLatch(1)
        val streams =
          object : RealWebSocket.Streams(false, source, sink) {
            override fun close() = connectionClose.countDown()
    
            override fun cancel() {
              socket.closeQuietly()
            }
          }
        val webSocket =
          RealWebSocket(
            taskRunner = taskRunner,
            originalRequest = fancyRequest,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
Back to top