Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 881 for state (0.03 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. 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)
  3. 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)
  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. 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)
  6. internal/grid/connection.go

    		}
    	}
    }
    
    // State returns the current connection status.
    func (c *Connection) State() State {
    	return State(atomic.LoadUint32((*uint32)(&c.state)))
    }
    
    // Stats returns the current connection stats.
    func (c *Connection) Stats() madmin.RPCMetrics {
    	conn := 0
    	if c.State() == StateConnected {
    		conn++
    	}
    	var lastConn time.Time
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K 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. 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)
  9. 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)
  10. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    	for _, secret := range secretDump {
    		if strings.Contains(secret.State, "Unavailable") {
    			secret.State = "Unavailable"
    		}
    		if len(secret.CertChain) == 0 {
    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\n",
    				secret.Identity, valueOrNA(""), secret.State, false, valueOrNA(""), valueOrNA(""), valueOrNA(""))
    		} else {
    			for i, ca := range secret.CertChain {
    				t := "Intermediate"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 25 16:38:16 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top