Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 607 for setRate (0.08 sec)

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

          }
        }
    
        @Override
        public void stopping(State from) {
          ServiceManagerState state = this.state.get();
          if (state != null) {
            state.transitionService(service, from, STOPPING);
          }
        }
    
        @Override
        public void terminated(State from) {
          ServiceManagerState state = this.state.get();
          if (state != null) {
            if (!(service instanceof NoOpService)) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  2. docs/sts/web-identity.go

    		v.Set("redirect_uri", c.RedirectURL)
    	}
    	if len(c.Scopes) > 0 {
    		v.Set("scope", strings.Join(c.Scopes, " "))
    	}
    	v.Set("state", state)
    	v.Set("nonce", state)
    	if strings.Contains(c.Endpoint.AuthURL, "?") {
    		buf.WriteByte('&')
    	} else {
    		buf.WriteByte('?')
    	}
    	buf.WriteString(v.Encode())
    	return buf.String()
    }
    
    func main() {
    	flag.Parse()
    	if clientID == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  3. istioctl/pkg/admin/istiodconfig_test.go

    	tests := []struct {
    		name    string
    		state   flagState
    		want    string
    		wantErr bool
    	}{
    		{
    			name:    "resetState.run() should throw an error if the /scopej endpoint is missing",
    			state:   &resetState{client: ctrzClientNoScopejHandler},
    			wantErr: true,
    		},
    		{
    			name: "logLevelState.run() should throw an error if the /scopej endpoint is missing",
    			state: &logLevelState{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

          startUpCalled++;
          assertEquals(State.STARTING, state());
        }
    
        @Override
        protected void shutDown() throws Exception {
          assertEquals(1, startUpCalled);
          assertEquals(0, shutDownCalled);
          shutDownCalled++;
          assertEquals(State.STOPPING, state());
        }
    
        @Override
        protected Executor executor() {
          transitionStates.add(state());
          return directExecutor();
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/AbstractIterator.java

      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
        return false;
      }
    
      @CanIgnoreReturnValue // TODO(kak): Should we remove this?
      @Override
      @ParametricNullness
      public final T next() {
        if (!hasNext()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Mar 18 02:04:10 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        state = STATE_WRITING_REQUEST_BODY
        return ChunkedSink()
      }
    
      private fun newKnownLengthSink(): Sink {
        check(state == STATE_OPEN_REQUEST_BODY) { "state: $state" }
        state = STATE_WRITING_REQUEST_BODY
        return KnownLengthSink()
      }
    
      private fun newFixedLengthSource(length: Long): Source {
        check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" }
        state = STATE_READING_RESPONSE_BODY
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/Parameter.java

        public Parameter() {}
    
        public Parameter(org.apache.maven.api.plugin.descriptor.Parameter p) {
            this.setAlias(p.getAlias());
            this.setName(p.getName());
            this.setRequired(p.isRequired());
            this.setEditable(p.isEditable());
            this.setDescription(p.getDescription());
            this.setExpression(p.getExpression());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/ServiceTest.java

    import static com.google.common.util.concurrent.Service.State.FAILED;
    import static com.google.common.util.concurrent.Service.State.NEW;
    import static com.google.common.util.concurrent.Service.State.RUNNING;
    import static com.google.common.util.concurrent.Service.State.STARTING;
    import static com.google.common.util.concurrent.Service.State.STOPPING;
    import static com.google.common.util.concurrent.Service.State.TERMINATED;
    
    import java.util.Locale;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.9K bytes
    - Viewed (0)
  9. compat/maven-model/src/test/java/org/apache/maven/model/OrganizationTest.java

            Organization org = new Organization();
            org.setName("Testing Maven Unit");
            org.setUrl("https://maven.localdomain");
    
            assertEquals("Organization {name=Testing Maven Unit, url=https://maven.localdomain}", org.toString());
        }
    
        public void testToStringNotNonsense10() {
            Organization org = new Organization();
            org.setName("Testing Maven Unit");
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/compare/sds/util.go

    func (s *secretItemBuilder) Destination(dest string) SecretItemBuilder {
    	s.dest = dest
    	return s
    }
    
    // State sets the state of the secret on the agent or sidecar
    func (s *secretItemBuilder) State(state string) SecretItemBuilder {
    	s.state = state
    	return s
    }
    
    // TrustDomain sets the trust domain of the secret on the agent or sidecar
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top