Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for timeEnd (0.13 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractFuture.java

      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the
      //   waiters field.
      // * Future completion is defined by when #value becomes non-null/non SetFuture
      // * Future completion can be observed if the waiters field contains a TOMBSTONE
    
      // Timed Get
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the
      //   waiters field.
      // * Future completion is defined by when #value becomes non-null/non SetFuture
      // * Future completion can be observed if the waiters field contains a TOMBSTONE
    
      // Timed Get
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  3. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    		deviceState            operationexecutor.DeviceMountState
    		unmountDeviceCallCount int
    		volumeName             string
    		supportRemount         bool
    	}{
    		{
    			name:                   "timed out operations should result in device marked as uncertain",
    			deviceState:            operationexecutor.DeviceMountUncertain,
    			unmountDeviceCallCount: 1,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. pkg/volume/testing/testing.go

    	if fv.VolName == TimeoutAndFailOnMountDeviceVolumeName {
    		_, ok := fv.DeviceMountState[fv.VolName]
    		if !ok {
    			fv.DeviceMountState[fv.VolName] = deviceMountUncertain
    			return "", volumetypes.NewUncertainProgressError("timed out mounting error")
    		}
    		fv.DeviceMountState[fv.VolName] = deviceNotMounted
    		return "", fmt.Errorf("error mapping disk: %s", fv.VolName)
    	}
    
    	if fv.VolName == SuccessAndTimeoutDeviceName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  5. src/crypto/tls/tls_test.go

    		t.Fatal("Write which previously failed should still time out")
    	}
    
    	// Verify the error
    	if ne := err.(net.Error); ne.Temporary() != false {
    		t.Error("Write timed out but incorrectly classified the error as Temporary")
    	}
    	if !isTimeoutError(err) {
    		t.Error("Write timed out but did not classify the error as a Timeout")
    	}
    }
    
    type readerFunc func([]byte) (int, error)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 60.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

      private Futures() {}
    
      /**
       * Creates a {@code ListenableFuture} which has its value set immediately upon construction. The
       * getters just return the value. This {@code Future} can't be canceled or timed out and its
       * {@code isDone()} method always returns {@code true}.
       */
      public static <V extends @Nullable Object> ListenableFuture<V> immediateFuture(
          @ParametricNullness V value) {
        if (value == null) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  7. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    		t.Logf("Warning: MultiAttach error not yet set on Node. Will retry.")
    		return false, nil
    	}
    
    	err := retryWithExponentialBackOff(100*time.Millisecond, multAttachCheckFunc)
    	if err != nil {
    		t.Fatalf("Timed out waiting for MultiAttach Error to be set on non-attached node")
    	}
    }
    
    func waitForNewAttacherCallCount(
    	t *testing.T,
    	expectedCallCount int,
    	fakePlugin *volumetesting.FakeVolumePlugin) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Futures.java

      private Futures() {}
    
      /**
       * Creates a {@code ListenableFuture} which has its value set immediately upon construction. The
       * getters just return the value. This {@code Future} can't be canceled or timed out and its
       * {@code isDone()} method always returns {@code true}.
       */
      public static <V extends @Nullable Object> ListenableFuture<V> immediateFuture(
          @ParametricNullness V value) {
        if (value == null) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 64.1K bytes
    - Viewed (0)
  9. src/crypto/tls/conn.go

    	return c.conn.RemoteAddr()
    }
    
    // SetDeadline sets the read and write deadlines associated with the connection.
    // A zero value for t means [Conn.Read] and [Conn.Write] will not time out.
    // After a Write has timed out, the TLS state is corrupt and all future writes will return the same error.
    func (c *Conn) SetDeadline(t time.Time) error {
    	return c.conn.SetDeadline(t)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  10. src/syscall/zerrors_solaris_amd64.go

    	133: "transport endpoint is already connected",
    	134: "transport endpoint is not connected",
    	143: "cannot send after socket shutdown",
    	144: "too many references: cannot splice",
    	145: "connection timed out",
    	146: "connection refused",
    	147: "host is down",
    	148: "no route to host",
    	149: "operation already in progress",
    	150: "operation now in progress",
    	151: "stale NFS file handle",
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:52:34 UTC 2024
    - 50.8K bytes
    - Viewed (0)
Back to top