Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for stopped_ (0.23 sec)

  1. src/time/tick_test.go

    // to have the same signatures as Timer.
    type tickerTimer struct {
    	*Ticker
    	stopped bool
    }
    
    func (t *tickerTimer) Stop() bool {
    	pending := !t.stopped
    	t.stopped = true
    	t.Ticker.Stop()
    	return pending
    }
    
    func (t *tickerTimer) Reset(d Duration) bool {
    	pending := !t.stopped
    	t.stopped = false
    	t.Ticker.Reset(d)
    	return pending
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:10:37 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java

    import java.util.List;
    
    /**
     * The entry point for a daemon process.
     *
     * If the daemon hits the specified idle timeout the process will exit with 0. If the daemon encounters an internal error or is explicitly stopped (which can be via receiving a stop command, or
     * unexpected client disconnection) the process will exit with 1.
     */
    public class DaemonMain extends EntryPoint {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  3. pilot/pkg/bootstrap/server.go

    					s.grpcServer.Stop()
    					if s.secureGrpcServer != nil {
    						s.secureGrpcServer.Stop()
    					}
    					close(stopped)
    				}
    			}()
    			s.grpcServer.GracefulStop()
    			if s.secureGrpcServer != nil {
    				s.secureGrpcServer.GracefulStop()
    			}
    			close(stopped)
    		}()
    
    		t := time.NewTimer(s.shutdownDuration)
    		select {
    		case <-t.C:
    			s.grpcServer.Stop()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  4. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/BuildActionsFactory.java

                    globalServices.get(UserInputReader.class),
                    System.in,
                    globalServices.get(BuildExecutor.class)
                ));
    
            // Force the user home services to be stopped first, the dependencies between the user home services and the global services are not preserved currently
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  5. src/go/types/unify.go

    			// endless recursion occurs if the cycle is not detected.
    			//
    			// If x and y were compared before, they must be equal
    			// (if they were not, the recursion would have stopped);
    			// search the ifacePair stack for the same pair.
    			//
    			// This is a quadratic algorithm, but in practice these stacks
    			// are extremely short (bounded by the nesting depth of interface
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 16:24:39 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/types2/unify.go

    			// endless recursion occurs if the cycle is not detected.
    			//
    			// If x and y were compared before, they must be equal
    			// (if they were not, the recursion would have stopped);
    			// search the ifacePair stack for the same pair.
    			//
    			// This is a quadratic algorithm, but in practice these stacks
    			// are extremely short (bounded by the nesting depth of interface
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 16:24:39 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. pilot/pkg/bootstrap/istio_ca.go

    	var timerC <-chan time.Time
    	for {
    		select {
    		case <-timerC:
    			timerC = nil
    			handleEvent(s)
    
    		case event, ok := <-s.cacertsWatcher.Events:
    			if !ok {
    				log.Debug("plugin cacerts watch stopped")
    				return
    			}
    			if event.Has(fsnotify.Write) || event.Has(fsnotify.Create) {
    				if timerC == nil {
    					timerC = time.After(100 * time.Millisecond)
    				}
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 20.6K bytes
    - Viewed (0)
Back to top