Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 711 for _state (0.09 sec)

  1. guava/src/com/google/common/base/AbstractIterator.java

        checkState(state != State.FAILED);
        switch (state) {
          case DONE:
            return false;
          case READY:
            return true;
          default:
        }
        return tryToComputeNext();
      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jul 09 17:31:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // +optional
      optional LimitedPriorityLevelConfiguration limited = 2;
    }
    
    // PriorityLevelConfigurationStatus represents the current state of a "request-priority".
    message PriorityLevelConfigurationStatus {
      // `conditions` is the current state of "request-priority".
      // +listType=map
      // +listMapKey=type
      // +patchMergeKey=type
      // +patchStrategy=merge
      // +optional
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/util/transport/Transport.java

                    if (log.level >= 1)
                        log.println("Invalid state: " + state);
                    state = 0;
                    thread = null;
                }
            }
        }
        public synchronized void disconnect( boolean hard ) throws IOException {
            IOException ioe = null;
    
            switch (state) {
                case 0: /* not connected - just return */
                    return;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

            AggregateFutureState<?> state, @CheckForNull Set<Throwable> expect, Set<Throwable> update) {
          synchronized (state) {
            if (state.seenExceptions == expect) {
              state.seenExceptions = update;
            }
          }
        }
    
        @Override
        int decrementAndGetRemainingCount(AggregateFutureState<?> state) {
          synchronized (state) {
            return --state.remaining;
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. architecture/README.md

    ## Build state model
    
    As Gradle executes, it acts on various pieces of the build definition, such as each project in the build.
    Gradle tracks the state of each piece and transitions each piece through its lifecycle as the build runs.
    
    A central part of the Gradle architecture is the "build state model", which holds the state for each piece and coordinates state transitions and other mutations. 
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu May 02 06:42:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java

        if (mockWebServer == null) throw new IllegalStateException();
    
        ByteString state = randomToken();
        synchronized (this) {
          listeners.put(state, listener);
        }
    
        return slackApi.authorizeUrl(scopes, redirectUrl(), state, team);
      }
    
      private ByteString randomToken() {
        byte[] bytes = new byte[16];
        secureRandom.nextBytes(bytes);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  8. internal/bucket/versioning/versioning.go

    	"io"
    	"strings"
    
    	"github.com/minio/pkg/v3/wildcard"
    )
    
    // State - enabled/disabled/suspended states
    // for multifactor and status of versioning.
    type State string
    
    // Various supported states
    const (
    	Enabled State = "Enabled"
    	// Disabled  State = "Disabled" only used by MFA Delete not supported yet.
    	Suspended State = "Suspended"
    )
    
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java

        protected static DcerpcBinding parseBinding(String str) throws DcerpcException {
            int state, mark, si;
            char[] arr = str.toCharArray();
            String proto = null, key = null;
            DcerpcBinding binding = null;
    
            state = mark = si = 0;
            do {
                char ch = arr[si];
    
                switch (state) {
                    case 0:
                        if (ch == ':') {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 8.8K bytes
    - Viewed (0)
  10. cmd/erasure.go

    		state = madmin.DriveStatePermission
    	case errors.Is(err, errFaultyDisk):
    		state = madmin.DriveStateFaulty
    	case errors.Is(err, errDriveIsRoot):
    		state = madmin.DriveStateRootMount
    	case err == nil:
    		state = madmin.DriveStateOk
    	default:
    		state = fmt.Sprintf("%s (cause: %s)", madmin.DriveStateUnknown, err)
    	}
    
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
Back to top